EventDataSource

internal class EventDataSource(notificationApi: NotificationApi, metadataDAO: MetadataDAO, eventDAO: EventDAO, currentClientId: CurrentClientIdProvider, selfUserId: UserId, clientRegistrationStorage: ClientRegistrationStorage, restartSlowSyncProcessForRecovery: RestartSlowSyncProcessForRecoveryUseCase, eventMapper: EventMapper = MapperProvider.eventMapper(selfUserId), logger: KaliumLogger) : EventRepository

Constructors

constructor(notificationApi: NotificationApi, metadataDAO: MetadataDAO, eventDAO: EventDAO, currentClientId: CurrentClientIdProvider, selfUserId: UserId, clientRegistrationStorage: ClientRegistrationStorage, restartSlowSyncProcessForRecovery: RestartSlowSyncProcessForRecoveryUseCase, eventMapper: EventMapper = MapperProvider.eventMapper(selfUserId), logger: KaliumLogger)

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

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

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

Clears the last saved event ID.

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

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

Fetches the oldest available event ID from remote.

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

Retrieves the last saved event ID from the storage.

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

open override fun observeEvents(): Flow<List<EventEnvelope>>

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

Parse events from an external JSON payload

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

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

open override fun setUnprocessedEventsBatchLimit(limit: Int?)

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

Updates the last saved event ID.