logic/com.wire.kalium.logic.sync.slow

Package-level declarations

Types

NoOpSyncNomadMessagesDuringSlowSyncUseCase

internal data object NoOpSyncNomadMessagesDuringSlowSyncUseCase : SyncNomadMessagesDuringSlowSyncUseCase

OnSlowSyncRetryCallback

internal fun interface OnSlowSyncRetryCallback

RestartSlowSyncProcessForRecoveryUseCase

interface RestartSlowSyncProcessForRecoveryUseCase

Restart slowSync process for recovery.

RestartSlowSyncProcessForRecoveryUseCaseImpl

internal class RestartSlowSyncProcessForRecoveryUseCaseImpl(slowSyncRepository: SlowSyncRepository) : RestartSlowSyncProcessForRecoveryUseCase

SlowSlowSyncCriteriaProviderImpl

internal class SlowSlowSyncCriteriaProviderImpl(clientRepository: ClientRepository, logoutRepository: LogoutRepository) : SlowSyncCriteriaProvider

SlowSyncCriteriaProvider

internal interface SlowSyncCriteriaProvider

Ingests multiple signals across the logic module to signal if Sync should start or not.

SlowSyncManager

internal interface SlowSyncManager

internal sealed interface SlowSyncParam

SlowSyncRecoveryHandler

internal interface SlowSyncRecoveryHandler

SlowSyncRecoveryHandlerImpl

internal class SlowSyncRecoveryHandlerImpl(logoutUseCase: LogoutUseCase) : SlowSyncRecoveryHandler

internal interface SlowSyncWorker

SlowSyncWorkerImpl

internal class SlowSyncWorkerImpl(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, syncSelfUser: SyncSelfUserUseCase, syncUserProperties: SyncUserPropertiesUseCase, syncFeatureConfigs: SyncFeatureConfigsUseCase, updateSupportedProtocols: UpdateSelfUserSupportedProtocolsUseCase, syncConversations: SyncConversationsUseCase, syncConnections: SyncConnectionsUseCase, syncSelfTeam: SyncSelfTeamUseCase, syncContacts: SyncContactsUseCase, joinMLSConversations: JoinExistingMLSConversationsUseCase, fetchLegalHoldForSelfUserFromRemoteUseCase: FetchLegalHoldForSelfUserFromRemoteUseCase, oneOnOneResolver: OneOnOneResolver, transactionProvider: CryptoTransactionProvider, optimizer: OptimizeDatabaseUseCase, syncNomadMessagesDuringSlowSync: SyncNomadMessagesDuringSlowSyncUseCase = NoOpSyncNomadMessagesDuringSlowSyncUseCase, syncMeetings: SyncMeetingsUseCase, logger: KaliumLogger = kaliumLogger) : SlowSyncWorker

SyncCriteriaResolution

internal interface SyncCriteriaResolution

A signal that represents the resolution of all the needed for sync to happen.

SyncNomadMessagesDuringSlowSyncUseCase

internal interface SyncNomadMessagesDuringSlowSyncUseCase

SyncNomadMessagesDuringSlowSyncUseCaseImpl

internal class SyncNomadMessagesDuringSlowSyncUseCaseImpl(selfUserId: UserId, nomadServiceUrl: String?, userStorageProvider: UserStorageProvider, userAuthenticatedNetworkProvider: UserAuthenticatedNetworkProvider, logger: KaliumLogger) : SyncNomadMessagesDuringSlowSyncUseCase

Functions

SlowSyncManager

internal fun SlowSyncManager(slowSyncCriteriaProvider: SlowSyncCriteriaProvider, slowSyncRepository: SlowSyncRepository, slowSyncWorker: SlowSyncWorker, slowSyncRecoveryHandler: SlowSyncRecoveryHandler, networkStateObserver: NetworkStateObserver, syncMigrationStepsProvider: () -> SyncMigrationStepsProvider, userScopedLogger: KaliumLogger, apiVersion: Int, exponentialDurationHelper: ExponentialDurationHelper = ExponentialDurationHelper( SlowSyncManager.MIN_RETRY_DELAY, SlowSyncManager.MAX_RETRY_DELAY )): SlowSyncManager

Starts and stops SlowSync based on a set of criteria, defined in SlowSyncCriteriaProvider. Once the criteria are met, this Manager will take care of running SlowSync.