feat: EN commit, prove, execute batch transactions verification and finality status

core/bin/external_node/src/config/mod.rs

@@ -14,7 +14,8 @@ use zksync_config::{
         },
         networks::{NetworksConfig, SharedL1ContractsConfig},
         CommitmentGeneratorConfig, ConsistencyCheckerConfig, DataAvailabilitySecrets, L1Secrets,
-        ObservabilityConfig, PrometheusConfig, PruningConfig, Secrets, SnapshotRecoveryConfig,
+        NodeSyncConfig, ObservabilityConfig, PrometheusConfig, PruningConfig, Secrets,
+        SnapshotRecoveryConfig,
     },
     ApiConfig, CapturedParams, ConfigRepository, DAClientConfig, DBConfig, ObjectStoreConfig,
     PostgresConfig,
@@ -239,6 +240,8 @@ pub(crate) struct LocalConfig {
     pub consistency_checker: ConsistencyCheckerConfig,
     #[config(flatten)]
     pub secrets: Secrets,
+    #[config(nest)]
+    pub node_sync: NodeSyncConfig,
 }
 
 impl LocalConfig {
@@ -333,6 +336,7 @@ impl LocalConfig {
                 data_availability: None,
                 contract_verifier: ContractVerifierSecrets::default(),
             },
+            node_sync: NodeSyncConfig::default(),
         }
     }
 }

core/bin/external_node/src/node_builder.rs

@@ -46,8 +46,8 @@ use zksync_node_storage_init::{
     SnapshotRecoveryConfig,
 };
 use zksync_node_sync::node::{
-    BatchStatusUpdaterLayer, DataAvailabilityFetcherLayer, ExternalIOLayer, SyncStateUpdaterLayer,
-    TreeDataFetcherLayer, ValidateChainIdsLayer,
+    BatchStatusUpdaterLayer, BatchTransactionUpdaterLayer, DataAvailabilityFetcherLayer,
+    ExternalIOLayer, SyncStateUpdaterLayer, TreeDataFetcherLayer, ValidateChainIdsLayer,
 };
 use zksync_reorg_detector::node::ReorgDetectorLayer;
 use zksync_state::RocksdbStorageOptions;
@@ -282,6 +282,20 @@ impl<R> ExternalNodeBuilder<R> {
         Ok(self)
     }
 
+    fn add_batch_transaction_updater_layer(mut self) -> anyhow::Result<Self> {
+        self.node.add_layer(BatchTransactionUpdaterLayer::new(
+            self.config
+                .local
+                .node_sync
+                .batch_transaction_updater_interval,
+            self.config
+                .local
+                .node_sync
+                .batch_transaction_updater_batch_size,
+        ));
+        Ok(self)
+    }
+
     fn add_tree_data_fetcher_layer(mut self) -> anyhow::Result<Self> {
         self.node.add_layer(TreeDataFetcherLayer);
         Ok(self)
@@ -681,6 +695,7 @@ impl ExternalNodeBuilder {
                         .add_consistency_checker_layer()?
                         .add_commitment_generator_layer()?
                         .add_batch_status_updater_layer()?
+                        .add_batch_transaction_updater_layer()?
                         .add_logs_bloom_backfill_layer()?;
                 }
             }

core/lib/basic_types/src/web3/mod.rs

@@ -391,6 +391,15 @@ impl Log {
     }
 }
 
+impl From<Log> for ethabi::RawLog {
+    fn from(log: Log) -> Self {
+        ethabi::RawLog {
+            topics: log.topics,
+            data: log.data.0,
+        }
+    }
+}
+
 // `BlockHeader`, `BlockId`, `BlockNumber`: from `web3::types::block`
 
 /// The block header type returned from RPC calls.

core/lib/config/src/configs/mod.rs

@@ -21,6 +21,7 @@ pub use self::{
     gateway_migrator::GatewayMigratorConfig,
     general::{full_config_schema, GeneralConfig},
     genesis::{GenesisConfig, GenesisConfigWrapper},
+    node_sync::NodeSyncConfig,
     object_store::ObjectStoreConfig,
     observability::{ObservabilityConfig, OpentelemetryConfig},
     proof_data_handler::ProofDataHandlerConfig,
@@ -61,6 +62,7 @@ mod general;
 pub mod genesis;
 pub mod house_keeper;
 pub mod networks;
+pub mod node_sync;
 pub mod object_store;
 pub mod observability;
 pub mod proof_data_handler;

core/lib/config/src/configs/node_sync.rs

@@ -0,0 +1,54 @@
+use std::{num::NonZeroU64, time::Duration};
+
+use smart_config::{DescribeConfig, DeserializeConfig};
+
+/// Configuration for node synchronization
+#[derive(Debug, Clone, PartialEq, DescribeConfig, DeserializeConfig)]
+#[config(derive(Default))]
+pub struct NodeSyncConfig {
+    /// Interval between batch transaction updates
+    #[config(default_t = Duration::from_millis(5000))]
+    pub batch_transaction_updater_interval: Duration,
+    /// Maximum number of transactions to process in a single batch
+    #[config(default_t = NonZeroU64::new(10_000).unwrap())]
+    pub batch_transaction_updater_batch_size: NonZeroU64,
+}
+
+#[cfg(test)]
+mod tests {
+    use smart_config::{testing::test_complete, Environment, Yaml};
+
+    use super::*;
+
+    fn expected_config() -> NodeSyncConfig {
+        NodeSyncConfig {
+            batch_transaction_updater_interval: Duration::from_secs(2),
+            batch_transaction_updater_batch_size: NonZeroU64::new(100).unwrap(),
+        }
+    }
+
+    #[test]
+    fn parsing_from_env() {
+        let env = r#"
+            NODE_SYNC_BATCH_TRANSACTION_UPDATER_INTERVAL=2sec
+            NODE_SYNC_BATCH_TRANSACTION_UPDATER_BATCH_SIZE=100
+        "#;
+        let env = Environment::from_dotenv("test.env", env)
+            .unwrap()
+            .strip_prefix("NODE_SYNC_");
+
+        let config: NodeSyncConfig = test_complete(env).unwrap();
+        assert_eq!(config, expected_config());
+    }
+
+    #[test]
+    fn parsing_from_yaml() {
+        let yaml = r#"
+          batch_transaction_updater_interval: 2sec
+          batch_transaction_updater_batch_size: 100
+        "#;
+        let yaml = Yaml::new("test.yml", serde_yaml::from_str(yaml).unwrap()).unwrap();
+        let config: NodeSyncConfig = test_complete(yaml).unwrap();
+        assert_eq!(config, expected_config());
+    }
+}