'use strict';

module.exports.create = function () {
  var m = new (require('events').EventEmitter)();

  m.addWorker = function (worker) {
    m._workers = [];

    var w = new (require('events').EventEmitter)();

    worker.on('online', function () {
      //console.log('debug mw: worker is up')
      m.emit('connection', w);
    });

    worker.on('message', function (data) {
      //console.log('debug mw: worker sends message', data)
      w.emit('message', data);
    });

    w.send = function (data) {
      worker.send(data);
    };

    m._workers.push(w);
  };

  return m;
};