persistence/com.wire.kalium.persistence.dao.conversation/PendingSubconversationProposalDAOImpl

PendingSubconversationProposalDAOImpl

internal class PendingSubconversationProposalDAOImpl(database: UserDatabase, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher) : PendingSubconversationProposalDAO

Constructors

PendingSubconversationProposalDAOImpl

constructor(database: UserDatabase, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher)

Functions

open suspend override fun acknowledge(record: PendingSubconversationProposalEntity)

Remove only the exact observed record, including its retirement marker.

open suspend override fun clear()

Clear client-owned work and its legacy source without importing it.

open suspend override fun current(groupId: String): PendingSubconversationProposalEntity?

open suspend override fun isCurrent(record: PendingSubconversationProposalEntity): Boolean

markForRetirement

open suspend override fun markForRetirement(record: PendingSubconversationProposalEntity): PendingSubconversationProposalEntity?

Mark only the exact observed record; return null when another owner has replaced it.

open override fun observe(): Flow<List<PendingSubconversationProposalEntity>>

open suspend override fun schedule(record: PendingSubconversationProposalEntity)

Replace the token and reset retirement, preserving the earliest outstanding deadline.