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

fix(engine): aggregate state for chain notification (#10295)

Browse Source
This commit is contained in:
Roman Krasiuk
2024-08-14 18:04:39 -07:00
committed by GitHub
parent c2808f1164
commit a0cf68ead8
1 changed files with 27 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
crates/chain-state/src/in_memory.rs
View File

@ -16,7 +16,6 @@ use reth_storage_api::StateProviderBox;
use reth_trie::{updates::TrieUpdates, HashedPostState};
use std::{
collections::{BTreeMap, HashMap},
ops::Deref,
sync::Arc,
time::Instant,
};
@ -752,28 +751,34 @@ impl NewCanonicalChain {
/// Converts the new chain into a notification that will be emitted to listeners
pub fn to_chain_notification(&self) -> CanonStateNotification {
// TODO: do we need to merge execution outcome for multiblock commit or reorg?
// implement this properly
match self {
Self::Commit { new } => CanonStateNotification::Commit {
new: Arc::new(Chain::new(
new.iter().map(ExecutedBlock::sealed_block_with_senders),
new.last().unwrap().execution_output.deref().clone(),
None,
)),
},
Self::Reorg { new, old } => CanonStateNotification::Reorg {
new: Arc::new(Chain::new(
new.iter().map(ExecutedBlock::sealed_block_with_senders),
new.last().unwrap().execution_output.deref().clone(),
None,
)),
old: Arc::new(Chain::new(
old.iter().map(ExecutedBlock::sealed_block_with_senders),
old.last().unwrap().execution_output.deref().clone(),
None,
)),
},
Self::Commit { new } => {
let new = Arc::new(new.iter().fold(Chain::default(), |mut chain, exec| {
chain.append_block(
exec.sealed_block_with_senders(),
exec.execution_outcome().clone(),
);
chain
}));
CanonStateNotification::Commit { new }
}
Self::Reorg { new, old } => {
let new = Arc::new(new.iter().fold(Chain::default(), |mut chain, exec| {
chain.append_block(
exec.sealed_block_with_senders(),
exec.execution_outcome().clone(),
);
chain
}));
let old = Arc::new(old.iter().fold(Chain::default(), |mut chain, exec| {
chain.append_block(
exec.sealed_block_with_senders(),
exec.execution_outcome().clone(),
);
chain
}));
CanonStateNotification::Reorg { new, old }
}
}
}