Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

SQLite-backed durable store.

Implementations

impl SqliteStore

pub fn open(path: impl AsRef<Path>) -> StoreResult<Self>

Opens a SQLite store at path, creating parent directories and schema.

pub fn open_in_memory() -> StoreResult<Self>

Opens an in-memory SQLite store.

pub fn upsert_dialog(&self, dialog: DialogRecord) -> StoreResult<()>

Inserts or replaces a dialog.

pub fn upsert_user(&self, user: UserRecord) -> StoreResult<()>

Inserts or replaces a user summary.

pub fn insert_message(&self, message: MessageRecord) -> StoreResult<()>

Inserts a message into history.

Trait Implementations

impl ClientStore for SqliteStore

fn save_session( &self, session: StoredSession, ) -> BoxFuture<'static, StoreResult<()>>

Saves the current session.

fn load_session(&self) -> BoxFuture<'static, StoreResult<Option<StoredSession>>>

Loads the current session.

fn clear_session(&self) -> BoxFuture<'static, StoreResult<()>>

Clears the current session.

fn clear_account_data(&self) -> BoxFuture<'static, StoreResult<()>>

Clears all account-owned cache, sync, and transaction state while leaving the session row under separate lifecycle control.

fn sync_state(&self) -> BoxFuture<'static, StoreResult<SyncState>>

Loads the global synchronization discovery cursor.

fn save_sync_state( &self, state: SyncState, ) -> BoxFuture<'static, StoreResult<()>>

Saves the global synchronization discovery cursor.

fn clear_sync_state(&self) -> BoxFuture<'static, StoreResult<()>>

Clears the global synchronization cursor and all bucket cursors.

fn sync_bucket_state( &self, key: SyncBucketKey, ) -> BoxFuture<'static, StoreResult<SyncBucketState>>

Loads the cursor for one update bucket.

fn save_sync_bucket_state( &self, key: SyncBucketKey, state: SyncBucketState, ) -> BoxFuture<'static, StoreResult<()>>

Saves the cursor for one update bucket.

fn save_sync_bucket_states( &self, states: Vec<(SyncBucketKey, SyncBucketState)>, ) -> BoxFuture<'static, StoreResult<()>>

Saves multiple bucket cursors atomically when supported by the store.

fn remove_sync_bucket_state( &self, key: SyncBucketKey, ) -> BoxFuture<'static, StoreResult<()>>

Removes the cursor for one update bucket.

fn save_pending_sync_batch( &self, batch: PendingSyncBatch, ) -> BoxFuture<'static, StoreResult<()>>

Saves or replaces the write-ahead batch for one bucket before reducer state is changed.

fn pending_sync_batches( &self, ) -> BoxFuture<'static, StoreResult<Vec<PendingSyncBatch>>>

Lists write-ahead batches that were not fully committed.

fn discard_pending_sync_batch( &self, key: SyncBucketKey, ) -> BoxFuture<'static, StoreResult<()>>

Removes an invalid write-ahead batch without advancing its bucket cursor. Stores should implement this so a journal written by an older or incompatible client cannot permanently poison startup recovery.

fn commit_pending_sync_batch( &self, key: SyncBucketKey, state: SyncBucketState, ) -> BoxFuture<'static, StoreResult<()>>

Atomically advances a bucket cursor and removes its write-ahead batch.

fn commit_pending_sync_batch_with_events( &self, key: SyncBucketKey, state: SyncBucketState, events: Vec<ClientEvent>, ) -> BoxFuture<'static, StoreResult<Vec<ClientEventDelivery>>>

Atomically advances a bucket cursor, records resulting lossless events, and removes its write-ahead batch. Custom stores must override this to use durable lossless delivery; the default fails before cursor commit.

fn append_client_events( &self, events: Vec<ClientEvent>, ) -> BoxFuture<'static, StoreResult<Vec<ClientEventDelivery>>>

Appends committed events to the durable lossless outbox while retaining best-effort events as unsequenced deliveries.

fn pending_client_events( &self, ) -> BoxFuture<'static, StoreResult<Vec<ClientEventDelivery>>>

Lists durable lossless events that have not yet been acknowledged by the host consumer.

fn acknowledge_client_event( &self, delivery_id: u64, ) -> BoxFuture<'static, StoreResult<()>>

Acknowledges one durable lossless event after the host has persisted or otherwise committed its handling.

fn dialogs( &self, request: DialogsRequest, ) -> BoxFuture<'static, StoreResult<DialogsPage>>

Lists stored dialogs.

fn dialog( &self, chat_id: InlineId, ) -> BoxFuture<'static, StoreResult<Option<DialogRecord>>>

Loads one stored dialog by chat ID.

fn record_dialog( &self, dialog: DialogRecord, ) -> BoxFuture<'static, StoreResult<()>>

Records a dialog in local state.

fn remove_dialog( &self, chat_id: InlineId, ) -> BoxFuture<'static, StoreResult<()>>

Removes a dialog and its client-owned per-chat state.

fn deleted_chat_ids(&self) -> BoxFuture<'static, StoreResult<Vec<InlineId>>>

Lists durable chat deletion tombstones.

fn record_users( &self, users: Vec<UserRecord>, ) -> BoxFuture<'static, StoreResult<()>>

Records user summaries in local state.

fn user( &self, user_id: InlineId, ) -> BoxFuture<'static, StoreResult<Option<UserRecord>>>

