lively-events.js

var EventEmitter = require('events').EventEmitter;
var statusEmitter = new EventEmitter();
var workerLib = require('./lib/workerlib');
workerLib.initialize('lively_events', function() {
  var deployment = require('./lib/deployment').init({workerLib: workerLib});
  var workerManagement = require('./lib/worker_management').init({
    workerLib: workerLib,
    deployment: deployment
  });
  var subscriptionHandling = require('./lib/subscription_handling').init({
    workerLib: workerLib,
    workerManagement: workerManagement
  });

  var myutils = require('./lib/myutils');

  var openStdin = function() {
    var stdin = process.openStdin();
    stdin.on('data', function(d) {
      server.listen(parseInt(JSON.parse(d)));
    });
    stdin.on('end', function() {
      workerLib.emitLivelyEvent('stopped');
      console.log('lively-events.js exits');
      process.exit(0);
    });
  }
  var startup = function(startupCb) {
    openStdin();
    myutils.doLinear([
    function(cb) {
      deployment.checkAndDeploy(cb)
    },
    function(cb) {
      subscriptionHandling.createEventsChangeListener(cb)
    },
    function(cb) {
      subscriptionHandling.launchEventSystem(cb)
    },
    function(cb) {
      deployment.createWorkerChangeListener();
      cb();
    }
    ], function() {
      startupCb();
    });
  }
  startup( function() {
    statusEmitter.emit('started');
  });
});
exports.statusEmitter = statusEmitter;