test: run tests against a Redis cluster

Author: darrachequesne

.github/workflows/ci.yml

@@ -30,6 +30,16 @@ jobs:
         ports:
           - 6379:6379
 
+      redis-cluster:
+        image: grokzen/redis-cluster:7.0.10
+        options: >-
+          --health-cmd "redis-cli -p 7005 ping"
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 5
+        ports:
+          - "7000-7005:7000-7005"
+
     steps:
       - name: Checkout repository
         uses: actions/checkout@v3

docker-compose.yml

@@ -3,3 +3,8 @@ services:
     image: redis:7
     ports:
       - "6379:6379"
+
+  redis-cluster:
+    image: grokzen/redis-cluster:7.0.10
+    ports:
+      - "7000-7005:7000-7005"

package.json

@@ -13,12 +13,7 @@
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "scripts": {
-    "test": "npm run format:check && tsc && npm run test:default && npm run test:redis-v4-specific-channel && npm run test:redis-v3 && npm run test:ioredis && npm run test:sharded",
-    "test:default": "nyc mocha --bail --require ts-node/register test/*.ts",
-    "test:redis-v4-specific-channel": "SPECIFIC_CHANNEL=1 npm run test:default",
-    "test:redis-v3": "REDIS_CLIENT=redis-v3 npm run test:default",
-    "test:ioredis": "REDIS_CLIENT=ioredis npm run test:default",
-    "test:sharded": "SHARDED=1 npm run test:default",
+    "test": "npm run format:check && tsc && nyc mocha --bail --require ts-node/register test/test-runner.ts",
     "format:check": "prettier --parser typescript --check 'lib/**/*.ts' 'test/**/*.ts'",
     "format:fix": "prettier --parser typescript --write 'lib/**/*.ts' 'test/**/*.ts'",
     "prepack": "tsc"

test/custom-parser.ts

@@ -2,22 +2,37 @@ import type { Server } from "socket.io";
 import type { Socket as ClientSocket } from "socket.io-client";
 import { setup, times } from "./util";
 import expect = require("expect.js");
+import { createClient } from "redis";
+import { createAdapter } from "../lib";
 
 describe("custom parser", () => {
   let servers: Server[];
   let clientSockets: ClientSocket[];
   let cleanup: () => void;
 
   beforeEach(async () => {
-    const testContext = await setup({
-      parser: {
-        decode(msg) {
-          return JSON.parse(msg);
-        },
-        encode(msg) {
-          return JSON.stringify(msg);
+    const testContext = await setup(async () => {
+      const pubClient = createClient();
+      const subClient = pubClient.duplicate();
+
+      await Promise.all([pubClient.connect(), subClient.connect()]);
+
+      return [
+        createAdapter(pubClient, subClient, {
+          parser: {
+            decode(msg) {
+              return JSON.parse(msg);
+            },
+            encode(msg) {
+              return JSON.stringify(msg);
+            },
+          },
+        }),
+        () => {
+          pubClient.disconnect();
+          subClient.disconnect();
         },
-      },
+      ];
     });
     servers = testContext.servers;
     clientSockets = testContext.clientSockets;