jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(rpc): impl trace_get (#1769)

Browse Source
This commit is contained in:
Matthias Seitz
2023-03-15 15:51:46 +01:00
committed by GitHub
parent 7f0e32dd09
commit 0dfb940f1a
2 changed files with 58 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
crates/rpc/rpc-builder/tests/it/http.rs
View File

@ -191,9 +191,6 @@ where
assert!(is_unimplemented(
TraceApiClient::trace_filter(client, trace_filter).await.err().unwrap()
));
assert!(is_unimplemented(
TraceApiClient::trace_get(client, H256::default(), vec![]).await.err().unwrap()
));
}
async fn test_basic_web3_calls<C>(client: &C)

84
crates/rpc/rpc/src/trace.rs
View File

@ -1,5 +1,5 @@
use crate::{
eth::{cache::EthStateCache, revm_utils::inspect, EthTransactions},
eth::{cache::EthStateCache, error::EthResult, revm_utils::inspect, EthTransactions},
result::internal_rpc_err,
};
use async_trait::async_trait;
@ -41,6 +41,58 @@ impl<Client, Eth> TraceApi<Client, Eth> {
}
}
// === impl TraceApi ===
impl<Client, Eth> TraceApi<Client, Eth>
where
Client: BlockProvider + StateProviderFactory + EvmEnvProvider + 'static,
Eth: EthTransactions + 'static,
{
/// Returns transaction trace with the given address.
pub async fn trace_get(
&self,
hash: H256,
trace_address: Vec<usize>,
) -> EthResult<Option<LocalizedTransactionTrace>> {
match self.trace_transaction(hash).await? {
None => Ok(None),
Some(traces) => {
let trace =
traces.into_iter().find(|trace| trace.trace.trace_address == trace_address);
Ok(trace)
}
}
}
/// Returns all traces for the given transaction hash
pub async fn trace_transaction(
&self,
hash: H256,
) -> EthResult<Option<Vec<LocalizedTransactionTrace>>> {
let (transaction, at) = match self.eth_api.transaction_by_hash_at(hash).await? {
None => return Ok(None),
Some(res) => res,
};
let (cfg, block, at) = self.eth_api.evm_env_at(at).await?;
let (tx, tx_info) = transaction.split();
self.eth_api.with_state_at(at, |state| {
let tx = tx_env_with_recovered(&tx);
let env = Env { cfg, block, tx };
let db = SubState::new(State::new(state));
let mut inspector = TracingInspector::new(TraceInspectorConfig::default_parity());
inspect(db, env, &mut inspector)?;
let traces = inspector.into_parity_builder().into_localized_transaction_traces(tx_info);
Ok(Some(traces))
})
}
}
#[async_trait]
impl<Client, Eth> TraceApiServer for TraceApi<Client, Eth>
where
@ -107,13 +159,14 @@ where
Err(internal_rpc_err("unimplemented"))
}
/// Returns transaction trace at given index.
/// Handler for `trace_get`
async fn trace_get(
&self,
_hash: H256,
_indices: Vec<Index>,
hash: H256,
indices: Vec<Index>,
) -> Result<Option<LocalizedTransactionTrace>> {
Err(internal_rpc_err("unimplemented"))
Ok(TraceApi::trace_get(self, hash, indices.into_iter().map(Into::into).collect()).await?)
}
/// Handler for `trace_transaction`
@ -121,28 +174,7 @@ where
&self,
hash: H256,
) -> Result<Option<Vec<LocalizedTransactionTrace>>> {
let (transaction, at) = match self.eth_api.transaction_by_hash_at(hash).await? {
None => return Ok(None),
Some(res) => res,
};
let (cfg, block, at) = self.eth_api.evm_env_at(at).await?;
let (tx, tx_info) = transaction.split();
let traces = self.eth_api.with_state_at(at, |state| {
let tx = tx_env_with_recovered(&tx);
let env = Env { cfg, block, tx };
let db = SubState::new(State::new(state));
let mut inspector = TracingInspector::new(TraceInspectorConfig::default_parity());
inspect(db, env, &mut inspector)?;
let traces = inspector.into_parity_builder().into_localized_transaction_traces(tx_info);
Ok(traces)
})?;
Ok(Some(traces))
Ok(TraceApi::trace_transaction(self, hash).await?)
}
}