server.js

#!/usr/bin/env node

var fs = require('fs');

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);

var httpRequest = require('http-request');
var url = require("url");
var BufferedNetstringStream = require('./netstring').BufferedNetstringStream;
var colors = require('colors/safe');


var verbose = true;
var portNum = 5600;
var clients = [];

var urlRules = [
	['.png','image/png'],
	['.js','application/javascript'],
	['.html','text/html'],
	['.css','text/css'],
	['.json','text/event-stream'],
	['.xml','text/xml'],

	['.svg','image/svg+xml'],
	['.ttf','application/x-font-ttf'],
	['.otf','application/x-font-opentype'],
	['.woff','application/x-font-woff'],
	['.eot','application/vnd.ms-fontobject'],

	['.ico','image/x-icon']
];


// Init kinect stream functions
var id = 0;
function writeImage(image) {

	var uri = 'data:image/png;base64,' + image.toString('base64');

	clients.forEach(function(client) {
		client.write('id: ' + id + '\n');
		client.write('data: ' + uri + '\n\n');
	});

	id++;
}

function stream(req, res) {

	res.writeHead(200, {
		'Content-Type':  'text/event-stream',
		'Cache-Control': 'no-cache',
		'Connection':    'keep-alive'
	});

	clients.push(res);

	req.on('close', function() {
		var index = clients.indexOf(res);
		if (index != -1) {
			clients.splice(index, 1);
		}

	});
}


// Start Express webserver
app.get('*', function(req, res) {

	var parsedURL = url.parse(req.url, true);
	var pathname = parsedURL.pathname;

	var reqURL = __dirname + req.url;
	if(pathname == '/') reqURL = __dirname + '/webroot/index.html';
	else if(pathname == '/ui') reqURL = __dirname + '/webroot/ui.html';
	
	if (pathname == '/images') {

		stream(req, res, 'text/event-stream');
		if(verbose) console.log('kinect stream requested');		

	} else {

		var mimeType = false;
		for(var i=0; i< urlRules.length; i++) {
			if (reqURL.indexOf(urlRules[i][0]) > -1) {
				mimeType = urlRules[i][1];
				i = urlRules.length;
			}
		}
		if(!mimeType) mimeType = 'text/plain';
		fs.readFile(reqURL, function (err, data) {
			if (err) {
				res.writeHead(500);
				return res.end('Error loading ' +reqURL);
				console.log('Error loading ' +reqURL);
			}
			res.writeHead(200,{
				'Content-Type': mimeType
			});
			res.end(data);
		});
	}

});


// Set up Socket.IO connections
io.on('connection', function (socket) {

	socket.on('deviceActive', function (data) {
		console.log('New socket opened for device "' + data.deviceName + '"');
	});

	socket.on('effectList', function (data) {
		io.emit('effectList', data);
		if(data.request == 'SET') console.log('Effect list received!', data.data.effectList);
	});

	socket.on('effectParams', function (data) {
		io.emit('effectParams', data);
		if(data.request == 'SET') console.log('Effect params received!', data.data);
	});

	socket.on('filterParams', function (data) {
		io.emit('filterParams', data);
		if(data.request == 'SET') console.log('Filter params received!', data.data);
	});

	socket.on('calibrationParams', function (data) {
		io.emit('calibrationParams', data);
		if(data.request == 'SET') console.log('Calibration params received!', data.data);
	});

	socket.on('effectChanged', function (data) {
		io.emit('effectChanged', data);
		if(data.request == 'SET') console.log('Effect change received!', data.data);
	});

	socket.on('serviceStatus', function (data) {
		io.emit('serviceStatus', data);
		if(data.request == 'SET') console.log('Service status sent from ' + data.deviceName + ' for ' + data.data.service, data.data);
	});

	socket.on('currentEffectParams', function (data) {
		io.emit('currentEffectParameters', data);
	});

	socket.on('paramUpdated', function(data) {
		io.emit('paramUpdated', data);
		if(data.request == 'SET') console.log('Param updated from ' + data.deviceName);
	});

	socket.on('disconnect', function () {
		io.emit('user disconnected');
		console.log('IO Socket disconnected');
	});

});


// Launch server
process.stdin.resume();
process.stdin.pipe(new BufferedNetstringStream).on('data', writeImage);
http.listen(portNum);

console.log(colors.green.bold('Node server started!')); 

setTimeout(function() {
	console.log('socket io sending fake get effect list request')
	io.emit('effectList', {request: 'GET'});
},3000);