node-mjpeg-proxy.js

/**************************
TODO:
1. Make it work with existing HTTP servers and listen to resource URLs
**************************/

var http = require('http'),
sys = require('sys'),
url = require('url');

Proxy = exports.Proxy = function (srcURL, options) {
  if (!srcURL) throw new Error("Please provide a source feed URL");
  srcURL = url.parse(srcURL);

  var srcClient = http.createClient(srcURL.port || 80, srcURL.hostname);

  var audienceServer = options.audienceServer || http.createServer();
  var audienceServerPort = options.port || 5080;
  var audienceClients = [];

  // Starting the stream on from the source
  var request = srcClient.request('GET', srcURL.pathname +
  (srcURL.search ? srcURL.search : ""),
  {'host': srcURL.hostname});
  request.end();
  request.on('response', function (srcResponse) {
    /** Setup Audience server listener **/
    audienceServer.on('request', function (req, res) {
      /** Replicate the header from the source **/
      res.writeHead(200, srcResponse.headers);
      /** Push the client into the client list **/
      audienceClients.push(res);
      /** Clean up connections when they're dead **/
      res.socket.on('close', function () {
        audienceClients.splice(audienceClients.indexOf(res), 1);
      });
    });
    audienceServer.listen(audienceServerPort);
    sys.puts('node-mjpeg-proxy server started on port 5080');

    /** Send data to relevant clients **/
    srcResponse.setEncoding('binary');
    srcResponse.on('data', function (chunk) {
      var i;
      for (i = audienceClients.length; i--;) {
        audienceClients[i].write(chunk, 'binary');
      }
    });
  });
};