Add PoS block seal indexing and duplicate seal evidence retention

blockprod/src/tests/helpers.rs

@@ -135,6 +135,7 @@ impl BlockprodTestSetupBuilder {
             enable_db_reckless_mode_in_ibd: Default::default(),
             max_orphan_blocks: Default::default(),
             allow_checkpoints_mismatch: Default::default(),
+            pos_seal_duplication_tracking: Default::default(),
         };
 
         let mempool_config = self.mempool_config.unwrap_or_default();

chainstate/src/config.rs

@@ -21,6 +21,7 @@ use utils::make_config_setting;
 make_config_setting!(MaxDbCommitAttempts, usize, 10);
 make_config_setting!(MaxOrphanBlocks, usize, 512);
 make_config_setting!(MaxTipAge, Duration, Duration::from_secs(60 * 60 * 24));
+make_config_setting!(PosSealDuplicationTracking, bool, true);
 
 /// The chainstate subsystem configuration.
 #[derive(Debug, Clone, Default)]
@@ -47,6 +48,10 @@ pub struct ChainstateConfig {
 
     /// If true, blocks and block headers will not be rejected if checkpoints mismatch is detected.
     pub allow_checkpoints_mismatch: Option<bool>,
+
+    /// If true, the seals (stake pool id + VRF output) of the processed PoS blocks will be
+    /// indexed and the evidence of a seal seen on more than one block will be recorded.
+    pub pos_seal_duplication_tracking: PosSealDuplicationTracking,
 }
 
 impl ChainstateConfig {
@@ -70,6 +75,10 @@ impl ChainstateConfig {
         self
     }
 
+    pub fn pos_seal_duplication_tracking_enabled(&self) -> bool {
+        *self.pos_seal_duplication_tracking
+    }
+
     pub fn db_reckless_mode_in_ibd_enabled(&self) -> bool {
         self.enable_db_reckless_mode_in_ibd.unwrap_or(false)
     }

chainstate/src/detail/chainstateref/mod.rs

@@ -17,6 +17,7 @@ mod block_info;
 mod consistency_checker;
 mod epoch_seal;
 mod in_memory_reorg;
+pub(crate) mod seal_index;
 mod tx_verifier_storage;
 
 use itertools::Itertools;
@@ -1427,6 +1428,21 @@ impl<S: BlockchainStorageWrite, V: TransactionVerificationStrategy> ChainstateRe
         self.db_tx.add_block(block).map_err(BlockError::from)
     }
 
+    /// Index the seal of the given block, recording evidence if the seal was already
+    /// seen on another block. A no-op if seal duplication tracking is disabled.
+    pub fn index_block_seal_if_enabled(
+        &mut self,
+        block: &WithId<Block>,
+        block_height: BlockHeight,
+    ) -> Result<(), BlockError> {
+        seal_index::index_block_seal_if_enabled(
+            self.chainstate_config,
+            &mut self.db_tx,
+            block,
+            block_height,
+        )
+    }
+
     #[log_error]
     pub fn set_block_index(&mut self, block_index: &BlockIndex) -> Result<(), BlockError> {
         self.db_tx.set_block_index(block_index).map_err(BlockError::from)