feat: add signet-rpc-storage crate with ETH RPC endpoints

Cargo.toml

@@ -43,6 +43,7 @@ signet-node-config = { version = "0.16.0-rc.7", path = "crates/node-config" }
 signet-node-tests = { version = "0.16.0-rc.7", path = "crates/node-tests" }
 signet-node-types = { version = "0.16.0-rc.7", path = "crates/node-types" }
 signet-rpc = { version = "0.16.0-rc.7", path = "crates/rpc" }
+signet-rpc-storage = { version = "0.16.0-rc.7", path = "crates/rpc-storage" }
 
 init4-bin-base = { version = "0.18.0-rc.8", features = ["alloy"] }
 
@@ -55,9 +56,13 @@ signet-tx-cache = "0.16.0-rc.8"
 signet-types = "0.16.0-rc.8"
 signet-zenith = "0.16.0-rc.8"
 signet-journal = "0.16.0-rc.8"
+signet-storage = "0.6.0"
+signet-cold = "0.6.0"
+signet-hot = "0.6.0"
+signet-storage-types = "0.6.0"
 
 # ajj
-ajj = { version = "0.3.4" }
+ajj = { version = "0.6.0" }
 
 # trevm
 trevm = { version = "0.34.0", features = ["full_env_cfg"] }
@@ -132,6 +137,11 @@ alloy-rlp = "0.3.11"
 tempfile = "3.17.0"
 
 # [patch.crates-io]
+# signet-cold = { path = "../storage/crates/cold" }
+# signet-hot = { path = "../storage/crates/hot" }
+# signet-storage = { path = "../storage/crates/storage" }
+# signet-storage-types = { path = "../storage/crates/types" }
+
 # signet-bundle = { path = "../sdk/crates/bundle"}
 # signet-constants = { path = "../sdk/crates/constants"}
 # signet-evm = { path = "../sdk/crates/evm"}

crates/block-processor/Cargo.toml

@@ -13,7 +13,6 @@ repository.workspace = true
 signet-constants.workspace = true
 signet-evm.workspace = true
 signet-extract.workspace = true
-signet-journal.workspace = true
 signet-types.workspace = true
 
 init4-bin-base.workspace = true

crates/block-processor/src/v1/processor.rs

@@ -1,7 +1,7 @@
 use crate::{AliasOracle, AliasOracleFactory, Chain, metrics};
 use alloy::{
     consensus::BlockHeader,
-    primitives::{Address, B256, map::HashSet},
+    primitives::{Address, map::HashSet},
 };
 use core::fmt;
 use eyre::ContextCompat;
@@ -21,10 +21,9 @@ use signet_constants::SignetSystemConstants;
 use signet_db::{DataCompat, DbProviderExt, RuChain, RuRevmState, RuWriter};
 use signet_evm::{BlockResult, EvmNeedsCfg, SignetDriver};
 use signet_extract::{Extractor, Extracts};
-use signet_journal::HostJournal;
 use signet_node_types::{NodeTypesDbTrait, SignetNodeTypes};
 use std::{collections::VecDeque, sync::Arc};
-use tracing::{Instrument, debug, error, info, info_span, instrument};
+use tracing::{Instrument, error, info, info_span, instrument};
 use trevm::revm::primitives::hardfork::SpecId;
 
 /// A block processor that listens to host chain commits and processes
@@ -145,7 +144,6 @@ where
         let mut start = None;
         let mut current = 0;
         let last_ru_height = self.ru_provider.last_block_number()?;
-        let mut prev_block_journal = self.ru_provider.provider_rw()?.latest_journal_hash()?;
 
         let mut net_outcome = ExecutionOutcome::default();
 
@@ -191,10 +189,8 @@ where
             metrics::record_block_result(&block_result, &start_time);
 
             let _ = span.enter();
-            let journal =
-                self.commit_evm_results(&block_extracts, &block_result, prev_block_journal)?;
+            self.commit_evm_results(&block_extracts, &block_result)?;
 
-            prev_block_journal = journal.journal_hash();
             net_outcome.extend(block_result.execution_outcome.convert());
         }
         info!("committed blocks");
@@ -308,36 +304,21 @@ where
 
     /// Commit the outputs of a zenith block to the database.
     #[instrument(skip_all)]
-    fn commit_evm_results<'a>(
+    fn commit_evm_results(
         &self,
         extracts: &Extracts<'_, ExtractableChainShim<'_>>,
-        block_result: &'a BlockResult,
-        prev_block_journal: B256,
-    ) -> eyre::Result<HostJournal<'a>> {
-        let journal = block_result.make_host_journal(prev_block_journal);
-        let time = std::time::Instant::now();
-        let jh = journal.journal_hash();
-
-        debug!(
-            target: "signet::journal::serialize",
-            bytes = journal.serialized().len(),
-            hash = %jh,
-            elapsed_micros = %time.elapsed().as_micros(),
-            "journal produced"
-        );
-
+        block_result: &BlockResult,
+    ) -> eyre::Result<()> {
         self.ru_provider.provider_rw()?.update(|writer| {
-            // add execution results to database
             writer.append_host_block(
                 extracts.ru_header(),
                 extracts.transacts().cloned(),
                 extracts.enters(),
                 extracts.enter_tokens(),
                 block_result,
-                jh,
             )?;
             Ok(())
         })?;
-        Ok(journal)
+        Ok(())
     }
 }

crates/db/Cargo.toml

@@ -12,7 +12,6 @@ repository.workspace = true
 signet-node-types.workspace = true
 
 signet-evm.workspace = true
-signet-journal.workspace = true
 signet-types.workspace = true
 signet-zenith.workspace = true
 
@@ -28,8 +27,6 @@ reth-stages-types.workspace = true
 itertools.workspace = true
 serde.workspace = true
 tracing.workspace = true
-futures-util = "0.3.31"
-tokio.workspace = true
 auto_impl = "1.3.0"
 
 [dev-dependencies]

crates/db/README.md

@@ -6,7 +6,7 @@ Node.
 This library contains the following:
 
 - Traits for reading and writing Signet events
-- Table definitions for Signet Events, Headers, and JournalHashes
+- Table definitions for Signet Events and Headers
 - Helpers for reading, writing, reverting, Signet EVM blocks and headers
 
 ## Significant Traits

crates/db/src/lib.rs

@@ -23,14 +23,11 @@ pub use consistency::ProviderConsistencyExt;
 mod convert;
 pub use convert::DataCompat;
 
-pub mod journal;
-
 mod provider;
 
 mod tables;
 pub use tables::{
-    DbEnter, DbEnterToken, DbSignetEvent, DbTransact, DbZenithHeader, JournalHashes, SignetEvents,
-    ZenithHeaders,
+    DbEnter, DbEnterToken, DbSignetEvent, DbTransact, DbZenithHeader, SignetEvents, ZenithHeaders,
 };
 
 mod traits;