fix: Make sure script caches interval is cleared. [#1215]

Author: ShogunPanda

lib/cluster/index.ts

@@ -331,6 +331,7 @@ class Cluster extends EventEmitter {
     this.setStatus("disconnecting");
 
     clearInterval(this._addedScriptHashesCleanInterval);
+    this._addedScriptHashesCleanInterval = null;
 
     if (!reconnect) {
       this.manuallyClosing = true;
@@ -362,6 +363,9 @@ class Cluster extends EventEmitter {
     const status = this.status;
     this.setStatus("disconnecting");
 
+    clearInterval(this._addedScriptHashesCleanInterval);
+    this._addedScriptHashesCleanInterval = null;
+
     this.manuallyClosing = true;
 
     if (this.reconnectTimeout) {

lib/redis/index.ts

@@ -406,6 +406,7 @@ Redis.prototype.connect = function (callback) {
  */
 Redis.prototype.disconnect = function (reconnect) {
   clearInterval(this._addedScriptHashesCleanInterval);
+  this._addedScriptHashesCleanInterval = null;
 
   if (!reconnect) {
     this.manuallyClosing = true;
@@ -698,6 +699,11 @@ Redis.prototype.sendCommand = function (command, stream) {
     return command.promise;
   }
 
+  if (command.name === "quit") {
+    clearInterval(this._addedScriptHashesCleanInterval);
+    this._addedScriptHashesCleanInterval = null;
+  }
+
   let writable =
     this.status === "ready" ||
     (!stream &&

test/functional/cluster/connect.ts

@@ -411,3 +411,31 @@ describe("cluster:connect", function () {
     });
   });
 });
+
+describe("cluster:disconnect", function () {
+  it("should clear the added script hashes interval when disconnecting", function (done) {
+    new MockServer(30001);
+    const cluster = new Cluster([{ host: "127.0.0.1", port: "30001" }], {
+      enableReadyCheck: false,
+    });
+    cluster.once("ready", function () {
+      cluster.disconnect();
+
+      expect(cluster._addedScriptHashesCleanInterval).to.be.null;
+      done();
+    });
+  });
+
+  it("should clear the added script hashes interval when quitting", function (done) {
+    new MockServer(30001);
+    const cluster = new Cluster([{ host: "127.0.0.1", port: "30001" }], {
+      enableReadyCheck: false,
+    });
+    cluster.once("ready", function () {
+      cluster.quit();
+
+      expect(cluster._addedScriptHashesCleanInterval).to.be.null;
+      done();
+    });
+  });
+});

test/functional/connection.ts

@@ -475,3 +475,25 @@ describe("connection", function () {
     });
   });
 });
+
+describe("disconnection", function () {
+  it("should clear the added script hashes interval when disconnecting", function (done) {
+    const redis = new Redis();
+    redis.once("ready", function () {
+      redis.disconnect();
+
+      expect(redis._addedScriptHashesCleanInterval).to.be.null;
+      done();
+    });
+  });
+
+  it("should clear the added script hashes interval when quitting", function (done) {
+    const redis = new Redis();
+    redis.once("ready", function () {
+      redis.quit();
+
+      expect(redis._addedScriptHashesCleanInterval).to.be.null;
+      done();
+    });
+  });
+});