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}`);