Loads one stored user summary.

fn record_space( &self, space: SpaceRecord, ) -> BoxFuture<'static, StoreResult<()>>

Inserts or replaces a durable space summary.

fn space( &self, space_id: InlineId, ) -> BoxFuture<'static, StoreResult<Option<SpaceRecord>>>

Loads a durable space summary.

fn record_space_member( &self, member: SpaceMemberRecord, ) -> BoxFuture<'static, StoreResult<()>>

Inserts or replaces one durable space member.

fn record_space_members( &self, space_id: InlineId, members: Vec<SpaceMemberRecord>, ) -> BoxFuture<'static, StoreResult<()>>

Replaces the complete durable membership snapshot for one space.

fn remove_space_member( &self, space_id: InlineId, user_id: InlineId, ) -> BoxFuture<'static, StoreResult<()>>

Removes one durable space member.

fn space_members( &self, space_id: InlineId, ) -> BoxFuture<'static, StoreResult<Vec<SpaceMemberRecord>>>

Lists durable members for a space.

fn record_user_settings( &self, settings: UserSettingsRecord, ) -> BoxFuture<'static, StoreResult<()>>

Replaces durable global user settings.

fn user_settings( &self, ) -> BoxFuture<'static, StoreResult<Option<UserSettingsRecord>>>

Loads durable global user settings.

fn record_chat_participants( &self, chat_id: InlineId, participants: Vec<ChatParticipantRecord>, ) -> BoxFuture<'static, StoreResult<()>>

Replaces the durable participant snapshot for a chat.

fn record_chat_participant( &self, chat_id: InlineId, participant: ChatParticipantRecord, ) -> BoxFuture<'static, StoreResult<()>>

Inserts or replaces one durable chat participant.

fn remove_chat_participant( &self, chat_id: InlineId, user_id: InlineId, ) -> BoxFuture<'static, StoreResult<()>>

Removes one durable chat participant.

fn chat_participants( &self, chat_id: InlineId, ) -> BoxFuture<'static, StoreResult<Vec<ChatParticipantRecord>>>

Loads the durable participant snapshot for a chat.

fn chat_participants_complete( &self, chat_id: InlineId, ) -> BoxFuture<'static, StoreResult<bool>>

Returns whether the participant list was observed as a complete snapshot.

fn history( &self, request: HistoryRequest, ) -> BoxFuture<'static, StoreResult<HistoryPage>>

Fetches stored history.

fn record_message( &self, message: MessageRecord, ) -> BoxFuture<'static, StoreResult<()>>

Records a message in stored history.

fn record_message_deleted( &self, chat_id: InlineId, message_id: InlineId, ) -> BoxFuture<'static, StoreResult<()>>

Records a durable message tombstone and removes the live message row.

fn message_deleted( &self, chat_id: InlineId, message_id: InlineId, ) -> BoxFuture<'static, StoreResult<bool>>

Returns whether a message has a durable deletion tombstone.

fn deleted_message_ids( &self, chat_id: InlineId, ) -> BoxFuture<'static, StoreResult<Vec<InlineId>>>

Lists durable message deletion tombstones for one chat.

fn clear_chat_messages( &self, chat_id: InlineId, before_date: Option<i64>, ) -> BoxFuture<'static, StoreResult<Vec<InlineId>>>

Clears stored messages for one chat and returns the removed IDs.

fn chat_ids_in_space( &self, space_id: InlineId, ) -> BoxFuture<'static, StoreResult<Vec<InlineId>>>

Lists chat IDs currently associated with a space.

fn record_reaction( &self, reaction: StoredReaction, ) -> BoxFuture<'static, StoreResult<()>>

Inserts or replaces one current reaction.

fn remove_reaction( &self, reaction: StoredReaction, ) -> BoxFuture<'static, StoreResult<()>>

Removes one current reaction.

fn replace_message_reactions( &self, chat_id: InlineId, message_id: InlineId, reactions: Vec<StoredReaction>, ) -> BoxFuture<'static, StoreResult<()>>

Replaces the complete reaction set for one message.

fn reactions( &self, chat_id: InlineId, message_id: InlineId, ) -> BoxFuture<'static, StoreResult<Vec<StoredReaction>>>

Lists current reactions for a message.

fn reactions_for_chat( &self, chat_id: InlineId, ) -> BoxFuture<'static, StoreResult<Vec<StoredReaction>>>

Lists the current reaction set for all known messages in one chat.

fn reaction_snapshot_message_ids( &self, chat_id: InlineId, ) -> BoxFuture<'static, StoreResult<Vec<InlineId>>>

Lists message IDs whose reaction set is known to be complete.

fn record_read_state( &self, state: StoredReadState, ) -> BoxFuture<'static, StoreResult<()>>

Inserts or replaces read state for a chat.

fn read_state( &self, chat_id: InlineId, ) -> BoxFuture<'static, StoreResult<Option<StoredReadState>>>

Loads read state for a chat.

fn record_transaction( &self, transaction: StoredTransaction, ) -> BoxFuture<'static, StoreResult<()>>

Records a transaction state change.

fn transaction( &self, transaction_id: TransactionId, ) -> BoxFuture<'static, StoreResult<Option<StoredTransaction>>>

Finds a transaction by transaction ID.

impl Clone for SqliteStore

fn clone(&self) -> SqliteStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqliteStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.