remove get block from clickhouse verificatino

Author: nischitpra

internal/committer/reorg.go

@@ -225,6 +225,19 @@ func handleReorgForRange(startBlock uint64, endBlock uint64) error {
 		return fmt.Errorf("handleReorgForRange: failed to get old block data: %w", err)
 	}
 
+	nonNilOldBlocks := 0
+	for _, bd := range oldblockDataArray {
+		if bd != nil {
+			nonNilOldBlocks++
+		}
+	}
+	log.Debug().
+		Uint64("start_block", startBlock).
+		Uint64("end_block", endBlock).
+		Int("requested_old_blocks", len(oldblockDataArray)).
+		Int("non_nil_old_blocks", nonNilOldBlocks).
+		Msg("handleReorgForRange: loaded old block data from ClickHouse")
+
 	if err := libs.KafkaPublisherV2.PublishBlockDataReorg(newblockDataArray, oldblockDataArray); err != nil {
 		log.Error().
 			Err(err).

internal/libs/clickhouse.go

@@ -240,18 +240,6 @@ func GetBlockDataFromClickHouseV2(chainId uint64, startBlockNumber uint64, endBl
 				Msg("skipping block because chainId is nil")
 			continue
 		}
-		if blocksRaw[i].TransactionCount != uint64(len(transactionsRaw[i])) {
-			log.Info().
-				Any("transactionCount", blocksRaw[i].TransactionCount).
-				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).
-				Msg("skipping block because logsBloom is not empty and logsRaw is empty")
-			continue
-		}
 		blockData[i] = &common.BlockData{
 			Block:        blocksRaw[i],
 			Transactions: transactionsRaw[i],

internal/storage/kafka_publisher.go

@@ -116,6 +116,7 @@ func (p *KafkaPublisher) PublishBlockData(blockData []*common.BlockData) error {
 }
 
 func (p *KafkaPublisher) PublishBlockDataReorg(newBlockData []*common.BlockData, oldBlockData []*common.BlockData) error {
+	log.Debug().Int("new_block_data_count", len(newBlockData)).Int("old_block_data_count", len(oldBlockData)).Msg("PublishBlockDataReorg: Publishing block data reorg")
 	if err := p.publishBlockData(oldBlockData, true, true); err != nil {
 		return fmt.Errorf("failed to publish old block data: %v", err)
 	}