Struct SyncStateManager 

pub struct SyncStateManager<'a> { /* private fields */ }

Manages sync state persistence in the sync tree.

Implementations

impl<'a> SyncStateManager<'a>

pub fn new(txn: &'a Transaction) -> Self

Create a new sync state manager.

pub async fn get_sync_cursor( &self, peer_pubkey: &PublicKey, tree_id: &ID, clock: &dyn Clock, ) -> Result<SyncCursor>

Get or create a sync cursor for a peer-tree relationship.

Arguments

• peer_pubkey - The peer’s public key
• tree_id - The tree ID this cursor applies to
• clock - The time provider for timestamps (used when creating new cursor)

pub async fn update_sync_cursor(&self, cursor: &SyncCursor) -> Result<()>

Update a sync cursor.

pub async fn get_sync_metadata( &self, peer_pubkey: &PublicKey, clock: &dyn Clock, ) -> Result<SyncMetadata>

Get or create sync metadata for a peer.

Arguments

• peer_pubkey - The peer’s public key
• clock - The time provider for timestamps (used when creating new metadata)

pub async fn update_sync_metadata(&self, metadata: &SyncMetadata) -> Result<()>

Update sync metadata for a peer.

pub async fn add_sync_history( &self, history_entry: &SyncHistoryEntry, ) -> Result<()>

Add a sync history entry.

pub async fn get_sync_history( &self, peer_pubkey: &PublicKey, limit: Option<usize>, ) -> Result<Vec<SyncHistoryEntry>>

Get sync history for a peer, optionally limited to recent entries.

Implementation Note

This method navigates the nested map structure created by DocStore::set_path(). When using set_path("history.sync_id", data), it creates a nested structure { "history": { "sync_id": data } } rather than a flat key with dots.

pub async fn get_peers_with_sync_state(&self) -> Result<Vec<PublicKey>>

Get all peers with sync state.

Implementation Note

This method navigates the nested map structure created by DocStore::set_path(). The data is organized in nested maps like { "metadata": { "peer_key": data } } and { "cursors": { "peer_key": { "tree_id": data } } }.

pub async fn cleanup_old_history( &self, max_age_days: u32, clock: &dyn Clock, ) -> Result<usize>

Clean up old sync history entries.

Arguments

• max_age_days - Maximum age of history entries to keep (older entries are deleted)
• clock - The time provider for determining current time

Implementation Note

This method navigates the nested map structure created by DocStore::set_path(). History entries are stored as { "history": { "sync_id": data } } and the method properly navigates this structure to find and clean old entries.