cerc-io/watcher-ts
10
1
Fork 0
mirror of https://github.com/cerc-io/watcher-ts synced 2025-11-25 15:04:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle network error when fetching latest block

Browse Source
This commit is contained in:
Nabarun 2025-11-13 13:35:53 +05:30
parent 86609631c9
commit 2126c17f0d
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -191,16 +191,23 @@ export class EventWatcher {
if (isComplete) {
while (true) {
const { block: latestBlock } = await this._ethClient.getBlockByHash();
try {
const { block: latestBlock } = await this._ethClient.getBlockByHash();
// Process block if it is blockProcessingOffset blocks behind latest block
if (latestBlock.number >= blockNumber + (this._config.jobQueue.blockProcessingOffset ?? 0)) {
await processBlockByNumber(this._jobQueue, blockNumber + 1);
break;
// Process block if it is blockProcessingOffset blocks behind latest block
if (latestBlock.number >= blockNumber + (this._config.jobQueue.blockProcessingOffset ?? 0)) {
await processBlockByNumber(this._jobQueue, blockNumber + 1);
break;
}
log(`Latest block number fetched: ${latestBlock.number}`);
} catch (err: unknown) {
log(`Error while triggering processing for next block: ${blockNumber + 1}`);
log(err);
} finally {
log(`Retry next block to process: ${blockNumber + 1} after ${this._config.jobQueue.blockDelayInMilliSecs}ms`);
await wait(this._config.jobQueue.blockDelayInMilliSecs);
}
log(`Latest block: ${latestBlock.number}; retry next block to process: ${blockNumber + 1} after ${this._config.jobQueue.blockDelayInMilliSecs}ms`);
await wait(this._config.jobQueue.blockDelayInMilliSecs);
}
}
}