Skip to content

Commit d174539

Browse files
committed
[test] Test if worker responds to data
1 parent 3059a9d commit d174539

File tree

1 file changed

+19
-3
lines changed

1 file changed

+19
-3
lines changed

Diff for: test/worker-test.js

+19-3
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ var path = require('path'),
22
assert = require('assert'),
33
vows = require('vows'),
44
nssocket = require('nssocket'),
5+
MonitorMock = require('./helpers/mocks/monitor').MonitorMock,
56
Worker = require('../lib/forever/worker').Worker;
67

78
var SOCKET_PATH = path.join(__dirname, 'fixtures');
@@ -10,14 +11,15 @@ vows.describe('forever/worker').addBatch({
1011
'When using forever worker': {
1112
'and starting it and pinging it': {
1213
topic: function () {
13-
var self = this;
14+
var self = this,
15+
monitor = new MonitorMock();
1416

15-
var worker = new Worker({ sockPath: SOCKET_PATH }),
17+
var worker = new Worker({ sockPath: SOCKET_PATH, monitor: monitor }),
1618
reader = new nssocket.NsSocket();
1719

1820
worker.start(function (err, sock) {
1921
reader.connect(sock, function () {
20-
self.callback(null, reader);
22+
self.callback(null, reader, worker, monitor);
2123
});
2224
});
2325
},
@@ -28,6 +30,20 @@ vows.describe('forever/worker').addBatch({
2830
reader.data(['pong'], this.callback);
2931
},
3032
'with `pong`': function () {}
33+
},
34+
'and when queried for data': {
35+
topic: function (reader, _, monitor) {
36+
var self = this;
37+
38+
reader.send(['data']);
39+
reader.data(['data'], function (data) {
40+
self.callback(null, { data: data, monitor: monitor });
41+
});
42+
},
43+
'it should respond with data': function (obj) {
44+
assert.isObject(obj.data);
45+
assert.deepEqual(obj.data, obj.data);
46+
}
3147
}
3248
}
3349
}

0 commit comments

Comments
 (0)