@@ -2,6 +2,7 @@ var path = require('path'),
2
2
assert = require ( 'assert' ) ,
3
3
vows = require ( 'vows' ) ,
4
4
nssocket = require ( 'nssocket' ) ,
5
+ MonitorMock = require ( './helpers/mocks/monitor' ) . MonitorMock ,
5
6
Worker = require ( '../lib/forever/worker' ) . Worker ;
6
7
7
8
var SOCKET_PATH = path . join ( __dirname , 'fixtures' ) ;
@@ -10,14 +11,15 @@ vows.describe('forever/worker').addBatch({
10
11
'When using forever worker' : {
11
12
'and starting it and pinging it' : {
12
13
topic : function ( ) {
13
- var self = this ;
14
+ var self = this ,
15
+ monitor = new MonitorMock ( ) ;
14
16
15
- var worker = new Worker ( { sockPath : SOCKET_PATH } ) ,
17
+ var worker = new Worker ( { sockPath : SOCKET_PATH , monitor : monitor } ) ,
16
18
reader = new nssocket . NsSocket ( ) ;
17
19
18
20
worker . start ( function ( err , sock ) {
19
21
reader . connect ( sock , function ( ) {
20
- self . callback ( null , reader ) ;
22
+ self . callback ( null , reader , worker , monitor ) ;
21
23
} ) ;
22
24
} ) ;
23
25
} ,
@@ -28,6 +30,20 @@ vows.describe('forever/worker').addBatch({
28
30
reader . data ( [ 'pong' ] , this . callback ) ;
29
31
} ,
30
32
'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
+ }
31
47
}
32
48
}
33
49
}
0 commit comments