You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 
 

105 lines
2.4 KiB

'use strict';
const EventEmitter = require('events');
// This object keep track of the socket there are sended
class SocketListSend extends EventEmitter {
constructor(child, key) {
super();
this.key = key;
this.child = child;
}
_request(msg, cmd, callback) {
var self = this;
if (!this.child.connected) return onclose();
this.child.send(msg);
function onclose() {
self.child.removeListener('internalMessage', onreply);
callback(new Error('child closed before reply'));
}
function onreply(msg) {
if (!(msg.cmd === cmd && msg.key === self.key)) return;
self.child.removeListener('disconnect', onclose);
self.child.removeListener('internalMessage', onreply);
callback(null, msg);
}
this.child.once('disconnect', onclose);
this.child.on('internalMessage', onreply);
}
close(callback) {
this._request({
cmd: 'NODE_SOCKET_NOTIFY_CLOSE',
key: this.key
}, 'NODE_SOCKET_ALL_CLOSED', callback);
}
getConnections(callback) {
this._request({
cmd: 'NODE_SOCKET_GET_COUNT',
key: this.key
}, 'NODE_SOCKET_COUNT', function(err, msg) {
if (err) return callback(err);
callback(null, msg.count);
});
}
}
// This object keep track of the socket there are received
class SocketListReceive extends EventEmitter {
constructor(child, key) {
super();
this.connections = 0;
this.key = key;
this.child = child;
function onempty(self) {
if (!self.child.connected) return;
self.child.send({
cmd: 'NODE_SOCKET_ALL_CLOSED',
key: self.key
});
}
this.child.on('internalMessage', (msg) => {
if (msg.key !== this.key) return;
if (msg.cmd === 'NODE_SOCKET_NOTIFY_CLOSE') {
// Already empty
if (this.connections === 0) return onempty(this);
// Wait for sockets to get closed
this.once('empty', onempty);
} else if (msg.cmd === 'NODE_SOCKET_GET_COUNT') {
if (!this.child.connected) return;
this.child.send({
cmd: 'NODE_SOCKET_COUNT',
key: this.key,
count: this.connections
});
}
});
}
add(obj) {
this.connections++;
// Notify previous owner of socket about its state change
obj.socket.once('close', () => {
this.connections--;
if (this.connections === 0) this.emit('empty', this);
});
}
}
module.exports = {SocketListSend, SocketListReceive};