fix: unlimited retries with double time

seb-oss · Sep 25, 2024 · f145e39 · f145e39
1 parent 3fb8b8d
commit f145e39
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 9 deletions.
diff --git a/.changeset/dull-lions-bathe.md b/.changeset/dull-lions-bathe.md
@@ -0,0 +1,5 @@
+---
+"@sebspark/promise-cache": patch
+---
+
+Remove max 5 tries
diff --git a/packages/promise-cache/src/persistor.ts b/packages/promise-cache/src/persistor.ts
@@ -63,11 +63,8 @@ export class Persistor {
         ...this.redis,
         socket: {
           reconnectStrategy: (retries, cause) => {
-            if (retries === 5) {
-              console.error('Error reconnecting... ', cause)
-              return false
-            }
-            return retries * 1000
+            console.error(cause)
+            return 1000 * 2 ** retries
           },
         },
       })
@@ -131,8 +128,9 @@ export class Persistor {
     key: string,
     { value, timestamp, ttl }: SetParams<T>
   ): Promise<void> {
-    if (!this.client) {
-      throw new Error('Client not connected')
+    if (!this.client || !this.client.isReady) {
+      console.error('Client not ready')
+      return
     }
     try {
       const serializedData = JSON.stringify({ value, ttl, timestamp })
@@ -144,8 +142,9 @@ export class Persistor {
   }
 
   public async delete(key: string): Promise<void> {
-    if (!this.client) {
-      throw new Error('Client not connected')
+    if (!this.client || !this.client.isReady) {
+      console.error('Client not ready')
+      return
     }
     try {
       await this.client.del(key)