Skip to content

Commit 5a73358

Browse files
committed
making cluster test simplier, adjusting according to new cluster setup
1 parent 5978461 commit 5a73358

File tree

1 file changed

+10
-33
lines changed

1 file changed

+10
-33
lines changed

packages/client/lib/cluster/index.spec.ts

Lines changed: 10 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -343,12 +343,6 @@ describe('Cluster', () => {
343343
describe('clusterEvents', () => {
344344
testUtils.testWithCluster('should fire events', async (cluster) => {
345345
const log: string[] = [];
346-
const numberOfMasters = 2;
347-
const nodeConnect = numberOfMasters;
348-
const nodeReady = nodeConnect + numberOfMasters;
349-
const connect = nodeReady + 1;
350-
const nodeDisconnect = connect + numberOfMasters;
351-
const disconnect = nodeDisconnect + 1;
352346

353347
cluster
354348
.on('connect', () => log.push('connect'))
@@ -363,33 +357,16 @@ describe('Cluster', () => {
363357
await cluster.connect();
364358
cluster.destroy();
365359

366-
assert.equal(log.length, disconnect);
367-
368-
assert.deepEqual(
369-
log.slice(0, nodeConnect),
370-
new Array(numberOfMasters).fill('node-connect'),
371-
);
372-
assert.deepEqual(
373-
log.slice(nodeConnect, nodeReady),
374-
new Array(numberOfMasters).fill('node-ready'),
375-
);
376-
assert.deepEqual(
377-
log.slice(nodeReady, connect),
378-
new Array(1).fill('connect'),
379-
);
380-
assert.deepEqual(
381-
log.slice(connect, nodeDisconnect),
382-
new Array(numberOfMasters).fill('node-disconnect'),
383-
);
384-
assert.deepEqual(
385-
log.slice(nodeDisconnect, disconnect),
386-
new Array(1).fill('disconnect'),
387-
);
388-
389-
assert.equal(log.includes('error'), false);
390-
assert.equal(log.includes('node-error'), false);
391-
assert.equal(log.includes('node-reconnecting'), false);
392-
360+
assert.deepEqual(log, [
361+
'node-connect',
362+
'node-connect',
363+
'node-ready',
364+
'node-ready',
365+
'connect',
366+
'node-disconnect',
367+
'node-disconnect',
368+
'disconnect',
369+
]);
393370
}, {
394371
...GLOBAL.CLUSTERS.OPEN,
395372
disableClusterSetup: true,

0 commit comments

Comments
 (0)