node-ipc/node-ipc.js

295 lines
6.7 KiB
JavaScript
Raw Normal View History

2014-02-22 20:13:31 +11:00
var os = require('os'),
util = require('util'),
2014-02-22 20:13:31 +11:00
colors = require('colors'),
pubsub = require('event-pubsub'),
eventParser = require('./lib/eventParser.js'),
Client = require('./lib/client.js'),
2014-02-28 07:04:30 +11:00
Server = require('./lib/socketServer.js');
2014-02-22 20:13:31 +11:00
colors.setTheme(
{
good : 'green',
notice : 'yellow',
warn : 'red',
error : 'redBG',
debug : 'magenta',
variable: 'cyan',
data : 'blue'
}
);
var defaults={
2014-02-28 07:04:30 +11:00
appspace : 'app.',
2014-02-22 20:13:31 +11:00
socketRoot : '/tmp/',
2014-02-26 12:15:43 +11:00
networkHost : 'localhost',
networkPort : 8000,
2014-02-22 20:13:31 +11:00
id : os.hostname(),
encoding : 'utf8',
silent : false,
maxConnections : 100,
retry : 500,
stopRetrying : false,
2014-02-22 20:13:31 +11:00
}
var ipc = {
config : defaults,
connectTo : connect,
2014-02-27 09:04:09 +11:00
connectToNet: connectNet,
disconnect : disconnect,
2014-02-22 20:13:31 +11:00
serve : serve,
2014-02-27 09:04:09 +11:00
serveNet : serveNet,
2014-02-22 20:13:31 +11:00
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});
}
2014-02-22 20:13:31 +11:00
console.log(
args.join(' ')
2014-02-22 20:13:31 +11:00
);
}
function disconnect(id){
if(!ipc.of[id])
return;
ipc.of[id].off('*');
if(ipc.of[id].socket){
if(ipc.of[id].socket.destroy)
ipc.of[id].socket.destroy();
}
delete ipc.of[id];
}
2014-02-22 20:13:31 +11:00
function serve(path,callback){
if(typeof path=='function'){
callback=path;
path=false;
}
if(!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;
}
2014-02-26 12:15:43 +11:00
if(!callback)
callback=function(){};
2014-02-22 20:13:31 +11:00
ipc.server=new Server(
path,
ipc.config,
log
);
ipc.server.on(
'start',
callback
);
}
2014-02-27 09:04:09 +11:00
function serveNet(host,port,UDPType,callback){
2014-02-26 12:15:43 +11:00
if(typeof host=='number'){
2014-02-27 09:04:09 +11:00
callback=UDPType;
UDPType=port;
2014-02-26 12:15:43 +11:00
port=host;
host=false;
}
if(typeof host=='function'){
callback=host;
2014-02-27 09:04:09 +11:00
UDPType=false;
2014-02-26 12:15:43 +11:00
host=false;
port=false;
}
2014-02-27 09:04:09 +11:00
if(!host){
ipc.log(
'Server host not specified, so defaulting to'.notice,
'ipc.config.networkHost'.variable,
ipc.config.networkHost.data
);
host=ipc.config.networkHost;
}
if(host.toLowerCase()=='udp4' || host.toLowerCase()=='udp6'){
2014-02-26 12:15:43 +11:00
callback=port;
2014-02-27 09:04:09 +11:00
UDPType=host.toLowerCase();
port=false;
host=ipc.config.networkHost;
}
if(typeof port=='string'){
callback=UDPType;
UDPType=port;
2014-02-26 12:15:43 +11:00
port=false;
}
2014-02-27 09:04:09 +11:00
if(typeof port=='function'){
callback=port;
UDPType=false;
port=false;
}
2014-02-26 12:15:43 +11:00
if(!port){
ipc.log(
'Server port not specified, so defaulting to'.notice,
'ipc.config.networkPort'.variable,
ipc.config.networkPort
);
port=ipc.config.networkPort;
}
2014-02-27 09:04:09 +11:00
if(typeof UDPType=='function'){
callback=UDPType;
UDPType=false;
2014-02-26 12:15:43 +11:00
}
2014-02-27 09:04:09 +11:00
2014-02-26 12:15:43 +11:00
if(!callback)
callback=function(){};
ipc.server=new Server(
host,
ipc.config,
log,
port
);
2014-02-27 09:04:09 +11:00
if(UDPType)
ipc.server[UDPType]=true;
2014-02-26 12:15:43 +11:00
ipc.server.on(
'start',
callback
);
}
2014-02-22 20:13:31 +11:00
function connect(id,path,callback){
if(typeof path == 'function'){
callback=path;
path=false;
}
if(!callback)
callback=function(){};
if(!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;
}
if(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].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();
}
2014-02-28 07:04:30 +11:00
function connectNet(id,host,port,callback){
2014-02-26 12:15:43 +11:00
if(!id){
ipc.log(
'Service id required'.warn,
'Requested service connection without specifying service id. Aborting connection attempt'.notice
);
return;
}
if(typeof host=='number'){
callback=port;
port=host;
2014-02-27 09:04:09 +11:00
host=false;
2014-02-26 12:15:43 +11:00
}
if(typeof host=='function'){
callback=host;
host=false;
port=false;
}
2014-02-27 09:04:09 +11:00
if(!host){
ipc.log(
'Server host not specified, so defaulting to'.notice,
'ipc.config.networkHost'.variable,
ipc.config.networkHost.data
);
host=ipc.config.networkHost;
}
2014-02-26 12:15:43 +11:00
if(typeof port=='function'){
callback=port;
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;
}
2014-02-27 09:04:09 +11:00
if(typeof callback == 'string'){
UDPType=callback;
callback=false;
2014-02-26 12:15:43 +11:00
}
if(!callback)
callback=function(){};
if(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].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();
}
2014-02-22 20:13:31 +11:00
module.exports=ipc;