@@ -31,30 +31,28 @@ const generateRequest = ({method, url, params}) => {
31
31
id : Math . random ( ) . toString ( 36 ) ,
32
32
queues,
33
33
method,
34
- url
34
+ url,
35
35
} ) ;
36
36
37
37
request . params = params ;
38
38
return request ;
39
39
} ;
40
40
41
- const generateResponse = requestId => {
42
- return new Response ( {
43
- requestId,
44
- ws : {
45
- send : ( ) => { }
46
- }
47
- } ) ;
48
- } ;
41
+ const generateResponse = requestId => new Response ( {
42
+ requestId,
43
+ ws : {
44
+ send ( ) { } ,
45
+ } ,
46
+ } ) ;
49
47
50
48
describe ( 'count all state jobs' , ( ) => {
51
49
test ( 'with failed queue name' , ( ) => {
52
50
const request = generateRequest ( {
53
51
method : 'POST' ,
54
52
url : '/queues/not-found/jobs/_count' ,
55
53
params : {
56
- queueName : 'not-found'
57
- }
54
+ queueName : 'not-found' ,
55
+ } ,
58
56
} ) ;
59
57
const response = generateResponse ( request . id ) ;
60
58
const fn = ( ) => jobHandler . countAllStateJobs ( request , response ) ;
@@ -67,8 +65,8 @@ describe('count all state jobs', () => {
67
65
method : 'POST' ,
68
66
url : '/queues/test/jobs/_count' ,
69
67
params : {
70
- queueName : 'test'
71
- }
68
+ queueName : 'test' ,
69
+ } ,
72
70
} ) ;
73
71
const response = generateResponse ( request . id ) ;
74
72
@@ -97,8 +95,8 @@ describe('get jobs', () => {
97
95
method : 'GET' ,
98
96
url : `/queues/test/jobs?${ queryString . stringify ( query ) } ` ,
99
97
params : {
100
- queueName : 'test'
101
- }
98
+ queueName : 'test' ,
99
+ } ,
102
100
} ) ;
103
101
const response = generateResponse ( request . id ) ;
104
102
const fn = ( ) => jobHandler . getJobs ( request , response ) ;
@@ -117,8 +115,8 @@ describe('get jobs', () => {
117
115
method : 'GET' ,
118
116
url : '/queues/not-found/jobs' ,
119
117
params : {
120
- queueName : 'not-found'
121
- }
118
+ queueName : 'not-found' ,
119
+ } ,
122
120
} ) ;
123
121
const response = generateResponse ( request . id ) ;
124
122
const fn = ( ) => jobHandler . getJobs ( request , response ) ;
@@ -131,8 +129,8 @@ describe('get jobs', () => {
131
129
method : 'GET' ,
132
130
url : '/queues/test/jobs' ,
133
131
params : {
134
- queueName : 'test'
135
- }
132
+ queueName : 'test' ,
133
+ } ,
136
134
} ) ;
137
135
const response = generateResponse ( request . id ) ;
138
136
@@ -143,11 +141,11 @@ describe('get jobs', () => {
143
141
items : [
144
142
{
145
143
opts : {
146
- timestamp : expect . any ( Number )
144
+ timestamp : expect . any ( Number ) ,
147
145
} ,
148
- timestamp : expect . any ( Number )
149
- }
150
- ]
146
+ timestamp : expect . any ( Number ) ,
147
+ } ,
148
+ ] ,
151
149
} ) ;
152
150
expect ( status ) . toBeUndefined ( ) ;
153
151
} ) ;
@@ -167,8 +165,8 @@ describe('get jobs', () => {
167
165
method : 'GET' ,
168
166
url : `/queues/test/jobs?${ queryString . stringify ( query ) } ` ,
169
167
params : {
170
- queueName : 'test'
171
- }
168
+ queueName : 'test' ,
169
+ } ,
172
170
} ) ;
173
171
const response = generateResponse ( request . id ) ;
174
172
@@ -179,11 +177,11 @@ describe('get jobs', () => {
179
177
items : [
180
178
{
181
179
opts : {
182
- timestamp : expect . any ( Number )
180
+ timestamp : expect . any ( Number ) ,
183
181
} ,
184
- timestamp : expect . any ( Number )
185
- }
186
- ]
182
+ timestamp : expect . any ( Number ) ,
183
+ } ,
184
+ ] ,
187
185
} ) ;
188
186
expect ( status ) . toBeUndefined ( ) ;
189
187
} ) ;
@@ -204,8 +202,8 @@ describe('clean jobs', () => {
204
202
method : 'POST' ,
205
203
url : `/queues/test/jobs/_clean?state=${ JobState . WAITING } ` ,
206
204
params : {
207
- queueName : 'test'
208
- }
205
+ queueName : 'test' ,
206
+ } ,
209
207
} ) ;
210
208
const response = generateResponse ( request . id ) ;
211
209
const fn = ( ) => jobHandler . cleanJobs ( request , response ) ;
@@ -218,8 +216,8 @@ describe('clean jobs', () => {
218
216
method : 'POST' ,
219
217
url : `/queues/test/jobs/_clean?state=${ JobState . ACTIVE } ` ,
220
218
params : {
221
- queueName : 'test'
222
- }
219
+ queueName : 'test' ,
220
+ } ,
223
221
} ) ;
224
222
const response = generateResponse ( request . id ) ;
225
223
const fn = ( ) => jobHandler . cleanJobs ( request , response ) ;
@@ -232,8 +230,8 @@ describe('clean jobs', () => {
232
230
method : 'POST' ,
233
231
url : `/queues/test/jobs/_clean?state=${ JobState . DELAYED } ` ,
234
232
params : {
235
- queueName : 'test'
236
- }
233
+ queueName : 'test' ,
234
+ } ,
237
235
} ) ;
238
236
const response = generateResponse ( request . id ) ;
239
237
const fn = ( ) => jobHandler . cleanJobs ( request , response ) ;
@@ -246,8 +244,8 @@ describe('clean jobs', () => {
246
244
method : 'POST' ,
247
245
url : `/queues/test/jobs/_clean?state=${ JobState . PAUSED } ` ,
248
246
params : {
249
- queueName : 'test'
250
- }
247
+ queueName : 'test' ,
248
+ } ,
251
249
} ) ;
252
250
const response = generateResponse ( request . id ) ;
253
251
const fn = ( ) => jobHandler . cleanJobs ( request , response ) ;
@@ -260,8 +258,8 @@ describe('clean jobs', () => {
260
258
method : 'POST' ,
261
259
url : `/queues/not-found/jobs/_clean?state=${ JobState . COMPLETED } ` ,
262
260
params : {
263
- queueName : 'not-found'
264
- }
261
+ queueName : 'not-found' ,
262
+ } ,
265
263
} ) ;
266
264
const response = generateResponse ( request . id ) ;
267
265
const fn = ( ) => jobHandler . cleanJobs ( request , response ) ;
@@ -274,8 +272,8 @@ describe('clean jobs', () => {
274
272
method : 'POST' ,
275
273
url : `/queues/test/jobs/_clean?state=${ JobState . COMPLETED } ` ,
276
274
params : {
277
- queueName : 'test'
278
- }
275
+ queueName : 'test' ,
276
+ } ,
279
277
} ) ;
280
278
const response = generateResponse ( request . id ) ;
281
279
@@ -294,8 +292,8 @@ describe('clean jobs', () => {
294
292
method : 'POST' ,
295
293
url : `/queues/test/jobs/_clean?state=${ JobState . FAILED } ` ,
296
294
params : {
297
- queueName : 'test'
298
- }
295
+ queueName : 'test' ,
296
+ } ,
299
297
} ) ;
300
298
const response = generateResponse ( request . id ) ;
301
299
@@ -317,8 +315,8 @@ describe('get job', () => {
317
315
url : '/queues/not-found/jobs/1' ,
318
316
params : {
319
317
queueName : 'not-found' ,
320
- jobId : '1'
321
- }
318
+ jobId : '1' ,
319
+ } ,
322
320
} ) ;
323
321
const response = generateResponse ( request . id ) ;
324
322
@@ -335,18 +333,18 @@ describe('get job', () => {
335
333
url : '/queues/test/jobs/1' ,
336
334
params : {
337
335
queueName : 'test' ,
338
- jobId : '1'
339
- }
336
+ jobId : '1' ,
337
+ } ,
340
338
} ) ;
341
339
const response = generateResponse ( request . id ) ;
342
340
343
341
jest . spyOn ( queues [ 0 ] , 'getJob' ) ;
344
342
jest . spyOn ( response , 'json' ) . mockImplementation ( ( data , status ) => {
345
343
expect ( data ) . toMatchSnapshot ( {
346
344
opts : {
347
- timestamp : expect . any ( Number )
345
+ timestamp : expect . any ( Number ) ,
348
346
} ,
349
- timestamp : expect . any ( Number )
347
+ timestamp : expect . any ( Number ) ,
350
348
} ) ;
351
349
expect ( status ) . toBeUndefined ( ) ;
352
350
} ) ;
@@ -365,8 +363,8 @@ describe('get job', () => {
365
363
url : '/queues/test/jobs/2' ,
366
364
params : {
367
365
queueName : 'test' ,
368
- jobId : '2'
369
- }
366
+ jobId : '2' ,
367
+ } ,
370
368
} ) ;
371
369
const response = generateResponse ( request . id ) ;
372
370
@@ -385,8 +383,8 @@ describe('retry job', () => {
385
383
url : '/queues/not-found/jobs/1/_retry' ,
386
384
params : {
387
385
queueName : 'not-found' ,
388
- jobId : '1'
389
- }
386
+ jobId : '1' ,
387
+ } ,
390
388
} ) ;
391
389
const response = generateResponse ( request . id ) ;
392
390
const fn = ( ) => jobHandler . retryJob ( request , response ) ;
@@ -400,8 +398,8 @@ describe('retry job', () => {
400
398
url : '/queues/test/jobs/2/_retry' ,
401
399
params : {
402
400
queueName : 'test' ,
403
- jobId : '2'
404
- }
401
+ jobId : '2' ,
402
+ } ,
405
403
} ) ;
406
404
const response = generateResponse ( request . id ) ;
407
405
@@ -421,8 +419,8 @@ describe('retry job', () => {
421
419
url : '/queues/test/jobs/1/_retry' ,
422
420
params : {
423
421
queueName : 'test' ,
424
- jobId : '1'
425
- }
422
+ jobId : '1' ,
423
+ } ,
426
424
} ) ;
427
425
const response = generateResponse ( request . id ) ;
428
426
@@ -444,8 +442,8 @@ describe('retry job', () => {
444
442
url : '/queues/test/jobs/1/_retry' ,
445
443
params : {
446
444
queueName : 'test' ,
447
- jobId : '1'
448
- }
445
+ jobId : '1' ,
446
+ } ,
449
447
} ) ;
450
448
const response = generateResponse ( request . id ) ;
451
449
@@ -476,8 +474,8 @@ describe('delete job', () => {
476
474
url : '/queues/not-found/jobs/1' ,
477
475
params : {
478
476
queueName : 'not-found' ,
479
- jobId : '1'
480
- }
477
+ jobId : '1' ,
478
+ } ,
481
479
} ) ;
482
480
const response = generateResponse ( request . id ) ;
483
481
const fn = ( ) => jobHandler . deleteJob ( request , response ) ;
@@ -491,8 +489,8 @@ describe('delete job', () => {
491
489
url : '/queues/test/jobs/2' ,
492
490
params : {
493
491
queueName : 'test' ,
494
- jobId : '2'
495
- }
492
+ jobId : '2' ,
493
+ } ,
496
494
} ) ;
497
495
const response = generateResponse ( request . id ) ;
498
496
@@ -512,8 +510,8 @@ describe('delete job', () => {
512
510
url : '/queues/test/jobs/1' ,
513
511
params : {
514
512
queueName : 'test' ,
515
- jobId : '1'
516
- }
513
+ jobId : '1' ,
514
+ } ,
517
515
} ) ;
518
516
const response = generateResponse ( request . id ) ;
519
517
0 commit comments