cerc-io/watcher-ts
16
1
Fork 0
mirror of https://github.com/cerc-io/watcher-ts synced 2025-01-21 10:39:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Refactor blockProcessingOffset check to switch endpoint on max new block retries

Browse Source
This commit is contained in:
Nabarun 2024-07-03 11:23:47 +05:30
parent 3cd6491305
commit e1abd5f684
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
packages/util/src/events.ts
View File

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