1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
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('<!doctype html>');
res.write('<link rel="stylesheet" type="text/css" href="reset.css">');
res.write('<script src="sockjs-0.3.min.js"></script>');
res.write('<script src="jquery-2.0.3.min.js"></script>');
res.write('<script src="client.js"></script>');
res.write('<div id=bg>');
res.write('hello, this is #krebs:<br>');
res.write('<table id="chatbox"></table>');
res.end('<input type="text" id="input"><br>');
res.write('</div>');
})
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/');
|
