ChainRepository

Persistent store for TaskChain progress.

Stores which step each active chain is currently on. Used by TaskChainExecutor to resume chains from the correct step after app termination.

Functions

abstract suspend fun delete(chainId: String)

Deletes the progress record for chainId.

abstract suspend fun get(chainId: String): ChainProgress?

Returns the progress record for chainId, or null if not found.

Returns all chains that are currently RUNNING (for cold-launch restoration).

abstract suspend fun save(chainId: String, stepsJson: String, totalSteps: Int)

Saves the initial progress for a newly started chain.

abstract suspend fun updateStep(chainId: String, currentStep: Int, status: String)

Updates the current step and status of an existing chain.