@@ -16,23 +16,17 @@ describe('resolvmon watch', function () {
16
16
17
17
var temporary_conf = temp . openSync ( 'resolv.conf' ) . path ;
18
18
19
- after ( function ( ) {
20
- try {
21
- fs . unlinkSync ( temporary_conf ) ;
22
- } catch ( ex ) {
23
- }
24
- } ) ;
25
-
26
- beforeEach ( function ( ) {
19
+ before ( function ( done ) {
27
20
28
21
try {
29
- fs . unlinkSync ( temporary_conf ) ;
22
+ fs . unlink ( temporary_conf , done ) ;
30
23
} catch ( ex ) {
24
+ done ( ) ;
31
25
}
32
26
33
27
} ) ;
34
28
35
- afterEach ( function ( ) {
29
+ afterEach ( function ( done ) {
36
30
37
31
try {
38
32
resolvmon . removeAllListeners ( ) ;
@@ -50,29 +44,47 @@ describe('resolvmon watch', function () {
50
44
} catch ( ex ) {
51
45
}
52
46
47
+ try {
48
+ fs . unlink ( temporary_conf , function ( err ) {
49
+ done ( ) ;
50
+ } ) ;
51
+ } catch ( ex ) {
52
+ done ( ) ;
53
+ }
54
+
53
55
} ) ;
54
56
55
57
it ( 'detect resolv.conf create' , function ( done ) {
56
58
57
- resolvmon . setPath ( temporary_conf ) ;
59
+ fs . unlink ( temporary_conf , function ( err ) {
58
60
59
- resolvmon . on ( 'error' , function ( err ) {
60
61
expect ( err ) . not . to . be . defined ;
61
- done ( err ) ;
62
- } ) ;
63
62
64
- resolvmon . on ( 'update' , function ( nameservers ) {
63
+ if ( err ) {
64
+ return done ( ) ;
65
+ }
65
66
66
- expect ( nameservers ) . to . be . defined ;
67
- expect ( nameservers ) . to . be . instanceof ( Array ) ;
68
- expect ( nameservers ) . to . eql ( [ '127.0.0.10' , '127.0.0.20' ] ) ;
69
- done ( ) ;
70
- } ) ;
67
+ resolvmon . setPath ( temporary_conf ) ;
71
68
72
- resolvmon . start ( ) ;
69
+ resolvmon . on ( 'error' , function ( err ) {
70
+ expect ( err ) . not . to . be . defined ;
71
+ done ( err ) ;
72
+ } ) ;
73
+
74
+ resolvmon . on ( 'update' , function ( nameservers ) {
75
+
76
+ expect ( nameservers ) . to . be . defined ;
77
+ expect ( nameservers ) . to . be . instanceof ( Array ) ;
78
+ expect ( nameservers ) . to . eql ( [ '127.0.0.10' , '127.0.0.20' ] ) ;
79
+ done ( ) ;
80
+ } ) ;
81
+
82
+ resolvmon . start ( ) ;
83
+
84
+ process . nextTick ( function ( ) {
85
+ fs . writeFileSync ( temporary_conf , "nameserver 127.0.0.10\nnameserver 127.0.0.20\n" ) ;
86
+ } ) ;
73
87
74
- process . nextTick ( function ( ) {
75
- fs . writeFileSync ( temporary_conf , "nameserver 127.0.0.10\nnameserver 127.0.0.20\n" ) ;
76
88
} ) ;
77
89
78
90
} ) ;
@@ -90,16 +102,16 @@ describe('resolvmon watch', function () {
90
102
}
91
103
92
104
resolvmon . on ( 'error' , function ( err ) {
105
+ resolvmon . removeAllListeners ( ) ;
93
106
expect ( err ) . not . to . be . defined ;
94
107
done ( err ) ;
95
108
} ) ;
96
109
97
110
resolvmon . on ( 'update' , function ( nameservers ) {
98
-
111
+ resolvmon . removeAllListeners ( ) ;
99
112
expect ( nameservers ) . to . be . defined ;
100
113
expect ( nameservers ) . to . be . instanceof ( Array ) ;
101
114
expect ( nameservers ) . to . eql ( [ ] ) ;
102
-
103
115
done ( ) ;
104
116
105
117
} ) ;
@@ -127,18 +139,17 @@ describe('resolvmon watch', function () {
127
139
}
128
140
129
141
resolvmon . on ( 'error' , function ( err ) {
142
+ resolvmon . removeAllListeners ( ) ;
130
143
expect ( err ) . not . to . be . defined ;
131
144
done ( err ) ;
132
145
} ) ;
133
146
134
147
resolvmon . on ( 'update' , function ( nameservers ) {
135
-
148
+ resolvmon . removeAllListeners ( ) ;
136
149
expect ( nameservers ) . to . be . defined ;
137
150
expect ( nameservers ) . to . be . instanceof ( Array ) ;
138
151
expect ( nameservers ) . to . eql ( [ '127.0.0.12' , '127.0.0.23' , '127.0.0.34' , '127.0.0.45' ] ) ;
139
-
140
152
done ( ) ;
141
-
142
153
} ) ;
143
154
144
155
resolvmon . start ( ) ;
@@ -165,12 +176,13 @@ describe('resolvmon watch', function () {
165
176
}
166
177
167
178
resolvmon . on ( 'error' , function ( err ) {
179
+ resolvmon . removeAllListeners ( ) ;
168
180
expect ( err ) . not . to . be . defined ;
169
181
done ( err ) ;
170
182
} ) ;
171
183
172
184
resolvmon . on ( 'update' , function ( nameservers ) {
173
-
185
+ resolvmon . removeAllListeners ( ) ;
174
186
expect ( nameservers ) . to . be . defined ;
175
187
expect ( nameservers ) . to . be . instanceof ( Array ) ;
176
188
expect ( nameservers ) . to . eql ( [ '127.0.0.100' , '127.0.0.200' ] ) ;
@@ -191,32 +203,44 @@ describe('resolvmon watch', function () {
191
203
192
204
resolvmon . setPath ( temporary_conf ) ;
193
205
194
- fs . writeFileSync ( temporary_conf , "nameserver 127.0.0.91\nnameserver 127.0.0.81\n" ) ;
206
+ fs . writeFile ( temporary_conf , "nameserver 127.0.0.91\nnameserver 127.0.0.81\n" , function ( err ) {
195
207
196
- resolvmon . on ( 'error' , function ( err ) {
197
208
expect ( err ) . not . to . be . defined ;
198
- done ( err ) ;
199
- } ) ;
200
209
201
- resolvmon . on ( 'update' , function ( nameservers ) {
210
+ if ( err ) {
211
+ return done ( ) ;
212
+ }
202
213
203
- expect ( nameservers ) . to . be . defined ;
204
- expect ( nameservers ) . to . be . instanceof ( Array ) ;
205
- expect ( nameservers ) . to . eql ( [ ] ) ;
206
- done ( ) ;
207
- } ) ;
214
+ resolvmon . on ( 'error' , function ( err ) {
215
+ resolvmon . removeAllListeners ( ) ;
216
+ expect ( err ) . not . to . be . defined ;
217
+ done ( err ) ;
218
+ } ) ;
208
219
209
- resolvmon . start ( ) ;
220
+ resolvmon . on ( 'update' , function ( nameservers ) {
221
+ resolvmon . removeAllListeners ( ) ;
222
+ expect ( nameservers ) . to . be . defined ;
223
+ expect ( nameservers ) . to . be . instanceof ( Array ) ;
224
+ expect ( nameservers ) . to . eql ( [ ] ) ;
225
+ done ( ) ;
226
+ } ) ;
227
+
228
+ resolvmon . start ( ) ;
229
+
230
+ process . nextTick ( function ( ) {
231
+ fs . renameSync ( temporary_conf , temporary_conf + '.renamed' ) ;
232
+ } ) ;
210
233
211
- process . nextTick ( function ( ) {
212
- fs . renameSync ( temporary_conf , temporary_conf + '.renamed' ) ;
213
234
} ) ;
214
235
215
- after ( function ( ) {
236
+ after ( function ( done ) {
216
237
217
238
try {
218
- fs . unlinkSync ( temporary_conf + '.renamed' ) ;
239
+ fs . unlink ( temporary_conf + '.renamed' , function ( err ) {
240
+ done ( ) ;
241
+ } ) ;
219
242
} catch ( ex ) {
243
+ done ( ) ;
220
244
}
221
245
222
246
} ) ;
@@ -230,12 +254,13 @@ describe('resolvmon watch', function () {
230
254
fs . writeFileSync ( temporary_conf + '.renamed' , "nameserver 127.0.0.51\nnameserver 127.0.0.61\n" ) ;
231
255
232
256
resolvmon . on ( 'error' , function ( err ) {
257
+ resolvmon . removeAllListeners ( ) ;
233
258
expect ( err ) . not . to . be . defined ;
234
259
done ( err ) ;
235
260
} ) ;
236
261
237
262
resolvmon . on ( 'update' , function ( nameservers ) {
238
-
263
+ resolvmon . removeAllListeners ( ) ;
239
264
expect ( nameservers ) . to . be . defined ;
240
265
expect ( nameservers ) . to . be . instanceof ( Array ) ;
241
266
expect ( nameservers ) . to . eql ( [ '127.0.0.51' , '127.0.0.61' ] ) ;
@@ -248,11 +273,14 @@ describe('resolvmon watch', function () {
248
273
fs . renameSync ( temporary_conf + '.renamed' , temporary_conf ) ;
249
274
} ) ;
250
275
251
- after ( function ( ) {
276
+ after ( function ( done ) {
252
277
253
278
try {
254
- fs . unlinkSync ( temporary_conf + '.renamed' ) ;
279
+ fs . unlink ( temporary_conf + '.renamed' , function ( err ) {
280
+ done ( ) ;
281
+ } ) ;
255
282
} catch ( ex ) {
283
+ done ( ) ;
256
284
}
257
285
258
286
} ) ;
0 commit comments