Added checks to make sure RPC is good

Author: farhanW3

src/worker/queues/processEventLogsQueue.ts

@@ -37,9 +37,14 @@ export const enqueueProcessEventLogs = async (
 
   // Enqueue one job immediately and any delayed jobs.
   await _queue.add(jobName, serialized);
-  for (const retryDelay of retryDelays) {
+  for (let i = 0; i < retryDelays.length; i++) {
+    const delay = parseInt(retryDelays[i]) * 1000;
+    const attempts = i === retryDelays.length - 1 ? 10 : 0;
+
     await _queue.add(jobName, serialized, {
-      delay: parseInt(retryDelay) * 1000,
+      delay,
+      attempts,
+      backoff: { type: "exponential", delay: 30_000 },
     });
   }
 };

src/worker/queues/processTransactionReceiptsQueue.ts

@@ -38,9 +38,14 @@ export const enqueueProcessTransactionReceipts = async (
 
   // Enqueue one job immediately and any delayed jobs.
   await _queue.add(jobName, serialized);
-  for (const retryDelay of retryDelays) {
+  for (let i = 0; i < retryDelays.length; i++) {
+    const delay = parseInt(retryDelays[i]) * 1000;
+    const attempts = i === retryDelays.length - 1 ? 10 : 0;
+
     await _queue.add(jobName, serialized, {
-      delay: parseInt(retryDelay) * 1000,
+      delay,
+      attempts,
+      backoff: { type: "exponential", delay: 30_000 },
     });
   }
 };

src/worker/tasks/chainIndexer.ts

@@ -42,6 +42,15 @@ export const createChainIndexerTask = async (args: {
             return;
           }
 
+          // Ensuring that the block data exists.
+          // Sometimes the RPC providers nodes are aware of the latest block
+          // but the block data is not available yet.
+          const block = await provider.getBlockWithTransactions(toBlock);
+
+          if (!block) {
+            throw new Error(`Failed to get block: ${toBlock}`);
+          }
+
           // Get contract addresses to filter event logs and transaction receipts by.
           const contractSubscriptions = await getContractSubscriptionsByChainId(
             chainId,