fix

Author: sudo-shashank

src/chain/store/tipset_tracker.rs

@@ -60,7 +60,7 @@ impl<DB: Blockstore> TipsetTracker<DB> {
         cids.push(*header.cid());
         drop(map_lock);
 
-        self.check_consensus_fault(header);
+        self.check_consensus_faults(header);
         self.check_multiple_blocks_from_same_miner(&cids_to_verify, header);
         self.prune_entries(header.epoch);
     }
@@ -88,7 +88,7 @@ impl<DB: Blockstore> TipsetTracker<DB> {
     }
 
     /// Process block with slasher service for consensus fault detection
-    fn check_consensus_fault(&self, header: &CachingBlockHeader) {
+    fn check_consensus_faults(&self, header: &CachingBlockHeader) {
         if let Some(slasher) = &self.slasher_service {
             let slasher = slasher.clone();
             let header = header.clone();

src/slasher/db.rs

@@ -0,0 +1,65 @@
+// Copyright 2019-2025 ChainSafe Systems
+// SPDX-License-Identifier: Apache-2.0, MIT
+
+use crate::blocks::CachingBlockHeader;
+use anyhow::Result;
+use parity_db::{Db, Options};
+
+pub struct SlasherDb {
+    db: Db,
+}
+
+pub enum SlasherDbColumns {
+    ByEpoch = 0,
+    ByParents = 1,
+}
+
+impl SlasherDb {
+    pub fn new(data_dir: std::path::PathBuf) -> Result<Self> {
+        std::fs::create_dir_all(&data_dir)?;
+
+        let mut options = Options::with_columns(&data_dir, 2);
+        if let Some(column) = options.columns.get_mut(SlasherDbColumns::ByEpoch as usize) {
+            column.btree_index = true;
+            column.uniform = false;
+        }
+        if let Some(column) = options
+            .columns
+            .get_mut(SlasherDbColumns::ByParents as usize)
+        {
+            column.btree_index = true;
+            column.uniform = false;
+        }
+
+        let db = Db::open_or_create(&options)?;
+
+        Ok(Self { db })
+    }
+
+    pub fn put(&mut self, header: &CachingBlockHeader) -> Result<()> {
+        let miner = header.miner_address;
+        let epoch = header.epoch;
+
+        let epoch_key = format!("{}/{}", miner, epoch);
+        let parent_key = format!("{}/{}", miner, header.parents);
+
+        self.db.commit(vec![
+            (
+                SlasherDbColumns::ByEpoch as u8,
+                epoch_key.as_bytes(),
+                Some(header.cid().to_bytes()),
+            ),
+            (
+                SlasherDbColumns::ByParents as u8,
+                parent_key.as_bytes(),
+                Some(header.cid().to_bytes()),
+            ),
+        ])?;
+
+        Ok(())
+    }
+
+    pub fn get(&self, column: u8, key: &[u8]) -> Result<Option<Vec<u8>>> {
+        Ok(self.db.get(column, key)?)
+    }
+}

src/slasher/filter.rs

@@ -1,7 +1,7 @@
 // Copyright 2019-2025 ChainSafe Systems
 // SPDX-License-Identifier: Apache-2.0, MIT
 
-pub mod filter;
+pub mod db;
 pub mod service;
 pub mod types;