feat(rpc): implement morph_getTransactionHashesByReference

Cargo.toml

@@ -18,6 +18,7 @@ members = [
     "crates/payload/builder",
     "crates/payload/types",
     "crates/primitives",
+    "crates/reference-index",
     "crates/revm",
     "crates/txpool",
 ]
@@ -92,6 +93,7 @@ morph-node = { path = "crates/node"}
 morph-payload-builder = { path = "crates/payload/builder", default-features = false }
 morph-payload-types = { path = "crates/payload/types", default-features = false }
 morph-primitives = { path = "crates/primitives", default-features = false }
+morph-reference-index = { path = "crates/reference-index", default-features = false }
 morph-rpc = { path = "crates/rpc" }
 morph-revm = { path = "crates/revm", default-features = false }
 morph-txpool = { path = "crates/txpool", default-features = false }
@@ -114,6 +116,9 @@ reth-engine-primitives = { git = "https://github.com/morph-l2/reth", rev = "1b07
 reth-engine-tree = { git = "https://github.com/morph-l2/reth", rev = "1b0702546633c259306017717b2938f14adfe329" }
 reth-errors = { git = "https://github.com/morph-l2/reth", rev = "1b0702546633c259306017717b2938f14adfe329" }
 reth-eth-wire-types = { git = "https://github.com/morph-l2/reth", rev = "1b0702546633c259306017717b2938f14adfe329" }
+reth-exex = { git = "https://github.com/morph-l2/reth", rev = "1b0702546633c259306017717b2938f14adfe329" }
+reth-exex-test-utils = { git = "https://github.com/morph-l2/reth", rev = "1b0702546633c259306017717b2938f14adfe329" }
+reth-exex-types = { git = "https://github.com/morph-l2/reth", rev = "1b0702546633c259306017717b2938f14adfe329" }
 reth-ethereum = { git = "https://github.com/morph-l2/reth", rev = "1b0702546633c259306017717b2938f14adfe329" }
 reth-ethereum-cli = { git = "https://github.com/morph-l2/reth", rev = "1b0702546633c259306017717b2938f14adfe329" }
 reth-ethereum-consensus = { git = "https://github.com/morph-l2/reth", rev = "1b0702546633c259306017717b2938f14adfe329" }

bin/morph-reth/Cargo.toml

@@ -20,8 +20,10 @@ morph-chainspec = { workspace = true, features = ["cli"] }
 morph-consensus.workspace = true
 morph-evm.workspace = true
 morph-node.workspace = true
+morph-reference-index.workspace = true
 
 # Reth CLI
+reth-chainspec.workspace = true
 reth-cli.workspace = true
 reth-cli-util.workspace = true
 reth-ethereum-cli.workspace = true

bin/morph-reth/src/main.rs

@@ -7,9 +7,15 @@ use clap::Parser;
 use morph_chainspec::{MorphChainSpec, MorphChainSpecParser};
 use morph_consensus::MorphConsensus;
 use morph_evm::{MorphEvmConfig, evm::MorphEvmFactory};
-use morph_node::{MorphArgs, MorphNode};
+use morph_node::{
+    MorphAddOns, MorphArgs, MorphNode,
+    exex::{ReferenceIndexControl, reference_index_exex},
+};
+use morph_reference_index::ReferenceIndexDb;
+use reth_chainspec::EthChainSpec;
 use reth_cli_util::sigsegv_handler;
 use reth_ethereum_cli::Cli;
+use reth_node_builder::Node;
 use reth_rpc_server_types::DefaultRpcModuleValidator;
 use std::sync::Arc;
 use tracing::info;
@@ -43,8 +49,33 @@ fn main() {
             .run_with_components::<MorphNode>(components, async move |builder, morph_args| {
                 info!(target: "morph::cli", "Starting Morph-Reth node");
 
+                // Open the reference index DB before launching the node so we
+                // can wire it into both the ExEx and the add-ons.
+                let chain_spec = builder.config().chain.clone();
+                let datadir = builder.config().datadir();
+                let reference_index_path = datadir.data_dir().join("morph").join("reference_index");
+                let chain_id = chain_spec.chain().id();
+                let genesis_hash = chain_spec.genesis_hash(); // from EthChainSpec trait
+
+                info!(
+                    target: "morph::reference_index",
+                    path = %reference_index_path.display(),
+                    chain_id,
+                    "opening Morph reference index database"
+                );
+                let db = ReferenceIndexDb::open(&reference_index_path, chain_id, genesis_hash)?;
+                let (control, startup_rx) = ReferenceIndexControl::new(db);
+
+                let exex_control = control.clone();
+                let node = MorphNode::new(morph_args);
+
                 let handle = builder
-                    .node(MorphNode::new(morph_args))
+                    .with_types::<MorphNode>()
+                    .with_components(node.components_builder())
+                    .with_add_ons(MorphAddOns::new().with_reference_index(control))
+                    .install_exex("morph-reference-index", async move |ctx| {
+                        Ok(reference_index_exex(ctx, exex_control, startup_rx))
+                    })
                     .launch_with_debug_capabilities()
                     .await?;
 

crates/node/Cargo.toml

@@ -18,16 +18,19 @@ morph-evm.workspace = true
 morph-payload-builder.workspace = true
 morph-payload-types.workspace = true
 morph-primitives = { workspace = true, features = ["reth-codec"] }
+morph-reference-index.workspace = true
 morph-rpc.workspace = true
 morph-txpool.workspace = true
 
 # Reth dependencies
 reth-db.workspace = true
+reth-db-api.workspace = true
 reth-node-core.workspace = true
 reth-chainspec.workspace = true
 reth-engine-local.workspace = true
 reth-engine-tree.workspace = true
 reth-errors.workspace = true
+reth-exex.workspace = true
 reth-node-api.workspace = true
 reth-node-builder.workspace = true
 reth-node-ethereum.workspace = true
@@ -37,12 +40,15 @@ reth-primitives-traits.workspace = true
 reth-provider.workspace = true
 reth-rpc-builder.workspace = true
 reth-rpc-eth-api.workspace = true
+reth-storage-api.workspace = true
+reth-tasks.workspace = true
 reth-transaction-pool.workspace = true
 reth-tracing.workspace = true
 reth-trie.workspace = true
 
 # Alloy
 alloy-consensus.workspace = true
+alloy-eips.workspace = true
 alloy-genesis.workspace = true
 alloy-hardforks.workspace = true
 alloy-primitives.workspace = true
@@ -54,16 +60,15 @@ eyre.workspace = true
 clap.workspace = true
 dashmap.workspace = true
 parking_lot.workspace = true
+tokio = { workspace = true, features = ["sync", "rt"] }
 tokio-stream.workspace = true
+tracing.workspace = true
 
 serde = { workspace = true, features = ["derive"] }
 serde_json.workspace = true
 
 # Optional: E2E testing framework
 reth-e2e-test-utils = { workspace = true, optional = true }
-reth-tasks = { workspace = true, optional = true }
-tokio = { workspace = true, features = ["sync"], optional = true }
-alloy-eips = { workspace = true, optional = true }
 alloy-rlp = { workspace = true, optional = true }
 alloy-signer = { workspace = true, optional = true }
 alloy-signer-local = { workspace = true, optional = true }
@@ -85,9 +90,11 @@ alloy-primitives.workspace = true
 alloy-rpc-types-engine.workspace = true
 alloy-rpc-types-eth.workspace = true
 jsonrpsee.workspace = true
+morph-chainspec.workspace = true
 morph-payload-types.workspace = true
 morph-primitives.workspace = true
 serde_json.workspace = true
+tempfile.workspace = true
 
 [[test]]
 name = "it"
@@ -98,10 +105,7 @@ required-features = ["test-utils"]
 default = []
 test-utils = [
     "dep:reth-e2e-test-utils",
-    "dep:reth-tasks",
     "dep:alloy-signer",
-    "dep:tokio",
-    "dep:alloy-eips",
     "dep:alloy-rlp",
     "dep:alloy-signer-local",
 ]