support rfc2812-style LIST

[KiwiIRC.git] / server / irc / server.js

var util    = require('util'),
    EventBinder  = require('./eventbinder.js'),
    _ = require('lodash');

var IrcServer = function (irc_connection) {
    this.irc_connection = irc_connection;

    this.list_buffer = [];
    this.motd_buffer = '';
    
    this.irc_events = {
        connect:                onConnect,
        options:                onOptions,
        list_start:             onListStart,
        list_channel:           onListChannel,
        list_end:               onListEnd,
        motd_start:             onMotdStart,
        motd:                   onMotd,
        motd_end:               onMotdEnd,
        error:                  onError,
        password_mismatch:      onPasswordMismatch,
        channel_redirect:       onChannelRedirect,
        no_such_nick:           onNoSuchNick,
        cannot_send_to_channel: onCannotSendToChan,
        too_many_channels:      onTooManyChannels,
        user_not_in_channel:    onUserNotInChannel,
        not_on_channel:         onNotOnChannel,
        channel_is_full:        onChannelIsFull,
        invite_only_channel:    onInviteOnlyChannel,
        banned_from_channel:    onBannedFromChannel,
        bad_channel_key:        onBadChannelKey,
        chanop_privs_needed:    onChanopPrivsNeeded,
        nickname_in_use:        onNicknameInUse
    };
    EventBinder.bindIrcEvents('server:*', this.irc_events, this, this.irc_connection);
    

};


module.exports = IrcServer;


IrcServer.prototype.dispose = function (){
    EventBinder.unbindIrcEvents('server:*', this.irc_events, this.irc_connection);
    this.irc_connection = undefined;
};



function onConnect(event) {
    this.irc_connection.clientEvent('connect', {
        nick: event.nick
    });
};

function onOptions(event) {
    this.irc_connection.clientEvent('options', {
        options: event.options,
        cap: event.cap
    });
};

function onListStart(event) {
    this.irc_connection.clientEvent('list_start', {});
    this.list_buffer = [];
    this.busy_listing = true;
};

function onListChannel(event) {
    if (!this.busy_listing) {
      onListStart.call(this, event);
    }
    var buf;
    this.list_buffer.push({
        channel: event.channel,
        num_users: event.num_users,
        topic: event.topic
    });
    
    if (this.list_buffer.length > 200) {
        buf = _.sortBy(this.list_buffer, function (channel) {
            // sortBy sorts in ascending order, we want to sort by descending, hence using 0 - num_users.
            return 0 - channel.num_users;
        });
        this.irc_connection.clientEvent('list_channel', {
            chans: buf
        });
        this.list_buffer = [];
    }
};

function onListEnd(event) {
    var buf;
    
    buf = _.sortBy(this.list_buffer, function (channel) {
        // sortBy sorts in ascending order, we want to sort by descending, hence using 0 - num_users.
        return 0 - channel.num_users;
    });
    this.irc_connection.clientEvent('list_channel', {
        chans: buf
    });
    this.list_buffer = [];
    this.busy_listing = false;
    
    this.irc_connection.clientEvent('list_end', {});
};

function onMotdStart(event) {
    this.motd_buffer = '';
};

function onMotd(event) {
    this.motd_buffer += event.motd;
};

function onMotdEnd(event) {
    this.irc_connection.clientEvent('motd', {
        msg: this.motd_buffer
    });
};

function onError(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'error',
        reason: event.reason
    });
};

function onPasswordMismatch(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'password_mismatch'
    });
}

function onChannelRedirect(event) {
    this.irc_connection.clientEvent('channel_redirect', {
        from: event.from,
        to: event.to
    });
};

function onNoSuchNick(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'no_such_nick',
        nick: event.nick,
        reason: event.reason
    });
};

function onCannotSendToChan(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'cannot_send_to_chan',
        channel: event.channel,
        reason: event.reason
    });
};

function onTooManyChannels(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'too_many_channels',
        channel: event.channel,
        reason: event.reason
    });
};

function onUserNotInChannel(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'user_not_in_channel',
        nick: event.nick,
        channel: event.channel,
        reason: event.reason
    });
};

function onNotOnChannel(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'not_on_channel',
        channel: event.channel,
        reason: event.reason
    });
};

function onChannelIsFull(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'channel_is_full',
        channel: event.channel,
        reason: event.reason
    });
};

function onInviteOnlyChannel(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'invite_only_channel',
        channel: event.channel,
        reason: event.reason
    });
};

function onBannedFromChannel(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'banned_from_channel',
        channel: event.channel,
        reason: event.reason
    });
};

function onBadChannelKey(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'bad_channel_key',
        channel: event.channel,
        reason: event.reason
    });
};

function onChanopPrivsNeeded(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'chanop_privs_needed',
        channel: event.channel,
        reason: event.reason
    });
};

function onNicknameInUse(event) {
    this.irc_connection.clientEvent('irc_error', {
        error: 'nickname_in_use',
        nick: event.nick,
        reason: event.reason
    });
};