1
1
import test from 'ava' ;
2
2
3
3
import cluster from 'cluster' ;
4
+ import { default as strip } from 'strip-ansi' ;
4
5
5
6
import Cluster from '../../lib/Cluster.js' ;
6
7
@@ -13,7 +14,7 @@ test.beforeEach(t => {
13
14
test ( 'prints console log' , t => {
14
15
console . log = ( ...args ) => {
15
16
const msg = Array . from ( args ) . join ( ' ' ) ;
16
- t . is ( msg , `${ Cluster . workerID ( ) } log item` ) ;
17
+ t . is ( strip ( msg ) , strip ( `${ Cluster . workerID ( ) } log item` ) ) ;
17
18
} ;
18
19
19
20
Cluster . console . log ( 'log item' ) ;
@@ -22,7 +23,7 @@ test('prints console log', t => {
22
23
test ( 'prints console warning' , t => {
23
24
console . warn = ( ...args ) => {
24
25
const msg = Array . from ( args ) . join ( ' ' ) ;
25
- t . is ( msg , `${ Cluster . workerID ( ) } warning item` ) ;
26
+ t . is ( strip ( msg ) , strip ( `${ Cluster . workerID ( ) } warning item` ) ) ;
26
27
} ;
27
28
28
29
Cluster . console . warn ( 'warning item' ) ;
@@ -31,30 +32,30 @@ test('prints console warning', t => {
31
32
test ( 'prints console error' , t => {
32
33
console . error = ( ...args ) => {
33
34
const msg = Array . from ( args ) . join ( ' ' ) ;
34
- t . is ( msg , `${ Cluster . workerID ( ) } error item` ) ;
35
+ t . is ( strip ( msg ) , strip ( `${ Cluster . workerID ( ) } error item` ) ) ;
35
36
} ;
36
37
37
38
Cluster . console . error ( 'error item' ) ;
38
39
} ) ;
39
40
40
41
test ( 'prints access log' , t => {
41
42
const date = new Date ( ) . toISOString ( ) ;
42
- t . is ( Cluster . logger ( {
43
+ t . is ( strip ( Cluster . logger ( {
43
44
date : ( ) => date ,
44
45
method : ( ) => 'GET' ,
45
46
url : ( ) => '/' ,
46
47
status : ( ) => 304 ,
47
48
'response-time' : ( ) => 5.767
48
- } , { } , { } ) , `${ Cluster . workerID ( ) } [${ date } ] GET / 304 5.767 ms` ) ;
49
+ } , { } , { } ) ) , strip ( `${ Cluster . workerID ( ) } [${ date } ] GET / 304 5.767 ms` ) ) ;
49
50
} ) ;
50
51
51
52
test ( 'prints correct worker ID' , t => {
52
- t . is ( Cluster . workerID ( ) , `[W${ cluster . worker ? cluster . worker . id : 0 } /${ process . pid } ]` ) ;
53
+ t . is ( strip ( Cluster . workerID ( ) ) , strip ( `[W${ cluster . worker ? cluster . worker . id : 0 } /${ process . pid } ]` ) ) ;
53
54
} ) ;
54
55
55
56
test ( 'prints wakeup message' , t => {
56
57
console . log = msg => {
57
- t . is ( msg , `Worker ${ cluster . worker ? cluster . worker . id : 0 } (${ process . pid } ) now listening on port 4000` ) ;
58
+ t . is ( strip ( msg ) , strip ( `Worker ${ cluster . worker ? cluster . worker . id : 0 } (${ process . pid } ) now listening on port 4000` ) ) ;
58
59
} ;
59
60
60
61
Cluster . listening ( 4000 ) ;
@@ -63,7 +64,7 @@ test('prints wakeup message', t => {
63
64
test . serial ( 'prints group header' , t => {
64
65
console . log = ( ...args ) => {
65
66
const msg = Array . from ( args ) . join ( ' ' ) ;
66
- t . is ( msg , `${ Cluster . workerID ( ) } Group` ) ;
67
+ t . is ( strip ( msg ) , strip ( `${ Cluster . workerID ( ) } Group` ) ) ;
67
68
} ;
68
69
69
70
Cluster . console . group ( 'Group' ) ;
@@ -72,7 +73,7 @@ test.serial('prints group header', t => {
72
73
test . serial ( 'prints indented log item in group' , t => {
73
74
console . log = ( ...args ) => {
74
75
const msg = Array . from ( args ) . join ( ' ' ) ;
75
- t . is ( msg , `${ Cluster . workerID ( ) } Grouped item` ) ;
76
+ t . is ( strip ( msg ) , strip ( `${ Cluster . workerID ( ) } Grouped item` ) ) ;
76
77
} ;
77
78
78
79
Cluster . console . log ( 'Grouped item' ) ;
@@ -81,7 +82,7 @@ test.serial('prints indented log item in group', t => {
81
82
test . serial ( 'prints non-indented group item after group' , t => {
82
83
console . log = ( ...args ) => {
83
84
const msg = Array . from ( args ) . join ( ' ' ) ;
84
- t . is ( msg , `${ Cluster . workerID ( ) } Ungrouped item` ) ;
85
+ t . is ( strip ( msg ) , strip ( `${ Cluster . workerID ( ) } Ungrouped item` ) ) ;
85
86
} ;
86
87
87
88
Cluster . console . groupEnd ( ) ;
0 commit comments