1 files changed, 56 insertions, 24 deletions

diff --git a/webchat/index.js b/webchat/index.js
index d3bd0a71..cf045912 100644
--- a/webchat/index.js
+++ b/webchat/index.js
@@ -1,34 +1,51 @@
+'use strict';
 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) { //broadcast to all clients
-  Clients.forEach(function(client) {
-    client.write(JSON.stringify(object));
+var serverstate = {
+  connected = false,
+  nicks = [],
+  lastping = 0,
+}; 
+
+var clients = [];
+
+clients.notifyAll = function (method, params) {
+  var object = {
+    method: method,
+    params: params,
+  }
+  clients.forEach(function (client) {
+    client.conn.write(JSON.stringify(object));
   });
 }
 
+
 var serverCommands = {};
 
 serverCommands.say = function (settings, params) {
-  var nick = settings.nick || settings.conn.remoteAddress
-  var message = params.message
+  var nick = settings.nick
+  var message = params.msg
+  params.nick = nick
   irc_client.say("#krebs", nick + ' → ' + message);
-  return Clients.broadcast({ type: 'message', nick: nick, message: message })
+  return clients.notifyAll('message', params)
+//  return clients.broadcast({ method: 'message', params: params })
+
 }
 
 serverCommands.nick = function (settings, params) {
   var oldnick = settings.nick || settings.conn.remoteAddress
   var newnick = params.nick
   settings.nick = newnick
-  return Clients.broadcast({ type: 'nickchange', nick: oldnick, newnick: newnick })
+  return clients.notifyAll('nickchange', { nick: oldnick, newnick: newnick });
+//  return clients.broadcast({ method: 'nickchange', params: { nick: oldnick, newnick: newnick }})
 }
 
 serverCommands.badcommand = function (settings, params) {
-  settings.conn.write(JSON.stringify({ type: 'usererror', message: 'bad command' }))
+  settings.conn.write(JSON.stringify({ method: 'usererror', params: { message: 'bad command' }}))
 }
 
 var irc_reconnect = function() { //reconnt to irc
@@ -47,7 +64,7 @@ var irc_client = new irc.Client('irc.freenode.net', 'kweb', { //create irc_clien
   userName: 'kweb', //todo: read from local_config
   realName: 'kweb', //todo: read from local_config
   password: fs.readFileSync(__dirname+'/local_config/irc.key').toString(),
-  debug: false,
+  debug: true,
   showErrors: true,
   floodProtection: true,
   port: 6697,
@@ -65,24 +82,32 @@ irc_client.on('ping', function(server) { //restart timer on server ping
 
 irc_client.on('message#krebs', function(from, message) {
   console.log({ from: from, message: message });
-  Clients.broadcast({ type: 'message', from: from, message: message }); //broadcast irc messages to all connected clients
+  clients.notifyAll('message', { nick: from, msg: message });
+//  clients.broadcast({ method: 'message', params: {nick: from, msg: message} }); //broadcast irc messages to all connected clients
   clearTimeout(lastping);
 });
 
 irc_client.on('names#krebs', function(nicks) {
-  Clients.broadcast({type: 'nicklist', message: nicks});
+//  clients.broadcast({method: 'nicklist', params: { nicklist: nicks }});
+  clients.notifyAll('nicklist', { nicklist: nicks })
 });
 
 irc_client.on('join#krebs', function(nick, msg) {
   if (nick !== 'kweb'){
-    Clients.broadcast({type: 'join', from: nick});
+    clients.notifyAll('join', { from: nick })
+//    clients.broadcast({method: 'join', params: { from: nick }});
   }
 });
 
 irc_client.on('part#krebs', function(nick, rs, msg) {
-  Clients.broadcast({type: 'quit', from: nick});
+  clients.notifyAll('quit', { from: nick })
+//  clients.broadcast({method: 'quit', params: { from: nick }});
 });
 
+irc_client.on('error', function (error) {
+  console.log('irc-client error', error)
+})
+
 var web_serv_options = { //certificates for https
   key: fs.readFileSync(__dirname+'/local_config/server_npw.key'),
   cert: fs.readFileSync(__dirname+'/local_config/server.crt'),
@@ -92,29 +117,35 @@ var echo = sockjs.createServer();
 echo.on('connection', function(conn) {
   var origin = conn.remoteAddress;
   var settings = {
-    conn: conn
+    conn: conn,
+    addr: conn.remoteAddress,
+    nick: conn.remoteAddress
   }
-  Clients.push(conn);
-  Clients.broadcast({type: 'join', from: origin})
+  clients.push(settings);
+  clients.notifyAll('join', { from: settings.nick })
+//  clients.broadcast({method: 'join', params: { from: settings.nick }})
 //  irc_client.say("#krebs", origin + ' has joined');
   if (typeof irc_client.chans['#krebs'] === 'object') {
-    conn.write(JSON.stringify({type: 'nicklist', message: irc_client.chans['#krebs'].users})); //send current nicklist
+    conn.write(JSON.stringify({method: 'nicklist', params: { nicklist: irc_client.chans['#krebs'].users }})); //send current nicklist
   };
-  conn.write(JSON.stringify({type: 'message', from: 'system', message: 'hello' })) //welcome message
+  conn.write(JSON.stringify({method: 'message', params: { nick: 'system', msg: 'hello' }})) //welcome message
   console.log(irc_client.chans['#krebs'])
   conn.on('data', function(data) {
     console.log('data:',data);
     try {
       var command = JSON.parse(data);
-      return (serverCommands[command.method] || serverCommands.badcommand)(settings, command.params)
-
     } catch (error) {
       console.log(error);
     }
+    if (!command || typeof command !== 'object') {
+      command = {}
+    }
+    return (serverCommands[command.method] || serverCommands.badcommand)(settings, command.params)
   });
   conn.on('close', function() { //propagate if client quits the page
-  Clients.splice(Clients.indexOf(conn));
-  Clients.broadcast({type: 'quit', from: origin})
+  clients.splice(clients.indexOf(conn));
+  clients.notifyAll('quit', { from: settings.nick }) 
+//  clients.broadcast({method: 'quit', params: { from: origin }})
 //  irc_client.say("#krebs", origin + ' has quit');
 });
 });
@@ -125,12 +156,13 @@ var app = connect()
   .use(connect.static(__dirname+'/public'))
   .use( function (req, res) {
     res.writeHead(200, {'Content-Type': 'text/html'});
-    page_template='<!doctype html>\n';
+    var page_template='<!doctype html>\n';
     page_template+='<link rel="stylesheet" type="text/css" href="reset.css">\n';
     page_template+='<script src="sockjs-0.3.min.js"></script>\n';
     page_template+='<script src="jquery-2.0.3.min.js"></script>\n';
     page_template+='<script src="commands.js"></script>\n';
     page_template+='<script src="functions.js"></script>\n';
+    page_template+='<script src="handler.js"></script>\n';
     page_template+='<script src="client.js"></script>\n';
     page_template+='<div id="bg">';
     page_template+='<div id="chatter">';