diff --git a/subxt/src/backend/unstable/mod.rs b/subxt/src/backend/unstable/mod.rs index cf8e04909e..c13b127c18 100644 --- a/subxt/src/backend/unstable/mod.rs +++ b/subxt/src/backend/unstable/mod.rs @@ -451,6 +451,9 @@ impl Backend for UnstableBackend { static mut FIN_BLOCK: Option = None; unsafe { FIN_BLOCK = None }; + static mut PRUNED: Option = None; + unsafe { PRUNED = None }; + // First, subscribe to all new and finalized block refs. // - we subscribe to new refs so that when we see `BestChainBlockIncluded`, we // can try to return a block ref for the best block. @@ -466,7 +469,13 @@ impl Backend for UnstableBackend { None } FollowEvent::NewBlock(ev) => Some(SeenBlock::New(ev.block_hash)), - FollowEvent::Finalized(ev) => Some(SeenBlock::Finalized(ev.finalized_block_hashes)), + FollowEvent::Finalized(ev) => { + unsafe { + PRUNED = Some(format!(" pruned {:?} {:?}", PRUNED, ev.pruned_block_hashes)); + } + + Some(SeenBlock::Finalized(ev.finalized_block_hashes)) + } _ => None, }) }); @@ -493,6 +502,7 @@ impl Backend for UnstableBackend { loop { if now.elapsed().as_secs() > 120 { println!("Fin block {:?}", unsafe { &FIN_BLOCK }); + println!("Pruned block {:?}", unsafe { &PRUNED }); println!("MemLog: {:#?}", mem_log); println!("SeenBlocksLog: {:#?}", seen_blocks);