wip

dusk-network · Jul 3, 2024 · b9c59d6 · b9c59d6
1 parent 4cf586b
commit b9c59d6
Showing 1 changed file with 19 additions and 0 deletions.
diff --git a/node/src/database/rocksdb.rs b/node/src/database/rocksdb.rs
@@ -186,6 +186,10 @@ impl DB for Backend {
                 blocks_cf_opts.clone(),
             ),
             ColumnFamilyDescriptor::new(CF_LEDGER_TXS, blocks_cf_opts.clone()),
+            ColumnFamilyDescriptor::new(
+                CF_LEDGER_FAULTS,
+                blocks_cf_opts.clone(),
+            ),
             ColumnFamilyDescriptor::new(
                 CF_LEDGER_HEIGHT,
                 blocks_cf_opts.clone(),
@@ -314,6 +318,18 @@ impl<'db, DB: DBAccess> Ledger for DBTransaction<'db, DB> {
                 self.put_cf(cf, tx.inner.id(), d)?;
             }
         }
+
+        // COLUMN FAMILY: CF_LEDGER_FAULTS
+        {
+            let cf = self.ledger_faults_cf;
+
+            // store all block transactions
+            for f in faults {
+                let mut d = vec![];
+                f.write(&mut d)?;
+                self.put_cf(cf, f.hash(), d)?;
+            }
+        }
         self.store_block_label(header.height, &header.hash, label)?;
 
         Ok(self.get_size())
@@ -343,6 +359,9 @@ impl<'db, DB: DBAccess> Ledger for DBTransaction<'db, DB> {
         for tx in b.txs() {
             self.inner.delete_cf(self.ledger_txs_cf, tx.id())?;
         }
+        for f in b.faults() {
+            self.inner.delete_cf(self.ledger_faults_cf, f.hash())?;
+        }
 
         self.inner.delete_cf(self.ledger_cf, b.header().hash)?;