mjpeg-camera + socket.io

gistfile1.js

var MjpegCamera = require('mjpeg-camera');
var WriteStream = require('stream').Writable;
var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);

var camera = new MjpegCamera({
  user: 'username',
  password: 'password',
  url: 'http://camera-ip-address',
  name: 'camera'
});
camera.start();

var ws;
io.on('connection', function(socket) {
  ws = new WriteStream({objectMode: true});
  s._write = function(chunk, enc, next) {
    var jpeg = chunk.data.toString('base64');
    socket.emit('frame', {data: jpeg});
    next();
  };
  camera.pipe(ws);
});

io.on('disconnect', function() {
  camera.unpipe(ws);
});