skippy/source/notifications.d

import core.thread : Thread;
import tristanable.manager;
import tristanable.notifications;
import std.stdio;
import core.time : dur;
import tristanable.encoding;

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)
		{
			/* Check for notifications every 2 seconds */
			NotificationReply[] notifications =manager.popNotifications();

			if(notifications.length)
			{
				//writeln(notifications);
				foreach(NotificationReply notificationReply; notifications)
				{
					//writeln(notificationReply.getData());

                    /* Await a notification */
                    manager.awaitNotification();
					string msg = cast(string)notificationReply.getData();
					writeln("!> "~msg);
					process(notificationReply.getData());
				}
			}

			Thread.getThis().sleep(dur!("seconds")(2));
		}
	}

	/**
	* 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
			{
				
			}
		}
	}
}