SkypeHelper.js

var util = require("util");
var fs = require('fs');
var toMarkdown = require('to-markdown');

var config = JSON.parse(fs.readFileSync("config.json"));
var output = require("./Output");
var pipes = require("./PipesHelper");
var SkywebClient = require('skyweb');

var SkypeHelper = 
{
	skyweb : new SkywebClient(),
	isConnected : false,
	debug : false,
	converters : 
	[
		{
			filter: ['a', 'ss', 'quote', 'legacyquote'],
			replacement: function(content) { return content; }
		},
		{
			filter: "pre",
			replacement: function(content) { return "`" + content + "`"; }
		},
		{
			filter: "uriobject",
			replacement: function(content) { return "` Shared something on skype that can't be shared elsewhere! :-( `"; }
		},
		{
			filter: "topicupdate",
			replacement : function(content, node)
			{
				var initiatorTag = node.getElementsByTagName("initiator")[0];
				var valueTag = node.getElementsByTagName("value")[0];
				
				var initiator = initiatorTag.innerHTML.replace("8:", "");
				var value = valueTag.innerHTML;
				
				if(initiatorTag && valueTag)
					return util.format("Skype topic changed to \"%s\" by \"%s\".", value, initiator);
				else
					return "Someone changed the skype topic.";
			}
		},
		{
			filter: "deletemember",
			replacement : function(content, node)
			{
				var initiatorTag = node.getElementsByTagName("initiator")[0];
				var targetTag = node.getElementsByTagName("target")[0];
				
				var initiator = initiatorTag.innerHTML.replace("8:", "");
				var target = targetTag.innerHTML.replace("8:", "");
				
				if(initiatorTag && targetTag)
				{
					if(initiator != target)
						return util.format("\"%s\" was removed from the skype group by \"%s\".", target, initiator);
					else
						return util.format("\"%s\" left the skype group.", target);
				}
				else
					return "Someone left the skype group.";
			}
		},
		{
			filter: "addmember",
			replacement : function(content, node)
			{
				var initiatorTag = node.getElementsByTagName("initiator")[0];
				var targetTag = node.getElementsByTagName("target")[0];
				
				var initiator = initiatorTag.innerHTML.replace("8:", "");
				var target = targetTag.innerHTML.replace("8:", "");
				
				if(initiatorTag && targetTag)
				{
					if(initiator != target)
						return util.format("\"%s\" was added to the skype group by \"%s\".", target, initiator);
					else
						return util.format("\"%s\" joined the skype group.", target);
				}	
				else
					return "Someone joined the skype group.";
			}
		}
	],
	Connect : function()
	{
		output.write("Connecting Skype...\n");
		try
		{
			this.skyweb.login(config.skype_username, config.skype_password).then((skypeAccount) => 
			{    
				output.write(" * Skype connected.\n")
				SkypeHelper.skyweb.setStatus('Online');
				SkypeHelper.isConnected = true;
				pipes.each(function(pipe)
				{
					if(pipe.announceConnection)
						SkypeHelper.SendMessage(pipe, "Reconnected", "SPYPE");
				});
			});	
			this.skyweb.messagesCallback = SkypeHelper.skypeMessagesReceived;
		}
		catch(err)
		{
			output.write("SkypeHelper.Connect() error: \n");
			output.write(err);
			output.write("\n");
			this.isConnected = false;
		}
		this.skyweb.on("error", this.errorListener);
	},
	errorListener : function(eventName, error)
	{
		console.log("!! Error occured in SkypeHelper: " + error);
		process.exit();
	},
	SendMessage : function(pipe, message, sender)
	{
		var skypeMessage = "";

		//if(pipe.lastSkypeSender != null)
			//skypeMessage += "\n";

		if(sender != null && sender != pipe.lastSkypeSender)
			skypeMessage += util.format("[%s]\n", sender);
		
		skypeMessage += message;
		
		output.write("SKYPE: (" + pipe.name + ") " + skypeMessage);
		
		if(SkypeHelper.isConnected)
		{
			try
			{
				SkypeHelper.skyweb.sendMessage(pipe.skypeId, skypeMessage);
				pipe.lastSkypeSender = sender;	
				output.write("SENT!\n");
			}
			catch(err)
			{
				output.write("FAILED! Error:\n");
				output.write(err);
				output.write("\n");
			}
		}
		else
		{
			output.write("FAILED! Skype is not connected.\n");
		}
	},
	Callbacks : [],
	MessageCallback : function(callback)
	{
		this.Callbacks.push(callback);
	},
	skypeMessagesReceived : function(messages)
	{
		messages.forEach(function (message) 
		{
			var spypeIsNotSender = (message.resource.from.toLowerCase().indexOf(config.skype_username.toLowerCase()) === -1);
			if(spypeIsNotSender && message.resource.messagetype !== 'Control/Typing' && message.resource.messagetype !== 'Control/ClearTyping')
			{
				var conversationLink = message.resource.conversationLink;
				var conversationId = conversationLink.substring(conversationLink.lastIndexOf('/') + 1);
				var pipe = pipes.getPipe({ skypeId: conversationId });
				if(pipe != null)
				{
					// Skype message received, clear lastSkypeSender
					pipe.lastSkypeSender = null;
					// Output received object (testing)
					if(SkypeHelper.debug)
					{
						output.write("RECEIVED IN SKYPE\n");
						output.write(message);
						output.write("\n");
					}
					// Clean up message from skype (remove code etc)
					var cleanMessage = toMarkdown(message.resource.content, { converters: SkypeHelper.converters });
					// Send to callbacks
					var userName = message.resource.imdisplayname;
					for(var i = 0; i < SkypeHelper.Callbacks.length; i++)
					{
						SkypeHelper.Callbacks[i](pipe, cleanMessage, userName);
					}
				}
			}
		});
	}
}

module.exports = SkypeHelper;