bumped io-redis to 5.6.0

fcostaoliveira · fcostaoliveira · commit 8c1f1c4b6bae · 2025-12-01T10:30:23.000Z
diff --git a/js/ioredis/lib/subscriber.js b/js/ioredis/lib/subscriber.js
@@ -31,12 +31,14 @@ async function subscriberRoutine(
           }
           totalSubscribedRef.value -= channels.slice(1).length;
         }
-        // Duplicate connection afresh.
-        pubsub = client.duplicate();
-      } else {
-        pubsub = client.duplicate();
+        // Close existing connection before creating new one
+        await pubsub.quit();
       }
 
+      // Duplicate connection afresh.
+      // For cluster clients, duplicate() creates a new cluster-aware client
+      pubsub = client.duplicate();
+
       // Set up error logging.
       pubsub.on('error', (err) => {
         console.error(`[${clientName}] Redis error: ${err.message}`);
diff --git a/js/ioredis/package.json b/js/ioredis/package.json
@@ -6,7 +6,7 @@
     "dependencies": {
         "cluster-key-slot": "^1.1.0",
         "hdr-histogram-js": "^2.0.1",
-        "ioredis": "^4.30.0",
+        "ioredis": "^5.6.0",
         "seedrandom": "^3.0.5",
         "yargs": "^17.7.2"
     },

Original file line number	Diff line number	Diff line change
`@@ -31,12 +31,14 @@ async function subscriberRoutine(`
`31`	`31`	`}`
`32`	`32`	`totalSubscribedRef.value -= channels.slice(1).length;`
`33`	`33`	`}`
`34`		`- // Duplicate connection afresh.`
`35`		`- pubsub = client.duplicate();`
`36`		`- } else {`
`37`		`- pubsub = client.duplicate();`
	`34`	`+ // Close existing connection before creating new one`
	`35`	`+ await pubsub.quit();`
`38`	`36`	`}`
`39`	`37`
	`38`	`+ // Duplicate connection afresh.`
	`39`	`+ // For cluster clients, duplicate() creates a new cluster-aware client`
	`40`	`+ pubsub = client.duplicate();`
	`41`	`+`
`40`	`42`	`// Set up error logging.`
`41`	`43`	`pubsub.on('error', (err) => {`
`42`	`44`	console.error(`[${clientName}] Redis error: ${err.message}`);