@@ -24,25 +24,25 @@ test('creates Redis with logger', async (t) => {
24
24
logger . debug = ( message ) => {
25
25
switch ( message ) {
26
26
case 'redis connection established' :
27
- t . true ( true ) ;
27
+ t . pass ( ) ;
28
28
break ;
29
29
case 'redis connection ready' :
30
- t . true ( true ) ;
30
+ t . pass ( ) ;
31
31
break ;
32
32
case 'redis connection closed' :
33
- t . true ( true ) ;
33
+ t . pass ( ) ;
34
34
break ;
35
35
case 'redis reconnecting' :
36
- t . true ( true ) ;
36
+ t . pass ( ) ;
37
37
break ;
38
38
case 'redis connection ended' :
39
- t . true ( true ) ;
39
+ t . pass ( ) ;
40
40
break ;
41
41
case 'redis node connected' :
42
- t . true ( true ) ;
42
+ t . pass ( ) ;
43
43
break ;
44
44
case 'redis node disconnected' :
45
- t . true ( true ) ;
45
+ t . pass ( ) ;
46
46
break ;
47
47
default :
48
48
}
@@ -51,10 +51,10 @@ test('creates Redis with logger', async (t) => {
51
51
logger . error = ( message ) => {
52
52
switch ( message ) {
53
53
case 'node error' :
54
- t . true ( true ) ;
54
+ t . pass ( ) ;
55
55
break ;
56
56
case 'error' :
57
- t . true ( true ) ;
57
+ t . pass ( ) ;
58
58
break ;
59
59
default :
60
60
}
@@ -82,31 +82,31 @@ test('creates Redis with monitor', async (t) => {
82
82
// console.debug(message);
83
83
switch ( message ) {
84
84
case 'redis monitor instance created' :
85
- t . true ( true ) ;
85
+ t . pass ( ) ;
86
86
break ;
87
87
case 'redis monitor' :
88
- t . true ( true ) ;
88
+ t . pass ( ) ;
89
89
break ;
90
90
case 'redis connection established' :
91
- t . true ( true ) ;
91
+ t . pass ( ) ;
92
92
break ;
93
93
case 'redis connection ready' :
94
- t . true ( true ) ;
94
+ t . pass ( ) ;
95
95
break ;
96
96
case 'redis connection closed' :
97
- t . true ( true ) ;
97
+ t . pass ( ) ;
98
98
break ;
99
99
case 'redis reconnecting' :
100
- t . true ( true ) ;
100
+ t . pass ( ) ;
101
101
break ;
102
102
case 'redis connection ended' :
103
- t . true ( true ) ;
103
+ t . pass ( ) ;
104
104
break ;
105
105
case 'redis node connected' :
106
- t . true ( true ) ;
106
+ t . pass ( ) ;
107
107
break ;
108
108
case 'redis node disconnected' :
109
- t . true ( true ) ;
109
+ t . pass ( ) ;
110
110
break ;
111
111
default :
112
112
}
@@ -116,10 +116,10 @@ test('creates Redis with monitor', async (t) => {
116
116
// console.error(message);
117
117
switch ( message ) {
118
118
case 'node error' :
119
- t . true ( true ) ;
119
+ t . pass ( ) ;
120
120
break ;
121
121
case 'error' :
122
- t . true ( true ) ;
122
+ t . pass ( ) ;
123
123
break ;
124
124
default :
125
125
}
@@ -146,7 +146,7 @@ test('getMeta > empty status', (t) => {
146
146
const { logger } = t . context ;
147
147
logger . debug = ( ...args ) => {
148
148
// console.debug(args);
149
- if ( args [ 1 ] . status === '[empty]' ) t . true ( true ) ;
149
+ if ( args [ 1 ] . status === '[empty]' ) t . pass ( ) ;
150
150
} ;
151
151
152
152
const redis = new Redis ( { } , logger ) ;
@@ -159,7 +159,7 @@ test.serial('errors when creating monitor', (t) => {
159
159
160
160
const { logger } = t . context ;
161
161
logger . error = ( message ) => {
162
- if ( message === 'error' ) t . true ( true ) ;
162
+ if ( message === 'error' ) t . pass ( ) ;
163
163
} ;
164
164
165
165
const monitor = sinon . stub ( IORedis . prototype , 'monitor' ) . returns ( ( ) => { } ) ;
@@ -171,3 +171,48 @@ test.serial('errors when creating monitor', (t) => {
171
171
sinon . assert . called ( monitor ) ;
172
172
sinon . restore ( ) ;
173
173
} ) ;
174
+
175
+ test ( 'creates Redis with logger and does not bind events' , async ( t ) => {
176
+ const { logger } = t . context ;
177
+ logger . debug = ( message ) => {
178
+ switch ( message ) {
179
+ case 'redis connection established' :
180
+ t . fail ( ) ;
181
+ break ;
182
+ case 'redis connection ready' :
183
+ t . fail ( ) ;
184
+ break ;
185
+ case 'redis connection closed' :
186
+ t . fail ( ) ;
187
+ break ;
188
+ case 'redis reconnecting' :
189
+ t . fail ( ) ;
190
+ break ;
191
+ case 'redis connection ended' :
192
+ t . fail ( ) ;
193
+ break ;
194
+ case 'redis node connected' :
195
+ t . fail ( ) ;
196
+ break ;
197
+ case 'redis node disconnected' :
198
+ t . fail ( ) ;
199
+ break ;
200
+ default :
201
+ }
202
+ } ;
203
+
204
+ const redis = await new Redis ( { } , logger , undefined , undefined , false ) ;
205
+
206
+ t . is ( typeof redis , 'object' ) ;
207
+ redis . monitor ( ) ;
208
+ await delay ( 1000 ) ;
209
+ redis . emit ( 'reconnecting' ) ;
210
+ redis . emit ( '+node' ) ;
211
+ redis . emit ( '-node' ) ;
212
+ redis . emit ( 'node error' , 'node error' ) ;
213
+ t . throws ( ( ) => {
214
+ redis . emit ( 'error' , 'error' ) ;
215
+ } ) ;
216
+ redis . disconnect ( ) ;
217
+ await delay ( 1000 ) ;
218
+ } ) ;
0 commit comments