56 lines
1.4 KiB
JavaScript
56 lines
1.4 KiB
JavaScript
|
const uuid = require('uuid/v1');
|
||
|
|
const constants = require('../constants');
|
||
|
|
|
||
|
|
class Events {
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Constructs an event wrapper for processes.
|
||
|
|
* Handles sending an event message to the parent process and waiting for its response
|
||
|
|
* No need to create an instance of eventsWrapper for your own process, just extend ProcessWrapper
|
||
|
|
* Then, you an use `this.events.[on|request]` with the usual parameters you would use
|
||
|
|
*/
|
||
|
|
constructor() {
|
||
|
|
this.subscribedEvents = {};
|
||
|
|
this.listenToParentProcess();
|
||
|
|
}
|
||
|
|
|
||
|
|
listenToParentProcess() {
|
||
|
|
process.on('message', (msg) => {
|
||
|
|
if (!msg.event || msg.event !== constants.process.events.response) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
if (!this.subscribedEvents[msg.eventId]) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.subscribedEvents[msg.eventId](msg.result);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
sendEvent() {
|
||
|
|
const eventType = arguments[0];
|
||
|
|
const requestName = arguments[1];
|
||
|
|
|
||
|
|
let args = [].slice.call(arguments, 2);
|
||
|
|
const eventId = uuid();
|
||
|
|
this.subscribedEvents[eventId] = args[args.length - 1];
|
||
|
|
args = args.splice(0, args.length - 2);
|
||
|
|
|
||
|
|
process.send({
|
||
|
|
event: eventType,
|
||
|
|
requestName,
|
||
|
|
args,
|
||
|
|
eventId: eventId
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
on() {
|
||
|
|
this.sendEvent(constants.process.events.on, ...arguments);
|
||
|
|
}
|
||
|
|
|
||
|
|
request() {
|
||
|
|
this.sendEvent(constants.process.events.request, ...arguments);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
module.exports = Events;
|