Upgrade ioredis to v.5

.gitignore

@@ -1,4 +1,5 @@
 node_modules
 .vscode
+.idea
 dist
 __pycache__

package.json

@@ -1,6 +1,6 @@
 {
   "name": "celery-node",
-  "version": "0.5.9",
+  "version": "0.5.10",
   "description": "celery written in nodejs",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
@@ -36,14 +36,13 @@
   "devDependencies": {
     "@types/amqplib": "^0.5.17",
     "@types/chai": "^4.2.9",
-    "@types/ioredis": "^4.28.5",
     "@types/mocha": "^7.0.1",
     "@types/sinon": "^9.0.9",
     "@types/uuid": "^3.4.7",
-    "@typescript-eslint/eslint-plugin": "^2.23.0",
-    "@typescript-eslint/parser": "^2.23.0",
+    "@typescript-eslint/eslint-plugin": "^5.54.1",
+    "@typescript-eslint/parser": "^5.54.1",
     "chai": "^4.2.0",
-    "eslint": "^7.16.0",
+    "eslint": "^7.32.0",
     "eslint-config-prettier": "^7.1.0",
     "eslint-plugin-import": "^2.22.1",
     "eslint-plugin-mocha": "^8.0.0",
@@ -52,11 +51,11 @@
     "prettier": "^1.19.1",
     "sinon": "^7.2.2",
     "ts-node": "^8.10.2",
-    "typescript": "^3.7.2"
+    "typescript": "^4.9.5"
   },
   "dependencies": {
     "amqplib": "^0.8.0",
-    "ioredis": "^4.28.5",
+    "ioredis": "^5.3.1",
     "uuid": "^3.3.2"
   }
 }

src/backends/redis.ts

@@ -1,4 +1,4 @@
-import * as Redis from "ioredis";
+import Redis from "ioredis";
 import { CeleryBackend } from ".";
 
 /**
@@ -14,7 +14,7 @@ const keyPrefix = "celery-task-meta-";
  * @exports
  */
 export default class RedisBackend implements CeleryBackend {
-  redis: Redis.Redis;
+  redis: Redis;
 
   /**
    * Redis backend class

src/kombu/brokers/amqp.ts

@@ -36,7 +36,7 @@ export default class AMQPBroker implements CeleryBroker {
    * @method AMQPBroker#isReady
    * @returns {Promise} promises that continues if amqp connected.
    */
-  public isReady(): Promise<amqplib.Channel> {
+  public isReady(): Promise<void> {
     return new Promise((resolve, reject) => {
       this.channel.then(ch => {
         Promise.all([

src/kombu/brokers/redis.ts

@@ -1,4 +1,4 @@
-import * as Redis from "ioredis";
+import Redis from "ioredis";
 import { v4 } from "uuid";
 import { CeleryBroker } from ".";
 import { Message } from "../message";
@@ -21,7 +21,7 @@ class RedisMessage extends Message {
 }
 
 export default class RedisBroker implements CeleryBroker {
-  redis: Redis.Redis;
+  redis: Redis;
   channels = [];
   closing = false;
 

test/app/test_client.ts

@@ -1,5 +1,5 @@
 import { assert } from "chai";
-import * as Redis from "ioredis";
+import { Redis } from "ioredis";
 import * as sinon from "sinon";
 import Client from "../../src/app/client";
 import Worker from "../../src/app/worker";
@@ -33,7 +33,7 @@ describe("celery functional tests", () => {
     return worker.whenCurrentJobsFinished();
   });
 
-  after(() => {
+  after(async () => {
     Promise.all([client.disconnect(), worker.disconnect()]);
 
     const redis = new Redis();

test/app/test_result.ts

@@ -2,7 +2,7 @@ import { assert } from "chai";
 import { AsyncResult } from "../../src/app/result";
 import RedisBackend from "../../src/backends/redis";
 import * as sinon from "sinon";
-import * as Redis from "ioredis";
+import Redis from "ioredis";
 
 describe("AsyncResult", () => {
   const redisBackend = new RedisBackend("redis://localhost:6379/0", {});

test/app/test_worker.ts

@@ -1,5 +1,5 @@
 import { assert } from "chai";
-import * as Redis from "ioredis";
+import Redis from "ioredis";
 import Client from "../../src/app/client";
 import Worker from "../../src/app/worker";
 import { CeleryConf } from "../../src/app/conf";

test/kombu/brokers/test_redis.ts

@@ -1,4 +1,4 @@
-// import * as Redis from "ioredis";
+// import Redis from "ioredis";
 // import { assert } from "chai";
 // import RedisBroker from "../../../src/kombu/brokers/redis";