fix: closed redis connection

powerhouse-inc · May 3, 2024 · 3679cda · 3679cda
1 parent ad539ed
commit 3679cda
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 3 deletions.
diff --git a/api/src/graphql/server/index.ts b/api/src/graphql/server/index.ts
@@ -50,15 +50,17 @@ export const startServer = async (
 ): Promise<Server> => {
   logger.debug('Starting server');
 
+  if (process.env.REDIS_TLS_URL) {
+    await initRedis();
+  }
+
   const apolloIndex = createApolloIndexServer();
   const apolloDrive = createApolloDriveServer();
 
   await apolloIndex.start();
   await apolloDrive.start();
 
-  if (process.env.REDIS_TLS_URL) {
-    await initRedis()
-  }
+
 
   router.use(
     '/drives',

diff --git a/api/src/index.ts b/api/src/index.ts
@@ -1,6 +1,7 @@
 import { createApp } from './app';
 import { startServer } from './graphql/server';
 import { getChildLogger } from './logger';
+import { closeRedis } from './redis';
 
 const logger = getChildLogger({ msgPrefix: 'SERVER' });
 
@@ -18,6 +19,7 @@ startServer(app, router)
   })
   .catch((err) => {
     logger.warn('Shutting down...');
+    closeRedis();
     if (err instanceof Error) {
       logger.error(err);
     } else {

diff --git a/api/src/redis.ts b/api/src/redis.ts
@@ -17,3 +17,18 @@ export const initRedis = async () => {
 
   return redisClient;
 }
+
+
+
+const timer = setInterval(async () => {
+  try {
+    redisClient && await redisClient.ping();
+  } catch (err) {
+    console.error('Ping Interval Error', err);
+  }
+}, 1000 * 60 * 4);
+
+export const closeRedis = () => {
+  clearInterval(timer);
+  redisClient && redisClient.disconnect();
+}