@@ -355,17 +355,20 @@ proc runBackfillLoop(
355355 continue
356356
357357proc runBackfillLoopAuditMode (
358- bridge: PortalHistoryBridge , era1Dir: string
358+ bridge: PortalHistoryBridge , era1Dir: string , startEra: uint64 , endEra: uint64
359359) {.async : (raises: [CancelledError ]).} =
360360 let
361361 rng = newRng ()
362362 db = Era1DB .new (era1Dir, " mainnet" , loadAccumulator ())
363+ blockLowerBound = startEra * EPOCH_SIZE # inclusive
364+ blockUpperBound = ((endEra + 1 ) * EPOCH_SIZE ) - 1 # inclusive
365+ blockRange = blockUpperBound - blockLowerBound
363366
364367 var blockTuple: BlockTuple
365368 while true :
366369 let
367370 # Grab a random blockNumber to audit and potentially gossip
368- blockNumber = rng[].rand (network_metadata.mergeBlockNumber - 1 ).uint64
371+ blockNumber = blockLowerBound + rng[].rand (blockRange ).uint64
369372 db.getBlockTuple (blockNumber, blockTuple).isOkOr:
370373 error " Failed to get block tuple" , error, blockNumber
371374 continue
@@ -525,7 +528,9 @@ proc runHistory*(config: PortalBridgeConf) =
525528
526529 if config.backfill:
527530 if config.audit:
528- asyncSpawn bridge.runBackfillLoopAuditMode (config.era1Dir.string )
531+ asyncSpawn bridge.runBackfillLoopAuditMode (
532+ config.era1Dir.string , config.startEra, config.endEra
533+ )
529534 else :
530535 asyncSpawn bridge.runBackfillLoop (
531536 config.era1Dir.string , config.startEra, config.endEra
0 commit comments