Merge pull request #1 from nkaradzhov/cluster-client-events

add test template for the new cluster events

Author: NaughtySora

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

@@ -339,4 +339,30 @@ describe('Cluster', () => {
       minimumDockerVersion: [7]
     });
   });
+
+  describe('clusterEvents', () => {
+    testUtils.testWithCluster('should fire events', async (cluster) => {
+      const log: string[] = [];
+      cluster
+        .on('connect', () => log.push('connect'))
+        .on('disconnect', () => log.push('disconnect'))
+        .on('error', () => log.push('error'))
+        .on('node-error', () => log.push('node-error'))
+        .on('node-reconnecting', () => log.push('node-reconnecting'))
+        .on('node-ready', () => log.push('node-ready'))
+        .on('node-connect', () => log.push('node-connect'))
+        .on('node-disconnect', () => log.push('node-disconnect'))
+
+
+      await cluster.connect();
+      cluster.destroy();
+
+      /* assertions on the log */
+
+    }, {
+      ...GLOBAL.CLUSTERS.OPEN,
+      disableClusterSetup: true
+    })
+  });
+
 });

packages/test-utils/lib/index.ts

@@ -116,6 +116,7 @@ interface ClusterTestOptions<
   clusterConfiguration?: Partial<RedisClusterOptions<M, F, S, RESP, TYPE_MAPPING/*, POLICIES*/>>;
   numberOfMasters?: number;
   numberOfReplicas?: number;
+  disableClusterSetup?: boolean;
 }
 
 interface AllTestOptions<
@@ -558,6 +559,10 @@ export default class TestUtils {
           ...options.clusterConfiguration
         });
 
+      if(options.disableClusterSetup) {
+        return fn(cluster);
+      }
+
       await cluster.connect();
 
       try {