EventRepository

internal interface EventRepository

Functions

abstract suspend fun acknowledgeMissedEvent(): Either<CoreFailure, Unit>

Performs an acknowledgment of the missed event after performing a slow sync.

abstract suspend fun clearLastSavedEventId(): Either<StorageFailure, Unit>

Clears the last saved event ID.

abstract suspend fun fetchMostRecentEventId(): Either<CoreFailure, String>

abstract suspend fun fetchOldestAvailableEventId(): Either<CoreFailure, String>

Fetches the oldest available event ID from remote.

abstract suspend fun lastSavedEventId(): Either<StorageFailure, String>

Retrieves the last saved event ID from the storage.

abstract suspend fun liveEvents(): Either<CoreFailure, Flow<IncrementalSyncPhase>>

abstract fun observeEvents(): Flow<List<EventEnvelope>>

abstract fun parseExternalEvents(data: String): List<EventEnvelope>

Parse events from an external JSON payload

abstract suspend fun setEventAsProcessed(eventId: String): Either<StorageFailure, Unit>

abstract suspend fun setEventsAsProcessed(eventIds: List<String>): Either<StorageFailure, Unit>

abstract suspend fun updateLastSavedEventId(eventId: String): Either<StorageFailure, Unit>

Updates the last saved event ID.