From 91dbd32dc95cc0d043d288a0bccda6d894b888bb Mon Sep 17 00:00:00 2001 From: indexzero Date: Sat, 8 Oct 2011 23:51:19 -0400 Subject: [PATCH] [api test] Expose `this.spawnWith` in Monitor.data --- lib/forever/monitor.js | 3 ++- test/multiple-processes-test.js | 19 +++++++++++++++++-- 2 files changed, 19 insertions(+), 3 deletions(-) diff --git a/lib/forever/monitor.js b/lib/forever/monitor.js index 24c5f379..bb5ad93b 100644 --- a/lib/forever/monitor.js +++ b/lib/forever/monitor.js @@ -297,7 +297,8 @@ Monitor.prototype.__defineGetter__('data', function () { options: this.options.slice(1), pid: this.child.pid, silent: this.silent, - uid: this.uid + uid: this.uid, + spawnWith: this.spawnWith }; ['pidFile', 'outFile', 'errFile', 'env', 'cwd'].forEach(function (key) { diff --git a/test/multiple-processes-test.js b/test/multiple-processes-test.js index 5913ced6..11b001e3 100644 --- a/test/multiple-processes-test.js +++ b/test/multiple-processes-test.js @@ -17,6 +17,7 @@ vows.describe('forever/multiple-processes').addBatch({ "and spawning two processes using the same script": { topic: function () { var that = this, + output = '' script = path.join(__dirname, '..', 'examples', 'server.js'); this.child1 = new (forever.Monitor)(script, { @@ -31,11 +32,26 @@ vows.describe('forever/multiple-processes').addBatch({ maxRestart: 1, options: [ "--port=8081"] }); + + function buildJson (data) { + var json; + + try { + output += data; + json = JSON.parse(output.toString()); + that.callback(null, json); + } + catch (ex) { + // + // Do nothing here + // + } + } that.child2.on('start', function () { forever.startServer(that.child1, that.child2, function (err, server, socketPath) { var socket = new net.Socket(); - socket.on('data', that.callback.bind(null, null)); + socket.on('data', buildJson); socket.on('error', that.callback); socket.connect(socketPath); }); @@ -48,7 +64,6 @@ vows.describe('forever/multiple-processes').addBatch({ }, "should spawn both processes appropriately": function (err, data) { assert.isNull(err); - data = JSON.parse(data.toString()); assert.length(data.monitors, 2); this.child1.stop(); this.child2.stop();