var net = require('net'),
tls = require('tls'),
events = require('events'),
- util = require('util');
+ util = require('util'),
+ _ = require('underscore');
-var IrcConnection = function (hostname, port, ssl, nick, user, pass, webirc) {
+var IrcConnection = function (hostname, port, ssl, nick, user, pass) {
var that = this;
events.EventEmitter.call(this);
if (ssl) {
- this.socket = tls.connect(port, hostname, {}, connect_handler);
+ this.socket = tls.connect({host: hostname, port: port, rejectUnauthorized: global.config.reject_unauthorised_certificates}, connect_handler);
} else {
this.socket = net.createConnection(port, hostname);
this.socket.on('connect', function () {
this.connected = false;
this.registered = false;
+ this.cap_negotiation = true;
this.nick = nick;
this.user = user;
+ this.irc_host = {hostname: hostname, port: port};
this.ssl = !(!ssl);
this.options = Object.create(null);
+ this.cap = {requested: [], enabled: []};
+ this.sasl = false;
- this.webirc = webirc;
this.password = pass;
this.hold_last = false;
this.held_data = '';
};
IrcConnection.prototype.end = function (data, callback) {
- console.log('Closing IRC socket');
end.call(this, data + '\r\n', 'utf-8', callback);
};
+IrcConnection.prototype.dispose = function () {
+ this.removeAllListeners();
+};
+
+
var write = function (data, encoding, callback) {
this.socket.write(data, encoding, callback);
};
var connect_handler = function () {
- if (this.webirc) {
- this.write('WEBIRC ' + this.webirc.pass + ' KiwiIRC ' + this.user.hostname + ' ' + this.user.address);
- }
- if (this.password) {
- this.write('PASS ' + this.password);
+ var that = this,
+ connect_data;
+
+ // Build up data to be used for webirc/etc detection
+ connect_data = {
+ user: this.user,
+ nick: this.nick,
+ realname: '[www.kiwiirc.com] ' + this.nick,
+ username: this.nick.replace(/[^0-9a-zA-Z\-_.]/, ''),
+ irc_host: this.irc_host
+ };
+
+ // Let the webirc/etc detection modify any required parameters
+ connect_data = findWebIrc(connect_data);
+
+ // Send any initial data for webirc/etc
+ if (connect_data.prepend_data) {
+ _.each(connect_data.prepend_data, function(data) {
+ that.write(data);
+ });
}
- //this.write('CAP LS');
- this.write('NICK ' + this.nick);
- this.write('USER kiwi_' + this.nick.replace(/[^0-9a-zA-Z\-_.]/, '') + ' 0 0 :' + this.nick);
+
+ this.write('CAP LS');
+
+ this.registration_timeout = setTimeout(function () {
+ that.register.call(that);
+ }, 1000);
this.connected = true;
- console.log("IrcConnection.emit('connected')");
this.emit('connected');
};
-parse_regex = /^(?::(?:([a-z0-9\x5B-\x60\x7B-\x7D\.\-]+)|([a-z0-9\x5B-\x60\x7B-\x7D\.\-]+)!([a-z0-9~\.\-_|]+)@?([a-z0-9\.\-:\/]+)?) )?(\S+)(?: (?!:)(.+?))?(?: :(.+))?$/i;
+IrcConnection.prototype.register = function () {
+ if (this.registration_timeout !== null) {
+ clearTimeout(this.registeration_timeout);
+ this.registration_timeout = null;
+ }
+ if ((this.password) && (!this.sasl)) {
+ this.write('PASS ' + this.password);
+ }
+ this.write('NICK ' + this.nick);
+ this.write('USER ' + this.nick.replace(/[^0-9a-zA-Z\-_.]/, '') + ' 0 0 :' + '[www.kiwiirc.com] ' + this.nick);
+ if (this.cap_negotation) {
+ this.write('CAP END');
+ }
+};
+
+
+
+function findWebIrc(connect_data) {
+ var webirc_pass = global.config.webirc_pass;
+ var ip_as_username = global.config.ip_as_username;
+ var tmp;
+
+ // Do we have a WEBIRC password for this?
+ if (webirc_pass && webirc_pass[connect_data.irc_host.hostname]) {
+ tmp = 'WEBIRC ' + webirc_pass[connect_data.irc_host.hostname] + ' KiwiIRC ';
+ tmp += connect_data.user.hostname + ' ' + connect_data.user.address;
+ connect_data.prepend_data = [tmp];
+ }
+
+
+ // Check if we need to pass the users IP as its username/ident
+ if (ip_as_username && ip_as_username.indexOf(connect_data.irc_host.hostname) > -1) {
+ // Get a hex value of the clients IP
+ connect_data.username = connect_data.user.address.split('.').map(function(i, idx){
+ return parseInt(i, 10).toString(16);
+ }).join('');
+
+ }
+
+ return connect_data;
+}
+
+
+parse_regex = /^(?:(?:(?:(@[^ ]+) )?):(?:([a-z0-9\x5B-\x60\x7B-\x7D\.\-]+)|([a-z0-9\x5B-\x60\x7B-\x7D\.\-]+)!([a-z0-9~\.\-_|]+)@?([a-z0-9\.\-:\/]+)?) )?(\S+)(?: (?!:)(.+?))?(?: :(.+))?$/i;
var parse = function (data) {
var i,
msg,
- msg2,
- trm;
+ msg2,
+ trm,
+ j,
+ tags = [],
+ tag;
if ((this.hold_last) && (this.held_data !== '')) {
data = this.held_data + data;
// We have a complete line of data, parse it!
msg = parse_regex.exec(data[i].replace(/^\r+|\r+$/, ''));
if (msg) {
+ if (msg[1]) {
+ tags = msg[1].split(';');
+ for (j = 0; j < tags.length; j++) {
+ tag = tags[j].split('=');
+ tags[j] = {tag: tag[0], value: tag[1]};
+ }
+ }
msg = {
- prefix: msg[1],
- nick: msg[2],
- ident: msg[3],
- hostname: msg[4] || '',
- command: msg[5],
- params: msg[6] || '',
- trailing: (msg[7]) ? msg[7].trim() : ''
+ tags: tags,
+ prefix: msg[2],
+ nick: msg[3],
+ ident: msg[4],
+ hostname: msg[5] || '',
+ command: msg[6],
+ params: msg[7] || '',
+ trailing: (msg[8]) ? msg[8].trim() : ''
};
msg.params = msg.params.split(' ');
projects / KiwiIRC.git / blobdiff