initial commit

app.js

@@ -0,0 +1,86 @@
+var express = require('express')
+  , routes = require('./routes');
+
+var users = [];
+
+var app = module.exports = express.createServer();
+
+app.configure(function(){
+  app.set('views', __dirname + '/views');
+  app.set('view engine', 'jade');
+  app.use(express.bodyParser());
+  app.use(express.methodOverride());
+  app.use(app.router);
+  app.use(express.static(__dirname + '/public'));
+});
+
+app.configure('development', function(){
+  app.use(express.errorHandler({ dumpExceptions: true, showStack: true }));
+});
+
+app.configure('production', function(){
+  app.use(express.errorHandler());
+});
+
+app.get('/', routes.index);
+
+app.get('/getNext/:socket', function(req, res){
+
+  if (users.length > 1) {
+    console.log(req.params.socket);
+
+    // Remove caller from KV (no longer available)
+    var userFilter = users.filter(function (user) { return user.socket == req.params.socket });
+    users.splice(users.indexOf(userFilter[0]), 1); 
+
+
+    // Get first available key/jid to call
+    // delete user from KV (no longer available)
+    var nextUser = users.shift();
+
+    console.log(nextUser);
+    res.send({jid: nextUser.jid});
+
+  } else {
+    res.send({jid: false});
+  }
+
+});
+
+app.listen(3000, function(){
+  console.log("Express server listening on port %d in %s mode", app.address().port, app.settings.env);
+});
+
+
+var io = require('socket.io').listen(app);
+
+io.configure(function() {
+  io.enable("browser client minification");
+  io.enable("browser client etag");
+  io.enable("browser client gzip");
+  io.set("destroy upgrade", false);
+  io.set("log level", 1);
+  io.set("transports", ["websocket", "htmlfile", "xhr-polling", "jsonp-polling"]);
+  // return io.set("store", new RedisStore({
+  //   redisPub: pub,
+  //   redisSub: sub,
+  //   redisClient: store
+  // }));
+});
+
+io.sockets.on("connection", function(socket) {
+  socket.on("hello", function(jid) {
+    users.push({socket: socket.id.toString(), jid: jid});
+    console.log("connected: " + socket.id.toString() + " jid=" + jid);
+    console.log(users);
+  });
+  socket.on("disconnect", function() {
+    var userFilter = users.filter(function (user) { return user.socket == socket.id.toString() });
+    if (userFilter && userFilter.length){
+      users.splice(users.indexOf(userFilter[0]), 1);      
+    }
+    console.log("disconnected: " + socket.id.toString());
+    console.log(users);
+  });
+});
+