LumeWeb
/
helios
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: parallel tx receipt fetching (#57)

This commit is contained in:
Noah Citron 2022-09-23 22:52:51 -04:00 committed by GitHub
parent fb28a61043
commit c57c866c17
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
execution/src/execution.rs
View File

@ -10,6 +10,7 @@ use eyre::Result;
use common::utils::hex_str_to_bytes;
use consensus::types::ExecutionPayload;
use futures::future::join_all;
use revm::KECCAK_EMPTY;
use triehash_ethereum::ordered_trie_root;
@ -164,16 +165,17 @@ impl<R: Rpc> ExecutionClient<R> {
.map(|tx| H256::from_slice(&keccak256(tx)))
.collect::<Vec<H256>>();
let mut receipts = vec![];
for hash in tx_hashes {
let receipt = self.rpc.get_transaction_receipt(&hash).await?.unwrap();
let receipts_fut = tx_hashes.iter().map(|hash| async move {
let receipt = self.rpc.get_transaction_receipt(hash).await;
receipt?.ok_or(eyre::eyre!("not reachable"))
});
receipts.push(receipt);
}
let receipts = join_all(receipts_fut).await;
let receipts = receipts.into_iter().collect::<Result<Vec<_>>>()?;
let receipts_encoded: Vec<Vec<u8>> = receipts
.iter()
.map(|receipt| encode_receipt(receipt))
.map(|receipt| encode_receipt(&receipt))
.collect();
let expected_receipt_root = ordered_trie_root(receipts_encoded);