feat: metric of reorg depth of blockchain tree

crates/blockchain-tree/src/blockchain_tree.rs

@@ -1001,9 +1001,12 @@ impl<DB: Database, C: Consensus, EF: ExecutorFactory> BlockchainTree<DB, C, EF>
                     old: Arc::new(old_canon_chain.clone()),
                     new: Arc::new(new_canon_chain.clone()),
                 };
+                let reorg_depth = old_canon_chain.len();
+
                 // insert old canon chain
                 self.insert_chain(AppendableChain::new(old_canon_chain));
-                self.metrics.reorgs.increment(1);
+
+                self.update_reorg_metrics(reorg_depth as f64);
             } else {
                 // error here to confirm that we are reverting nothing from db.
                 error!(target: "blockchain_tree", "Reverting nothing from db on block: #{:?}", block_hash);
@@ -1094,6 +1097,11 @@ impl<DB: Database, C: Consensus, EF: ExecutorFactory> BlockchainTree<DB, C, EF>
         }
     }
 
+    fn update_reorg_metrics(&mut self, reorg_depth: f64) {
+        self.metrics.reorgs.increment(1);
+        self.metrics.latest_reorg_depth.set(reorg_depth);
+    }
+
     /// Update blockchain tree chains (canonical and sidechains) and sync metrics.
     ///
     /// NOTE: this method should not be called during the pipeline sync, because otherwise the sync

crates/blockchain-tree/src/metrics.rs

@@ -13,6 +13,8 @@ pub struct TreeMetrics {
     pub canonical_chain_height: Gauge,
     /// The number of reorgs
     pub reorgs: Counter,
+    /// The latest reorg depth
+    pub latest_reorg_depth: Gauge,
     /// Longest sidechain height
     pub longest_sidechain_height: Gauge,
 }

crates/storage/provider/src/chain.rs

@@ -136,6 +136,11 @@ impl Chain {
         Self { state, blocks: block_num_hash }
     }
 
+    /// Returns length of the chain.
+    pub fn len(&self) -> usize {
+        self.blocks.len()
+    }
+
     /// Get all receipts for the given block.
     pub fn receipts_by_block_hash(&self, block_hash: BlockHash) -> Option<&[Receipt]> {
         let num = self.block_number(block_hash)?;