cameraServer.js

var camera = require('./camera.js');
var STREAM_SECRET = require('secure-random').randomArray(40).map(code => code.toString(16)).join('')

var STREAM_PORT = 8082;
var WEBSOCKET_PORT = 8084;
var STREAM_MAGIC_BYTES = 'jsmp'; // Must be 4 bytes

var width = 640;
var height = 480;

var socketServer = new(require('ws').Server)({
	port: WEBSOCKET_PORT
});

socketServer.on('connection', function(socket) {
	// Send magic bytes and video size to the newly connected socket
	// struct { char magic[4]; unsigned short width, height;}
	var streamHeader = new Buffer(8);
	streamHeader.write(STREAM_MAGIC_BYTES);
	streamHeader.writeUInt16BE(width, 4);
	streamHeader.writeUInt16BE(height, 6);
	socket.send(streamHeader, {
		binary: true
	});

	console.log('New WebSocket Connection (' + socketServer.clients.length + ' total)');

	socket.on('close', function(code, message) {
		console.log('Disconnected WebSocket (' + socketServer.clients.length + ' total)');
	});
});

socketServer.broadcast = function(data, opts) {
	this.clients.forEach( function(client, i) {
		if (client.readyState == 1) {
			client.send(data, opts);
		}
		else {
			console.log('cameraServer Error: client', i, 'not connected...');
		}
	});
};

// HTTP Server to accept incomming MPEG Stream
var streamServer = require('http').createServer(function(request, response) {
	var params = request.url.substr(1).split('/');

		if (params[0] == STREAM_SECRET) {

			console.log(
				'Stream Connected: ' + request.socket.remoteAddress +
				':' + request.socket.remotePort + ' size: ' + width + 'x' + height
			);
			request.on('data', function(data) {
				socketServer.broadcast(data, {
					binary: true
				});
			});
		}
		else {
			console.log(
				'Failed Stream Connection: ' + request.socket.remoteAddress +
				request.socket.remotePort + ' - wrong secret.'
			);
			response.end();
		}
}).listen(STREAM_PORT);
camera.start(STREAM_PORT, STREAM_SECRET);