test: update signet-node-tests for HostNotifier API

Use decompose_exex_context to construct RethHostNotifier and pass
it through the new builder API.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: prestwich

crates/node-tests/Cargo.toml

@@ -12,10 +12,12 @@ repository.workspace = true
 signet-node.workspace = true
 signet-node-config = { workspace = true, features = ["test_utils"] }
 
+signet-blobber.workspace = true
 signet-cold = { workspace = true, features = ["in-memory"] }
 signet-constants.workspace = true
 signet-evm.workspace = true
 signet-genesis.workspace = true
+signet-host-reth.workspace = true
 signet-hot = { workspace = true, features = ["in-memory"] }
 signet-storage.workspace = true
 signet-storage-types.workspace = true
@@ -31,6 +33,7 @@ reth-exex-test-utils.workspace = true
 reth-node-api.workspace = true
 
 eyre.workspace = true
+reqwest.workspace = true
 tokio.workspace = true
 tracing.workspace = true
 tracing-subscriber.workspace = true

crates/node-tests/src/context.rs

@@ -18,6 +18,7 @@ use reth::transaction_pool::{TransactionOrigin, TransactionPool, test_utils::Moc
 use reth_exex_test_utils::{Adapter, TestExExHandle};
 use reth_node_api::FullNodeComponents;
 use signet_cold::{ColdStorageReadHandle, mem::MemColdBackend};
+use signet_host_reth::decompose_exex_context;
 use signet_hot::{
     db::{HotDbRead, UnsafeDbWrite},
     mem::MemKv,
@@ -104,6 +105,9 @@ impl SignetTestContext {
         let (ctx, handle) = reth_exex_test_utils::test_exex_context().await.unwrap();
         let components = ctx.components.clone();
 
+        // Decompose the ExEx context into notifier + configs
+        let decomposed = decompose_exex_context(ctx);
+
         // set up Signet Node storage
         let constants = cfg.constants().unwrap();
 
@@ -148,10 +152,25 @@ impl SignetTestContext {
 
         let alias_oracle: Arc<Mutex<HashSet<Address>>> = Arc::new(Mutex::new(HashSet::default()));
 
+        // Build the blob cacher from the decomposed pool
+        let blob_cacher = signet_blobber::BlobFetcher::builder()
+            .with_config(cfg.block_extractor())
+            .unwrap()
+            .with_pool(decomposed.pool)
+            .with_client(reqwest::Client::new())
+            .build_cache()
+            .unwrap()
+            .spawn::<alloy::consensus::SimpleCoder>();
+
         let (node, mut node_status) = SignetNodeBuilder::new(cfg.clone())
-            .with_ctx(ctx)
+            .with_notifier(decomposed.notifier)
             .with_storage(Arc::clone(&storage))
             .with_alias_oracle(Arc::clone(&alias_oracle))
+            .with_chain_name(decomposed.chain_name)
+            .with_blob_cacher(blob_cacher)
+            .with_serve_config(decomposed.serve_config)
+            .with_rpc_config(decomposed.rpc_config)
+            .with_client(reqwest::Client::new())
             .build()
             .await
             .unwrap();

crates/node-tests/tests/db.rs

@@ -1,13 +1,15 @@
+use alloy::primitives::map::HashSet;
 use serial_test::serial;
 use signet_cold::mem::MemColdBackend;
+use signet_host_reth::decompose_exex_context;
 use signet_hot::{
     db::{HotDbRead, UnsafeDbWrite},
     mem::MemKv,
 };
 use signet_node::SignetNodeBuilder;
 use signet_node_config::test_utils::test_config;
 use signet_storage::{CancellationToken, HistoryRead, HistoryWrite, HotKv, UnifiedStorage};
-use std::sync::Arc;
+use std::sync::{Arc, Mutex};
 
 #[serial]
 #[tokio::test]
@@ -19,6 +21,8 @@ async fn test_genesis() {
     let chain_spec: Arc<_> = cfg.chain_spec().clone();
     assert_eq!(chain_spec.genesis().config.chain_id, consts.unwrap().ru_chain_id());
 
+    let decomposed = decompose_exex_context(ctx);
+
     let cancel_token = CancellationToken::new();
     let hot = MemKv::new();
     {
@@ -30,9 +34,26 @@ async fn test_genesis() {
 
     let storage = Arc::new(UnifiedStorage::spawn(hot, MemColdBackend::new(), cancel_token.clone()));
 
+    let blob_cacher = signet_blobber::BlobFetcher::builder()
+        .with_config(cfg.block_extractor())
+        .unwrap()
+        .with_pool(decomposed.pool)
+        .with_client(reqwest::Client::new())
+        .build_cache()
+        .unwrap()
+        .spawn::<alloy::consensus::SimpleCoder>();
+
+    let alias_oracle: Arc<Mutex<HashSet<_>>> = Arc::new(Mutex::new(HashSet::default()));
+
     let (_, _) = SignetNodeBuilder::new(cfg.clone())
-        .with_ctx(ctx)
+        .with_notifier(decomposed.notifier)
         .with_storage(Arc::clone(&storage))
+        .with_alias_oracle(Arc::clone(&alias_oracle))
+        .with_chain_name(decomposed.chain_name)
+        .with_blob_cacher(blob_cacher)
+        .with_serve_config(decomposed.serve_config)
+        .with_rpc_config(decomposed.rpc_config)
+        .with_client(reqwest::Client::new())
         .build()
         .await
         .unwrap();