:core:room/dev.atick.core.room.data/LocalDataSource

LocalDataSource

interface LocalDataSource(source)

Room operations used by the Home repository for content and pending-sync metadata.

User-scoped lists exclude soft-deleted rows. Pending queries include rows with needsSync set or lastUpdated greater than lastSynced. The stored server timestamp supplies the pull cursor. Writes do not schedule sync; the repository requests it separately.

See also

Functions

deleteJetpackPermanently

abstract suspend fun deleteJetpackPermanently(id: String)

Permanently deletes a jetpack from the database.

abstract fun getJetpack(id: String): Flow<JetpackEntity>

Retrieves a specific jetpack by its ID.

abstract fun getJetpacks(userId: String): Flow<List<JetpackEntity>>

Observes a user's non-deleted jetpacks, newest edit first.

abstract suspend fun getSyncCursor(userId: String): Long

Returns the largest stored server write time, including soft-deleted rows. This timestamp alone does not establish a complete pull checkpoint.

getUnsyncedJetpacks

abstract suspend fun getUnsyncedJetpacks(userId: String): List<JetpackEntity>

Retrieves a list of jetpacks for a specific user that need to be synced.

abstract suspend fun insertJetpack(jetpackEntity: JetpackEntity)

Inserts a new jetpack into the database.

abstract suspend fun markAsSynced(id: String, timestamp: Long = System.currentTimeMillis())

Clears pending flags by ID and sets lastSynced, without checking the uploaded version.

markJetpackAsDeleted

abstract suspend fun markJetpackAsDeleted(id: String)

Marks a jetpack as deleted.

abstract suspend fun updateJetpack(jetpackEntity: JetpackEntity)

Updates an existing jetpack in the database.

abstract suspend fun upsertJetpack(jetpackEntity: JetpackEntity)

Inserts or updates a jetpack in the database.

abstract suspend fun upsertJetpacks(remoteJetpacks: List<JetpackEntity>)

Upserts (insert or update) jetpacks from a remote source.