feat: 🎸 stop all clients on cluster stop

src/__tests__/commands/string/SET.spec.ts

@@ -0,0 +1,30 @@
+import {RedisCluster} from '../../../cluster/RedisCluster';
+import {ClusterTestSetup} from '../../types';
+import {run} from './SET';
+
+const host = 'redis-15083.c28691.us-east-1-4.ec2.cloud.rlrcp.com';
+const port = 15083;
+const user = 'default';
+const pwd = '7UAmqOMRcZ0KFZUfzze2KaWW8w0Fe8pP';
+const client = new RedisCluster({
+  seeds: [{host, port}],
+  connectionConfig: {
+    user,
+    pwd,
+  },
+});
+client.onError.listen((err) => {
+  console.error('onError', err);
+});
+client.start();
+
+const setupCluster: ClusterTestSetup = async () => {
+  await client.whenRouterReady();
+  return {client};
+};
+
+run(setupCluster);
+
+afterAll(() => {
+  client.stop();
+});

src/__tests__/commands/string/SET.ts

@@ -0,0 +1,17 @@
+import {ClusterTestSetup} from '../../types';
+
+export const run = (setup: ClusterTestSetup) => {
+  describe('SET', () => {
+    test('can set a key', async () => {
+      const {client} = await setup();
+      const res = await client.cmd(['SET', 'foo', 'bar']);
+      expect(res).toBe('OK');
+    });
+
+    test('can set a key with partition brackets', async () => {
+      const {client} = await setup();
+      const res = await client.cmd(['SET', '{foo}', 'bar']);
+      expect(res).toBe('OK');
+    });
+  });
+};

src/__tests__/types.ts

@@ -0,0 +1,9 @@
+import {RedisCluster} from '../cluster/RedisCluster';
+
+export type TestSetup = ClusterTestSetup;
+export type ClusterTestSetup = () => Promise<{
+  client: ClusterTestClient;
+}>;
+
+export type TextClient = ClusterTestClient;
+export type ClusterTestClient = Pick<RedisCluster, 'cmd'>;

src/cluster/RedisCluster.ts

@@ -78,6 +78,7 @@ export class RedisCluster implements Printable {
     this.isRebuildingRouteTable = false;
     this.routeTableRebuildRetry = 0;
     this.stopped = true;
+    this.clients.forEach((client) => client.stop());
   }
 
   // ---------------------------------------------- Build initial routing table