Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 3 additions & 6 deletions src/block_range_scanner/reorg_handler.rs
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ impl<N: Network> ReorgHandler<N> {
return Ok(None);
}

info!("Reorg detected, searching for common ancestor");
tracing::info!("Reorg detected, searching for common ancestor");

while let Some(&block_hash) = self.buffer.back() {
info!(block_hash = %block_hash, "Checking if block exists on-chain");
Expand All @@ -93,12 +93,12 @@ impl<N: Network> ReorgHandler<N> {
// no need to store finalized block's hash in the buffer, as it is returned by default only
// if not buffered hashes exist on-chain

warn!("Possible deep reorg detected, setting finalized block as common ancestor");
tracing::warn!("Possible deep reorg detected, setting finalized block as common ancestor");

let finalized = self.provider.get_block_by_number(BlockNumberOrTag::Finalized).await?;

let header = finalized.header();
info!(finalized_hash = %header.hash(), block_number = header.number(), "Finalized block set as common ancestor");
tracing::info!(finalized_hash = %header.hash(), block_number = header.number(), "Finalized block set as common ancestor");

Ok(Some(finalized))
}
Expand All @@ -122,9 +122,6 @@ impl<N: Network> ReorgHandler<N> {
info!(common_ancestor = %common_ancestor_header.hash(), block_number = common_ancestor_header.number(), "Common ancestor found");
common_ancestor
} else {
warn!(
finalized_hash = %finalized_header.hash(), block_number = finalized_header.number(), "Possible deep reorg detected, using finalized block as common ancestor"
);
// all buffered blocks are finalized, so no more need to track them
self.buffer.clear();
finalized
Expand Down