var fs = require('fs');
var http = require('https');
var sockjs = require('sockjs');
var connect = require('connect');
var irc = require('irc');
var Clients = [];
Clients.broadcast = function(object) {
Clients.forEach(function(client) {
client.write(JSON.stringify(object));
});
}
var pingTimeoutDelay = 5*60*1000
var lastping = setTimeout(reconnect, pingTimeoutDelay)
var irc_client = new irc.Client('irc.freenode.net', 'kweb', {
channels: ['#krebs'],
sasl: true,
secure: true,
userName: 'kweb',
realName: 'kweb',
password: fs.readFileSync(__dirname+'/local_config/irc.key').toString(),
debug: true,
showErrors: true,
port: 6697,
autoRejoin: true,
autoConnect: true,
stripColors: true
});
var reconnect = function() {
console.log("reconnecting due to pingtimeout");
irc_client.disconnect();
irc_client.connect();
}
irc_client.on('ping', function(server) {
console.log("got ping from server, renewing timeout for automatic reconnect");
clearTimeout(lastping);
lastping = setTimeout(reconnect, pingTimeoutDelay);
})
irc_client.on('message#krebs', function(from, message) {
console.log({ from: from, message: message });
Clients.broadcast({ from: from, message: message });
clearTimeout(lastping);
});
var echo = sockjs.createServer();
echo.on('connection', function(conn) {
var origin = '['+conn.remoteAddress+':'+conn.remotePort+']';
Clients.push(conn);
irc_client.say("#krebs", name + ' has joined');
Clients.broadcast({from: 'system', message: origin + ' has joined'})
conn.write(JSON.stringify({from: 'system', message: 'hello'}))
conn.on('data', function(data) {
console.log('data:',data);
try {
var object = JSON.parse(data);
if (/^\/nick\s+(.+)$/.test(object.message)) {
object.from = origin;
} else if (typeof object.nick === 'string') {
object.from = object.nick;
} else {
object.from = origin;
};
console.log(object.message);
irc_client.say("#krebs", object.from + ' → ' + object.message);
Clients.broadcast(object);
} catch (error) {
console.log(error);
}
});
conn.on('close', function() {
Clients.splice(Clients.indexOf(conn));
irc_client.say("#krebs", name + ' has quit');
Clients.broadcast({from: 'system', message: origin + ' has quit'})
});
});
var options = {
key: fs.readFileSync(__dirname+'/local_config/server_npw.key'),
cert: fs.readFileSync(__dirname+'/local_config/server.crt'),
};
var app = connect()
.use(connect.logger('dev'))
.use(connect.static(__dirname+'/public'))
.use( function (req, res) {
res.writeHead(200, {'Content-Type': 'text/html'});
res.write('');
res.write('');
res.write('');
res.write('');
res.write('');
res.write('
');
res.write('hello, this is #krebs: ');
res.write('
');
res.end(' ');
res.write('
');
})
var server = http.createServer(options, app);
echo.installHandlers(server, {prefix:'/echo'});
server.listen(1337, '0.0.0.0');
console.log('Server running at https://127.0.0.1:1337/');