wip

Author: kariy

Cargo.lock

@@ -118,9 +118,9 @@ impl Node {
         // --- build pipeline
 
         let (mut pipeline, _) = Pipeline::new(provider.clone(), 50);
-        let block_downloader = BatchBlockDownloader::new_gateway(gateway_client.clone(), 50);
+        let block_downloader = BatchBlockDownloader::new_gateway(gateway_client.clone(), 8);
         pipeline.add_stage(Blocks::new(provider.clone(), block_downloader));
-        pipeline.add_stage(Classes::new(provider.clone(), gateway_client.clone(), 3));
+        pipeline.add_stage(Classes::new(provider.clone(), gateway_client.clone(), 8));
         pipeline.add_stage(StateTrie::new(provider.clone()));
 
         // --- build rpc server

crates/node/src/full/mod.rs

@@ -103,5 +103,4 @@ impl ContractClassProvider for PendingStateProvider {
 }
 
 impl StateRootProvider for PendingStateProvider {}
-
 impl StateProofProvider for PendingStateProvider {}

crates/node/src/full/pending.rs

@@ -6,7 +6,7 @@ use anyhow::Result;
 use futures::future::BoxFuture;
 use katana_pipeline::PipelineHandle;
 use katana_starknet::StarknetCore;
-use tracing::{error, info, trace};
+use tracing::{error, info};
 
 type TipWatcherFut = BoxFuture<'static, Result<()>>;
 

crates/node/src/full/tip_watcher.rs

@@ -19,6 +19,7 @@ katana-trie.workspace = true
 anyhow.workspace = true
 auto_impl.workspace = true
 bitvec.workspace = true
+lazy_static.workspace = true
 parking_lot.workspace = true
 starknet.workspace = true
 starknet-types-core.workspace = true

crates/storage/provider/provider/Cargo.toml

@@ -11,6 +11,7 @@ katana-executor.workspace = true
 katana-gateway.workspace = true
 katana-messaging.workspace = true
 katana-pool.workspace = true
+katana-trie.workspace = true
 katana-primitives.workspace = true
 katana-provider.workspace = true
 katana-rpc-types.workspace = true

crates/sync/stage/Cargo.toml

@@ -5,6 +5,7 @@ use katana_provider::api::block::HeaderProvider;
 use katana_provider::api::state_update::StateUpdateProvider;
 use katana_provider::api::trie::TrieWriter;
 use katana_rpc_types::class;
+use katana_trie::CommitId;
 use starknet::macros::short_string;
 use starknet_types_core::hash::{Poseidon, StarkHash};
 use tracing::{debug, error, info_span, trace, trace_span};

crates/sync/stage/src/trie.rs

@@ -1,7 +1,9 @@
 use bitvec::view::AsBits;
 pub use bonsai::{BitVec, MultiProof, Path, ProofNode};
 use bonsai_trie::BonsaiStorage;
-pub use bonsai_trie::{BonsaiDatabase, BonsaiPersistentDatabase, BonsaiStorageConfig};
+pub use bonsai_trie::{
+    databases::HashMapDb, BonsaiDatabase, BonsaiPersistentDatabase, BonsaiStorageConfig,
+};
 use katana_primitives::class::ClassHash;
 use katana_primitives::Felt;
 use starknet_types_core::hash::{Pedersen, StarkHash};