use darkfi_serial::{deserialize, serialize}; use crate::{crypto::merkle_node::MerkleNode, Result}; const SLED_ROOTS_TREE: &[u8] = b"_merkleroots"; /// The `RootStore` is a `sled` tree storing all the Merkle roots seen /// in existing blocks. The key is the Merkle root itself, while the value /// is an empty vector that's not used. #[derive(Clone)] pub struct RootStore(sled::Tree); impl RootStore { /// Opens a new or existing `RootStore` on the given sled database. pub fn new(db: &sled::Db) -> Result { let tree = db.open_tree(SLED_ROOTS_TREE)?; Ok(Self(tree)) } /// Insert a slice of [`MerkleNode`] into the store. With sled, the /// operation is done as a batch. The Merkle root is used as a key, /// while the value is an empty vector. pub fn insert(&self, roots: &[MerkleNode]) -> Result<()> { let mut batch = sled::Batch::default(); for root in roots { batch.insert(serialize(root), vec![] as Vec); } self.0.apply_batch(batch)?; Ok(()) } /// Check if the rootstore contains a given Merkle root. pub fn contains(&self, root: &MerkleNode) -> Result { Ok(self.0.contains_key(serialize(root))?) } /// Retrieve all Merkle roots from the store. /// Be careful as this will try to load everything in memory. pub fn get_all(&self) -> Result> { let mut roots = vec![]; for root in self.0.iter() { let (key, _) = root.unwrap(); let root = deserialize(&key)?; roots.push(root); } Ok(roots) } }