test: add internal/socket_list tests

PR-URL: #12109
Reviewed-By: James M Snell <jasnell@gmail.com>

Author: davidtaikocha

test/parallel/test-internal-socket-list-receive.js

@@ -0,0 +1,67 @@
+// Flags: --expose-internals
+'use strict';
+
+constcommon=require('../common');
+constassert=require('assert');
+constEventEmitter=require('events');
+constSocketListReceive=require('internal/socket_list').SocketListReceive;
+
+constkey='test-key';
+
+// Verify that the message won't be sent when slave is not connected.
+{
+constslave=Object.assign(newEventEmitter(),{
+connected: false,
+send: common.mustNotCall()
+});
+
+constlist=newSocketListReceive(slave,key);
+list.slave.emit('internalMessage',{ key,cmd: 'NODE_SOCKET_NOTIFY_CLOSE'});
+}
+
+// Verify that a "NODE_SOCKET_ALL_CLOSED" message will be sent.
+{
+constslave=Object.assign(newEventEmitter(),{
+connected: true,
+send: common.mustCall((msg)=>{
+assert.strictEqual(msg.cmd,'NODE_SOCKET_ALL_CLOSED');
+assert.strictEqual(msg.key,key);
+})
+});
+
+constlist=newSocketListReceive(slave,key);
+list.slave.emit('internalMessage',{ key,cmd: 'NODE_SOCKET_NOTIFY_CLOSE'});
+}
+
+// Verify that a "NODE_SOCKET_COUNT" message will be sent.
+{
+constslave=Object.assign(newEventEmitter(),{
+connected: true,
+send: common.mustCall((msg)=>{
+assert.strictEqual(msg.cmd,'NODE_SOCKET_COUNT');
+assert.strictEqual(msg.key,key);
+assert.strictEqual(msg.count,0);
+})
+});
+
+constlist=newSocketListReceive(slave,key);
+list.slave.emit('internalMessage',{ key,cmd: 'NODE_SOCKET_GET_COUNT'});
+}
+
+// Verify that the connections count is added and an "empty" event
+// will be emitted when all sockets in obj were closed.
+{
+constslave=newEventEmitter();
+constobj={socket: newEventEmitter()};
+
+constlist=newSocketListReceive(slave,key);
+assert.strictEqual(list.connections,0);
+
+list.add(obj);
+assert.strictEqual(list.connections,1);
+
+list.on('empty',common.mustCall((self)=>assert.strictEqual(self,list)));
+
+obj.socket.emit('close');
+assert.strictEqual(list.connections,0);
+}

test/parallel/test-internal-socket-list-send.js

@@ -0,0 +1,114 @@
+// Flags: --expose-internals
+'use strict';
+
+constcommon=require('../common');
+constassert=require('assert');
+constEventEmitter=require('events');
+constSocketListSend=require('internal/socket_list').SocketListSend;
+
+constkey='test-key';
+
+// Verify that an error will be received in callback when slave is not
+// connected.
+{
+constslave=Object.assign(newEventEmitter(),{connected: false});
+assert.strictEqual(slave.listenerCount('internalMessage'),0);
+
+constlist=newSocketListSend(slave,'test');
+
+list._request('msg','cmd',common.mustCall((err)=>{
+assert.strictEqual(err.message,'Slave closed before reply');
+assert.strictEqual(slave.listenerCount('internalMessage'),0);
+}));
+}
+
+// Verify that the given message will be received in callback.
+{
+constslave=Object.assign(newEventEmitter(),{
+connected: true,
+send: function(msg){
+process.nextTick(()=>
+this.emit('internalMessage',{ key,cmd: 'cmd'})
+);
+}
+});
+
+constlist=newSocketListSend(slave,key);
+
+list._request('msg','cmd',common.mustCall((err,msg)=>{
+assert.strictEqual(err,null);
+assert.strictEqual(msg.cmd,'cmd');
+assert.strictEqual(msg.key,key);
+assert.strictEqual(slave.listenerCount('internalMessage'),0);
+assert.strictEqual(slave.listenerCount('disconnect'),0);
+}));
+}
+
+// Verify that an error will be received in callback when slave was
+// disconnected.
+{
+constslave=Object.assign(newEventEmitter(),{
+connected: true,
+send: function(msg){process.nextTick(()=>this.emit('disconnect'));}
+});
+
+constlist=newSocketListSend(slave,key);
+
+list._request('msg','cmd',common.mustCall((err)=>{
+assert.strictEqual(err.message,'Slave closed before reply');
+assert.strictEqual(slave.listenerCount('internalMessage'),0);
+}));
+}
+
+// Verify that a "NODE_SOCKET_ALL_CLOSED" message will be received
+// in callback.
+{
+constslave=Object.assign(newEventEmitter(),{
+connected: true,
+send: function(msg){
+assert.strictEqual(msg.cmd,'NODE_SOCKET_NOTIFY_CLOSE');
+assert.strictEqual(msg.key,key);
+process.nextTick(()=>
+this.emit('internalMessage',{ key,cmd: 'NODE_SOCKET_ALL_CLOSED'})
+);
+}
+});
+
+constlist=newSocketListSend(slave,key);
+
+list.close(common.mustCall((err,msg)=>{
+assert.strictEqual(err,null);
+assert.strictEqual(msg.cmd,'NODE_SOCKET_ALL_CLOSED');
+assert.strictEqual(msg.key,key);
+assert.strictEqual(slave.listenerCount('internalMessage'),0);
+assert.strictEqual(slave.listenerCount('disconnect'),0);
+}));
+}
+
+// Verify that the count of connections will be received in callback.
+{
+constcount=1;
+constslave=Object.assign(newEventEmitter(),{
+connected: true,
+send: function(msg){
+assert.strictEqual(msg.cmd,'NODE_SOCKET_GET_COUNT');
+assert.strictEqual(msg.key,key);
+process.nextTick(()=>
+this.emit('internalMessage',{
+ key,
+ count,
+cmd: 'NODE_SOCKET_COUNT'
+})
+);
+}
+});
+
+constlist=newSocketListSend(slave,key);
+
+list.getConnections(common.mustCall((err,msg)=>{
+assert.strictEqual(err,null);
+assert.strictEqual(msg,count);
+assert.strictEqual(slave.listenerCount('internalMessage'),0);
+assert.strictEqual(slave.listenerCount('disconnect'),0);
+}));
+}