Skip to content

Commit 0c024d9

Browse files
committed
Fix indexing blocks range
1 parent a4f064a commit 0c024d9

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

src/app.service.ts

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -215,16 +215,15 @@ export class AppService {
215215
await this.processTradeEvents(sellEvents, TradeType.sell)
216216

217217
this.logger.log(`[${fromBlock}-${toBlock}] (${((toBlock - fromBlock + 1))} blocks), new tokens=${tokenCreatedEvents.length}, trade=${[...buyEvents, ...sellEvents].length} (buy=${buyEvents.length}, sell=${sellEvents.length})`)
218-
toBlock += 1
219218
} else {
220219
// Wait for blockchain
221-
toBlock = fromBlockParam
222-
await new Promise(resolve => setTimeout(resolve, 5 * 60 * 1000));
220+
toBlock = fromBlockParam - 1
221+
await new Promise(resolve => setTimeout(resolve, 5 * 1000));
223222
}
224223
} catch (e) {
225-
toBlock = fromBlockParam
224+
toBlock = fromBlockParam - 1
226225
this.logger.error(`[${fromBlock} - ${toBlock}] Failed to index blocks range:`, e)
227-
await new Promise(resolve => setTimeout(resolve, 5 * 60 * 1000));
226+
await new Promise(resolve => setTimeout(resolve, 30 * 1000));
228227
}
229228

230229
try {

0 commit comments

Comments
 (0)