chore(retry): remove recurrsion

XP-NETWORK · Sep 12, 2024 · 54147cb · 54147cb
1 parent 3d7018e
commit 54147cb
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 16 deletions.
diff --git a/src/handler/index.ts b/src/handler/index.ts
@@ -57,11 +57,6 @@ export async function listenEvents(
   }
 
   async function processEvent(chain: THandler, ev: LockEvent) {
-    log.info(
-      "--------------------------------------",
-      ev.transactionHash,
-      "--------------------------------------",
-    );
     const sourceChain = map.get(ev.sourceChain as TSupportedChains);
     if (!sourceChain) {
       log.warn(
@@ -177,11 +172,6 @@ export async function listenEvents(
     log.info(
       `Approved and Signed Data for ${inft.transactionHash} on ${sourceChain.chainIdent} at TX: ${approved?.hash}`,
     );
-    log.info(
-      "--------------------------------------",
-      ev.transactionHash,
-      "--------------------------------------",
-    );
   }
 
   async function poolEvents(chain: THandler) {

diff --git a/src/handler/utils.ts b/src/handler/utils.ts
@@ -46,12 +46,15 @@ export async function retry<T>(
   ctx: string,
   log: LogInstance,
 ): Promise<T> {
-  try {
-    return await func();
-  } catch (err) {
-    log.info(`Context: ${ctx} - Retrying. Error:`, err);
-    await setTimeout(5000);
-    return retry(func, ctx, log);
+  while (true) {
+    try {
+      const res = await func();
+      return res; // Only returns once the function succeeds
+    } catch (err) {
+      log.info(`Context: ${ctx} - Retrying. Error:`, err);
+      // Use a Promise-based delay
+      await setTimeout(5000);
+    }
   }
 }