reorg lag by 100 blocks

nischitpra · nischitpra · commit f968988e0581 · 2025-10-31T11:42:33.000+05:45
diff --git a/internal/committer/reorg.go b/internal/committer/reorg.go
@@ -30,7 +30,7 @@ func RunReorgValidator() {
 			continue
 		}
 
-		if endBlock == lastBlockCheck || endBlock-startBlock < 5 {
+		if endBlock == lastBlockCheck || endBlock-startBlock < 100 {
 			log.Debug().Msg("Not enough new blocks to check. Sleeping for 1 minute.")
 			time.Sleep(1 * time.Minute)
 			continue
@@ -59,7 +59,7 @@ func getReorgRange() (int64, int64, error) {
 		return 0, 0, fmt.Errorf("failed to get max block number: %w", err)
 	}
 
-	endBlock = min(endBlock-5, startBlock+100) // lag by some blocks for safety
+	endBlock = min(endBlock-100, startBlock+100) // lag by some blocks for safety
 
 	if startBlock >= endBlock {
 		return 0, 0, fmt.Errorf("start block is greater than end block (%d >= %d)", startBlock, endBlock)

Original file line number	Diff line number	Diff line change
`@@ -30,7 +30,7 @@ func RunReorgValidator() {`
`30`	`30`	`continue`
`31`	`31`	`}`
`32`	`32`
`33`		`- if endBlock == lastBlockCheck \|\| endBlock-startBlock < 5 {`
	`33`	`+ if endBlock == lastBlockCheck \|\| endBlock-startBlock < 100 {`
`34`	`34`	`log.Debug().Msg("Not enough new blocks to check. Sleeping for 1 minute.")`
`35`	`35`	`time.Sleep(1 * time.Minute)`
`36`	`36`	`continue`
`@@ -59,7 +59,7 @@ func getReorgRange() (int64, int64, error) {`
`59`	`59`	`return 0, 0, fmt.Errorf("failed to get max block number: %w", err)`
`60`	`60`	`}`
`61`	`61`
`62`		`- endBlock = min(endBlock-5, startBlock+100) // lag by some blocks for safety`
	`62`	`+ endBlock = min(endBlock-100, startBlock+100) // lag by some blocks for safety`
`63`	`63`
`64`	`64`	`if startBlock >= endBlock {`
`65`	`65`	`return 0, 0, fmt.Errorf("start block is greater than end block (%d >= %d)", startBlock, endBlock)`