| 'use strict' |
| |
| let $module |
| |
| /* |
| let contextProto = this.context; |
| while (contextProto = Object.getPrototypeOf(contextProto)) { |
| completionGroups.push(Object.getOwnPropertyNames(contextProto)); |
| } |
| */ |
| |
| |
| function handle (data) { |
| let idx = data.idx |
| , child = data.child |
| , method = data.method |
| , args = data.args |
| , callback = function () { |
| let _args = Array.prototype.slice.call(arguments) |
| if (_args[0] instanceof Error) { |
| let e = _args[0] |
| _args[0] = { |
| '$error' : '$error' |
| , 'type' : e.constructor.name |
| , 'message' : e.message |
| , 'stack' : e.stack |
| } |
| Object.keys(e).forEach(function(key) { |
| _args[0][key] = e[key] |
| }) |
| } |
| process.send({ owner: 'farm', idx: idx, child: child, args: _args }) |
| } |
| , exec |
| |
| if (method == null && typeof $module == 'function') |
| exec = $module |
| else if (typeof $module[method] == 'function') |
| exec = $module[method] |
| |
| if (!exec) |
| return console.error('NO SUCH METHOD:', method) |
| |
| exec.apply(null, args.concat([ callback ])) |
| } |
| |
| |
| process.on('message', function (data) { |
| if (data.owner !== 'farm') { |
| return; |
| } |
| |
| if (!$module) return $module = require(data.module) |
| if (data.event == 'die') return process.exit(0) |
| handle(data) |
| }) |
