DNET/dnetd_old
1
0
Fork 0
mirror of https://github.com/deavminet/dnetd synced 2024-09-21 01:33:24 +02:00
Code Issues Releases Activity

Added 'join' broadcast to channel on user join channel

Browse Source
This commit is contained in:
Tristan B. Kildaire 2020-09-28 13:58:18 +02:00
parent ea34d7b4a2
commit 1b1827738c
1 changed files with 57 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
source/dnetd/dchannel.d
View File

@ -45,6 +45,9 @@ public class DChannel
*/
public bool join(DConnection client)
{
/* Send a message stating the user has joined (TODO: This should be done later, possibly, how defensive should we program) */
broadcastJoin(client);
/* Lock the members list */
memberLock.lock();
@ -156,6 +159,10 @@ public class DChannel
broadcastLeave(client);
}
/**
* Sends a message to all users of this
* channel that the given user has left
*/
private void broadcastLeave(DConnection left)
{
/* Lock the members list */
@ -171,6 +178,10 @@ public class DChannel
memberLock.unlock();
}
/**
* Sends a message to the user stating the given
* (other) user has left the channel
*/
private void sendLeaveMessage(DConnection member, DConnection left)
{
/* The protocol data to send */
@ -179,6 +190,9 @@ public class DChannel
/* Set the notificaiton type to `channel status` */
protocolData ~= [1];
/* Set the sub-type to leave */
protocolData ~= [0];
/* Set the channel notificaiton type to `member leave` */
protocolData ~= cast(byte[])left.getUsername();
@ -186,6 +200,49 @@ public class DChannel
member.writeSocket(0, protocolData);
}
/**
* Sends a message to all users of this
* channel that the given user has joined
*/
private void broadcastJoin(DConnection joined)
{
/* Lock the members list */
memberLock.lock();
/* Send join message here */
foreach(DConnection currentMember; members)
{
sendJoinMessage(currentMember, joined);
}
/* Unlock the members list */
memberLock.unlock();
}
/**
* Sends a message to the user stating the given
* (other) user has joined the channel
*/
private void sendJoinMessage(DConnection member, DConnection joined)
{
/* The protocol data to send */
byte[] protocolData;
/* Set the notificaiton type to `channel status` */
protocolData ~= [1];
/* Set the sub-type to join */
protocolData ~= [1];
/* Set the channel notificaiton type to `member join` */
protocolData ~= cast(byte[])joined.getUsername();
/* Write the notification */
member.writeSocket(0, protocolData);
}
public bool sendMessage(DConnection sender, string message)
{
bool status;