diff --git a/lib/client.js b/lib/client.js index 07eb63b..cd7f6d4 100644 --- a/lib/client.js +++ b/lib/client.js @@ -13,6 +13,8 @@ function init(config,log){ } new pubsub(client); + console.log(this) + return client; } diff --git a/testHarness/tests/stopRetrieing-unix-socket-test/client.js b/testHarness/tests/stopRetrieing-unix-socket-test/client.js new file mode 100644 index 0000000..bda3a18 --- /dev/null +++ b/testHarness/tests/stopRetrieing-unix-socket-test/client.js @@ -0,0 +1,32 @@ +var ipc = require('../../../node-ipc'), + server=__dirname.split('/'), + server=server[server.length-1] + +ipc.config.id = server+'-client'; +ipc.config.stopRetrying=true; + +//Wait to connect to ensure test server is started +setTimeout( + function(){ + ipc.connectTo( + server, + function(){ + ipc.of[server].on( + 'connect', + function(){ + ipc.disconnect(server); + + //wait long enough that the test will fail if disconnect does not happen + setTimeout( + function(){ + process.exit(0); + }, + 2000 + ); + } + ); + } + ); + }, + 400 +); \ No newline at end of file diff --git a/testHarness/tests/stopRetrieing-unix-socket-test/server.js b/testHarness/tests/stopRetrieing-unix-socket-test/server.js new file mode 100644 index 0000000..445e7bb --- /dev/null +++ b/testHarness/tests/stopRetrieing-unix-socket-test/server.js @@ -0,0 +1,48 @@ +var ipc = require('../../../node-ipc'), + expectedClient=ipc.config.id+'-client'; + +ipc.config.id = __dirname.split('/'); +ipc.config.id = ipc.config.id[ipc.config.id.length-1] +ipc.config.maxRetries=1; + +ipc.connectTo( + 'testHarness', + function(){ + ipc.of.testHarness.on( + 'connect', + function(){ + ipc.of.testHarness.emit( + 'start.test', + { + id : ipc.config.id, + duration: 1800 + } + ); + } + ) + } +); + +ipc.serve( + function(){ + + } +); + +ipc.server.on( + 'socket.disconnected', + function(socket,id){ + ipc.of.testHarness.emit( + 'pass', + 'stopRetrying-unix-server' + ); + + ipc.of.testHarness.emit( + 'end.test' + ); + + process.exit(0); + } +) + +ipc.server.start(); \ No newline at end of file diff --git a/testHarness/tests/unix-socket-test/server.js b/testHarness/tests/unix-socket-test/server.js index 690a0de..7ea4aab 100644 --- a/testHarness/tests/unix-socket-test/server.js +++ b/testHarness/tests/unix-socket-test/server.js @@ -79,6 +79,6 @@ ipc.server.on( } ); -ipc.server.define.listen['app.message']='This event type listens for message strings as value of data key.'; +ipc.server.define.listen['test-test']='Registers and tests ipc communication.'; ipc.server.start(); \ No newline at end of file