fix: redis graceful exit and job cleanup

Author: wei

scripts/full-sync.ts

@@ -8,10 +8,11 @@ import { appConfig } from "@/src/configs/app-config.ts";
 
 async function main() {
   let exitCode = 0;
+  let redisClient: ReturnType<typeof getRedisClient> | undefined;
 
   try {
     await connectMongoDB();
-    const redisClient = getRedisClient(`${appConfig.appSlug}-full-sync`);
+    redisClient = getRedisClient(`${appConfig.appSlug}-full-sync`);
 
     const probot = createProbot({ overrides: { log: logger } });
     await fullSync(probot, {
@@ -23,6 +24,13 @@ async function main() {
     exitCode = 1;
   } finally {
     await disconnectMongoDB();
+    if (redisClient) {
+      try {
+        await redisClient.quit();
+      } catch {
+        // ignore
+      }
+    }
     Deno.exit(exitCode);
   }
 }

src/index.ts

@@ -56,6 +56,12 @@ Deno.addSignalListener("SIGTERM", () => handleAppTermination("SIGTERM"));
 function handleAppTermination(signal: string) {
   log.info(`[${signal}] Signal received: closing MongoDB connection`);
   disconnectMongoDB();
+  try {
+    // Close Redis connection to avoid lingering connections
+    redisClient.quit();
+  } catch {
+    // ignore
+  }
   log.info("[MongoDB] Connection closed due to app termination");
   Deno.exit(0);
 }

src/worker.ts

@@ -17,6 +17,14 @@ const worker = createSchedulerWorker(
   {
     connection: redisClient,
     concurrency: 10,
+    removeOnComplete: {
+      count: 1000,
+      age: 3600,
+    },
+    removeOnFail: {
+      count: 1000,
+      age: 3600,
+    },
   },
 );
 
@@ -31,6 +39,11 @@ worker.on("failed", (job, err) => {
 const gracefulShutdown = async (signal: string) => {
   console.log(`Received ${signal}, closing worker...`);
   await worker.close();
+  try {
+    await redisClient.quit();
+  } catch {
+    // ignore
+  }
   Deno.exit(0);
 };