webmgst.js

var express = require('express')
var net = require('net');
var child = require('child_process');

var cmd = 'gst-launch';
var args = '';
var options = null;
  // {env: {LD_LIBRARY_PATH: '/usr/local/lib',
  // PATH: '/usr/local/bin:/usr/bin:/bin'}};

var app = express.createServer();

app.get('/', function(req, res) {
  var date = new Date();

  res.writeHead(200, {
    'Date':date.toUTCString(),
    'Connection':'close',
    'Cache-Control':'private',
    'Content-Type':'video/webm',
    'Server':'CustomStreamer/0.0.1',
    });

  var server = net.createServer(function (socket) {
    socket.on('data', function (data) {
      res.write(data);
    });
    socket.on('close', function(had_error) {
      res.end();
    });
  });

  server.listen(function() {
    args =
    [//'ximagesrc',
    //'v4l2src',
    'videotestsrc', 'horizontal-speed=3', 'is-live=1',
    '!', 'video/x-raw-rgb,framerate=3/1',
    '!', 'ffmpegcolorspace',
    '!', 'vp8enc', 'speed=2',
    '!', 'queue2',
    '!', 'm.', 'audiotestsrc',
    '!', 'audioconvert',
    '!', 'vorbisenc',
    '!', 'queue2',
    '!', 'm.', 'webmmux', 'name=m', 'streamable=true',
    '!', 'tcpclientsink', 'host=localhost',
    'port='+server.address().port];
    console.log(args.toString());

    var gstMuxer = child.spawn(cmd, args, options);
    gstMuxer.stderr.on('data', onSpawnError);
    gstMuxer.on('exit', onSpawnExit);

    res.connection.on('close', function() {
      gstMuxer.kill();
    });
  });
});

app.listen(9001);

function onSpawnError(data) {
  console.log(data.toString());
}

function onSpawnExit(code) {
  if (code != null) {
    console.error('GStreamer error, exit code ' + code);
  }
}

process.on('uncaughtException', function(err) {
  console.debug(err);
});