| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| node-ipc/ | +70.37% | +95/135 | +61.11% | +44/72 | +60% | +6/10 | +70.37% | +95/135 | +|
| node-ipc/lib/ | +64.07% | +173/270 | +52.31% | +68/130 | +78.79% | +26/33 | +64.07% | +173/270 | +
| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| node-ipc.js | +70.37% | +95/135 | +61.11% | +44/72 | +60% | +6/10 | +70.37% | +95/135 | +
| 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 | 1× + + + + + + + +1× +8× + + + + + + + + +8× + +8× + + +1× +12× + +12× +12× +12× + +12× + + +12× + + +12× +1× +1× + + +11× + + + + +1× +11× +11× + + +1× + +14× + +14× +14× + + + + +14× +7× + +7× + +7× + + + + +7× + + + + + +7× +7× +7× + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +14× + +14× + + +10× +10× + + + + +14× + + +4× +4× +4× + + + +14× + + +14× + +14× + + + +8× +8× + + + + + +8× +8× +8× + +8× + + +6× + +6× + + +6× +6× +6× +6× +6× + +6× +2× + + + + + + + + + +6× + + + +14× + + +12× +12× + + + + + + + + + + + + +12× +12× + +12× + +12× + + + + +12× + +12× +12× +12× +12× +12× + +12× +12× + + + + + +12× + + + +12× + + + + +1× + | var 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){
+ var 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);
+
+ var 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.
+ var 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);
+
+ var 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(var 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(){
+ client.trigger('connect');
+ client.retriesRemaining=client.config.maxRetries;
+ client.log('retrying reset');
+ }
+ );
+
+ client.socket.on(
+ 'close',
+ function(){
+ 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(client){
+ return function(){
+ client.retriesRemaining--;
+ client.isRetrying=false;
+ client.connect();
+ setTimeout(
+ function(){
+ if(!client.isRetrying)
+ client.retriesRemaining=client.config.maxRetries;
+ },
+ 100
+ )
+ }
+ }
+ )(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='';
+
+ var events = eventParser.parse(data);
+ var eCount = events.length;
+ for(var i=0; i<eCount; i++){
+ var 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× +14× + + +14× + + + +14× +14× + + +1× +15× +15× +15× + + +1× + + + + + +1× + | var Message = require('js-message');
+
+function formatData(message){
+ Iif(!message.data){
+ message.data={};
+ }
+ Iif(message.data['_maxListeners']){
+ message.data={};
+ }
+
+ message=message.JSON+parser.delimiter;
+ return message;
+};
+
+function parseDataEvents(data){
+ var events=data.split(parser.delimiter);
+ events.pop();
+ return events;
+}
+
+var parser={
+ parse : parseDataEvents,
+ format : formatData,
+ delimiter : '\f'
+}
+
+module.exports=parser;
+ |
| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| client.js | +73.08% | +76/104 | +52.38% | +22/42 | +100% | +11/11 | +73.08% | +76/104 | +|
| eventParser.js | +85.71% | +12/14 | +50% | +2/4 | +100% | +2/2 | +85.71% | +12/14 | +|
| socketServer.js | +55.92% | +85/152 | +52.38% | +44/84 | +65% | +13/20 | +55.92% | +85/152 | +
| 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 | 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× +1× +1× + + + + + + + + + + +2× + + +2× +2× + + +2× + + + + +4× + + + + + + + + + + + +4× + +1× +4× + +4× +2× + +4× +4× + + + + + + + + + +4× + + + + + + + + +4× + + +3× +3× + + + + + + + + + +3× +3× + +3× + +3× + + + + +3× + +3× + +3× +3× +3× + +3× + +3× +3× + +3× + + + + + + + + +4× + + +1× + +1× +1× + +1× + + +1× + +1× + + + +4× + + + + +4× + + + + +1× +4× + + +4× +1× +1× + + + + + +1× + + + + +1× + + +3× +1× +1× + + + + +1× + + +2× +2× + + + + +2× + + + + + + + + + + + + +4× + +4× + + + + + + + + + + + + + + + + + + + + + + + + + + + + +4× + + +1× + | var 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);
+
+ var 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);
+ var 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(var i=1, count=this.sockets.length; i<count; i++){
+ this.server.write(message,this.sockets[i]);
+ }
+ }else{
+ for(var i=0, count=this.sockets.length; i<count; i++){
+ this.sockets[i].write(message);
+ }
+ }
+};
+
+function init(path,config,log,port){
+ var server={
+ config : config,
+ path : path,
+ port : port,
+ udp4 : false,
+ udp6 : false,
+ log : log,
+ server : false,
+ sockets : [],
+ emit : emit,
+ broadcast : broadcast,
+ onStart : function(socket){
+ this.trigger(
+ 'start',
+ socket
+ );
+ },
+ stop:function(){
+ server.server.close();
+ },
+ start : function(){
+ Iif(!this.path){
+ server.log('Socket Server Path not specified, refusing to start'.warn);
+ return;
+ }
+
+ fs.unlink(
+ this.path,
+ (
+ function(server){
+ return 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(var 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){
+ var data=new Buffer(message, server.config.encoding);
+ server.server.send(
+ data,
+ 0,
+ data.length,
+ socket.port,
+ socket.address,
+ function(err, bytes) {
+ if(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){
+ var 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){
+ var 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);
+ var 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
+ }
+ );
+ }
+ }
+ )(this)
+ );
+ }
+ };
+
+ new pubsub(server);
+
+ server.on(
+ 'close',
+ function(){
+ for(var i=0, count=server.sockets.length; i<count; i++){
+ var socket=server.sockets[i];
+ var destroyedSocketId=false;
+
+ if(socket){
+ if(socket.readable)
+ continue;
+ }
+
+ if(socket.id)
+ destroyedSocketId=socket.id;
+
+ server.log('socket disconnected'.notice,' '+destroyedSocketId.variable);
+
+ if(socket)
+ 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 +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 | 1× + + + + + + + + +1× + + + + + + + + + + + +1× + + + +1× + + + + + + + + + + + + + + + + + +1× + + + + + + + + + + + +1× +140× +69× + +71× + +71× +229× +210× + +19× + + +71× + + + + +1× +8× + + +8× + +8× +8× +8× +8× + + +8× + + +1× +1× +1× +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× + +3× + + + + + +1× +4× +2× +2× + + +4× + + +4× + + + + + + + +4× +2× + + + + +2× + + +4× + + + + + + + + + + + + +4× +4× +4× + +4× + +4× + + +1× +4× + + + + + + +4× +4× +4× +4× + +4× + + + + +4× +4× + + + + +4× + + +4× + + + +4× + + + + + + + + +4× + + + +4× + + +4× + + + + + + + + + + + + +4× +4× +4× +4× + +4× + +4× + + +1× + | var os = require('os'),
+ dns = require('dns'),
+ util = require('util'),
+ colors = require('colors'),
+ pubsub = require('event-pubsub'),
+ eventParser = require('./lib/eventParser.js'),
+ Client = require('./lib/client.js'),
+ Server = require('./lib/socketServer.js');
+
+colors.setTheme(
+ {
+ good : 'green',
+ notice : 'yellow',
+ warn : 'red',
+ error : 'redBG',
+ debug : 'magenta',
+ variable: 'cyan',
+ data : 'blue'
+ }
+);
+
+var IPType=os.networkInterfaces()[
+ Object.keys(os.networkInterfaces())[0]
+][0].family
+
+var defaults={
+ appspace : 'app.',
+ socketRoot : '/tmp/',
+ networkHost : (IPType=='IPv6')? '::1' : '127.0.0.1',
+ networkPort : 8000,
+ id : os.hostname(),
+ encoding : 'utf8',
+ rawBuffer : false,
+ sync : false,
+ silent : false,
+ maxConnections : 100,
+ retry : 500,
+ maxRetries : Infinity,
+ stopRetrying : false,
+ IPType : IPType,
+ tls : false
+}
+
+var ipc = {
+ config : defaults,
+ connectTo : connect,
+ connectToNet: connectNet,
+ disconnect : disconnect,
+ serve : serve,
+ serveNet : serveNet,
+ of : {},
+ server : false,
+ log : log
+}
+
+function log(){
+ if(ipc.config.silent)
+ return;
+
+ var args=Array.prototype.slice.call(arguments);
+
+ for(var i=0, count=args.length; i<count; i++){
+ if(typeof args[i] != 'object')
+ continue;
+
+ args[i]=util.inspect(args[i],{colors:true});
+ }
+
+ console.log(
+ args.join(' ')
+ );
+}
+
+function disconnect(id){
+ Iif(!ipc.of[id])
+ return;
+
+ ipc.of[id].config.stopRetrying=true;
+
+ ipc.of[id].off('*');
+ Eif(ipc.of[id].socket){
+ Eif(ipc.of[id].socket.destroy)
+ ipc.of[id].socket.destroy();
+ }
+
+ delete ipc.of[id];
+}
+
+function serve(path,callback){
+ Eif(typeof path=='function'){
+ callback=path;
+ path=false;
+ }
+ Eif(!path){
+ ipc.log(
+ 'Server path not specified, so defaulting to'.notice,
+ 'ipc.config.socketRoot + ipc.config.appspace + ipc.config.id'.variable,
+ (ipc.config.socketRoot+ipc.config.appspace+ipc.config.id).data
+ );
+ path=ipc.config.socketRoot+ipc.config.appspace+ipc.config.id;
+ }
+
+ Iif(!callback)
+ callback=function(){};
+
+ ipc.server=new Server(
+ path,
+ ipc.config,
+ log
+ );
+
+ ipc.server.on(
+ 'start',
+ callback
+ );
+}
+
+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){
+ ipc.log(
+ 'Server host not specified, so defaulting to'.notice,
+ 'ipc.config.networkHost'.variable,
+ ipc.config.networkHost.data
+ );
+ host=ipc.config.networkHost;
+ }
+ Iif(host.toLowerCase()=='udp4' || host.toLowerCase()=='udp6'){
+ callback=port;
+ UDPType=host.toLowerCase();
+ port=false;
+ host=ipc.config.networkHost;
+ }
+
+ Iif(typeof port=='string'){
+ callback=UDPType;
+ UDPType=port;
+ port=false;
+ }
+ Iif(typeof port=='function'){
+ callback=port;
+ UDPType=false;
+ port=false;
+ }
+ if(!port){
+ ipc.log(
+ 'Server port not specified, so defaulting to'.notice,
+ 'ipc.config.networkPort'.variable,
+ ipc.config.networkPort
+ );
+ port=ipc.config.networkPort;
+ }
+
+ Iif(typeof UDPType=='function'){
+ callback=UDPType;
+ UDPType=false;
+ }
+
+ Iif(!callback)
+ callback=function(){};
+
+
+ ipc.server=new Server(
+ host,
+ ipc.config,
+ log,
+ port
+ );
+
+ if(UDPType)
+ ipc.server[UDPType]=true;
+
+ ipc.server.on(
+ 'start',
+ callback
+ );
+}
+
+function connect(id,path,callback){
+ if(typeof path == 'function'){
+ callback=path;
+ path=false;
+ }
+
+ Iif(!callback)
+ callback=function(){};
+
+ Iif(!id){
+ ipc.log(
+ 'Service id required'.warn,
+ 'Requested service connection without specifying service id. Aborting connection attempt'.notice
+ );
+ return;
+ }
+
+ if(!path){
+ ipc.log(
+ 'Service path not specified, so defaulting to'.notice,
+ 'ipc.config.socketRoot + ipc.config.appspace + id'.variable,
+ (ipc.config.socketRoot+ipc.config.appspace+id).data
+ );
+ path=ipc.config.socketRoot+ipc.config.appspace+id;
+ }
+
+ Iif(ipc.of[id]){
+ if(!ipc.of[id].socket.destroyed){
+ ipc.log(
+ 'Already Connected to'.notice,
+ id.variable,
+ '- So executing success without connection'.notice
+ );
+ callback();
+ return;
+ }
+ ipc.of[id].socket.destroy();
+ }
+
+ ipc.of[id] = new Client(ipc.config,ipc.log);
+ ipc.of[id].id = id;
+ ipc.of[id].path = path;
+
+ ipc.of[id].connect();
+
+ callback(ipc);
+}
+
+function connectNet(id,host,port,callback){
+ Iif(!id){
+ ipc.log(
+ 'Service id required'.warn,
+ 'Requested service connection without specifying service id. Aborting connection attempt'.notice
+ );
+ return;
+ }
+ Eif(typeof host=='number'){
+ callback=port;
+ port=host;
+ host=false;
+ }
+ Iif(typeof host=='function'){
+ callback=host;
+ host=false;
+ port=false;
+ }
+ Eif(!host){
+ ipc.log(
+ 'Server host not specified, so defaulting to'.notice,
+ 'ipc.config.networkHost'.variable,
+ ipc.config.networkHost.data
+ );
+ host=ipc.config.networkHost;
+ }
+
+ Iif(typeof port=='function'){
+ callback=port;
+ port=false;
+ }
+ Iif(!port){
+ ipc.log(
+ 'Server port not specified, so defaulting to'.notice,
+ 'ipc.config.networkPort'.variable,
+ ipc.config.networkPort
+ );
+ port=ipc.config.networkPort;
+ }
+
+ Iif(typeof callback == 'string'){
+ UDPType=callback;
+ callback=false;
+ }
+ Iif(!callback)
+ callback=function(){};
+
+ Iif(ipc.of[id]){
+ if(!ipc.of[id].socket.destroyed){
+ ipc.log(
+ 'Already Connected to'.notice,
+ id.variable,
+ '- So executing success without connection'.notice
+ );
+ callback();
+ return;
+ }
+ ipc.of[id].socket.destroy();
+ }
+
+ ipc.of[id] = new Client(ipc.config,ipc.log);
+ ipc.of[id].id = id;
+ ipc.of[id].path = host;
+ ipc.of[id].port = port;
+
+ ipc.of[id].connect();
+
+ callback(ipc);
+}
+
+module.exports=ipc;
+ |