Merge pull request #2900 from KukretiShubham/redis-cli

fix: redis client max reach bug on passport page
dev-protocol · Nov 14, 2024 · 116f6ee · 116f6ee
2 parents b9f625c + 0f210ca
commit 116f6ee
Show file tree

Hide file tree

Showing 7 changed files with 8 additions and 5 deletions.
diff --git a/src/pages/api/authenticate.ts b/src/pages/api/authenticate.ts
@@ -28,7 +28,7 @@ export const POST = async ({ request }: { request: Request }) => {
   const res = whenNotError(authenticated, (_auth) =>
     _auth ? _auth : new Error('Unauthorized'),
   )
-
+  await client.quit()
   return isNotError(res)
     ? new Response(
         json({

diff --git a/src/pages/api/clubs.ts b/src/pages/api/clubs.ts
@@ -71,7 +71,7 @@ export const GET: APIRoute = async ({ url }): Promise<Response> => {
         ),
       ),
     )) ?? []
-
+  await client.quit()
   return new Response(JSON.stringify(res), {
     status: 200,
     headers: { ...headers, ...cache({ maxAge: 604800 }) },

diff --git a/src/pages/api/decrypt.ts b/src/pages/api/decrypt.ts
@@ -53,7 +53,7 @@ export const POST = async ({ request }: { request: Request }) => {
   }
 
   let decoded = jsonwebtoken.verify(encryptedText, process.env.SALT ?? '')
-
+  await client.quit()
   return new Response(
     JSON.stringify({
       decoded,

diff --git a/src/pages/api/fetchClubs.ts b/src/pages/api/fetchClubs.ts
@@ -59,7 +59,7 @@ export const POST = async ({ request }: { request: Request }) => {
     configs.push(decode(config))
   }
 
-  await client.disconnect()
+  await client.quit()
 
   return new Response(JSON.stringify(configs), { status: 200 })
 }
diff --git a/src/pages/api/plugins/addPluginToClub.ts b/src/pages/api/plugins/addPluginToClub.ts
@@ -130,6 +130,7 @@ export const POST = async ({ request }: { request: Request }) => {
     await client.quit()
     return new Response(JSON.stringify({}), { status: 200 })
   } catch (error) {
+    await client.quit()
     return new Response(JSON.stringify({ error }), { status: 500 })
   }
 }
diff --git a/src/pages/api/profile/index.ts b/src/pages/api/profile/index.ts
@@ -74,6 +74,7 @@ export const POST = async ({ request }: { request: Request }) => {
     await client.quit()
     return new Response(JSON.stringify({}), { status: 200 })
   } catch (error) {
+    await client.quit()
     return new Response(JSON.stringify({ error }), { status: 500 })
   }
 }
diff --git a/src/pages/api/profile/updateLike.ts b/src/pages/api/profile/updateLike.ts
@@ -82,10 +82,11 @@ export const POST = async ({ request }: { request: Request }) => {
 
   try {
     await client.set(profileIdForDB, JSON.stringify(newProfile))
+    await client.quit()
   } catch (error) {
+    await client.quit()
     return new Response(JSON.stringify({ error }), { status: 500 })
   }
 
-  await client.quit()
   return new Response(JSON.stringify({}), { status: 200 })
 }