term-notify-server/notify-term/app.js

"use strict";

var cl = global.botanLoader;
var Dragonfly = global.Dragonfly;

var HttpRequest = cl.load( "botanss.net.HttpRequest" );
var Base = cl.load( "botanss.net.PostFrame" );

var WNSAuth = cl.load( "notifyterm.WNSAuth" );
var NotisQ = cl.load( "notifyterm.Notis" );
var SrvAuth = cl.load( "notifyterm.config.auth" );

class App extends Base
{
	constructor( Http )
	{
		super( Http );

		// Everything here is plain text
		this.HTTP.response.headers[ "Content-Type" ] = "text/plain; charset=utf-8";

		this.result = "Hello there! This is a notify-term server.\nFor more information please head to https://github.com/tgckpg/term-notify";

		if( !this.HTTP.request.isPost )
		{
			if( this.HTTP.request.uri.path != "/" )
			{
				this.result = "This site has no static content";
				this.HTTP.response.statusCode = 404;
			}

			this.plantResult();
			return;
		}

		this.OAuth = new WNSAuth();
		this.OAuth.addListener( "AuthComplete", this.OnAuthed.bind( this ) );
		this.OAuth.Authenticate();
		this.RequestQueue = [];

		this.addListener( "PostRequest", this.PostRequest );
	}

	PostRequest( sender, e )
	{
		e.Handled = true;

		var query = e.Data;

		// Protected Actions
		switch( query.action )
		{
			case "register":
			case "remove":
				if(!( query.pass && query.pass == SrvAuth.Client ))
				{
					Dragonfly.Debug( "Unauthorized Access" );

					this.result = "Unauthorized Access";
					this.plantResult();

					return;
				}
				break;
		}

		switch( query.action )
		{
			case "register":
				console.log( "HEiiiiRE" );
				this.OAuth.Register(
				query.id, query.uri, ( sender, mesg ) => {
					this.result = mesg;
					this.plantResult();
				} );
				break;

			case "deliver":
				this.__sendMesg( query );
				break;

			case "remove":
				this.OAuth.Unregister( query.id, ( err, data ) => {

					if( err )
					{
						Dragonfly.Error( err );
					}
					else
					{
						Dragonfly.Debug( "Removed " + query.id + ": " + data );
					}

					this.result = "OK";
					this.plantResult();
				} );
				break;
			default:
				this.result = "Invalid Action";
				this.plantResult();
		}
	}

	__sendMesg( query )
	{
		var N = new NotisQ( query );
		if( N.Valid )
		{
			this.RequestQueue.push( N );
			this.result = "Your message has been queued";
		}
		else
		{
			this.result = "Invalid message format";
		}

		this.plantResult();
		this.OAuth.Authenticate();
	}

	OnAuthed( OAuth )
	{
		if( !OAuth.IsAuthenticated )
		{
			Dragonfly.Error( "Unable to authenticate" );
		}

		this.ProcessQueue();
	}

	ProcessQueue()
	{
		if(!( this.RequestQueue && this.RequestQueue.length ))
		{
			this.RequestQueue = [];
			return;
		}

		var Request = this.RequestQueue.shift();
		this.OAuth.Deliver( Request );
	}
}

module.exports = App;