feat: update bullmq to 1.91.1 & fix typing for indirectly updated ioredis

relates: #72

Author: Boris Dorofeev

package.json

@@ -25,7 +25,7 @@
   },
   "homepage": "https://github.com/graphql-compose/graphql-compose-bullmq",
   "peerDependencies": {
-    "bullmq": "^1.14.4",
+    "bullmq": "^1.91.1",
     "graphql-compose": "^7.15.0 || ^8.0.0 || ^9.0.0"
   },
   "devDependencies": {
@@ -37,7 +37,7 @@
     "@types/node-fetch": "2.5.10",
     "@typescript-eslint/eslint-plugin": "4.25.0",
     "@typescript-eslint/parser": "4.25.0",
-    "bullmq": "1.28.0",
+    "bullmq": "1.91.1",
     "cpx": "^1.5.0",
     "cross-env": "7.0.3",
     "eslint": "7.27.0",

src/definitions.ts

@@ -1,5 +1,5 @@
 import { ObjectTypeComposer } from 'graphql-compose';
-import IORedis, { RedisOptions } from 'ioredis';
+import Redis, { RedisOptions } from 'ioredis';
 
 export type Options = {
   typePrefix: string;
@@ -8,5 +8,5 @@ export type Options = {
     name?: string;
     prefix?: string;
   };
-  redis?: RedisOptions | IORedis.Redis;
+  redis?: RedisOptions | Redis;
 };

src/helpers/fixDelayStream.ts

@@ -33,8 +33,8 @@ export async function addFixRecordToDelayStream(
 
   const streamName = fullQueueName + ':delay';
 
-  const first = await redis.xrange(streamName, '-', '+', 'count', 1);
-  const last = await redis.xrevrange(streamName, '+', '-', 'count', 1);
+  const first = await redis.xrange(streamName, '-', '+', 'COUNT', 1);
+  const last = await redis.xrevrange(streamName, '+', '-', 'COUNT', 1);
   const defaultRec = {
     id: '0-0',
     nextTimestamp: '',
@@ -53,6 +53,10 @@ export async function addFixRecordToDelayStream(
     }
   }
 
+  if (!fixLastId) {
+    throw new Error(`The command <xadd ${streamName}> returns a Null reply.`);
+  }
+
   return {
     first: readRecords(first),
     last: readRecords(last),

src/helpers/getBullConnection.ts

@@ -1,17 +1,17 @@
 import { Options } from './../definitions';
 import Redis from 'ioredis';
 
-const connectionMap = new Map<Options['redis'], Redis.Redis>();
+const connectionMap = new Map<Options['redis'], Redis>();
 
-export function getBullConnection(opts?: Options): Redis.Redis {
+export function getBullConnection(opts?: Options): Redis {
   const optsRedis = opts?.redis;
   let connection = connectionMap.get(optsRedis);
   if (connection) {
     return connection;
   }
 
   if (optsRedis instanceof Redis || optsRedis?.constructor?.name === 'Redis') {
-    connection = optsRedis as Redis.Redis;
+    connection = optsRedis as Redis;
   } else if (optsRedis) {
     connection = new Redis(optsRedis);
   } else {

src/helpers/memoryUsage.ts

@@ -7,7 +7,7 @@ import fs from 'fs';
 
 let commandDefined = false;
 
-async function defineCommand(redis: Redis.Redis) {
+async function defineCommand(redis: Redis) {
   const readFile = util.promisify(fs.readFile);
   const lua = await readFile(path.join(__dirname, 'zsetKeysMemoryUsage.lua'));
 

src/helpers/queueEventsListen.ts

@@ -63,7 +63,7 @@ function createAsyncIterator<T = any>(
     pushValue(event);
   };
 
-  queueEvents.on(eventName, handler);
+  queueEvents.on(eventName as any, handler);
 
   function release() {
     if (listening) {