124 lines
No EOL
2.9 KiB
JavaScript
124 lines
No EOL
2.9 KiB
JavaScript
var os = require('os'),
|
|
colors = require('colors'),
|
|
pubsub = require('event-pubsub'),
|
|
eventParser = require('./lib/eventParser.js'),
|
|
Client = require('./lib/client.js'),
|
|
Server = require('./lib/socketServer.js'),
|
|
socketPrefix= 'app.';
|
|
|
|
colors.setTheme(
|
|
{
|
|
good : 'green',
|
|
notice : 'yellow',
|
|
warn : 'red',
|
|
error : 'redBG',
|
|
debug : 'magenta',
|
|
variable: 'cyan',
|
|
data : 'blue'
|
|
}
|
|
);
|
|
|
|
var defaults={
|
|
root : process.env.HOME,
|
|
appspace : socketPrefix,
|
|
socketRoot : '/tmp/',
|
|
id : os.hostname(),
|
|
encoding : 'utf8',
|
|
silent : false,
|
|
maxConnections : 100,
|
|
retry : 500
|
|
}
|
|
|
|
var ipc = {
|
|
config : defaults,
|
|
connectTo : connect,
|
|
serve : serve,
|
|
of : {},
|
|
server : false,
|
|
log : log
|
|
}
|
|
|
|
function log(){
|
|
if(ipc.config.silent)
|
|
return;
|
|
|
|
console.log(
|
|
Array.prototype.slice.call(arguments).join(' ')
|
|
);
|
|
}
|
|
|
|
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;
|
|
}
|
|
|
|
ipc.server=new Server(
|
|
path,
|
|
ipc.config,
|
|
log
|
|
);
|
|
|
|
ipc.server.on(
|
|
'start',
|
|
callback
|
|
);
|
|
}
|
|
|
|
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();
|
|
}
|
|
|
|
module.exports=ipc; |