From e1abd5f684831f226493ab886c0d52f5b5de85f5 Mon Sep 17 00:00:00 2001
From: Nabarun <nabarun@deepstacksoft.com>
Date: Wed, 3 Jul 2024 11:23:47 +0530
Subject: [PATCH] Refactor blockProcessingOffset check to switch endpoint on
 max new block retries

---
 packages/util/src/events.ts | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/packages/util/src/events.ts b/packages/util/src/events.ts
index 564b9f47..c91ec9e9 100644
--- a/packages/util/src/events.ts
+++ b/packages/util/src/events.ts
@@ -158,6 +158,12 @@ export class EventWatcher {
       endBlockNumber = Math.floor(endBlockNumber / this._config.jobQueue.historicalLogsBlockRangeEndFactor) * this._config.jobQueue.historicalLogsBlockRangeEndFactor;
     }
 
+    if (endBlockNumber < startBlockNumber) {
+      await this.startRealtimeBlockProcessing(startBlockNumber);
+
+      return;
+    }
+
     this._historicalProcessingEndBlockNumber = endBlockNumber;
     log(`Starting historical block processing in batches from ${startBlockNumber} up to block ${this._historicalProcessingEndBlockNumber}`);