perf(l1, l2): pipeline VM merklelization (#5084)

**Motivation**

We want to parallelize VM execution and merkelization.

**Description**

<!-- A clear and concise general description of the changes this PR
introduces -->

<!-- Link to issues: Resolves #111, Resolves #222 -->

Closes #issue_number

---------

Co-authored-by: Mario Rugiero <[email protected]>
Co-authored-by: Lucas Fiegl <[email protected]>
Co-authored-by: Javier Rodríguez Chatruc <[email protected]>
Co-authored-by: Javier Chatruc <[email protected]>

Author: 4 people

CHANGELOG.md

@@ -4,6 +4,7 @@
 
 ### 2025-10-30
 
+- Pipeline Merkleization and Execution [#5084](https://github.com/lambdaclass/ethrex/pull/5084)
 - Add bloom filters to snapshot layers [#5112](https://github.com/lambdaclass/ethrex/pull/5112)
 - Make trusted setup warmup non blocking [#5124](https://github.com/lambdaclass/ethrex/pull/5124)
 

Cargo.lock

@@ -575,7 +575,7 @@ pub async fn import_blocks(
             }
 
             blockchain
-                .add_block(block)
+                .add_block_pipeline(block)
                 .inspect_err(|err| match err {
                     // Block number 1's parent not found, the chain must not belong to the same network as the genesis file
                     ChainError::ParentNotFound if number == 1 => warn!("The chain file is not compatible with the genesis file. Are you sure you selected the correct network?"),

cmd/ethrex/cli.rs

@@ -557,7 +557,7 @@ pub async fn regenerate_head_state(
             .await?
             .ok_or_else(|| eyre::eyre!("Block {i} not found"))?;
 
-        blockchain.add_block(block)?;
+        blockchain.add_block_pipeline(block)?;
     }
 
     info!("Finished regenerating state");

cmd/ethrex/initializers.rs

@@ -423,12 +423,12 @@ impl Command {
                     let state_diff = StateDiff::decode(&blob)?;
 
                     // Apply all account updates to trie
-                    let trie = store.open_direct_state_trie(current_state_root)?;
+                    let mut trie = store.open_direct_state_trie(current_state_root)?;
 
                     let account_updates = state_diff.to_account_updates(&trie)?;
 
                     let account_updates_list = store
-                        .apply_account_updates_from_trie_batch(trie, account_updates.values())
+                        .apply_account_updates_from_trie_batch(&mut trie, account_updates.values())
                         .map_err(|e| format!("Error applying account updates: {e}"))
                         .unwrap();
 

cmd/ethrex/l2/command.rs

@@ -269,18 +269,19 @@ pub async fn init_l2(
         info!("P2P is disabled");
     }
 
+    let l2_url = Url::parse(&format!(
+        "http://{}:{}",
+        opts.node_opts.http_addr, opts.node_opts.http_port
+    ))
+    .map_err(|err| eyre::eyre!("Failed to parse L2 RPC URL: {err}"))?;
+
     let l2_sequencer = ethrex_l2::start_l2(
         store,
         rollup_store,
         blockchain,
         l2_sequencer_cfg,
         cancellation_token.clone(),
-        #[cfg(feature = "metrics")]
-        Url::parse(&format!(
-            "http://{}:{}",
-            opts.node_opts.http_addr, opts.node_opts.http_port
-        ))
-        .map_err(|err| eyre::eyre!("Failed to parse L2 RPC URL: {err}"))?,
+        l2_url,
         genesis,
         checkpoints_dir,
     )

cmd/ethrex/l2/initializers.rs

@@ -11,13 +11,16 @@ documentation.workspace = true
 ethrex-rlp.workspace = true
 ethrex-common.workspace = true
 ethrex-storage.workspace = true
+ethrex-trie.workspace = true
 ethrex-vm.workspace = true
 secp256k1.workspace = true
 
 thiserror.workspace = true
 sha3.workspace = true
 tracing.workspace = true
 bytes.workspace = true
+hex.workspace = true
+rustc-hash.workspace = true
 tokio = { workspace = true, features = ["time", "rt"] }
 tokio-util.workspace = true