refactor: improve Redis connection handling and add process exit handler

#10
kuoruan · Jan 10, 2025 · 4937548 · 4937548
1 parent 08aca7e
commit 4937548
Showing 1 changed file with 5 additions and 8 deletions.
diff --git a/src/server/store/Redis.ts b/src/server/store/Redis.ts
@@ -1,9 +1,5 @@
-import process from "node:process";
-
 import { Cluster, Redis } from "ioredis";
 
-import logger from "@/server/logger";
-
 import {
   BaseStore,
   type RedisClusterConfig,
@@ -16,7 +12,6 @@ import {
 
 const defaultOptions = {
   ttl: STATE_TTL,
-  lazyConnect: true,
 } satisfies RedisConfig;
 
 export default class RedisStore extends BaseStore implements Store {
@@ -66,10 +61,12 @@ export default class RedisStore extends BaseStore implements Store {
       }
     }
 
-    this.redis.connect().catch((e) => {
-      logger.error({ message: e.message }, "Failed to connect to redis: @{message}");
+    this.addProcessExitHandler();
+  }
 
-      process.exit(1);
+  private addProcessExitHandler(): void {
+    process.once("exit", async () => {
+      await this.redis.quit();
     });
   }