mirror of https://github.com/deavminet/skippy.git
79 lines
1.6 KiB
D
79 lines
1.6 KiB
D
import core.thread : Thread;
|
|
import tristanable.manager;
|
|
import std.stdio;
|
|
import core.time : dur;
|
|
import tristanable.encoding;
|
|
import libdnet.dclient : DClient;
|
|
|
|
public class NotificationWatcher : Thread
|
|
{
|
|
private DClient client;
|
|
|
|
this(DClient client)
|
|
{
|
|
super(&worker);
|
|
this.client = client;
|
|
|
|
/* Start the notification watcher */
|
|
start();
|
|
}
|
|
|
|
private void worker()
|
|
{
|
|
while(true)
|
|
{
|
|
/* Await a notification */
|
|
byte[] notification = client.awaitNotification();
|
|
process(notification);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Processes an incoming notification
|
|
* accordingly
|
|
*/
|
|
private void process(byte[] data)
|
|
{
|
|
/* TODO: Implement me */
|
|
|
|
/* TODO: Check notification type */
|
|
byte notificationType = data[0];
|
|
|
|
/* For normal message (to channel or user) */
|
|
if(notificationType == cast(byte)0)
|
|
{
|
|
/* TODO: Decode using tristanable */
|
|
writeln("new message");
|
|
|
|
/* TODO: CHeck sub-type here */
|
|
}
|
|
/* Channel notification (ntype=1) */
|
|
else if(notificationType == cast(byte)1)
|
|
{
|
|
/* TODO: Decode using tristanable */
|
|
/* TODO: Get the username of the user that left */
|
|
//writeln("user left/join message");
|
|
|
|
/* Get the sub-type */
|
|
byte subType = data[1];
|
|
|
|
/* If the notification was leave (stype=0) */
|
|
if(subType == cast(byte)0)
|
|
{
|
|
string username = cast(string)data[2..data.length];
|
|
writeln("<-- "~username~" left the channel");
|
|
}
|
|
/* If the notification was join (stype=1) */
|
|
else if(subType == cast(byte)1)
|
|
{
|
|
string username = cast(string)data[2..data.length];
|
|
writeln("--> "~username~" joined the channel");
|
|
}
|
|
/* TODO: Unknown */
|
|
else
|
|
{
|
|
|
|
}
|
|
}
|
|
}
|
|
} |