skyweb2irc.js

var Skyweb = require('skyweb');
var irc = require('irc');
var striptags = require('striptags');
var Entities = require('html-entities').XmlEntities;
var entities = new Entities();

var config = require('./config')

/**********************************************
 * Connect to Skype
 **********************************************/

var skyweb = new Skyweb();

var skype_account;

function main() {
    skyweb.login(config.skype_login, config.skype_password).then(function (skypeAccount) {
        console.log('Skyweb is initialized now');
        skype_account = skypeAccount;
        on_skype_initialized();
    });

    function on_skype_initialized() {
        if (config.skype_conversation_id == 'unknown') {
            // Only partially configured. Help the user get the Conversation ID.
            console.log('Conversation ID unknown, trying to find it. Please send a message on the Skype chat.')
            skyweb.messagesCallback = (function (messages) {
                var conversation_link = messages[0].resource.conversationLink;
                var conversation_id = conversation_link.substring(conversation_link.lastIndexOf('/') + 1);
                console.log('Conversation ID: ' + conversation_id);
                process.exit();
            });
        }
        else {
            // Fully configured, let's connect to IRC and start relaying.
            connect_to_irc();
            setup_irc_to_skype();
            setup_skype_to_irc();
            setInterval(reconnect_skype, 30*60*1000); // reconnect to skyweb every 30 minutes
        }
    }
}
main();

function reconnect_skype() {
    console.log('Reinitializing Skyweb (upkeep).');
    var new_skyweb = new Skyweb();
    new_skyweb.login(config.skype_login, config.skype_password).then(function (skypeAccount) {
        console.log('Skyweb reinitialized.');
        skype_account = skypeAccount;
        var old_skyweb = skyweb;
        skyweb = new_skyweb;
        setup_skype_to_irc();
        old_skyweb.messagesCallback = undefined;
    });
}

/**********************************************
 * Connect to IRC
 **********************************************/

var irc_client;

function connect_to_irc() {
    irc_client = new irc.Client(config.irc_hostname, config.irc_nick, {
        channels: [config.irc_channel],
        port: config.irc_port,
        secure: config.irc_tls,
    });

    irc_client.addListener('error', function(message) {
        console.log('irc error: ', message);
    });
}

/**********************************************
 * IRC to Skype
 **********************************************/

// the & is for > , which is likely to be an URL delimiter (RFC 2396)
var url_regexp = /(\b(https?|ftp):\/\/[^  ">&]+)/g
function encode_skype(text) {
    text = entities.encode(text); // Escape HTML entities
    text = text.replace(url_regexp, '<a href="$1">$1</a>'); // Make links clickable for Skype users.
    return text;
}

function mirc_color_to_html(fg, bg, text) { // foreground, background, contenT
    // TODO
    return text;
}

var bold_re = /\x02(.*?)\x02/g
var italic_re = /\x1D(.*?)\x1D/g
var underline_re = /\x1F(.*?)\x1F/g
var end_bold_re = /\x02(.*)/g
var end_italic_re = /\x1D(.*)/g
var end_underline_re = /\x1F(.*)/g
var color_re = /\x03(\d{1,2})?(,(\d{1,2}))?(.*?)\x0F/g
var end_color_re = /\x03(\d{1,2})?(,(\d{1,2}))?(.*)/g
function mirc_codes_to_html(text) {
    text = text.replace(bold_re, "<b>$1</b>");
    text = text.replace(italic_re, "<i>$1</i>");
    text = text.replace(underline_re, "<u>$1</u>");
    text = text.replace(end_bold_re, "<b>$1</b>");
    text = text.replace(end_italic_re, "<i>$1</i>");
    text = text.replace(end_underline_re, "<u>$1</u>");

    text = text.replace(color_re, function (match, fg, _, bg, text) { return mirc_color_to_html(fg, bg, text) });
    text = text.replace(end_color_re, function (match, fg, _, bg, text) { return mirc_color_to_html(fg, bg, text) });

    return text;
}

// A /me from IRC (aka CTCP ACTION)
var action_regexp = /^ACTION (.*)$/

function setup_irc_to_skype() {
    function send_to_skype(message) {
        console.log('IRC -> Skype: ' + message);
        skyweb.sendMessage(config.skype_conversation_id, message);
    }

    // Callback for when an IRC non-CTCP message is received
    irc_client.addListener('message' + config.irc_channel, function (from, message) {
        send_to_skype('&lt;' + from + '&gt; ' + mirc_codes_to_html(encode_skype(message)));
    });

    // Callback for when a CTCP message is received, eg. ACTION (aka. /me)
    irc_client.addListener('ctcp-privmsg', function (from, to, text, message) {
        var res = text.match(action_regexp);
        if (to != config.irc_channel || !res) {
            return;
        }
        send_to_skype('* ' + from + ' ' + encode_skype(res[1]));
    });

    // Callback for when a user joins the channel.
    irc_client.addListener('join' + config.irc_channel, function (nick, message) {
        send_to_skype('--&gt; ' + nick + ' joined.');
    });

    // Callback for when a user is kicked from the channel.
    irc_client.addListener('kick' + config.irc_channel, function (nick, by, reason, message) {
        send_to_skype('&lt;-- ' + nick + ' was kicked by ' + by + ' (' + reason + ')');
    });

    // Callback for when a user leaves a channel.
    irc_client.addListener('part' + config.irc_channel, function (nick, reason, message) {
        if (typeof reason == 'undefined') {
            send_to_skype('&lt;-- ' + nick + ' left the channel.');
        }
        else {
            send_to_skype('&lt;-- ' + nick + ' left the channel: ' + encode_skype(reason));
        }
    });

    // Callback for when a user leaves the network.
    irc_client.addListener('quit', function (nick, reason, channels, message) {
        send_to_skype('&lt;-- ' + nick + ' left the network: ' + encode_skype(reason));
    });

    // Callback for when the topic is changed, or when the bot joins the channel
    irc_client.addListener('topic', function (channel, topic, nick, message) {
        if (message.rawCommand != 'TOPIC') { // Probably 333
            // Don't relay the topic when joining the channel.
            return;
        }
        send_to_skype('--- ' + nick + ' changed the topic to: ' + encode_skype(topic));
    });
}


/**********************************************
 * Skype to IRC
 **********************************************/

// Magic thing in some actions, like topic/picture update or kick/joins
var initiator_regexp = /<initiator>8:([^<]+)<\/initiator>/
var target_regexp = /<target>8:([^<]+)<\/target>/

// Magic thing to get the URL of the group picture
var url_value_regexp = /<value>URL@([^<]+)<\/value>/
var uri_object_regexp = /url_thumbnail="([^"]+)"/

