| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| node-ipc/ | -100% | -4/4 | -100% | -0/0 | -100% | -1/1 | -100% | -4/4 | -|
| node-ipc/dao/ | -68.27% | -185/271 | -55.24% | -79/143 | -82.14% | -23/28 | -68.27% | -185/271 | -|
| node-ipc/entities/ | -93.02% | -40/43 | -56.25% | -9/16 | -100% | -5/5 | -93.02% | -40/43 | -|
| node-ipc/services/ | -65.67% | -88/134 | -60.81% | -45/74 | -87.5% | -7/8 | -65.67% | -88/134 | -
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 -110 -111 -112 -113 -114 -115 -116 -117 -118 -119 -120 -121 -122 -123 -124 -125 -126 -127 -128 -129 -130 -131 -132 -133 -134 -135 -136 -137 -138 -139 -140 -141 -142 -143 -144 -145 -146 -147 -148 -149 -150 -151 -152 -153 -154 -155 -156 -157 -158 -159 -160 -161 -162 -163 -164 -165 -166 -167 -168 -169 -170 -171 -172 -173 -174 -175 -176 -177 -178 -179 -180 -181 -182 -183 -184 -185 -186 -187 -188 -189 -190 -191 -192 -193 -194 -195 -196 -197 -198 -199 -200 -201 -202 -203 -204 -205 -206 -207 -208 -209 -210 -211 -212 -213 -214 -215 -216 -217 -218 -219 -220 -221 -222 -223 -224 -225 -226 -227 -228 -229 -230 -231 -232 -233 -234 -235 -236 -237 -238 -239 -240 -241 -242 -243 -244 -245 -246 -247 -248 -249 -250 -251 -252 -253 -254 -255 -256 -257 | - -1× - - - - - - - -1× - - - -7× -7× - - - - - - - - - - - - - - -7× - - - -1× -7× - -7× -7× -7× - -7× - - -7× - - -7× -1× -1× - - -6× - - - - -1× -6× -6× - - -1× - -13× - -13× -13× - - - - -13× - -13× -7× - -7× - -7× -7× -7× -7× - - -7× - -6× -6× - -6× - - - -6× - - - -6× - - - -6× - - - -6× - - - -6× -6× -6× - - - - - - - - - - - - - - - - - - - - - - - - - - - - -13× - -13× - - -10× -10× - - - - -13× - - -3× -3× -3× - - - -13× - - -13× - - - -13× - - - - - -7× -7× - - - - - -7× -7× -7× - -7× - - -6× - -6× - - -6× -6× - - - - -6× - - - -13× - - -7× -7× - - - - - - - - - - - - -7× -7× - - -7× - -7× - - - - -7× - -7× -7× -7× -7× -7× - -7× -7× - - - - - -7× - - - -7× - - - - -1× - | 'use strict';
-
-const net = require('net'),
- tls = require('tls'),
- EventParser = require('../entities/EventParser.js'),
- Message = require('js-message'),
- fs = require('fs'),
- Queue = require('js-queue'),
- Events = require('event-pubsub');
-
-let eventParser = new EventParser();
-
-class Client extends Events{
- constructor(config,log){
- super();
- Object.assign(
- this,
- {
- Client : Client,
- config : config,
- queue : new Queue,
- socket : false,
- connect : connect,
- emit : emit,
- log : log,
- retriesRemaining:config.maxRetries||0,
- explicitlyDisconnected: false
- }
- );
-
- eventParser=new EventParser(this.config);
- }
-}
-
-function emit(type,data){
- this.log('dispatching event to ', this.id, this.path, ' : ', type, ',', data);
-
- let message=new Message;
- message.type=type;
- message.data=data;
-
- Iif(this.config.rawBuffer){
- message=Buffer.from(type,this.config.encoding);
- }else{
- message=eventParser.format(message);
- }
-
- if(!this.config.sync){
- this.socket.write(message);
- return;
- }
-
- this.queue.add(
- syncEmit.bind(this,message)
- );
-}
-
-function syncEmit(message){
- this.log('dispatching event to ', this.id, this.path, ' : ', message);
- this.socket.write(message);
-}
-
-function connect(){
- //init client object for scope persistance especially inside of socket events.
- let client=this;
-
- client.log('requested connection to ', client.id, client.path);
- Iif(!this.path){
- client.log('\n\n######\nerror: ', client.id ,' client has not specified socket path it wishes to connect to.');
- return;
- }
-
- const options={};
-
- if(!client.port){
- client.log('Connecting client on Unix Socket :', client.path);
-
- options.path=client.path;
-
- Eif (process.platform ==='win32' && !client.path.startsWith('\\\\.\\pipe\\')){
- options.path = options.path.replace(/^\//, '');
- options.path = options.path.replace(/\//g, '-');
- options.path= `\\\\.\\pipe\\${options.path}`;
- }
-
- client.socket = net.connect(options);
- }else{
- options.host=client.path;
- options.port=client.port;
-
- Iif(client.config.interface.localAddress){
- options.localAddress=client.config.interface.localAddress;
- }
-
- Iif(client.config.interface.localPort){
- options.localPort=client.config.interface.localPort;
- }
-
- Iif(client.config.interface.family){
- options.family=client.config.interface.family;
- }
-
- Iif(client.config.interface.hints){
- options.hints=client.config.interface.hints;
- }
-
- Iif(client.config.interface.lookup){
- options.lookup=client.config.interface.lookup;
- }
-
- Eif(!client.config.tls){
- client.log('Connecting client via TCP to', options);
- client.socket = net.connect(options);
- }else{
- client.log('Connecting client via TLS to', client.path ,client.port,client.config.tls);
- if(client.config.tls.private){
- client.config.tls.key=fs.readFileSync(client.config.tls.private);
- }
- if(client.config.tls.public){
- client.config.tls.cert=fs.readFileSync(client.config.tls.public);
- }
- if(client.config.tls.trustedConnections){
- if(typeof client.config.tls.trustedConnections === 'string'){
- client.config.tls.trustedConnections=[client.config.tls.trustedConnections];
- }
- client.config.tls.ca=[];
- for(let i=0; i<client.config.tls.trustedConnections.length; i++){
- client.config.tls.ca.push(
- fs.readFileSync(client.config.tls.trustedConnections[i])
- );
- }
- }
-
- Object.assign(client.config.tls,options);
-
- client.socket = tls.connect(
- client.config.tls
- );
- }
- }
-
- client.socket.setEncoding(this.config.encoding);
-
- client.socket.on(
- 'error',
- function(err){
- client.log('\n\n######\nerror: ', err);
- client.publish('error', err);
-
- }
- );
-
- client.socket.on(
- 'connect',
- function connectionMade(){
- client.publish('connect');
- client.retriesRemaining=client.config.maxRetries;
- client.log('retrying reset');
- }
- );
-
- client.socket.on(
- 'close',
- function connectionClosed(){
- client.log('connection closed' ,client.id , client.path,
- client.retriesRemaining, 'tries remaining of', client.config.maxRetries
- );
-
- if(
- client.config.stopRetrying ||
- client.retriesRemaining<1 ||
- client.explicitlyDisconnected
-
- ){
- client.publish('disconnect');
- client.log(
- (client.config.id),
- 'exceeded connection rety amount of',
- ' or stopRetrying flag set.'
- );
-
- client.socket.destroy();
- client.publish('destroy');
- client=undefined;
-
- return;
- }
-
- setTimeout(
- function retryTimeout(){
- Iif (client.explicitlyDisconnected) {
- return;
- }
- client.retriesRemaining--;
- client.connect();
- }.bind(null,client),
- client.config.retry
- );
-
- client.publish('disconnect');
- }
- );
-
- client.socket.on(
- 'data',
- function(data) {
- client.log('## received events ##');
- Iif(client.config.rawBuffer){
- client.publish(
- 'data',
- Buffer.from(data,client.config.encoding)
- );
- if(!client.config.sync){
- return;
- }
-
- client.queue.next();
- return;
- }
-
- Eif(!this.ipcBuffer){
- this.ipcBuffer='';
- }
-
- data=(this.ipcBuffer+=data);
-
- Iif(data.slice(-1)!=eventParser.delimiter || data.indexOf(eventParser.delimiter) == -1){
- client.log('Messages are large, You may want to consider smaller messages.');
- return;
- }
-
- this.ipcBuffer='';
-
- const events = eventParser.parse(data);
- const eCount = events.length;
- for(let i=0; i<eCount; i++){
- let message=new Message;
- message.load(events[i]);
-
- client.log('detected event', message.type, message.data);
- client.publish(
- message.type,
- message.data
- );
- }
-
- Iif(!client.config.sync){
- return;
- }
-
- client.queue.next();
- }
- );
-}
-
-module.exports=Client;
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 | - -1× - - - - - -1× -9× - - -9× - - - -9× -9× - - -1× -9× -9× -9× - - -1× - | 'use strict';
-
-const parser={
- parse : parseDataEvents,
- format : formatData,
- delimiter : '\f'
-};
-
-function formatData(message){
- Iif(!message.data && message.data!==false && message.data!==0){
- message.data={};
- }
- Iif(message.data['_maxListeners']){
- message.data={};
- }
-
- message=message.JSON+parser.delimiter;
- return message;
-}
-
-function parseDataEvents(data){
- let events=data.split(parser.delimiter);
- events.pop();
- return events;
-}
-
-module.exports=parser;
- |
| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| client.js | -73.21% | -82/112 | -52.83% | -28/53 | -100% | -9/9 | -73.21% | -82/112 | -|
| socketServer.js | -64.78% | -103/159 | -56.67% | -51/90 | -73.68% | -14/19 | -64.78% | -103/159 | -
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 -110 -111 -112 -113 -114 -115 -116 -117 -118 -119 -120 -121 -122 -123 -124 -125 -126 -127 -128 -129 -130 -131 -132 -133 -134 -135 -136 -137 -138 -139 -140 -141 -142 -143 -144 -145 -146 -147 -148 -149 -150 -151 -152 -153 -154 -155 -156 -157 -158 -159 -160 -161 -162 -163 -164 -165 -166 -167 -168 -169 -170 -171 -172 -173 -174 -175 -176 -177 -178 -179 -180 -181 -182 -183 -184 -185 -186 -187 -188 -189 -190 -191 -192 -193 -194 -195 -196 -197 -198 -199 -200 -201 -202 -203 -204 -205 -206 -207 -208 -209 -210 -211 -212 -213 -214 -215 -216 -217 -218 -219 -220 -221 -222 -223 -224 -225 -226 -227 -228 -229 -230 -231 -232 -233 -234 -235 -236 -237 -238 -239 -240 -241 -242 -243 -244 -245 -246 -247 -248 -249 -250 -251 -252 -253 -254 -255 -256 -257 -258 -259 -260 -261 -262 -263 -264 -265 -266 -267 -268 -269 -270 -271 -272 -273 -274 -275 -276 -277 -278 -279 -280 -281 -282 -283 -284 -285 -286 -287 -288 -289 -290 -291 -292 -293 -294 -295 -296 -297 -298 -299 -300 -301 -302 -303 -304 -305 -306 -307 -308 -309 -310 -311 -312 -313 -314 -315 -316 -317 -318 -319 -320 -321 -322 -323 -324 -325 -326 -327 -328 -329 -330 -331 -332 -333 -334 -335 -336 -337 -338 -339 -340 -341 -342 -343 -344 -345 -346 -347 -348 -349 -350 -351 -352 -353 -354 -355 -356 -357 -358 -359 -360 -361 -362 -363 -364 -365 -366 -367 -368 -369 -370 -371 -372 -373 -374 -375 -376 -377 -378 -379 -380 -381 -382 -383 -384 -385 -386 -387 -388 -389 -390 -391 -392 -393 -394 -395 -396 -397 -398 -399 | - -1× - - - - - - - -1× - - - -4× -4× - - - - - - - - - - - - - - - -4× - -4× - - - - - - -4× - - - - - - -4× - - - -4× - - - - -4× -4× - - - - - - - - - -1× -2× - -2× -2× -2× - -2× - - - -2× - - -2× - -2× - - - - - -2× - - - -2× - - - - - -1× - - - - - - - - - - - - - - - - - - - - - - -1× -2× -2× -2× - -2× -2× - - - - -2× - - - -2× - -2× - - - -2× - -2× - -2× - - - -1× -2× -2× - - - - - - - - - -2× -2× - - -2× - -2× - - - - -2× - -2× - -2× -2× -2× - - -2× -2× - - -2× - -2× - - - - - - - -1× -2× - - - - - -1× -4× - -4× -2× - - -4× -4× - - - - -4× - - - - - - - - -4× - - - - -4× - - -2× - - - -2× -2× - -2× - - -2× - -2× - - - -4× - - - - -4× - - - - -1× -4× - - - - -4× -2× -2× -2× - - - - - - -2× - - -2× -2× - - -2× - - - - -4× - - - - - - - - - - - -4× - -4× -1× -1× -1× -1× -1× - - -1× - - - - -1× - - -3× -1× -1× - - - - -1× - - -2× - -2× - - - - -2× - - - - - - - -1× - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -1× -2× -2× - - - - - - -2× - - - - - - - - - - - - -1× - | 'use strict';
-
-const net = require('net'),
- tls = require('tls'),
- fs = require('fs'),
- dgram = require('dgram'),
- EventParser = require('../entities/EventParser.js'),
- Message = require('js-message'),
- Events = require('event-pubsub');
-
-let eventParser = new EventParser();
-
-class Server extends Events{
- constructor(path,config,log,port){
- super();
- Object.assign(
- this,
- {
- config : config,
- path : path,
- port : port,
- udp4 : false,
- udp6 : false,
- log : log,
- server : false,
- sockets : [],
- emit : emit,
- broadcast : broadcast
- }
- );
-
- eventParser=new EventParser(this.config);
-
- this.on(
- 'close',
- serverClosed.bind(this)
- );
- }
-
- onStart(socket){
- this.trigger(
- 'start',
- socket
- );
- }
-
- stop(){
- this.server.close();
- }
-
- start(){
- Iif(!this.path){
- this.log('Socket Server Path not specified, refusing to start');
- return;
- }
-
- Eif(this.config.unlink){
- fs.unlink(
- this.path,
- startServer.bind(this)
- );
- }else{
- startServer.bind(this)();
- }
- }
-}
-
-function emit(socket, type, data){
- this.log('dispatching event to socket', ' : ', type, data);
-
- let message=new Message;
- message.type=type;
- message.data=data;
-
- Iif(this.config.rawBuffer){
- this.log(this.config.encoding)
- message=Buffer.from(type,this.config.encoding);
- }else{
- message=eventParser.format(message);
- }
-
- Eif(this.udp4 || this.udp6){
-
- Iif(!socket.address || !socket.port){
- this.log('Attempting to emit to a single UDP socket without supplying socket address or port. Redispatching event as broadcast to all connected sockets');
- this.broadcast(type,data);
- return;
- }
-
- this.server.write(
- message,
- socket
- );
- return;
- }
-
- socket.write(message);
-}
-
-function broadcast(type,data){
- this.log('broadcasting event to all known sockets listening to ', this.path,' : ', ((this.port)?this.port:''), type, data);
- let message=new Message;
- message.type=type;
- message.data=data;
-
- if(this.config.rawBuffer){
- message=Buffer.from(type,this.config.encoding);
- }else{
- message=eventParser.format(message);
- }
-
- if(this.udp4 || this.udp6){
- for(let i=1, count=this.sockets.length; i<count; i++){
- this.server.write(message,this.sockets[i]);
- }
- }else{
- for(let i=0, count=this.sockets.length; i<count; i++){
- this.sockets[i].write(message);
- }
- }
-}
-
-function serverClosed(){
- for(let i=0, count=this.sockets.length; i<count; i++){
- let socket=this.sockets[i];
- let destroyedSocketId=false;
-
- Eif(socket){
- Iif(socket.readable){
- continue;
- }
- }
-
- Iif(socket.id){
- destroyedSocketId=socket.id;
- }
-
- this.log('socket disconnected',destroyedSocketId.toString());
-
- Iif(socket && socket.destroy){
- socket.destroy();
- }
-
- this.sockets.splice(i,1);
-
- this.publish('socket.disconnected', socket, destroyedSocketId);
-
- return;
- }
-}
-
-function gotData(socket,data,UDPSocket){
- let sock=((this.udp4 || this.udp6)? UDPSocket : socket);
- Iif(this.config.rawBuffer){
- data=Buffer.from(data,this.config.encoding);
- this.publish(
- 'data',
- data,
- sock
- );
- return;
- }
-
- Eif(!sock.ipcBuffer){
- sock.ipcBuffer='';
- }
-
- data=(sock.ipcBuffer+=data);
-
- Iif(data.slice(-1)!=eventParser.delimiter || data.indexOf(eventParser.delimiter) == -1){
- this.log('Messages are large, You may want to consider smaller messages.');
- return;
- }
-
- sock.ipcBuffer='';
-
- data=eventParser.parse(data);
-
- while(data.length>0){
- let message=new Message;
- message.load(data.shift());
-
- // Only set the sock id if it is specified.
- Eif (message.data && message.data.id){
- sock.id=message.data.id;
- }
-
- this.log('received event of : ',message.type,message.data);
-
- this.publish(
- message.type,
- message.data,
- sock
- );
- }
-}
-
-function socketClosed(socket){
- this.publish(
- 'close',
- socket
- );
-}
-
-function serverCreated(socket) {
- this.sockets.push(socket);
-
- if(socket.setEncoding){
- socket.setEncoding(this.config.encoding);
- }
-
- this.log('## socket connection to server detected ##');
- socket.on(
- 'close',
- socketClosed.bind(this)
- );
-
- socket.on(
- 'error',
- function(err){
- this.log('server socket error',err);
-
- this.publish('error',err);
- }.bind(this)
- );
-
- socket.on(
- 'data',
- gotData.bind(this,socket)
- );
-
- socket.on(
- 'message',
- function(msg,rinfo) {
- Iif (!rinfo){
- return;
- }
-
- this.log('Received UDP message from ', rinfo.address, rinfo.port);
- let data;
-
- Iif(this.config.rawSocket){
- data=Buffer.from(msg,this.config.encoding);
- }else{
- data=msg.toString();
- }
- socket.emit('data',data,rinfo);
- }.bind(this)
- );
-
- this.publish(
- 'connect',
- socket
- );
-
- Iif(this.config.rawBuffer){
- return;
- }
-}
-
-function startServer() {
- this.log(
- 'starting server on ',this.path,
- ((this.port)?`:${this.port}`:'')
- );
-
- if(!this.udp4 && !this.udp6){
- this.log('starting TLS server',this.config.tls);
- Eif(!this.config.tls){
- this.server=net.createServer(
- serverCreated.bind(this)
- );
- }else{
- startTLSServer.bind(this)();
- }
- }else{
- this.server=dgram.createSocket(
- ((this.udp4)? 'udp4':'udp6')
- );
- this.server.write=UDPWrite.bind(this);
- this.server.on(
- 'listening',
- function UDPServerStarted() {
- serverCreated.bind(this)(this.server);
- }.bind(this)
- );
- }
-
- this.server.on(
- 'error',
- function(err){
- this.log('server error',err);
-
- this.publish(
- 'error',
- err
- );
- }.bind(this)
- );
-
- this.server.maxConnections=this.config.maxConnections;
-
- if(!this.port){
- this.log('starting server as', 'Unix || Windows Socket');
- Eif (process.platform ==='win32'){
- this.path = this.path.replace(/^\//, '');
- this.path = this.path.replace(/\//g, '-');
- this.path= `\\\\.\\pipe\\${this.path}`;
- }
-
- this.server.listen(
- this.path,
- this.onStart.bind(this)
- );
-
- return;
- }
-
- if(!this.udp4 && !this.udp6){
- this.log('starting server as', (this.config.tls?'TLS':'TCP'));
- this.server.listen(
- this.port,
- this.path,
- this.onStart.bind(this)
- );
- return;
- }
-
- this.log('starting server as',((this.udp4)? 'udp4':'udp6'));
-
- this.server.bind(
- this.port,
- this.path
- );
-
- this.onStart(
- {
- address : this.path,
- port : this.port
- }
- );
-}
-
-function startTLSServer(){
- this.log('starting TLS server',this.config.tls);
- if(this.config.tls.private){
- this.config.tls.key=fs.readFileSync(this.config.tls.private);
- }else{
- this.config.tls.key=fs.readFileSync(`${__dirname}/../local-node-ipc-certs/private/server.key`);
- }
- if(this.config.tls.public){
- this.config.tls.cert=fs.readFileSync(this.config.tls.public);
- }else{
- this.config.tls.cert=fs.readFileSync(`${__dirname}/../local-node-ipc-certs/server.pub`);
- }
- if(this.config.tls.dhparam){
- this.config.tls.dhparam=fs.readFileSync(this.config.tls.dhparam);
- }
- if(this.config.tls.trustedConnections){
- if(typeof this.config.tls.trustedConnections === 'string'){
- this.config.tls.trustedConnections=[this.config.tls.trustedConnections];
- }
- this.config.tls.ca=[];
- for(let i=0; i<this.config.tls.trustedConnections.length; i++){
- this.config.tls.ca.push(
- fs.readFileSync(this.config.tls.trustedConnections[i])
- );
- }
- }
- this.server=tls.createServer(
- this.config.tls,
- serverCreated.bind(this)
- );
-}
-
-function UDPWrite(message,socket){
- let data=Buffer.from(message, this.config.encoding);
- this.server.send(
- data,
- 0,
- data.length,
- socket.port,
- socket.address,
- function(err, bytes) {
- Iif(err){
- this.log('error writing data to socket',err);
- this.publish(
- 'error',
- function(err){
- this.publish('error',err);
- }
- );
- }
- }
- );
-}
-
-module.exports=Server;
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 | - - - - - - - -1× - - - - - - - - - - - - - - -3× -3× -3× - -3× -3× -3× -3× - -3× - -3× -3× -3× -3× - -3× -3× -3× -3× - -3× -3× -3× -3× - -3× - - - - - - - - - - - - - - - -1× -3× -3× -3× - - - - - - - -3× - - -1× - | 'use strict';
-
-/*eslint no-magic-numbers: ["error", { "ignore": [ 0] }]*/
-
-/**
- * @module entities
- */
-
-const os = require('os');
-
-/**
- * @class Defaults
- * @description Defaults Entity
- */
-class Defaults{
-
- /**
- * @constructor
- * @method constructor
- * @return {void}
- */
- constructor(){
-
- this.appspace='app.';
- this.socketRoot='/tmp/';
- this.id=os.hostname();
-
- this.encoding='utf8';
- this.rawBuffer=false;
- this.sync=false;
- this.unlink=true;
-
- this.delimiter='\f';
-
- this.silent=false;
- this.logDepth=5;
- this.logInColor=true;
- this.logger=console.log.bind(console);
-
- this.maxConnections=100;
- this.retry=500;
- this.maxRetries=Infinity;
- this.stopRetrying=false;
-
- this.IPType=getIPType();
- this.tls=false;
- this.networkHost = (this.IPType == 'IPv6') ? '::1' : '127.0.0.1';
- this.networkPort = 8000;
-
- this.interface={
- localAddress:false,
- localPort:false,
- family:false,
- hints:false,
- lookup:false
- }
- }
-}
-
-/**
- * method to get ip type
- *
- * @method getIPType
- * @return {string} ip type
- */
-function getIPType() {
- const networkInterfaces = os.networkInterfaces();
- let IPType = '';
- Iif (networkInterfaces
- && Array.isArray(networkInterfaces)
- && networkInterfaces.length > 0) {
- // getting the family of first network interface available
- IPType = networkInterfaces [
- Object.keys( networkInterfaces )[0]
- ][0].family;
- }
- return IPType;
-}
-
-module.exports=Defaults;
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 | - -1× - - - -13× -2× - -13× - - - -9× - - -9× - - - -9× -9× - - - -9× -9× -9× - - - -1× - | 'use strict';
-
-const Defaults = require('./Defaults.js');
-
-class Parser{
- constructor(config){
- if(!config){
- config=new Defaults;
- }
- this.delimiter=config.delimiter;
- }
-
- format(message){
- Iif(!message.data && message.data!==false && message.data!==0){
- message.data={};
- }
- Iif(message.data['_maxListeners']){
- message.data={};
- }
-
- message=message.JSON+this.delimiter;
- return message;
- }
-
- parse(data){
- let events=data.split(this.delimiter);
- events.pop();
- return events;
- }
-}
-
-module.exports=Parser;
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 | - - - -1× -1× -1× -1× -1× -1× -1× - - - -1× - | 'use strict';
-
-class LogColors{
- constructor(){
- this.good='green';
- this.notice='yellow';
- this.warn='red';
- this.error='redBG';
- this.debug='magenta';
- this.variable='cyan';
- this.data='blue';
- }
-}
-
-module.exports=LogColors;
- |
| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| Defaults.js | -96.55% | -28/29 | -57.14% | -4/7 | -100% | -2/2 | -96.55% | -28/29 | -|
| EventParser.js | -85.71% | -12/14 | -55.56% | -5/9 | -100% | -3/3 | -85.71% | -12/14 | -
| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| node-ipc.js | -100% | -4/4 | -100% | -0/0 | -100% | -1/1 | -100% | -4/4 | -
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 -110 -111 -112 -113 -114 -115 -116 -117 -118 -119 -120 -121 -122 -123 -124 -125 -126 -127 -128 -129 -130 -131 -132 -133 -134 -135 -136 -137 -138 -139 -140 -141 -142 -143 -144 -145 -146 -147 -148 -149 -150 -151 -152 -153 -154 -155 -156 -157 -158 -159 -160 -161 -162 -163 -164 -165 -166 -167 -168 -169 -170 -171 -172 -173 -174 -175 -176 -177 -178 -179 -180 -181 -182 -183 -184 -185 -186 -187 -188 -189 -190 -191 -192 -193 -194 -195 -196 -197 -198 -199 -200 -201 -202 -203 -204 -205 -206 -207 -208 -209 -210 -211 -212 -213 -214 -215 -216 -217 -218 -219 -220 -221 -222 -223 -224 -225 -226 -227 -228 -229 -230 -231 -232 -233 -234 -235 -236 -237 | - -1× - - - - - - - -1× -7× - - - - - - - - - -7× - -7× - - -1× -7× - -7× -7× -7× - -7× - - -7× - - -7× -1× -1× - - -6× - - - - -1× -6× -6× - - -1× - -13× - -13× -13× - - - - -13× -7× - -7× - -7× - - - - -7× - - - - - -6× -6× -6× - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -13× - -13× - - -10× -10× - - - - -13× - - -3× -3× -3× - - - -13× - - -13× - -13× - - - -7× -7× - - - - - -7× -7× -7× - -7× - - -6× - -6× - -6× -6× -6× -6× - -6× -2× - - - - - - - - -6× - - - -13× - - -7× -7× - - - - - - - - - - - - -7× -7× - - -7× - -7× - - - - -7× - -7× -7× -7× -7× -7× - -7× -7× - - - - - -7× - - - -7× - - - - -1× - | 'use strict';
-
-const net = require('net'),
- tls = require('tls'),
- eventParser = require('../lib/eventParser.js'),
- Pubsub = require('event-pubsub'),
- Message = require('js-message'),
- fs = require('fs'),
- Queue = require('js-queue');
-
-function init(config,log){
- let client={
- config : config,
- queue : new Queue,
- socket : false,
- connect : connect,
- emit : emit,
- log : log,
- retriesRemaining:config.maxRetries||0
- };
-
- new Pubsub(client);
-
- return client;
-}
-
-function emit(type,data){
- this.log('dispatching event to '.debug, this.id.variable, this.path.variable,' : ', type.data,',', data);
-
- let message=new Message;
- message.type=type;
- message.data=data;
-
- Iif(this.config.rawBuffer){
- message=new Buffer(type,this.encoding);
- }else{
- message=eventParser.format(message);
- }
-
- if(!this.config.sync){
- this.socket.write(message);
- return;
- }
-
- this.queue.add(
- syncEmit.bind(this,message)
- );
-}
-
-function syncEmit(message){
- this.log('dispatching event to '.debug, this.id.variable, this.path.variable,' : ', message.data);
- this.socket.write(message);
-}
-
-function connect(){
- //init client object for scope persistance especially inside of socket events.
- let client=this;
-
- client.log('requested connection to '.debug, client.id.variable, client.path.variable);
- Iif(!this.path){
- client.log('\n\n######\nerror: '.error, client.id .info,' client has not specified socket path it wishes to connect to.'.error);
- return;
- }
-
- if(!client.port){
- client.log('Connecting client on Unix Socket :'.debug, client.path.variable);
-
- let path = client.path;
-
- Iif (process.platform ==='win32' && !client.path.startsWith('\\\\.\\pipe\\')){
- path = path.replace(/^\//, '');
- path = path.replace(/\//g, '-');
- path= '\\\\.\\pipe\\'+path;
- }
- client.socket = net.connect(
- {
- path: path
- }
- );
- }else{
- Eif(!client.config.tls){
- client.log('Connecting client via TCP to'.debug, client.path.variable ,client.port);
- client.socket = net.connect(
- {
- port:client.port,
- host:client.path
- }
- );
- }else{
- client.log('Connecting client via TLS to'.debug, client.path.variable ,client.port,client.config.tls);
- if(client.config.tls.private){
- client.config.tls.key=fs.readFileSync(client.config.tls.private);
- }
- if(client.config.tls.public){
- client.config.tls.cert=fs.readFileSync(client.config.tls.public);
- }
- if(client.config.tls.trustedConnections){
- if(typeof client.config.tls.trustedConnections === 'string'){
- client.config.tls.trustedConnections=[client.config.tls.trustedConnections];
- }
- client.config.tls.ca=[];
- for(let i=0; i<client.config.tls.trustedConnections.length; i++){
- client.config.tls.ca.push(
- fs.readFileSync(client.config.tls.trustedConnections[i])
- );
- }
- }
-
- client.config.tls.host=client.path;
- client.config.tls.port=client.port;
-
- client.socket = tls.connect(
- client.config.tls
- );
- }
- }
-
- client.socket.setEncoding(this.config.encoding);
-
- client.socket.on(
- 'error',
- function(err){
- client.log('\n\n######\nerror: '.error, err);
- client.trigger('error', err);
-
- }
- );
-
- client.socket.on(
- 'connect',
- function connectionMade(){
- client.trigger('connect');
- client.retriesRemaining=client.config.maxRetries;
- client.log('retrying reset');
- }
- );
-
- client.socket.on(
- 'close',
- function connectionClosed(){
- client.log('connection closed'.notice ,client.id.variable , client.path.variable, client.retriesRemaining+' tries remaining of '+client.config.maxRetries);
-
- if(
- client.config.stopRetrying || client.retriesRemaining<1
-
- ){
- client.trigger('disconnect');
- client.log(
- client.config.id.variable,
- 'exceeded connection rety amount of'.warn,
- ' or stopRetrying flag set.'
- );
-
- client.socket.destroy();
- client.trigger('destroy');
- client=undefined;
-
- return;
- }
-
- client.isRetrying=true;
-
- setTimeout(
- function retryTimeout(){
- client.retriesRemaining--;
- client.isRetrying=false;
- client.connect();
- setTimeout(
- function resetRetriesCheck(){
- if(!client.isRetrying){
- client.retriesRemaining=client.config.maxRetries;
- }
- },
- 100
- );
- }.bind(null,client),
- client.config.retry
- );
-
- client.trigger('disconnect');
- }
- );
-
- client.socket.on(
- 'data',
- function(data) {
- client.log('## recieved events ##'.rainbow);
- Iif(client.config.rawBuffer){
- client.trigger(
- 'data',
- new Buffer(data,this.encoding)
- );
- if(!client.config.sync){
- return;
- }
-
- client.queue.next();
- return;
- }
-
- Eif(!this.ipcBuffer){
- this.ipcBuffer='';
- }
-
- data=(this.ipcBuffer+=data);
-
- Iif(data.slice(-1)!=eventParser.delimiter || data.indexOf(eventParser.delimiter) == -1){
- client.log('Implementing larger buffer for this socket message. You may want to consider smaller messages'.notice);
- return;
- }
-
- this.ipcBuffer='';
-
- const events = eventParser.parse(data);
- const eCount = events.length;
- for(let i=0; i<eCount; i++){
- let message=new Message;
- message.load(events[i]);
-
- client.log('detected event of type '.debug, message.type.data, message.data);
- client.trigger(
- message.type,
- message.data
- );
- }
-
- Iif(!client.config.sync){
- return;
- }
-
- client.queue.next();
- }
- );
-}
-
-module.exports=init;
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 | - -1× - - - - - -1× -9× - - -9× - - - -9× -9× - - -1× -9× -9× -9× - - -1× - | 'use strict';
-
-const parser={
- parse : parseDataEvents,
- format : formatData,
- delimiter : '\f'
-};
-
-function formatData(message){
- Iif(!message.data){
- message.data={};
- }
- Iif(message.data['_maxListeners']){
- message.data={};
- }
-
- message=message.JSON+parser.delimiter;
- return message;
-}
-
-function parseDataEvents(data){
- let events=data.split(parser.delimiter);
- events.pop();
- return events;
-}
-
-module.exports=parser;
- |
| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| client.js | -72.82% | -75/103 | -52.38% | -22/42 | -100% | -10/10 | -72.82% | -75/103 | -|
| eventParser.js | -84.62% | -11/13 | -50% | -2/4 | -100% | -2/2 | -84.62% | -11/13 | -|
| socketServer.js | -62.91% | -95/151 | -55.81% | -48/86 | -78.95% | -15/19 | -62.91% | -95/151 | -
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 -110 -111 -112 -113 -114 -115 -116 -117 -118 -119 -120 -121 -122 -123 -124 -125 -126 -127 -128 -129 -130 -131 -132 -133 -134 -135 -136 -137 -138 -139 -140 -141 -142 -143 -144 -145 -146 -147 -148 -149 -150 -151 -152 -153 -154 -155 -156 -157 -158 -159 -160 -161 -162 -163 -164 -165 -166 -167 -168 -169 -170 -171 -172 -173 -174 -175 -176 -177 -178 -179 -180 -181 -182 -183 -184 -185 -186 -187 -188 -189 -190 -191 -192 -193 -194 -195 -196 -197 -198 -199 -200 -201 -202 -203 -204 -205 -206 -207 -208 -209 -210 -211 -212 -213 -214 -215 -216 -217 -218 -219 -220 -221 -222 -223 -224 -225 -226 -227 -228 -229 -230 -231 -232 -233 -234 -235 -236 -237 -238 -239 -240 -241 -242 -243 -244 -245 -246 -247 -248 -249 -250 -251 -252 -253 -254 -255 -256 -257 -258 -259 -260 -261 -262 -263 -264 -265 -266 -267 -268 -269 -270 -271 -272 -273 -274 -275 -276 -277 -278 -279 -280 -281 -282 -283 -284 -285 -286 -287 -288 -289 -290 -291 -292 -293 -294 -295 -296 -297 -298 -299 -300 -301 -302 -303 -304 -305 -306 -307 -308 -309 -310 -311 -312 -313 -314 -315 -316 -317 -318 -319 -320 -321 -322 -323 -324 -325 -326 -327 -328 -329 -330 -331 -332 -333 -334 -335 -336 -337 -338 -339 -340 -341 -342 -343 -344 -345 -346 -347 -348 -349 -350 -351 -352 -353 -354 -355 -356 -357 -358 -359 -360 -361 -362 -363 -364 -365 -366 -367 -368 -369 -370 | - -1× - - - - - - - -1× -2× - -2× -2× -2× - -2× - - -2× - - -2× - -2× - - - - - -2× - - - -2× - - - - - -1× - - - - - - - - - - - - - - - - - - - - - - -1× -4× - - - - - - - - - - - -4× - - - - - -4× - - -4× - - - - -4× - - -4× - -4× -2× -2× - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -1× -2× -2× - - - - - - -2× - - - - - - - - - - - - -2× - - -2× -2× - - -2× - - - - -4× - - - - - - - - - - - -4× - -1× -4× - -4× -2× - - -4× -4× - - -2× - - - - - - -4× - - - - - - - - -4× - - -2× -2× - - - - - - - - - -2× -2× - - -2× - -2× - - - - -2× - -2× - -2× -2× -2× - -2× - -2× -2× - -2× - - - - - - - - -4× - - -2× - - - -2× -2× - -2× - - -2× - -2× - - - -4× - - - - -4× - - - - -1× -4× - - -4× -1× -1× - - - - - -1× - - - - -1× - - -3× -1× -1× - - - - -1× - - -2× -2× - - - - -2× - - - - - - - - - - -4× - -4× - - -2× -2× -2× - -2× -2× - - - - -2× - - - -2× - -2× - - - -2× - -2× - -2× - - - - -4× - - -1× - | 'use strict';
-
-const net = require('net'),
- tls = require('tls'),
- fs = require('fs'),
- dgram = require('dgram'),
- eventParser = require('../lib/eventParser.js'),
- Pubsub = require('event-pubsub'),
- Message = require('js-message');
-
-function emit(socket, type, data){
- this.log('dispatching event to socket'.debug, ' : ', type.data, data);
-
- let message=new Message;
- message.type=type;
- message.data=data;
-
- Iif(this.config.rawBuffer){
- message=new Buffer(type,this.encoding);
- }else{
- message=eventParser.format(message);
- }
-
- Eif(this.udp4 || this.udp6){
-
- Iif(!socket.address || !socket.port){
- this.log('Attempting to emit to a single UDP socket without supplying socket address or port. Redispatching event as broadcast to all connected sockets');
- this.broadcast(type,data);
- return;
- }
-
- this.server.write(
- message,
- socket
- );
- return;
- }
-
- socket.write(message);
-}
-
-function broadcast(type,data){
- this.log('broadcasting event to all known sockets listening to '.debug, this.path.variable,' : ', ((this.port)?this.port:''), type, data);
- let message=new Message;
- message.type=type;
- message.data=data;
-
- if(this.config.rawBuffer){
- message=new Buffer(type,this.encoding);
- }else{
- message=eventParser.format(message);
- }
-
- if(this.udp4 || this.udp6){
- for(let i=1, count=this.sockets.length; i<count; i++){
- this.server.write(message,this.sockets[i]);
- }
- }else{
- for(let i=0, count=this.sockets.length; i<count; i++){
- this.sockets[i].write(message);
- }
- }
-}
-
-function init(path,config,log,port){
- let server={
- config : config,
- path : path,
- port : port,
- udp4 : false,
- udp6 : false,
- log : log,
- server : false,
- sockets : [],
- emit : emit,
- broadcast : broadcast,
- onStart : function onStart(socket){
- this.trigger(
- 'start',
- socket
- );
- },
- stop:function stop(){
- server.server.close();
- },
- start : function start(){
- Iif(!this.path){
- server.log('Socket Server Path not specified, refusing to start'.warn);
- return;
- }
-
- fs.unlink(
- this.path,
- function () {
- server.log('starting server on '.debug,server.path.variable,((server.port)?':'+server.port:'').variable);
-
- if(!server.udp4 && !server.udp6){
- Eif(!server.config.tls){
- server.server=net.createServer(
- serverCreated
- );
- }else{
- server.log('starting TLS server'.debug,server.config.tls);
- if(server.config.tls.private){
- server.config.tls.key=fs.readFileSync(server.config.tls.private);
- }else{
- server.config.tls.key=fs.readFileSync(__dirname+'/../local-node-ipc-certs/private/server.key');
- }
- if(server.config.tls.public){
- server.config.tls.cert=fs.readFileSync(server.config.tls.public);
- }else{
- server.config.tls.cert=fs.readFileSync(__dirname+'/../local-node-ipc-certs/server.pub');
- }
- if(server.config.tls.dhparam){
- server.config.tls.dhparam=fs.readFileSync(server.config.tls.dhparam);
- }
- if(server.config.tls.trustedConnections){
- if(typeof server.config.tls.trustedConnections === 'string'){
- server.config.tls.trustedConnections=[server.config.tls.trustedConnections];
- }
- server.config.tls.ca=[];
- for(let i=0; i<server.config.tls.trustedConnections.length; i++){
- server.config.tls.ca.push(
- fs.readFileSync(server.config.tls.trustedConnections[i])
- );
- }
- }
- server.server=tls.createServer(
- server.config.tls,
- serverCreated
- );
- }
- }else{
- function UDPWrite(message,socket){
- let data=new Buffer(message, server.config.encoding);
- server.server.send(
- data,
- 0,
- data.length,
- socket.port,
- socket.address,
- function(err, bytes) {
- Iif(err){
- server.log('error writing data to socket'.warn,err);
- server.trigger(
- 'error',
- function(err){
- server.trigger('error',err);
- }
- );
- }
- }
- );
- }
-
- server.server=dgram.createSocket(
- ((server.udp4)? 'udp4':'udp6')
- );
- server.server.write=UDPWrite;
- server.server.on(
- 'listening',
- function () {
- serverCreated(server.server);
- }
- );
- }
-
- server.server.on(
- 'error',
- function(err){
- server.log('server error'.warn,err);
-
- server.trigger(
- 'error',
- err
- );
- }
- );
-
- server.server.maxConnections=server.config.maxConnections;
-
- function serverCreated(socket) {
- server.sockets.push(socket);
-
- if(socket.setEncoding){
- socket.setEncoding(server.config.encoding);
- }
-
- server.log('## socket connection to server detected ##'.rainbow);
- socket.on(
- 'close',
- function(socket){
- server.trigger(
- 'close',
- socket
- );
- }
- );
-
- socket.on(
- 'error',
- function(err){
- server.log('server socket error'.warn,err);
-
- server.trigger('error',err);
- }
- );
-
- socket.on(
- 'data',
- function(data,UDPSocket){
- let sock=((server.udp4 || server.udp6)? UDPSocket : socket);
- Iif(server.config.rawBuffer){
- data=new Buffer(data,this.encoding);
- server.trigger(
- 'data',
- data,
- sock
- );
- return;
- }
-
- Eif(!this.ipcBuffer){
- this.ipcBuffer='';
- }
-
- data=(this.ipcBuffer+=data);
-
- Iif(data.slice(-1)!=eventParser.delimiter || data.indexOf(eventParser.delimiter) == -1){
- server.log('Implementing larger buffer for this socket message. You may want to consider smaller messages'.notice);
- return;
- }
-
- this.ipcBuffer='';
-
- data=eventParser.parse(data);
-
- while(data.length>0){
- let message=new Message;
- message.load(data.shift());
-
- server.log('received event of : '.debug,message.type.data,message.data);
-
- Eif(message.data.id)
- sock.id=message.data.id;
-
- server.trigger(
- message.type,
- message.data,
- sock
- );
- }
- }
- );
-
- socket.on(
- 'message',
- function(msg,rinfo) {
- Iif (!rinfo){
- return;
- }
-
- server.log('Received UDP message from '.debug, rinfo.address.variable, rinfo.port);
- let data;
-
- Iif(server.config.rawSocket){
- data=new Buffer(msg,this.encoding);
- }else{
- data=msg.toString();
- }
- socket.emit('data',data,rinfo);
- }
- );
-
- server.trigger(
- 'connect',
- socket
- );
-
- Iif(server.config.rawBuffer){
- return;
- }
- }
-
- function started(socket){
- server.onStart(socket);
- }
-
- if(!port){
- server.log('starting server as'.debug, 'Unix || Windows Socket'.variable);
- Iif (process.platform ==='win32'){
- server.path = server.path.replace(/^\//, '');
- server.path = server.path.replace(/\//g, '-');
- server.path= '\\\\.\\pipe\\'+server.path;
- }
-
- server.server.listen(
- server.path,
- started
- );
-
- return;
- }
-
- if(!server.udp4 && !server.udp6){
- server.log('starting server as'.debug, (server.config.tls?'TLS':'TCP').variable);
- server.server.listen(
- server.port,
- server.path,
- started
- );
- return;
- }
-
- server.log('starting server as'.debug,((server.udp4)? 'udp4':'udp6').variable);
- server.server.bind(
- server.port,
- server.path
- );
-
- started(
- {
- address : server.path,
- port : server.port
- }
- );
- }
- );
- }
- };
-
- new Pubsub(server);
-
- server.on(
- 'close',
- function(){
- for(let i=0, count=server.sockets.length; i<count; i++){
- let socket=server.sockets[i];
- let destroyedSocketId=false;
-
- Eif(socket){
- Iif(socket.readable){
- continue;
- }
- }
-
- Iif(socket.id){
- destroyedSocketId=socket.id;
- }
-
- server.log('socket disconnected'.notice,' '+destroyedSocketId.variable);
-
- Iif(socket && socket.destroy){
- socket.destroy();
- }
-
- server.sockets.splice(i,1);
-
- server.trigger('socket.disconnected', socket, destroyedSocketId);
-
- return;
- }
- }
- );
-
- return server;
-}
-
-module.exports=init;
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 | - -1× - - - -1× - -1× - - - - - - - - - - - -1× - | 'use strict';
-
-const IPC = require('./services/IPC.js');
-
-class IPCModule extends IPC{
- constructor(){
- super();
- //include IPC to make extensible
- Object.defineProperty(
- this,
- 'IPC',
- {
- enumerable:true,
- writable:false,
- value:IPC
- }
- )
- }
-}
-
-module.exports=new IPCModule;
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 -110 -111 -112 -113 -114 -115 -116 -117 -118 -119 -120 -121 -122 -123 -124 -125 -126 -127 -128 -129 -130 -131 -132 -133 -134 -135 -136 -137 -138 -139 -140 -141 -142 -143 -144 -145 -146 -147 -148 -149 -150 -151 -152 -153 -154 -155 -156 -157 -158 -159 -160 -161 -162 -163 -164 -165 -166 -167 -168 -169 -170 -171 -172 -173 -174 -175 -176 -177 -178 -179 -180 -181 -182 -183 -184 -185 -186 -187 -188 -189 -190 -191 -192 -193 -194 -195 -196 -197 -198 -199 -200 -201 -202 -203 -204 -205 -206 -207 -208 -209 -210 -211 -212 -213 -214 -215 -216 -217 -218 -219 -220 -221 -222 -223 -224 -225 -226 -227 -228 -229 -230 -231 -232 -233 -234 -235 -236 -237 -238 -239 -240 -241 -242 -243 -244 -245 -246 -247 -248 -249 -250 -251 -252 -253 -254 -255 -256 -257 -258 -259 -260 -261 -262 -263 -264 -265 -266 -267 -268 -269 -270 -271 -272 -273 -274 -275 -276 -277 -278 -279 -280 -281 -282 -283 -284 -285 -286 -287 -288 -289 -290 -291 -292 -293 -294 -295 -296 -297 -298 -299 -300 -301 -302 -303 -304 -305 -306 -307 -308 -309 -310 -311 -312 -313 -314 -315 -316 -317 -318 -319 -320 -321 -322 -323 -324 -325 -326 -327 -328 -329 -330 -331 -332 -333 -334 -335 -336 -337 -338 | - -1× - - - - - - -1× - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -1× -116× - - - -116× -370× -336× - - -34× - - - - - - - - -116× - - - - -1× -7× - - - -7× - -7× -7× -7× -7× - - - -7× - - -1× -1× - - - -1× - - - - - - - - -1× - - - -1× - - - - - -1× - - - - - -1× - - - -1× -3× -1× -1× -1× -1× - -3× -1× -1× -1× -1× - -3× -2× - - - - -2× - -3× - - - - - - -3× - - - - -3× - - - - -3× -1× - - - - -1× - - -3× - - - - -3× - - - -3× - - - - - - -3× -2× -2× - - - - - -3× - - - - - -1× -4× -2× -2× - - -4× - - - -4× - - - - - - - -4× -2× - - - - -2× - - -4× - - - - - - - - - - - - -4× -4× -4× - -4× - -4× - - -1× -3× - - - - - - -3× -3× -3× -3× - -3× - - - - -3× -3× - - - - -3× - - -3× - - - -3× - - - - - - - - -3× - - - -3× - - - -3× - - - - - - - - - - - - - -3× -3× -3× -3× - -3× - -3× - - -1× - | 'use strict';
-
-const Defaults = require('../entities/Defaults.js'),
- Client = require('../dao/client.js'),
- Server = require('../dao/socketServer.js'),
- util = require('util');
-
-class IPC{
- constructor(){
- Object.defineProperties(
- this,
- {
- config : {
- enumerable:true,
- writable:true,
- value:new Defaults
- },
- connectTo : {
- enumerable:true,
- writable:false,
- value:connect
- },
- connectToNet: {
- enumerable:true,
- writable:false,
- value:connectNet
- },
- disconnect : {
- enumerable:true,
- writable:false,
- value:disconnect
- },
- serve : {
- enumerable:true,
- writable:false,
- value:serve
- },
- serveNet : {
- enumerable:true,
- writable:false,
- value:serveNet
- },
- of : {
- enumerable:true,
- writable:true,
- value:{}
- },
- server : {
- enumerable:true,
- writable:true,
- configurable:true,
- value:false
- },
- log : {
- enumerable:true,
- writable:false,
- value:log
- }
- }
- );
- }
-}
-
-function log(...args){
- Iif(this.config.silent){
- return;
- }
-
- for(let i=0, count=args.length; i<count; i++){
- if(typeof args[i] != 'object'){
- continue;
- }
-
- args[i]=util.inspect(
- args[i],
- {
- depth:this.config.logDepth,
- colors:this.config.logInColor
- }
- );
- }
-
- this.config.logger(
- args.join(' ')
- );
-}
-
-function disconnect(id){
- Iif(!this.of[id]){
- return;
- }
-
- this.of[id].explicitlyDisconnected=true;
-
- this.of[id].off('*','*');
- Eif(this.of[id].socket){
- Eif(this.of[id].socket.destroy){
- this.of[id].socket.destroy();
- }
- }
-
- delete this.of[id];
-}
-
-function serve(path,callback){
- Iif(typeof path=='function'){
- callback=path;
- path=false;
- }
- Iif(!path){
- this.log(
- 'Server path not specified, so defaulting to',
- 'ipc.config.socketRoot + ipc.config.appspace + ipc.config.id',
- this.config.socketRoot+this.config.appspace+this.config.id
- );
- path=this.config.socketRoot+this.config.appspace+this.config.id;
- }
-
- Iif(!callback){
- callback=emptyCallback;
- }
-
- this.server=new Server(
- path,
- this.config,
- log
- );
-
- this.server.on(
- 'start',
- callback
- );
-}
-
-function emptyCallback(){
- //Do Nothing
-}
-
-function serveNet(host,port,UDPType,callback){
- if(typeof host=='number'){
- callback=UDPType;
- UDPType=port;
- port=host;
- host=false;
- }
- if(typeof host=='function'){
- callback=host;
- UDPType=false;
- host=false;
- port=false;
- }
- if(!host){
- this.log(
- 'Server host not specified, so defaulting to',
- 'ipc.config.networkHost',
- this.config.networkHost
- );
- host=this.config.networkHost;
- }
- Iif(host.toLowerCase()=='udp4' || host.toLowerCase()=='udp6'){
- callback=port;
- UDPType=host.toLowerCase();
- port=false;
- host=this.config.networkHost;
- }
-
- Iif(typeof port=='string'){
- callback=UDPType;
- UDPType=port;
- port=false;
- }
- Iif(typeof port=='function'){
- callback=port;
- UDPType=false;
- port=false;
- }
- if(!port){
- this.log(
- 'Server port not specified, so defaulting to',
- 'ipc.config.networkPort',
- this.config.networkPort
- );
- port=this.config.networkPort;
- }
-
- Iif(typeof UDPType=='function'){
- callback=UDPType;
- UDPType=false;
- }
-
- Iif(!callback){
- callback=emptyCallback;
- }
-
- this.server=new Server(
- host,
- this.config,
- log,
- port
- );
-
- if(UDPType){
- this.server[UDPType]=true;
- Iif(UDPType === "udp4" && host === "::1") {
- // bind udp4 socket to an ipv4 address
- this.server.path = "127.0.0.1";
- }
- }
-
- this.server.on(
- 'start',
- callback
- );
-}
-
-function connect(id,path,callback){
- if(typeof path == 'function'){
- callback=path;
- path=false;
- }
-
- Iif(!callback){
- callback=emptyCallback;
- }
-
- Iif(!id){
- this.log(
- 'Service id required',
- 'Requested service connection without specifying service id. Aborting connection attempt'
- );
- return;
- }
-
- if(!path){
- this.log(
- 'Service path not specified, so defaulting to',
- 'ipc.config.socketRoot + ipc.config.appspace + id',
- (this.config.socketRoot+this.config.appspace+id).data
- );
- path=this.config.socketRoot+this.config.appspace+id;
- }
-
- Iif(this.of[id]){
- if(!this.of[id].socket.destroyed){
- this.log(
- 'Already Connected to',
- id,
- '- So executing success without connection'
- );
- callback();
- return;
- }
- this.of[id].socket.destroy();
- }
-
- this.of[id] = new Client(this.config,this.log);
- this.of[id].id = id;
- this.of[id].path = path;
-
- this.of[id].connect();
-
- callback(this);
-}
-
-function connectNet(id,host,port,callback){
- Iif(!id){
- this.log(
- 'Service id required',
- 'Requested service connection without specifying service id. Aborting connection attempt'
- );
- return;
- }
- Eif(typeof host=='number'){
- callback=port;
- port=host;
- host=false;
- }
- Iif(typeof host=='function'){
- callback=host;
- host=false;
- port=false;
- }
- Eif(!host){
- this.log(
- 'Server host not specified, so defaulting to',
- 'ipc.config.networkHost',
- this.config.networkHost
- );
- host=this.config.networkHost;
- }
-
- Iif(typeof port=='function'){
- callback=port;
- port=false;
- }
- Iif(!port){
- this.log(
- 'Server port not specified, so defaulting to',
- 'ipc.config.networkPort',
- this.config.networkPort
- );
- port=this.config.networkPort;
- }
-
- Iif(typeof callback == 'string'){
- UDPType=callback;
- callback=false;
- }
- Iif(!callback){
- callback=emptyCallback;
- }
-
- Iif(this.of[id]){
- if(!this.of[id].socket.destroyed){
-
- this.log(
- 'Already Connected to',
- id,
- '- So executing success without connection'
- );
- callback();
- return;
- }
- this.of[id].socket.destroy();
- }
-
- this.of[id] = new Client(this.config,this.log);
- this.of[id].id = id;
- this.of[id].path = host;
- this.of[id].port = port;
-
- this.of[id].connect();
-
- callback(this);
-}
-
-module.exports=IPC;
- |
| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| IPC.js | -65.67% | -88/134 | -60.81% | -45/74 | -87.5% | -7/8 | -65.67% | -88/134 | -