logic/com.wire.kalium.logic.sync

Package-level declarations

Types

This class is responsible for reporting the current sync state to AVS. It is used to report the start and end of the incremental sync. Main reason for it is to let AVS know that the app is syncing and it should not send incoming call callbacks for those pending events

AvsSyncStateReporterImpl

internal class AvsSyncStateReporterImpl(val callManager: <Error class: unknown class><CallManager>, val incrementalSyncRepository: IncrementalSyncRepository, kaliumLogger: <Error class: unknown class>) : AvsSyncStateReporter

DefaultWorker

interface DefaultWorker

ForegroundNotificationDetailsProvider

interface ForegroundNotificationDetailsProvider

Provide resources that will be displayed when Kalium needs to display a Foreground notification due to some work being done.

GlobalWorkScheduler

interface GlobalWorkScheduler : UpdateApiVersionsScheduler

GlobalWorkSchedulerImpl

internal expect class GlobalWorkSchedulerImpl : GlobalWorkScheduler

internal actual class GlobalWorkSchedulerImpl(coreLogic: CoreLogic) : GlobalWorkScheduler

KaliumSyncException

class KaliumSyncException(message: String, val coreFailureCause: CoreFailure)

MissingMetadataUpdateManager

internal interface MissingMetadataUpdateManager

This class is responsible for checking if there are any users or conversations without metadata and if so, it will refresh them.

MissingMetadataUpdateManagerImpl

internal class MissingMetadataUpdateManagerImpl(incrementalSyncRepository: IncrementalSyncRepository, refreshUsersWithoutMetadata: <Error class: unknown class><RefreshUsersWithoutMetadataUseCase>, refreshConversationsWithoutMetadata: <Error class: unknown class><RefreshConversationsWithoutMetadataUseCase>, timestampKeyRepository: <Error class: unknown class><TimestampKeyRepository>, kaliumDispatcher: <Error class: unknown class> = KaliumDispatcherImpl) : MissingMetadataUpdateManager

ObserveSyncStateUseCase

interface ObserveSyncStateUseCase

Allows observing of SyncState. A value is always available immediately for new observers. Assumes that old SyncStates are not relevant anymore, so the available Flow has a limited buffer size and will drop the oldest values as there's no point in waiting for slow collectors. In case a slow collector is interested in receiving all values, it should add a buffer of its own.

ObserveSyncStateUseCaseImpl

internal class ObserveSyncStateUseCaseImpl(slowSyncRepository: SlowSyncRepository, incrementalSyncRepository: IncrementalSyncRepository) : ObserveSyncStateUseCase

PendingMessagesSenderWorker

internal class PendingMessagesSenderWorker(messageRepository: MessageRepository, messageSender: MessageSender, userId: <Error class: unknown class>) : DefaultWorker

This worker attempts to send all pending messages created by this user.

Result

sealed class Result

SetConnectionPolicyUseCase

class SetConnectionPolicyUseCase(incrementalSyncRepository: IncrementalSyncRepository)

SyncExceptionHandler

internal class SyncExceptionHandler(onCancellation: () -> Unit, onFailure: (exception: CoreFailure) -> Unit)

SyncManager

interface SyncManager

SyncManagerImpl

internal class SyncManagerImpl(slowSyncRepository: SlowSyncRepository, incrementalSyncRepository: IncrementalSyncRepository, logger: <Error class: unknown class> = kaliumLogger) : SyncManager

SyncManagerLogger

internal class SyncManagerLogger(logger: <Error class: unknown class>, syncId: String, syncType: SyncType, syncStartedMoment: <Error class: unknown class>)

Logs the sync process by providing structured logs. It logs the sync process start and completion with the syncId as a unique identifier.

SyncStatus

internal enum SyncStatus : Enum<SyncStatus>

SyncType

internal enum SyncType : Enum<SyncType>

UserSessionWorkScheduler

interface UserSessionWorkScheduler : MessageSendingScheduler

UserSessionWorkSchedulerImpl

internal expect class UserSessionWorkSchedulerImpl : UserSessionWorkScheduler

internal actual class UserSessionWorkSchedulerImpl(val userId: <Error class: unknown class>) : UserSessionWorkScheduler

WrapperWorker

class WrapperWorker(innerWorker: DefaultWorker, appContext: <Error class: unknown class>, params: <Error class: unknown class>, foregroundNotificationDetailsProvider: ForegroundNotificationDetailsProvider)

WrapperWorkerFactory

class WrapperWorkerFactory(coreLogic: CoreLogic, foregroundNotificationDetailsProvider: ForegroundNotificationDetailsProvider)

Functions

provideNewSyncManagerLogger

internal fun <Error class: unknown class>.provideNewSyncManagerLogger(syncType: SyncType, syncId: String = uuid4().toString(), syncStartedMoment: <Error class: unknown class> = Clock.System.now()): <Error class: unknown class>

Provides a new SyncManagerLogger instance with the given parameters.