Struct PersistenceManager 

pub struct PersistenceManager { /* private fields */ }

Implementations

impl PersistenceManager

pub async fn new(backend: Arc<dyn Backend>) -> Result<Self, StoreError>

Create a PersistenceManager with a backend implementation.

Note: The backend should already be configured with the correct device_id (via SqliteStore::new_for_device for multi-account scenarios).

pub async fn get_device_arc(&self) -> Arc<RwLock<Device>>

Handle for store adapters that need &mut Device trait access. For plain reads, prefer get_device_snapshot.

pub fn get_device_snapshot(&self) -> Arc<Device>

Cheap point-in-time view of the device state: an Arc refcount bump, no locking against writers and no Device clone. Always reflects the last committed modify_device/process_command mutation.

pub fn backend(&self) -> Arc<dyn Backend>

pub fn is_saver_halted(&self) -> bool

Returns true if the background saver halted due to repeated flush failures.

pub async fn modify_device<F, R>(&self, modifier: F) -> R

where F: FnOnce(&mut Device) -> R,

pub async fn flush(&self) -> Result<(), StoreError>

Flush any dirty device state to the backend immediately.

pub async fn create_snapshot( &self, name: &str, extra_content: Option<&[u8]>, ) -> Result<(), StoreError>

Triggers a snapshot of the underlying storage backend. Useful for debugging critical errors like crypto state corruption.

pub fn run_background_saver( self: Arc<Self>, runtime: Arc<dyn Runtime>, interval: Duration, shutdown: ShutdownSignal, ) -> AbortHandle

Spawn the background saver. The task wakes on save_notify, the interval tick, or the shutdown signal; runs save_to_disk after each wake (no-op when the dirty flag is clear); and performs a final flush before exiting on shutdown.

Caller must keep the returned AbortHandle — dropping it aborts the task. ShutdownSignal is sticky (see ShutdownNotifier): a notify that races the task’s first listen() is observed via the flag on the first iteration, so no data is stranded.

impl PersistenceManager

pub async fn process_command(&self, command: DeviceCommand)

impl PersistenceManager

pub async fn get_sender_key_devices( &self, group_jid: &str, ) -> Result<Vec<(String, bool)>, StoreError>

pub async fn set_sender_key_status( &self, group_jid: &str, entries: &[(&str, bool)], ) -> Result<(), StoreError>

pub async fn clear_sender_key_devices( &self, group_jid: &str, ) -> Result<(), StoreError>

pub async fn delete_sender_key_device_rows( &self, device_jids: &[&str], ) -> Result<(), StoreError>