From aeb45b159743f6acdb2b751ed275fc14fcd05fd0 Mon Sep 17 00:00:00 2001 From: Dan Cline <6798349+Rjected@users.noreply.github.com> Date: Wed, 22 Jan 2025 15:31:54 -0500 Subject: [PATCH] chore: remove some unnecessary direct imports --- crates/net/network/src/eth_requests.rs | 4 +--- crates/net/p2p/src/test_utils/bodies.rs | 3 ++- crates/node/builder/src/components/execute.rs | 7 ++----- crates/optimism/node/src/engine.rs | 14 +++++++------- crates/revm/src/database.rs | 11 ++++++----- crates/storage/provider/src/traits/block.rs | 5 +++-- 6 files changed, 21 insertions(+), 23 deletions(-) diff --git a/crates/net/network/src/eth_requests.rs b/crates/net/network/src/eth_requests.rs index fe411912089b..f273e56f0356 100644 --- a/crates/net/network/src/eth_requests.rs +++ b/crates/net/network/src/eth_requests.rs @@ -158,9 +158,7 @@ where &self, _peer_id: PeerId, request: GetBlockBodies, - response: oneshot::Sender< - RequestResult::Body>>, - >, + response: oneshot::Sender::Body>>>, ) { self.metrics.eth_bodies_requests_received_total.increment(1); let mut bodies = Vec::new(); diff --git a/crates/net/p2p/src/test_utils/bodies.rs b/crates/net/p2p/src/test_utils/bodies.rs index 0689d403f2ce..a51ca1ea07fd 100644 --- a/crates/net/p2p/src/test_utils/bodies.rs +++ b/crates/net/p2p/src/test_utils/bodies.rs @@ -6,6 +6,7 @@ use crate::{ }; use alloy_primitives::B256; use futures::FutureExt; +use reth_network_peers::PeerId; use reth_primitives::BlockBody; use std::fmt::{Debug, Formatter}; use tokio::sync::oneshot; @@ -23,7 +24,7 @@ impl Debug for TestBodiesClient { } impl DownloadClient for TestBodiesClient { - fn report_bad_message(&self, _peer_id: reth_network_peers::PeerId) { + fn report_bad_message(&self, _peer_id: PeerId) { // noop } diff --git a/crates/node/builder/src/components/execute.rs b/crates/node/builder/src/components/execute.rs index 2c22bf2100ae..04cb93169e43 100644 --- a/crates/node/builder/src/components/execute.rs +++ b/crates/node/builder/src/components/execute.rs @@ -12,9 +12,7 @@ pub trait ExecutorBuilder: Send { type EVM: ConfigureEvmFor<::Primitives>; /// The type that knows how to execute blocks. - type Executor: BlockExecutorProvider< - Primitives = ::Primitives, - >; + type Executor: BlockExecutorProvider::Primitives>; /// Creates the EVM config. fn build_evm( @@ -27,8 +25,7 @@ impl ExecutorBuilder for F where Node: FullNodeTypes, EVM: ConfigureEvmFor<::Primitives>, - Executor: - BlockExecutorProvider::Primitives>, + Executor: BlockExecutorProvider::Primitives>, F: FnOnce(&BuilderContext) -> Fut + Send, Fut: Future> + Send, { diff --git a/crates/optimism/node/src/engine.rs b/crates/optimism/node/src/engine.rs index 29a13f9d8b3e..76113ef7f364 100644 --- a/crates/optimism/node/src/engine.rs +++ b/crates/optimism/node/src/engine.rs @@ -204,14 +204,14 @@ pub fn validate_withdrawals_presence( #[cfg(test)] mod test { + use super::*; use crate::engine; use alloy_primitives::{b64, Address, B256, B64}; use alloy_rpc_types_engine::PayloadAttributes; + use reth_node_builder::EngineValidator; use reth_optimism_chainspec::BASE_SEPOLIA; - use super::*; - fn get_chainspec() -> Arc { let hardforks = OpHardfork::base_sepolia(); Arc::new(OpChainSpec { @@ -251,7 +251,7 @@ mod test { let validator = OpEngineValidator::new(get_chainspec()); let attributes = get_attributes(None, 1732633199); - let result = >::ensure_well_formed_attributes( &validator, EngineApiMessageVersion::V3, &attributes @@ -264,7 +264,7 @@ mod test { let validator = OpEngineValidator::new(get_chainspec()); let attributes = get_attributes(None, 1732633200); - let result = >::ensure_well_formed_attributes( &validator, EngineApiMessageVersion::V3, &attributes @@ -277,7 +277,7 @@ mod test { let validator = OpEngineValidator::new(get_chainspec()); let attributes = get_attributes(Some(b64!("0000000000000008")), 1732633200); - let result = >::ensure_well_formed_attributes( &validator, EngineApiMessageVersion::V3, &attributes @@ -290,7 +290,7 @@ mod test { let validator = OpEngineValidator::new(get_chainspec()); let attributes = get_attributes(Some(b64!("0000000800000008")), 1732633200); - let result = >::ensure_well_formed_attributes( &validator, EngineApiMessageVersion::V3, &attributes @@ -303,7 +303,7 @@ mod test { let validator = OpEngineValidator::new(get_chainspec()); let attributes = get_attributes(Some(b64!("0000000000000000")), 1732633200); - let result = >::ensure_well_formed_attributes( &validator, EngineApiMessageVersion::V3, &attributes diff --git a/crates/revm/src/database.rs b/crates/revm/src/database.rs index db4dd554f3b0..3c161b348589 100644 --- a/crates/revm/src/database.rs +++ b/crates/revm/src/database.rs @@ -2,6 +2,7 @@ use crate::primitives::alloy_primitives::{BlockNumber, StorageKey, StorageValue} use alloy_primitives::{Address, B256, U256}; use core::ops::{Deref, DerefMut}; use reth_primitives::Account; +use reth_storage_api::{AccountReader, BlockHashReader, StateProvider}; use reth_storage_errors::provider::{ProviderError, ProviderResult}; use revm::{ db::DatabaseRef, @@ -37,20 +38,20 @@ pub trait EvmStateProvider: Send + Sync { } // Blanket implementation of EvmStateProvider for any type that implements StateProvider. -impl EvmStateProvider for T { +impl EvmStateProvider for T { fn basic_account(&self, address: &Address) -> ProviderResult> { - ::basic_account(self, address) + ::basic_account(self, address) } fn block_hash(&self, number: BlockNumber) -> ProviderResult> { - ::block_hash(self, number) + ::block_hash(self, number) } fn bytecode_by_hash( &self, code_hash: &B256, ) -> ProviderResult> { - ::bytecode_by_hash(self, code_hash) + ::bytecode_by_hash(self, code_hash) } fn storage( @@ -58,7 +59,7 @@ impl EvmStateProvider for T { account: Address, storage_key: StorageKey, ) -> ProviderResult> { - ::storage(self, account, storage_key) + ::storage(self, account, storage_key) } } diff --git a/crates/storage/provider/src/traits/block.rs b/crates/storage/provider/src/traits/block.rs index 6116cfdd0434..12ae006d8882 100644 --- a/crates/storage/provider/src/traits/block.rs +++ b/crates/storage/provider/src/traits/block.rs @@ -3,6 +3,7 @@ use reth_db_api::models::StoredBlockBodyIndices; use reth_execution_types::{Chain, ExecutionOutcome}; use reth_node_types::NodePrimitives; use reth_primitives::RecoveredBlock; +use reth_primitives_traits::Block; use reth_storage_api::{NodePrimitivesProvider, StorageLocation}; use reth_storage_errors::provider::ProviderResult; use reth_trie::{updates::TrieUpdates, HashedPostStateSorted}; @@ -71,7 +72,7 @@ pub trait StateReader: Send + Sync { #[auto_impl::auto_impl(&, Arc, Box)] pub trait BlockWriter: Send + Sync { /// The body this writer can write. - type Block: reth_primitives_traits::Block; + type Block: Block; /// The receipt type for [`ExecutionOutcome`]. type Receipt: Send + Sync; @@ -96,7 +97,7 @@ pub trait BlockWriter: Send + Sync { /// Bodies are passed as [`Option`]s, if body is `None` the corresponding block is empty. fn append_block_bodies( &self, - bodies: Vec<(BlockNumber, Option<::Body>)>, + bodies: Vec<(BlockNumber, Option<::Body>)>, write_to: StorageLocation, ) -> ProviderResult<()>;