jsbin/lib/processors/fork.js

'use strict';

var RSVP = require('rsvp');
var fork = require('child_process').fork;

module.exports = function (language, source) {
  return new RSVP.Promise(function (resolve) {
    var child = fork(__dirname);
    var output = '';

    var timeout = setTimeout(function () {
      console.error(language + ' processor timeout');
      child.kill();
    }, 1000);

    child.on('stderr', function (data) {
      console.error(language + ' processor errors');
      console.error(data);
    });

    child.on('message', function (message) {
      output += message;
    });

    child.on('exit', function () {
      clearTimeout(timeout);
      resolve(output);
    });

    child.send({ language: language, source: source });
  });
};