skippy/source/notifications.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");
		}
		/* 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
			{
				
			}
		}
	}
}