Refactor blockProcessingOffset check to switch endpoint on max new bl…

…ock retries
cerc-io · Aug 5, 2024 · 7397ea4 · 7397ea4
1 parent a2ff511
commit 7397ea4
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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}`);