server.js

var http = require('http')
var ecstatic = require('ecstatic');
var fs = require('fs');
var Engine = require('engine.io-stream');

var httpServer = http.createServer(ecstatic({
	root: __dirname
})).listen(8080);
console.log("listening on port 8080");

var clients = [];
var userTable = {};

/*
*	Video WebSocket
*/
var vidEngine = Engine(function (socket) {

	socket.once("data", function (data) {
		console.log("connection made!", data);
		clients.push({
			id: data,
			socket: socket
		});
	})

	socket.on('data', function (data) {
		var obj = {};
		for (var i=0; i < clients.length; i++) {
			obj[clients[i].id] = data;
			clients[i].socket.write(JSON.stringify(obj));
		}
	});

	socket.on('end', function () {
		var i = clients.indexOf(clients);
		clients.splice(i, 1);
	});

});


/*
*	Room WebSockets
*/
var roomEngine = Engine(function (socket) {
	console.log("socket user");
	socket.on('data', function (data) {
		var d = JSON.parse(data);
		if (!(d.id in userTable)) {
			userTable[d.id] = {
				username: d.username,
				createdAt: new Date()
			};
		}

		console.log(JSON.stringify(userTable));
		socket.write(JSON.stringify(userTable));

	})
});

vidEngine.attach(httpServer, "/video");
roomEngine.attach(httpServer, "/room");