logic/com.wire.kalium.logic.data.event/EventRepository

EventRepository

interface EventRepository

Inheritors

EventDataSource

Functions

acknowledgeMissedEvent

abstract suspend fun acknowledgeMissedEvent(): <Error class: unknown class><<Error class: unknown class>, Unit>

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

clearLastProcessedEventId

abstract suspend fun clearLastProcessedEventId(): <Error class: unknown class><<Error class: unknown class>, Unit>

Clears the last processed event ID.

fetchEvents

abstract suspend fun fetchEvents(): <Error class: unknown class><<Error class: unknown class><<Error class: unknown class>, EventEnvelope>>

fetchMostRecentEventId

abstract suspend fun fetchMostRecentEventId(): <Error class: unknown class><<Error class: unknown class>, String>

fetchOldestAvailableEventId

abstract suspend fun fetchOldestAvailableEventId(): <Error class: unknown class><<Error class: unknown class>, String>

Fetches the oldest available event ID from remote.

fetchServerTime

abstract suspend fun fetchServerTime(): String?

lastProcessedEventId

abstract suspend fun lastProcessedEventId(): <Error class: unknown class><<Error class: unknown class>, String>

Retrieves the last processed event ID from the storage.

liveEvents

abstract suspend fun liveEvents(): <Error class: unknown class><<Error class: unknown class>, <Error class: unknown class><<Error class: unknown class><Unit>>>

observeEvents

abstract suspend fun observeEvents(): <Error class: unknown class><List<EventEnvelope>>

parseExternalEvents

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

Parse events from an external JSON payload

updateLastProcessedEventId

abstract suspend fun updateLastProcessedEventId(eventId: String): <Error class: unknown class><<Error class: unknown class>, Unit>