First release

bin/remotedev.js

@@ -0,0 +1,10 @@
+#! /usr/bin/env node
+var argv = require('minimist')(process.argv.slice(2));
+var SocketCluster = require('socketcluster').SocketCluster;
+
+var socketCluster = new SocketCluster({
+  host: argv.hostname || null,
+  port: Number(argv.port) || 8000,
+  workerController: __dirname + '/worker.js',
+  allowClientPublish: false
+});

bin/worker.js

@@ -0,0 +1,27 @@
+module.exports.run = function(worker) {
+  var scServer = worker.scServer;
+
+  scServer.addMiddleware(scServer.MIDDLEWARE_EMIT, function (socket, channel, data, next) {
+    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: socket.id, data: data });
+    }
+    next();
+  });
+
+  scServer.on('connection', function(socket) {
+    socket.on('login', function (credentials, respond) {
+      var channelName = credentials === 'master' ? 'respond' : 'log';
+      worker.exchange.subscribe('sc-' + socket.id).watch(function(msg) {
+        socket.emit(channelName, msg);
+      });
+      respond(null, channelName);
+    });
+    socket.on('disconnect', function() {
+      var channel = worker.exchange.channel('sc-' + socket.id);
+      channel.unsubscribe(); channel.destroy();
+      scServer.exchange.publish('log', { id: socket.id, type: 'DISCONNECTED' });
+    });
+  });
+};