feat(commitment): Commitment component

.github/workflows/ci-core-reusable.yml

@@ -122,7 +122,7 @@ jobs:
       matrix:
         consensus: [false,true]
     env:
-      SERVER_COMPONENTS: "api,tree,eth,state_keeper,housekeeper,basic_witness_input_producer${{ matrix.consensus && ',consensus' || '' }}"
+      SERVER_COMPONENTS: "api,tree,eth,state_keeper,housekeeper,basic_witness_input_producer,commitment_generator${{ matrix.consensus && ',consensus' || '' }}"
 
     runs-on: [matterlabs-ci-runner]
     steps:
@@ -241,7 +241,7 @@ jobs:
     runs-on: [matterlabs-ci-runner]
 
     env:
-      SERVER_COMPONENTS: "api,tree,eth,state_keeper,housekeeper,basic_witness_input_producer${{ matrix.consensus && ',consensus' || '' }}"
+      SERVER_COMPONENTS: "api,tree,eth,state_keeper,housekeeper,basic_witness_input_producer,commitment_generator${{ matrix.consensus && ',consensus' || '' }}"
       EXT_NODE_FLAGS: "${{ matrix.consensus && '--enable-consensus' || '' }}"
 
     steps:

core/bin/external_node/src/main.rs

@@ -17,6 +17,7 @@ use zksync_core::{
         web3::{ApiBuilder, Namespace},
     },
     block_reverter::{BlockReverter, BlockReverterFlags, L1ExecutedBatchesRevert},
+    commitment_generator::CommitmentGenerator,
     consensus,
     consistency_checker::ConsistencyChecker,
     l1_gas_price::MainNodeFeeParamsFetcher,
@@ -264,6 +265,14 @@ async fn init_tasks(
         .context("failed to build a tree_pool")?;
     let tree_handle = task::spawn(metadata_calculator.run(tree_pool, tree_stop_receiver));
 
+    let commitment_generator_pool = singleton_pool_builder
+        .build()
+        .await
+        .context("failed to build a commitment_generator_pool")?;
+    let commitment_generator =
+        CommitmentGenerator::new(commitment_generator_pool, stop_receiver.clone());
+    let commitment_generator_handle = tokio::spawn(commitment_generator.run());
+
     let consistency_checker_handle = tokio::spawn(consistency_checker.run(stop_receiver.clone()));
 
     let updater_handle = task::spawn(batch_status_updater.run(stop_receiver.clone()));
@@ -360,6 +369,7 @@ async fn init_tasks(
         tree_handle,
         consistency_checker_handle,
         fee_params_fetcher_handle,
+        commitment_generator_handle,
     ]);
 
     Ok((task_handles, stop_sender, healthcheck_handle, stop_receiver))

core/bin/zksync_server/src/main.rs

@@ -43,7 +43,7 @@ struct Cli {
     /// Comma-separated list of components to launch.
     #[arg(
         long,
-        default_value = "api,tree,eth,state_keeper,housekeeper,basic_witness_input_producer"
+        default_value = "api,tree,eth,state_keeper,housekeeper,basic_witness_input_producer,commitment_generator"
     )]
     components: ComponentsToRun,
 }