diff --git a/internal/committer/reorg.go b/internal/committer/reorg.go index c235544..9e4fc4b 100644 --- a/internal/committer/reorg.go +++ b/internal/committer/reorg.go @@ -33,8 +33,8 @@ func RunReorgValidator() { continue } - if endBlock == lastBlockCheck || endBlock-startBlock < 100 { - log.Debug().Msg("Not enough new blocks to check. Sleeping for 1 minute.") + if endBlock-startBlock < 100 { + log.Debug().Int64("last_block_check", lastBlockCheck).Int64("start_block", startBlock).Int64("end_block", endBlock).Msg("Not enough new blocks to check. Sleeping for 1 minute.") time.Sleep(1 * time.Minute) continue } diff --git a/internal/libs/clickhouse.go b/internal/libs/clickhouse.go index 3aa33ef..d5f1076 100644 --- a/internal/libs/clickhouse.go +++ b/internal/libs/clickhouse.go @@ -243,14 +243,12 @@ func GetBlockDataFromClickHouseV2(chainId uint64, startBlockNumber uint64, endBl if blocksRaw[i].TransactionCount != uint64(len(transactionsRaw[i])) { log.Info(). Any("transactionCount", blocksRaw[i].TransactionCount). - Any("transactionsRaw", transactionsRaw[i]). Msg("skipping block because transactionCount does not match") continue } if (blocksRaw[i].LogsBloom != "" && blocksRaw[i].LogsBloom != EMPTY_LOGS_BLOOM) && len(logsRaw[i]) == 0 { log.Info(). Any("logsBloom", blocksRaw[i].LogsBloom). - Any("logsRaw", logsRaw[i]). Msg("skipping block because logsBloom is not empty and logsRaw is empty") continue }