Refactor directories

lib/worker.js

@@ -0,0 +1,60 @@
+var path = require('path');
+var app = require('express')();
+var bodyParser = require('body-parser');
+var cors = require('cors');
+
+module.exports.run = function(worker) {
+  var httpServer = worker.httpServer;
+  var scServer = worker.scServer;
+
+  httpServer.on('request', app);
+
+  app.set('view engine', 'ejs');
+  app.set('views', path.resolve(__dirname, '..', 'views'));
+  
+  app.get('/', function(req, res) {
+    res.render('index', { port: worker.options.port });
+  });
+
+  app.use(cors({ methods: 'POST' }));
+  app.use(bodyParser.json());
+  app.post('/', function(req, res) {
+    if (!req.body) return res.status(404).end();
+    scServer.exchange.publish('log', req.body);
+    res.send('OK');
+  });
+
+  scServer.addMiddleware(scServer.MIDDLEWARE_EMIT, function (req, next) {
+    var channel = req.event;
+    var data = req.data;
+    if (channel.substr(0, 3) === 'sc-' || channel === 'respond' || channel === 'log') {
+      scServer.exchange.publish(channel, data);
+    } else if (channel === 'log-noid') {
+      scServer.exchange.publish('log', { id: req.socket.id, data: data });
+    }
+    next();
+  });
+
+  scServer.on('connection', function(socket) {
+    var channelToWatch, channelToEmit;
+    socket.on('login', function (credentials, respond) {
+      if (credentials === 'master') {
+        channelToWatch = 'respond'; channelToEmit = 'log';
+      } else {
+        channelToWatch = 'log'; channelToEmit = 'respond';
+      }
+      worker.exchange.subscribe('sc-' + socket.id).watch(function(msg) {
+        socket.emit(channelToWatch, msg);
+      });
+      respond(null, channelToWatch);
+    });
+    socket.on('disconnect', function() {
+      var channel = worker.exchange.channel('sc-' + socket.id);
+      channel.unsubscribe(); channel.destroy();
+      scServer.exchange.publish(
+        channelToEmit,
+        { id: socket.id, type: 'DISCONNECTED' }
+      );
+    });
+  });
+};