55 lines
1.3 KiB
JavaScript
55 lines
1.3 KiB
JavaScript
|
|
class ProcessManager {
|
|
constructor(options) {
|
|
this.logger = options.logger;
|
|
this.events = options.events;
|
|
this.plugins = options.plugins;
|
|
this.processes = {};
|
|
|
|
this._registerAsPlugin();
|
|
this._registerEvents();
|
|
}
|
|
|
|
_registerAsPlugin() {
|
|
const self =this;
|
|
self.plugin = this.plugins.createPlugin('processManager', {});
|
|
self.plugin.registerAPICall(
|
|
'get',
|
|
'/embark-api/processes',
|
|
(req, res) => {
|
|
const formatter = (acc, processName) => {
|
|
acc.push({state: self.processes[processName].state, name: processName});
|
|
return acc;
|
|
};
|
|
res.send(Object.keys(self.processes).reduce(formatter, []));
|
|
}
|
|
);
|
|
}
|
|
|
|
_registerEvents() {
|
|
const self = this;
|
|
self.events.setCommandHandler('processes:register', (name, cb) => {
|
|
this.processes[name] = {
|
|
state: 'unstarted',
|
|
cb: cb
|
|
};
|
|
});
|
|
|
|
self.events.setCommandHandler('processes:launch', (name, cb) => {
|
|
let process = self.processes[name];
|
|
if (process.state !== 'unstarted') {
|
|
return cb();
|
|
}
|
|
process.state = 'starting';
|
|
process.cb.apply(process.cb, [
|
|
() => {
|
|
process.state = 'running';
|
|
cb();
|
|
}
|
|
]);
|
|
});
|
|
}
|
|
}
|
|
|
|
module.exports = ProcessManager;
|