// Magic to know if a user has set a realname
var unset_realname_regexp = /^cid-.*@outlook.com/

// IRC colors
var nick_colors = [
    "\x0305", "\x0304", "\x0303", "\x0309", "\x0302",
    "\x0312", "\x0306",   "\x0313", "\x0310", "\x0311"]

// Deterministically colorize a Skype a Skype nick on IRC, like most IRC clients do.
function nick_to_color(nick){
    var hash = 0;
    var i = nick.length;
    while (i--) {
        char = nick.charCodeAt(i);
        hash += char;
    }
    return nick_colors[hash % nick_colors.length];
}

// Decode a message from Skype. Basically, remove HTML tags and decode HTML entities.
function decode_skype(text) {
    text = text.replace(/<i raw_pre="_" raw_post="_">/g, '_').replace(/<\/i>/g, '_')
    text = text.replace(/<b raw_pre="\*" raw_post="\*">/g, '*').replace(/<\/b>/g, '*')
    text = text.replace(/<s raw_pre="~" raw_post="~">/g, '~').replace(/<\/s>/g, '~')
    return entities.decode(striptags(text));
}

function setup_skype_to_irc() {
    function send_to_irc(message) {
        console.log('Skype -> IRC: ' + message);
        irc_client.say(config.irc_channel, message);
    }

    // Called when something happens on the Skype side.
    skyweb.messagesCallback = (function (messages) {
        messages.forEach(function (message) {
            console.log(message);
            var resource = message.resource;
            var author_username = resource.from.split('/8:', 2)[1];
            var author;
            if (config.use_skype_realname &&
                    typeof (resource.imdisplayname) != 'undefined' &&
                    !unset_realname_regexp.test(resource.imdisplayname)) {
                author = resource.imdisplayname;
            }
            else {
                author = author_username; // XXX: What does that even mean?
            }
            if (resource.messagetype == 'Control/Typing') {
                // Someone is writing something. Ignore.
                return;
            }
            else if (resource.messagetype == 'Control/ClearTyping') {
                // Someone stopped writing. Ignore.
                return;
            }
            else if (resource.messagetype == 'RichText') {
                // Real message
                if (author_username == skype_account.selfInfo.username) {
                    // Sent by the bot itself, ignore.
                    return;
                }

                var edited = ''
                if (typeof (resource.skypeeditedid) != 'undefined') {
                    // This message is an edit of a previous message by the same author.
                    edited = ' (edited)';
                }
                content = resource.content;
                if (typeof (content) == 'undefined') {
                    content = '';
                }
                send_to_irc('<' + nick_to_color(author) + author + '\x0f' + edited + '> ' + decode_skype(content));
            }
            else if (resource.messagetype == 'RichText/UriObject') {
                console.log(message);
                var content = resource.content;
                if (typeof (content) == 'undefined') {
                    content = ""
                }
                var data = content.match(uri_object_regexp);
                if (data === null) {
                    // Apparently, this happens in some cases of image deletion, but not all
                    send_to_irc('--- ' + nick_to_color(author) + author + '\x0f deleted an URI object.');
                }
                else {
                    var uri = data[1];
                    send_to_irc('--- ' + nick_to_color(author) + author + '\x0f sent an image: ' + uri.replace('imgt1_anim', 'imgpsh_fullsize'));
                }
            }
            else if (resource.messagetype == 'ThreadActivity/TopicUpdate') {
                // Update of the name of the group.
                author = resource.content.match(initiator_regexp)[1];
                send_to_irc('--- ' + nick_to_color(author) + author + '\x0f changed the topic to: ' + decode_skype(resource.threadtopic));
            }
            else if (resource.messagetype == 'ThreadActivity/PictureUpdate') {
                // Update of the picture of the group.
                author = resource.content.match(initiator_regexp)[1];
                url = resource.content.match(url_value_regexp)[1];
                send_to_irc('--- ' + nick_to_color(author) + author + '\x0f changed the image to: ' + url);
            }
            else if (resource.messagetype == 'ThreadActivity/AddMember') {
                // Member added by an other member.
                initiator = resource.content.match(initiator_regexp)[1];
                target = resource.content.match(target_regexp)[1];
                send_to_irc('--> ' + nick_to_color(initiator) + initiator + '\x0f added member ' + nick_to_color(target) + target + '\x0f')
            }
            else if (resource.messagetype == 'ThreadActivity/DeleteMember') {
                // Member left group or was deleted by an other member.
                initiator = resource.content.match(initiator_regexp)[1];
                target = resource.content.match(target_regexp)[1];
                send_to_irc('<-- ' + nick_to_color(initiator) + initiator + '\x0f deleted member ' + nick_to_color(target) + target + '\x0f')
            }
            else {
                send_to_irc('*** Unknown message type: ' + resource.messagetype + ' ***');
                console.log(message);
            }
        });
    });
}