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

EventDataSource

class EventDataSource(notificationApi: <Error class: unknown class>, metadataDAO: <Error class: unknown class>, eventDAO: <Error class: unknown class>, currentClientId: CurrentClientIdProvider, selfUserId: <Error class: unknown class>, clientRegistrationStorage: <Error class: unknown class>, eventMapper: EventMapper = MapperProvider.eventMapper(selfUserId)) : EventRepository

Constructors

EventDataSource

constructor(notificationApi: <Error class: unknown class>, metadataDAO: <Error class: unknown class>, eventDAO: <Error class: unknown class>, currentClientId: CurrentClientIdProvider, selfUserId: <Error class: unknown class>, clientRegistrationStorage: <Error class: unknown class>, eventMapper: EventMapper = MapperProvider.eventMapper(selfUserId))

Functions

acknowledgeMissedEvent

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

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

clearLastSavedEventId

open suspend override fun clearLastSavedEventId(): <Error class: unknown class><<Error class: unknown class>, Unit>

Clears the last saved event ID.

fetchEvents

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

fetchMostRecentEventId

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

fetchOldestAvailableEventId

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

Fetches the oldest available event ID from remote.

fetchServerTime

open suspend override fun fetchServerTime(): String?

lastSavedEventId

open suspend override fun lastSavedEventId(): <Error class: unknown class><<Error class: unknown class>, String>

Retrieves the last saved event ID from the storage.

liveEvents

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

observeEvents

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

parseExternalEvents

open override fun parseExternalEvents(data: String): List<EventEnvelope>

Parse events from an external JSON payload

setEventAsProcessed

open suspend override fun setEventAsProcessed(eventId: String): <Error class: unknown class><<Error class: unknown class>, Unit>

updateLastSavedEventId

open suspend override fun updateLastSavedEventId(eventId: String): <Error class: unknown class><<Error class: unknown class>, Unit>

Updates the last saved event ID.