feat(en): Make consistency checker work with pruned data

core/bin/external_node/src/main.rs

@@ -196,7 +196,7 @@ async fn init_tasks(
     .await;
     healthchecks.push(Box::new(metadata_calculator.tree_health_check()));
 
-    let consistency_checker = ConsistencyChecker::new(
+    let mut consistency_checker = ConsistencyChecker::new(
         &config
             .required
             .eth_client_url()
@@ -207,6 +207,7 @@ async fn init_tasks(
             .await
             .context("failed to build connection pool for ConsistencyChecker")?,
     );
+    consistency_checker.log_l1_data_mismatches();
 
     let batch_status_updater = BatchStatusUpdater::new(
         &main_node_url,

core/lib/zksync_core/src/api_server/web3/tests/mod.rs

@@ -8,13 +8,12 @@ use zksync_config::configs::{
     chain::{NetworkConfig, StateKeeperConfig},
     ContractsConfig,
 };
-use zksync_contracts::BaseSystemContractsHashes;
 use zksync_dal::{transactions_dal::L2TxSubmissionResult, ConnectionPool};
 use zksync_health_check::CheckHealth;
 use zksync_state::PostgresStorageCaches;
 use zksync_types::{
     block::MiniblockHeader, fee::TransactionExecutionMetrics, tx::IncludedTxLocation, Address,
-    L1BatchNumber, ProtocolVersionId, VmEvent, H256, U64,
+    L1BatchNumber, VmEvent, H256, U64,
 };
 use zksync_web3_decl::{
     jsonrpsee::{core::ClientError as RpcError, http_client::HttpClient, types::error::ErrorCode},
@@ -27,7 +26,7 @@ use crate::{
     api_server::tx_sender::TxSenderConfig,
     genesis::{ensure_genesis_state, GenesisParams},
     l1_gas_price::L1GasPriceProvider,
-    state_keeper::tests::create_l2_transaction,
+    utils::testonly::{create_l2_transaction, create_miniblock},
 };
 
 mod ws;
@@ -205,22 +204,6 @@ fn assert_logs_match(actual_logs: &[api::Log], expected_logs: &[&VmEvent]) {
     }
 }
 
-fn create_miniblock(number: u32) -> MiniblockHeader {
-    MiniblockHeader {
-        number: MiniblockNumber(number),
-        timestamp: number.into(),
-        hash: H256::from_low_u64_be(number.into()),
-        l1_tx_count: 0,
-        l2_tx_count: 0,
-        base_fee_per_gas: 100,
-        l1_gas_price: 100,
-        l2_fair_gas_price: 100,
-        base_system_contracts_hashes: BaseSystemContractsHashes::default(),
-        protocol_version: Some(ProtocolVersionId::latest()),
-        virtual_blocks: 1,
-    }
-}
-
 async fn store_block(pool: &ConnectionPool) -> anyhow::Result<(MiniblockHeader, H256)> {
     let mut storage = pool.access_storage().await?;
     let new_tx = create_l2_transaction(1, 2);

core/lib/zksync_core/src/consensus/testonly.rs

@@ -11,14 +11,12 @@ use zksync_types::{
 
 use crate::{
     genesis::{ensure_genesis_state, GenesisParams},
-    state_keeper::{
-        tests::{create_l1_batch_metadata, create_l2_transaction, MockBatchExecutorBuilder},
-        MiniblockSealer, ZkSyncStateKeeper,
-    },
+    state_keeper::{tests::MockBatchExecutorBuilder, MiniblockSealer, ZkSyncStateKeeper},
     sync_layer::{
         sync_action::{ActionQueue, ActionQueueSender, SyncAction},
         ExternalIO, MainNodeClient, SyncState,
     },
+    utils::testonly::{create_l1_batch_metadata, create_l2_transaction},
 };
 
 #[derive(Debug, Default)]