fix: add reorg count (#166)

sprintertech · Feb 8, 2024 · f9dd12d · f9dd12d
1 parent e87e607
commit f9dd12d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/src/indexer/services/evmIndexer/evmIndexer.ts b/src/indexer/services/evmIndexer/evmIndexer.ts
@@ -20,8 +20,8 @@ import { OfacComplianceService } from "../ofac"
 import { getLogs } from "./evmfilter"
 import { decodeLogs } from "./evmEventParser"
 
-const BLOCK_TIME = 15000
-
+const BLOCK_TIME = Number(process.env.BLOCK_TIME) || 15000
+const BLOCK_DELAY = Number(process.env.BLOCK_DELAY) || 10
 export class EvmIndexer {
   private pastEventsQueryInterval = 1000
   private eventsQueryInterval = 1
@@ -92,7 +92,7 @@ export class EvmIndexer {
     while (!this.stopped) {
       try {
         const latestBlock = await this.provider.getBlockNumber()
-        if (currentBlock >= latestBlock) {
+        if (currentBlock + BLOCK_DELAY >= latestBlock) {
           await sleep(BLOCK_TIME)
           continue
         }

diff --git a/src/indexer/services/substrateIndexer/substrateIndexer.ts b/src/indexer/services/substrateIndexer/substrateIndexer.ts
@@ -15,8 +15,8 @@ import { saveEvents, sleep } from "../../../indexer/utils/substrate"
 import AccountRepository from "../../../indexer/repository/account"
 import CoinMarketCapService from "../coinmarketcap/coinmarketcap.service"
 
-const BLOCK_TIME = 12000
-
+const BLOCK_TIME = Number(process.env.BLOCK_TIME) || 12000
+const BLOCK_DELAY = Number(process.env.BLOCK_DELAY) || 10
 export class SubstrateIndexer {
   private domainRepository: DomainRepository
   private executionRepository: ExecutionRepository
@@ -85,7 +85,7 @@ export class SubstrateIndexer {
       try {
         const latestBlock = await this.provider.rpc.chain.getBlock()
         const currentBlockHash = await this.provider.rpc.chain.getBlockHash(currentBlock)
-        if (currentBlock >= Number(latestBlock.block.header.number)) {
+        if (currentBlock + BLOCK_DELAY >= Number(latestBlock.block.header.number)) {
           await sleep(BLOCK_TIME)
           continue
         }