test: use persist_test_utils to test file_store

Author: 110CodingP

crates/file_store/Cargo.toml

@@ -20,3 +20,5 @@ serde = { version = "1", features = ["derive"] }
 
 [dev-dependencies]
 tempfile = "3"
+bdk_testenv = {path = "../testenv"}
+bdk_chain = { path = "../chain", version = "0.23.1", default-features = false, features = ["serde"]}

crates/file_store/src/store.rs

@@ -285,6 +285,8 @@ impl<C: fmt::Debug> std::error::Error for StoreErrorWithDump<C> {}
 mod test {
     use super::*;
 
+    const DB_MAGIC: &[u8] = &[0x21, 0x24, 0x48];
+
     use std::{
         collections::BTreeSet,
         fs,
@@ -297,6 +299,13 @@ mod test {
 
     type TestChangeSet = BTreeSet<String>;
 
+    use bdk_chain::{keychain_txout, local_chain, tx_graph, ConfirmationBlockTime};
+    use bdk_testenv::persist_test_utils::{
+        persist_anchors, persist_first_seen, persist_indexer_changeset, persist_last_evicted,
+        persist_last_revealed, persist_last_seen, persist_local_chain_changeset, persist_spk_cache,
+        persist_txgraph_changeset, persist_txouts, persist_txs,
+    };
+
     /// Check behavior of [`Store::create`] and [`Store::load`].
     #[test]
     fn construct_store() {
@@ -599,4 +608,103 @@ mod test {
         // current position matches EOF
         assert_eq!(current_pointer, expected_pointer);
     }
+
+    #[test]
+    fn txgraph_is_persisted() {
+        persist_txgraph_changeset::<Store<tx_graph::ChangeSet<ConfirmationBlockTime>>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
+
+    #[test]
+    fn indexer_is_persisted() {
+        persist_indexer_changeset::<Store<keychain_txout::ChangeSet>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
+
+    #[test]
+    fn local_chain_is_persisted() {
+        persist_local_chain_changeset::<Store<local_chain::ChangeSet>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
+
+    #[test]
+    fn txouts_are_persisted() {
+        persist_txouts::<Store<tx_graph::ChangeSet<ConfirmationBlockTime>>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
+
+    #[test]
+    fn txs_are_persisted() {
+        persist_txs::<Store<tx_graph::ChangeSet<ConfirmationBlockTime>>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
+
+    #[test]
+    fn anchors_are_persisted() {
+        persist_anchors::<Store<tx_graph::ChangeSet<ConfirmationBlockTime>>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
+
+    #[test]
+    fn last_seen_is_persisted() {
+        persist_last_seen::<Store<tx_graph::ChangeSet<ConfirmationBlockTime>>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
+
+    #[test]
+    fn last_evicted_is_persisted() {
+        persist_last_evicted::<Store<tx_graph::ChangeSet<ConfirmationBlockTime>>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
+
+    #[test]
+    fn first_seen_is_persisted() {
+        persist_first_seen::<Store<tx_graph::ChangeSet<ConfirmationBlockTime>>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
+
+    #[test]
+    fn last_revealed_is_persisted() {
+        persist_last_revealed::<Store<keychain_txout::ChangeSet>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
+
+    #[test]
+    fn spk_cache_is_persisted() {
+        persist_spk_cache::<Store<keychain_txout::ChangeSet>, _, _, _>(
+            |path| Ok(Store::create(DB_MAGIC, path)?),
+            |db| Ok(db.dump().map(Option::unwrap_or_default)?),
+            |db, changeset| Ok(db.append(changeset)?),
+        );
+    }
 }