Merge pull request #238 from FalkorDB/quit_sentinel

Make sure sentinel is closed on quit()

package.json

@@ -1,6 +1,6 @@
 {
   "name": "falkordb",
-  "version": "6.2.3",
+  "version": "6.2.4",
   "description": "A FalkorDB javascript library",
   "license": "MIT",
   "main": "./dist/index.js",

src/clients/sentinel.ts

@@ -19,6 +19,8 @@ function extractDetails(masters: Array<Array<string>>) {
 
 export class Sentinel extends Single {
 
+    private sentinelClient!: SingleGraphConnection;
+
     init(falkordb: FalkorDB): Promise<void> {
         const redisOption = (this.client.options ?? {}) as TypedRedisClientOptions;
 		return this.tryConnectSentinelServer(this.client, redisOption, falkordb);
@@ -50,6 +52,9 @@ export class Sentinel extends Single {
         };
         const realClient = createClient<{ falkordb: typeof commands }, RedisFunctions, RedisScripts>(serverOptions)
 
+        // Save sentinel client to quit on quit()
+        this.sentinelClient = client;
+
         // Set original client as sentinel and server client as client
         this.client = realClient;
 
@@ -78,5 +83,16 @@ export class Sentinel extends Single {
             })
             .connect();
     }
+
+    async quit() {
+        const promises = [
+            super.quit()
+        ];
+        if (this.sentinelClient) {
+            const reply = this.sentinelClient.quit();
+            promises.push(reply.then(() => {}))
+        }
+        return Promise.all(promises).then(() => {});
+    }
 }