fix: revert "feat: update ioredis to 5x"

This reverts commit 3aa2b40.

Author: calebboyd

package-lock.json

@@ -37,7 +37,15 @@
   },
   "dependencies": {
     "debug": "^4.3.4",
-    "ioredis": "^5.2.3"
+    "ioredis": "^4.27.2"
+  },
+  "peerDependencies": {
+    "@types/ioredis": "^4"
+  },
+  "peerDependenciesMeta": {
+    "@types/ioredis": {
+      "optional": true
+    }
   },
   "devDependencies": {
     "@calebboyd/semantic-release-config": "^1.0.1",

package.json

@@ -1,4 +1,4 @@
-import { ChainableCommander } from 'ioredis'
+import { Pipeline } from 'ioredis'
 import { RedisStream } from './stream.js'
 import mkDebug from 'debug'
 import { XBatchResult, XStreamResult } from './types.js'
@@ -21,11 +21,6 @@ export async function readAckDelete(
   ack(pipeline, stream)
   read(pipeline, stream)
   const responses = await pipeline.exec()
-
-  if (!responses) {
-    return
-  }
-
   //TODO NOGROUP the consumer group this client was blocked on no longer exists
   for (const result of responses) {
     if (result[0] && !result[0]?.message.startsWith('BUSYGROUP')) {
@@ -47,10 +42,7 @@ export async function readAckDelete(
   }
 }
 
-function ack(
-  client: ChainableCommander,
-  { deleteOnAck, pendingAcks, group }: RedisStream<KindaAny>
-): void {
+function ack(client: Pipeline, { deleteOnAck, pendingAcks, group }: RedisStream<KindaAny>): void {
   if (!group || !pendingAcks.size) return
   for (const [stream, ids] of pendingAcks) {
     client.xack(stream, group, ...ids)
@@ -59,14 +51,11 @@ function ack(
   pendingAcks.clear()
 }
 
-function xgroup(
-  client: ChainableCommander,
-  { group, streams, first }: RedisStream<KindaAny>
-): void {
+function xgroup(client: Pipeline, { group, streams, first }: RedisStream<KindaAny>): void {
   if (!first || !group) return
   for (const [key, start] of streams) {
     debug(`xgroup create ${key} ${group} ${start} mkstream`)
-    client.xgroup('CREATE', key, group, start, 'MKSTREAM')
+    client.xgroup('create', key, group, start, 'mkstream')
   }
 }