NotificationEventStore

Stores complete REST pages and their fetch cursor in one SQLite transaction.

Constructors

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

suspend fun cursor(): String?

suspend fun defer(eventId: String, untilEpochMillis: Long)

A scheduling hint only. The original event remains the source of truth.

suspend fun deferredUntil(eventId: String): Long?

suspend fun markProcessed(eventIds: List<String>, metadataKeysByEvent: Map<String, List<String>>)

Acknowledge received events and retire their operation records in the same SQL commit.

suspend fun nextPendingAfter(afterId: Long): EventEntity?

Scan past deferred rows without acknowledging them or moving the fetch cursor.

suspend fun pendingAfter(afterId: Long, pageSize: Long = 100): List<EventEntity>

Read-only terminal-account preflight; never advances the processing cursor.

suspend fun storePage(expectedCursor: String?, events: List<NewEventEntity>)