Skip to main content

coven_database/store/store_session/test_support/
device_exclusion.rs

1use super::*;
2
3impl StoreDatabase {
4    pub async fn latest_local_write_facts_for_test(&self) -> Result<(String, i64, i64), DbError> {
5        self.call_store(|session| session.latest_local_write_facts_for_test())
6            .await
7    }
8
9    pub async fn install_retracted_device_state_failure_trigger_for_test(
10        &self,
11    ) -> Result<(), DbError> {
12        self.call_store(|session| session.install_retracted_device_state_failure_trigger_for_test())
13            .await
14    }
15
16    pub async fn prepared_write_count_for_test(&self, write_id: WriteId) -> Result<i64, DbError> {
17        self.call_store(move |session| session.prepared_write_count_for_test(&write_id))
18            .await
19    }
20
21    pub async fn begin_remote_candidate_nonactivation_for_test(
22        &self,
23        object_id: coven_protocol::store_commit::ObjectHash,
24        nonactivation: coven_protocol::remote_object::CandidateNonactivation,
25    ) -> Result<(), DbError> {
26        self.call_store(move |session| {
27            session.begin_remote_candidate_nonactivation_for_test(object_id, nonactivation)
28        })
29        .await
30    }
31
32    pub async fn install_indexed_shared_blobs_for_test(
33        &self,
34        write_id: WriteId,
35        records: Vec<coven_protocol::remote_object::RemoteObjectRecord>,
36    ) -> Result<(), DbError> {
37        self.call_store(move |session| {
38            session.install_indexed_shared_blobs_for_test(&write_id, records)
39        })
40        .await
41    }
42}