feat(auth, networks): add minimum 2 retries on fetchBlockchainData method

Author: Ansonhkg

packages/auth/src/lib/authenticators/helper/fetchBlockchainData.ts

@@ -1,26 +1,39 @@
 import { EthBlockhashInfo } from '@lit-protocol/types';
 
+const RETRY_ATTEMPTS = 2; // total attempts = RETRY_ATTEMPTS + 1
+const RETRY_DELAY_MS = 250;
+
+const delay = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));
+
 export const fetchBlockchainData = async () => {
-  try {
-    const resp = await fetch(
-      'https://block-indexer.litgateway.com/get_most_recent_valid_block'
-    );
-    if (!resp.ok) {
-      throw new Error(`Primary fetch failed with status: ${resp.status}`); // Or a custom error
-    }
+  let lastError: Error | undefined;
 
-    const blockHashBody: EthBlockhashInfo = await resp.json();
-    const { blockhash, timestamp } = blockHashBody;
+  for (let attempt = 0; attempt <= RETRY_ATTEMPTS; attempt++) {
+    try {
+      const resp = await fetch(
+        'https://block-indexer.litgateway.com/get_most_recent_valid_block'
+      );
+      if (!resp.ok) {
+        throw new Error(`Primary fetch failed with status: ${resp.status}`);
+      }
 
-    if (!blockhash || !timestamp) {
-      throw new Error('Invalid data from primary blockhash source');
-    }
+      const blockHashBody: EthBlockhashInfo = await resp.json();
+      const { blockhash, timestamp } = blockHashBody;
 
-    return blockhash;
-  } catch (error) {
-    if (error instanceof Error) {
-      throw new Error(error.message);
+      if (!blockhash || !timestamp) {
+        throw new Error('Invalid data from primary blockhash source');
+      }
+
+      return blockhash;
+    } catch (error) {
+      lastError = error instanceof Error ? error : new Error(String(error));
+      if (attempt === RETRY_ATTEMPTS) {
+        throw new Error(lastError.message);
+      }
+
+      await delay(RETRY_DELAY_MS * (attempt + 1));
     }
-    throw new Error(String(error));
   }
+
+  throw new Error(lastError?.message ?? 'Unknown fetchBlockchainData error');
 };

packages/networks/src/networks/vNaga/shared/managers/state-manager/helpers/fetchBlockchainData.ts

@@ -1,26 +1,39 @@
 import { EthBlockhashInfo } from '@lit-protocol/types';
 
+const RETRY_ATTEMPTS = 2; // total attempts = RETRY_ATTEMPTS + 1
+const RETRY_DELAY_MS = 250;
+
+const delay = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));
+
 export const fetchBlockchainData = async () => {
-  try {
-    const resp = await fetch(
-      'https://block-indexer.litgateway.com/get_most_recent_valid_block'
-    );
-    if (!resp.ok) {
-      throw new Error(`Primary fetch failed with status: ${resp.status}`); // Or a custom error
-    }
+  let lastError: Error | undefined;
 
-    const blockHashBody: EthBlockhashInfo = await resp.json();
-    const { blockhash, timestamp } = blockHashBody;
+  for (let attempt = 0; attempt <= RETRY_ATTEMPTS; attempt++) {
+    try {
+      const resp = await fetch(
+        'https://block-indexer.litgateway.com/get_most_recent_valid_block'
+      );
+      if (!resp.ok) {
+        throw new Error(`Primary fetch failed with status: ${resp.status}`);
+      }
 
-    if (!blockhash || !timestamp) {
-      throw new Error('Invalid data from primary blockhash source');
-    }
+      const blockHashBody: EthBlockhashInfo = await resp.json();
+      const { blockhash, timestamp } = blockHashBody;
 
-    return blockhash;
-  } catch (error) {
-    if (error instanceof Error) {
-      throw new Error(error.message);
+      if (!blockhash || !timestamp) {
+        throw new Error('Invalid data from primary blockhash source');
+      }
+
+      return blockhash;
+    } catch (error) {
+      lastError = error instanceof Error ? error : new Error(String(error));
+      if (attempt === RETRY_ATTEMPTS) {
+        throw new Error(lastError.message);
+      }
+
+      await delay(RETRY_DELAY_MS * (attempt + 1));
     }
-    throw new Error(String(error));
   }
+
+  throw new Error(lastError?.message ?? 'Unknown fetchBlockchainData error');
 };