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

EventDataSource

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

Constructors

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

Functions

Link copied to clipboard
open suspend override fun acknowledgeEvent(eventEnvelope: EventEnvelope): <Error class: unknown class><<Error class: unknown class>, Unit>

Performs an acknowledgment of the event. In case a legacy event is received, it will be ignored.

Link copied to clipboard
open suspend override fun clearLastProcessedEventId(): <Error class: unknown class><<Error class: unknown class>, Unit>

Clears the last processed event ID.

Link copied to clipboard
open suspend override fun fetchMostRecentEventId(): <Error class: unknown class><<Error class: unknown class>, String>
Link copied to clipboard
open suspend override fun fetchOldestAvailableEventId(): <Error class: unknown class><<Error class: unknown class>, String>

Fetches the oldest available event ID from remote.

Link copied to clipboard
open suspend override fun fetchServerTime(): String?
Link copied to clipboard
open suspend override fun lastProcessedEventId(): <Error class: unknown class><<Error class: unknown class>, String>

Retrieves the last processed event ID from the storage.

Link copied to clipboard
open suspend override fun liveEvents(): <Error class: unknown class><<Error class: unknown class>, <Error class: unknown class><<Error class: unknown class><EventEnvelope>>>
Link copied to clipboard
open override fun parseExternalEvents(data: String): List<EventEnvelope>

Parse events from an external JSON payload

Link copied to clipboard
open suspend override fun pendingEvents(): <Error class: unknown class><<Error class: unknown class><<Error class: unknown class>, EventEnvelope>>
Link copied to clipboard
open suspend override fun updateLastProcessedEventId(eventId: String): <Error class: unknown class>