summaryrefslogtreecommitdiffstats
path: root/webchat/hello_web.js
blob: e1f8f3125a7ad72e8b812b21625221a56881fb48 (plain)
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
var fs = require('fs');
var http = require('https');
var sockjs = require('sockjs');
var connect = require('connect');
var irc = require('irc');
var krebsimage = require('./krebs-img.js');
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 name = '['+conn.remoteAddress+':'+conn.remotePort+']';
  Clients.push(conn);
  Clients.broadcast({from: 'system', message: name + ' has joined'})
  irc_client.say("#krebs", name + ' has joined');
conn.write(JSON.stringify({from: 'system', message: 'hello'}))
  conn.on('data', function(message) {
    console.log('data:',message);
    try {
      var object = JSON.parse(message);
      object.from = name
    console.log(object.message);
  irc_client.say("#krebs", name + '→' + object.message);
  Clients.broadcast(object);

    } catch (error) {
      console.log(error);
    }
  });
conn.on('close', function() {
  Clients.splice(Clients.indexOf(conn));
  Clients.broadcast({from: 'system', message: name + ' has quit'})
  irc_client.say("#krebs", name + ' 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(krebsimage+'<br>');
    res.write('hello, this is #krebs:<br>');
    res.write('<table id="chatbox"></table>');
    res.end('<input type="text" id="input"><br>');

  })
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/');