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>, eventMapper: EventMapper = MapperProvider.eventMapper(selfUserId)) : EventRepository

Constructors

EventDataSource

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

Functions

clearLastProcessedEventId

open suspend override fun clearLastProcessedEventId(): Either<StorageFailure, Unit>

Clears the last processed event ID.

fetchMostRecentEventId

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

fetchOldestAvailableEventId

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

Fetches the oldest available event ID from remote.

fetchServerTime

open suspend override fun fetchServerTime(): String?

lastProcessedEventId

open suspend override fun lastProcessedEventId(): Either<StorageFailure, String>

Retrieves the last processed event ID from the storage.

liveEvents

open suspend override fun liveEvents(): Either<CoreFailure, <Error class: unknown class><<Error class: unknown class><EventEnvelope>>>

parseExternalEvents

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

Parse events from an external JSON payload

pendingEvents

open suspend override fun pendingEvents(): <Error class: unknown class><Either<CoreFailure, EventEnvelope>>

updateLastProcessedEventId

open suspend override fun updateLastProcessedEventId(eventId: String): <Error class: unknown class>