feat: Proof manager watcher (#4241)

## What ❔

Basic implementation of ETH proof manager watcher part.
This PR implements basic listening(with just logging received events)
for event from proof manager contracts
Parts of this PR are stubs, which should be filled in in coming changes.

## Why ❔

This is the part of proving networks integration

## Is this a breaking change?
- [ ] Yes
- [x] No

## Operational changes
<!-- Any config changes? Any new flags? Any changes to any scripts? -->
<!-- Please add anything that non-Matter Labs entities running their own
ZK Chain may need to know -->

## Checklist

<!-- Check your PR fulfills the following items. -->
<!-- For draft PRs check the boxes as you complete them. -->

- [ ] PR title corresponds to the body of PR (we generate changelog
entries from PRs).
- [ ] Tests for the changes have been added / updated.
- [ ] Documentation comments have been added / updated.
- [ ] Code has been formatted via `zkstack dev fmt` and `zkstack dev
lint`.

Author: Artemka374

core/Cargo.lock

@@ -42,6 +42,7 @@ members = [
   "node/da_clients",
   "node/gateway_migrator",
   "node/zk_os_tree_manager",
+  "node/eth_proof_manager",
   # Libraries
   "lib/db_connection",
   "lib/basic_types",
@@ -325,6 +326,7 @@ zksync_node_framework = { version = "28.9.0-non-semver-compat", path = "lib/node
 zksync_node_framework_derive = { version = "28.9.0-non-semver-compat", path = "lib/node_framework_derive" }
 zksync_shared_resources = { version = "28.9.0-non-semver-compat", path = "lib/shared_resources" }
 zksync_node_jemalloc = { version = "28.9.0-non-semver-compat", path = "node/jemalloc" }
+zksync_eth_proof_manager = { version = "28.9.0-non-semver-compat", path = "node/eth_proof_manager" }
 zksync_eth_watch = { version = "28.9.0-non-semver-compat", path = "node/eth_watch" }
 zksync_shared_metrics = { version = "28.9.0-non-semver-compat", path = "node/shared_metrics" }
 zksync_proof_data_handler = { version = "28.9.0-non-semver-compat", path = "node/proof_data_handler" }

core/Cargo.toml

@@ -47,6 +47,7 @@ zksync_state_keeper.workspace = true
 zksync_shared_resources.workspace = true
 zksync_tee_proof_data_handler.workspace = true
 zksync_vm_runner.workspace = true
+zksync_eth_proof_manager.workspace = true
 
 # Consensus dependenices
 zksync_consensus_crypto.workspace = true

core/bin/zksync_server/Cargo.toml

@@ -12,6 +12,8 @@ pub(crate) enum Component {
     Tree,
     /// Merkle tree API.
     TreeApi,
+    /// Eth proof manager. Component for interacting with proof manager (proof distribution contracts)
+    EthProofManager,
     EthWatcher,
     /// Eth tx generator.
     EthTxAggregator,
@@ -63,6 +65,7 @@ impl FromStr for Components {
             "tree_api" => Ok(Components(vec![Component::TreeApi])),
             "state_keeper" => Ok(Components(vec![Component::StateKeeper])),
             "housekeeper" => Ok(Components(vec![Component::Housekeeper])),
+            "eth_proof_manager" => Ok(Components(vec![Component::EthProofManager])),
             "eth" => Ok(Components(vec![
                 Component::EthWatcher,
                 Component::EthTxAggregator,

core/bin/zksync_server/src/components.rs

@@ -138,6 +138,7 @@ fn main() -> anyhow::Result<()> {
         // it'd be possible to get rid of settlement_layer_specific_contracts in our configs.
         // For easier refactoring in the future. We can mark it as Optional
         l1_sl_contracts: Some(contracts_config.settlement_layer_specific_contracts()),
+        eth_proof_manager_contracts: Some(contracts_config.eth_proof_manager_contracts()),
         multicall3: Some(contracts_config.l1.multicall3_addr),
     };
 

core/bin/zksync_server/src/main.rs

@@ -16,7 +16,9 @@ use zksync_config::{
         api::Namespace,
         consensus::ConsensusConfig,
         contracts::{
-            chain::L2Contracts, ecosystem::L1SpecificContracts, SettlementLayerSpecificContracts,
+            chain::{L2Contracts, ProofManagerContracts},
+            ecosystem::L1SpecificContracts,
+            SettlementLayerSpecificContracts,
         },
         da_client::DAClientConfig,
         secrets::DataAvailabilitySecrets,
@@ -37,6 +39,7 @@ use zksync_eth_client::{
     node::{BridgeAddressesUpdaterLayer, PKSigningEthClientLayer},
     web3_decl::node::QueryEthClientLayer,
 };
+use zksync_eth_proof_manager::node::EthProofManagerLayer;
 use zksync_eth_sender::node::{EthTxAggregatorLayer, EthTxManagerLayer};
 use zksync_eth_watch::node::EthWatchLayer;
 use zksync_external_proof_integration_api::node::ExternalProofIntegrationApiLayer;
@@ -102,6 +105,7 @@ pub(crate) struct MainNodeBuilder {
     // if use pre v26 contracts and not all functions are available for loading contracts
     pub l1_sl_contracts: Option<SettlementLayerSpecificContracts>,
     pub l2_contracts: L2Contracts,
+    pub eth_proof_manager_contracts: Option<ProofManagerContracts>,
     pub multicall3: Option<Address>,
 }
 
@@ -283,6 +287,16 @@ impl MainNodeBuilder {
         Ok(self)
     }
 
+    fn add_eth_proof_manager_layer(mut self) -> anyhow::Result<Self> {
+        self.node.add_layer(EthProofManagerLayer::new(
+            self.configs.eth_proof_manager.clone(),
+            self.eth_proof_manager_contracts
+                .clone()
+                .expect("Eth proof manager contracts are required to run eth proof manager"),
+        ));
+        Ok(self)
+    }
+
     fn add_eth_watch_layer(mut self) -> anyhow::Result<Self> {
         let eth_config = try_load_config!(self.configs.eth);
         self.node.add_layer(EthWatchLayer::new(
@@ -806,6 +820,9 @@ impl MainNodeBuilder {
                     );
                     // Do nothing, will be handled by the `Tree` component.
                 }
+                Component::EthProofManager => {
+                    self = self.add_eth_proof_manager_layer()?;
+                }
                 Component::EthWatcher => {
                     self = self.add_eth_watch_layer()?;
                 }

core/bin/zksync_server/src/node_builder.rs

@@ -241,6 +241,10 @@ impl ContractsConfig {
         }
     }
 
+    pub fn eth_proof_manager_contracts(&self) -> ProofManagerContracts {
+        self.proof_manager_contracts.clone()
+    }
+
     pub(crate) fn insert_into_schema(schema: &mut ConfigSchema) {
         schema.insert(&Self::DESCRIPTION, "contracts").unwrap();
         schema

core/lib/config/src/configs/contracts/chain.rs

@@ -0,0 +1,20 @@
+use std::time::Duration;
+
+use smart_config::{DescribeConfig, DeserializeConfig};
+
+#[derive(Debug, Clone, PartialEq, DescribeConfig, DeserializeConfig)]
+pub struct EthProofManagerConfig {
+    #[config(default_t = Duration::from_secs(10))]
+    pub event_poll_interval: Duration,
+    #[config(default_t = 1000)]
+    pub event_expiration_blocks: u64,
+}
+
+impl Default for EthProofManagerConfig {
+    fn default() -> Self {
+        Self {
+            event_poll_interval: Duration::from_secs(10),
+            event_expiration_blocks: 1000,
+        }
+    }
+}

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

@@ -6,6 +6,7 @@ use crate::{
         chain::{CircuitBreakerConfig, MempoolConfig, StateKeeperConfig, TimestampAsserterConfig},
         consensus::ConsensusConfig,
         da_dispatcher::DADispatcherConfig,
+        eth_proof_manager::EthProofManagerConfig,
         house_keeper::HouseKeeperConfig,
         prover_job_monitor::ProverJobMonitorConfig,
         pruning::PruningConfig,
@@ -58,6 +59,8 @@ pub struct GeneralConfig {
     pub db_config: DBConfig,
     #[config(nest)]
     pub eth: Option<EthConfig>,
+    #[config(nest, default)]
+    pub eth_proof_manager: EthProofManagerConfig,
     #[config(nest)]
     pub snapshot_creator: Option<SnapshotsCreatorConfig>,
     #[config(nest)]

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

@@ -48,6 +48,7 @@ pub mod contracts;
 pub mod da_client;
 pub mod da_dispatcher;
 pub mod database;
+pub mod eth_proof_manager;
 pub mod eth_sender;
 pub mod eth_watch;
 mod experimental;