@@ -355,17 +355,20 @@ proc runBackfillLoop(
355
355
continue
356
356
357
357
proc runBackfillLoopAuditMode(
358
- bridge: PortalHistoryBridge, era1Dir: string
358
+ bridge: PortalHistoryBridge, era1Dir: string , startEra: uint64 , endEra: uint64
359
359
) {.async: (raises: [CancelledError]) .} =
360
360
let
361
361
rng = newRng()
362
362
db = Era1DB.new(era1Dir, " mainnet" , loadAccumulator())
363
+ blockLowerBound = startEra * EPOCH_SIZE # inclusive
364
+ blockUpperBound = ((endEra + 1 ) * EPOCH_SIZE) - 1 # inclusive
365
+ blockRange = blockUpperBound - blockLowerBound
363
366
364
367
var blockTuple: BlockTuple
365
368
while true :
366
369
let
367
370
# 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
369
372
db.getBlockTuple(blockNumber, blockTuple).isOkOr:
370
373
error " Failed to get block tuple" , error, blockNumber
371
374
continue
@@ -525,7 +528,9 @@ proc runHistory*(config: PortalBridgeConf) =
525
528
526
529
if config.backfill:
527
530
if config.audit:
528
- asyncSpawn bridge.runBackfillLoopAuditMode(config.era1Dir.string )
531
+ asyncSpawn bridge.runBackfillLoopAuditMode(
532
+ config.era1Dir.string , config.startEra, config.endEra
533
+ )
529
534
else :
530
535
asyncSpawn bridge.runBackfillLoop(
531
536
config.era1Dir.string , config.startEra, config.endEra
0 commit comments