minor change

nischitpra · nischitpra · commit 1109c089074c · 2025-08-09T01:17:01.000+05:45
diff --git a/internal/storage/postgres.go b/internal/storage/postgres.go
@@ -388,7 +388,7 @@ func (p *PostgresConnector) GetLastStagedBlockNumber(chainId *big.Int, rangeStar
 }
 
 func (p *PostgresConnector) DeleteOlderThan(chainId *big.Int, blockNumber *big.Int) error {
-	query := `DELETE FROM block_data WHERE chain_id = $1 AND block_number < $2`
+	query := `DELETE FROM block_data WHERE chain_id = $1 AND block_number <= $2`
 	_, err := p.db.Exec(query, chainId.String(), blockNumber.String())
 	return err
 }

Original file line number	Diff line number	Diff line change
`@@ -388,7 +388,7 @@ func (p PostgresConnector) GetLastStagedBlockNumber(chainId big.Int, rangeStar`
`388`	`388`	`}`
`389`	`389`
`390`	`390`	`func (p PostgresConnector) DeleteOlderThan(chainId big.Int, blockNumber *big.Int) error {`
`391`		- query := `DELETE FROM block_data WHERE chain_id = $1 AND block_number < $2`
	`391`	+ query := `DELETE FROM block_data WHERE chain_id = $1 AND block_number <= $2`
`392`	`392`	`_, err := p.db.Exec(query, chainId.String(), blockNumber.String())`
`393`	`393`	`return err`
`394`	`394`	`}`