diff --git a/crates/rpc/rpc/src/eth/api/state.rs b/crates/rpc/rpc/src/eth/api/state.rs index 144b1504f..61566a355 100644 --- a/crates/rpc/rpc/src/eth/api/state.rs +++ b/crates/rpc/rpc/src/eth/api/state.rs @@ -45,7 +45,7 @@ where address: Address, block_id: Option, ) -> EthResult { - if block_id == Some(BlockId::Number(BlockNumberOrTag::Pending)) { + if block_id == Some(BlockId::pending()) { let address_txs = self.pool().get_transactions_by_sender(address); if let Some(highest_nonce) = address_txs.iter().map(|item| item.transaction.nonce()).max() diff --git a/crates/rpc/rpc/src/eth/api/transactions.rs b/crates/rpc/rpc/src/eth/api/transactions.rs index 17d2f85c0..538aa606b 100644 --- a/crates/rpc/rpc/src/eth/api/transactions.rs +++ b/crates/rpc/rpc/src/eth/api/transactions.rs @@ -787,9 +787,7 @@ where None => return Ok(None), Some(tx) => { let res = match tx { - tx @ TransactionSource::Pool(_) => { - (tx, BlockId::Number(BlockNumberOrTag::Pending)) - } + tx @ TransactionSource::Pool(_) => (tx, BlockId::pending()), TransactionSource::Block { transaction, index, @@ -873,17 +871,14 @@ where // set nonce if not already set before if request.nonce.is_none() { - let nonce = - self.get_transaction_count(from, Some(BlockId::Number(BlockNumberOrTag::Pending)))?; + let nonce = self.get_transaction_count(from, Some(BlockId::pending()))?; // note: `.to()` can't panic because the nonce is constructed from a `u64` request.nonce = Some(nonce.to::()); } let chain_id = self.chain_id(); - let estimated_gas = self - .estimate_gas_at(request.clone(), BlockId::Number(BlockNumberOrTag::Pending), None) - .await?; + let estimated_gas = self.estimate_gas_at(request.clone(), BlockId::pending(), None).await?; let gas_limit = estimated_gas; let TransactionRequest { diff --git a/crates/rpc/rpc/src/trace.rs b/crates/rpc/rpc/src/trace.rs index 0a1494e0e..b2104ff47 100644 --- a/crates/rpc/rpc/src/trace.rs +++ b/crates/rpc/rpc/src/trace.rs @@ -7,9 +7,7 @@ use crate::eth::{ use async_trait::async_trait; use jsonrpsee::core::RpcResult as Result; use reth_consensus_common::calc::{base_block_reward, block_reward}; -use reth_primitives::{ - revm::env::tx_env_with_recovered, BlockId, BlockNumberOrTag, Bytes, SealedHeader, B256, U256, -}; +use reth_primitives::{revm::env::tx_env_with_recovered, BlockId, Bytes, SealedHeader, B256, U256}; use reth_provider::{BlockReader, ChainSpecProvider, EvmEnvProvider, StateProviderFactory}; use reth_revm::database::StateProviderDatabase; use reth_rpc_api::TraceApiServer; @@ -133,7 +131,7 @@ where calls: Vec<(TransactionRequest, HashSet)>, block_id: Option, ) -> EthResult> { - let at = block_id.unwrap_or(BlockId::Number(BlockNumberOrTag::Pending)); + let at = block_id.unwrap_or(BlockId::pending()); let (cfg, block_env, at) = self.inner.eth_api.evm_env_at(at).await?; let gas_limit = self.inner.eth_api.call_gas_limit();