Struct SyncService 

pub struct SyncService {
    pub device_id: String,
}

Configuration for a sync service.

Fields

device_id: String

Implementations

impl SyncService

pub fn new(device_id: String) -> Self

pub async unsafe fn sync( &self, db: *mut sqlite3, session: SyncSession, local_seq: u64, cursors: &HashMap<String, u64>, storage: &dyn SyncStorage, timestamp: &str, message: &str, keypair: &UserKeypair, library_dir: &LibraryDir, blob_plan: &dyn BlobPlan, ) -> Result<SyncResult, SyncCycleError>

Run a full sync cycle.

This takes the current session, grabs its changeset, drops the session, pulls remote changes, and returns what the caller needs to push and to start a new session.

The message parameter is a human-readable description of what changed (e.g., “Imported Album One”). Callers derive this from the app event that triggered the sync.

The caller should:

1. Push outgoing to the storage (if Some).
2. Persist updated_cursors to the sync_cursors table.
3. Start a new SyncSession on the write connection.

Safety

db must be a valid, open sqlite3 connection pointer. The session must have been created on this same connection.