SqlDelightTaskRepository

SQLDelight-backed implementation of TaskRepository.

All DB operations are dispatched to Dispatchers.IO to avoid blocking the main thread.

The Tasks data class is generated by SQLDelight in the same package (io.neuralheads.kmpworker.persistence), not in the .db sub-package.

database

The SQLDelight generated database instance.

Constructors

constructor(database: KmpWorkerDatabase)

open suspend override fun delete(id: String)

Removes a task from the store. Call after TaskState.Success.

open suspend override fun getAll(): List<TaskRequest>

Returns all persisted tasks.

open suspend override fun getById(id: String): TaskRequest?

Returns a single task by ID, or null if not found.

open suspend override fun getPending(): List<TaskRequest>

Returns tasks with status PENDING or RUNNING. Use this on app restart to recover and re-enqueue interrupted tasks.

open suspend override fun insert(task: TaskRequest)

Persists a new TaskRequest with status PENDING. No-ops if a task with the same ID already exists.

open suspend override fun updateStatus(id: String, status: String, retryCount: Int)

Updates the status and retry count for a task.