logic/com.wire.kalium.logic.feature

Package-level declarations

Types

class AccountBusyException(val holder: String?) : IllegalStateException

Apple only: another process, such as an app extension, kept the account past the app's wait for it. Nothing changed, and opening can be retried. holder is what that process recorded when it took the account, for logs.

CachedClientIdClearer

internal fun interface CachedClientIdClearer

LocalVideoPreviewAttachment

expect class LocalVideoPreviewAttachment

A local preview stays attached until detach. Capture starts only after startCapture. Capture and call video-send state are separate; detach stops capture before removing the view.

actual class LocalVideoPreviewAttachment(owner: LocalVideoPreviewAttachmentOwner, val view: PlatformView)

A local preview stays attached until detach. Capture starts only after startCapture. Capture and call video-send state are separate; detach stops capture before removing the view.

LocalVideoPreviewAttachmentOwner

internal class LocalVideoPreviewAttachmentOwner(attachNative: (PlatformView) -> Boolean, detachNative: (PlatformView) -> Boolean, startNativeCapture: () -> Unit, stopNativeCapture: () -> Unit)

RemoteVideoViewAttachment

expect class RemoteVideoViewAttachment

Owns one native remote view attachment. detach releases only this attachment and runs on the main dispatcher. Repeated detach, or detach after the same view has been rebound, does nothing. A failed native detach throws and leaves the attachment owned so the caller can retry.

actual class RemoteVideoViewAttachment(owner: RemoteVideoViewAttachmentOwner, val view: PlatformView, val userId: String, val clientId: String)

RemoteVideoViewAttachmentOwner

internal class RemoteVideoViewAttachmentOwner(attachNative: (PlatformView, String, String) -> Boolean, detachNative: (PlatformView) -> Boolean)

TimestampKeyRepository

internal interface TimestampKeyRepository

TimestampKeyRepositoryImpl

internal class TimestampKeyRepositoryImpl(metadataDAO: MetadataDAO) : TimestampKeyRepository

TimestampKeys

internal enum TimestampKeys : Enum<TimestampKeys>

UserSessionScope

class UserSessionScope(userAgent: String, val userId: UserId, globalScope: GlobalKaliumScope, val globalCallManager: GlobalCallManager, globalDatabaseBuilder: GlobalDatabaseBuilder, globalPreferences: GlobalPrefProvider, authenticationScopeProvider: AuthenticationScopeProvider, val rootPathsProvider: RootPathsProvider, dataStoragePaths: DataStoragePaths, val kaliumConfigs: KaliumConfigs, userSessionScopeProvider: UserSessionScopeProvider, userStorageProvider: UserStorageProvider, userAuthenticatedNetworkProvider: UserAuthenticatedNetworkProvider, clientConfig: ClientConfig, platformUserStorageProperties: PlatformUserStorageProperties, networkStateObserver: NetworkStateObserver, logoutCallback: LogoutCallback, syncShutdownCoordinator: SyncShutdownCoordinator, enableDurableMLSReceiveRecovery: Boolean = false, resourceAccess: AccountResourceAccess? = null, coreCryptoCentralFactory: suspend (String, ByteArray) -> CoreCryptoCentral = { root, key -> com.wire.kalium.cryptography.coreCryptoCentral(root, key) }) : CoroutineScope

UserSessionScopeProvider

internal interface UserSessionScopeProvider

UserSessionScopeProviderCommon

internal abstract class UserSessionScopeProviderCommon(globalCallManager: GlobalCallManager, userStorageProvider: UserStorageProvider, removeAuthenticatedNetworkForUser: suspend (UserId) -> Unit, userAgent: String) : UserSessionScopeProvider

UserSessionScopeProviderImpl

internal actual open class UserSessionScopeProviderImpl : UserSessionScopeProviderCommon, UserSessionScopeProvider

internal expect class UserSessionScopeProviderImpl : UserSessionScopeProvider

internal actual open class UserSessionScopeProviderImpl : UserSessionScopeProviderCommon, UserSessionScopeProvider

Functions

attachLocalVideoPreview

expect suspend fun UserSessionScope.attachLocalVideoPreview(view: PlatformView): LocalVideoPreviewAttachment

Attach one plain native view as the local camera preview. The caller owns its lifetime. Do not pass AVSVideoPreview, which attaches itself when added to a window.

actual suspend fun UserSessionScope.attachLocalVideoPreview(view: PlatformView): LocalVideoPreviewAttachment

Attach one plain native view as the local camera preview. The caller owns its lifetime. Do not pass AVSVideoPreview, which attaches itself when added to a window.

attachRemoteVideoView

expect suspend fun UserSessionScope.attachRemoteVideoView(participantId: QualifiedID, clientId: String, view: PlatformView): RemoteVideoViewAttachment

Attach an iOS AVSVideoView to one remote client's stream. The caller owns the view lifetime. Different native views remain attached independently, including views of the same stream. Reattaching the same native view and stream returns its existing lease, even through another PlatformView wrapper. Rebinding that view to another stream detaches its previous attachment and invalidates the old lease. If that detach fails, the previous attachment remains owned and the new stream is not attached. If the new attach fails after detach succeeds, that view remains detached. Other views are unaffected. Operations run on the main dispatcher. The caller must detach each returned lease when its view disappears.

actual suspend fun UserSessionScope.attachRemoteVideoView(participantId: QualifiedID, clientId: String, view: PlatformView): RemoteVideoViewAttachment

getProxyCredentials

internal fun SessionManager.getProxyCredentials(): ProxyCredentials?

getServerConfig

internal fun SessionManager.getServerConfig(): ServerConfig

retryWhileAccountBusy

internal fun <T> Flow<T>.retryWhileAccountBusy(): Flow<T>

Observations that open every account keep going, with their last values, until another process lets go.

UserSessionScope

internal fun UserSessionScope(applicationContext: Context, userAgent: String, userId: UserId, globalScope: GlobalKaliumScope, globalDatabaseBuilder: GlobalDatabaseBuilder, globalCallManager: GlobalCallManager, globalPreferences: GlobalPrefProvider, authenticationScopeProvider: AuthenticationScopeProvider, rootPathsProvider: RootPathsProvider, dataStoragePaths: DataStoragePaths, kaliumConfigs: KaliumConfigs, userStorageProvider: UserStorageProvider, userAuthenticatedNetworkProvider: UserAuthenticatedNetworkProvider, userSessionScopeProvider: UserSessionScopeProvider, networkStateObserver: NetworkStateObserver, logoutCallback: LogoutCallback, syncShutdownCoordinator: SyncShutdownCoordinator): UserSessionScope

internal fun UserSessionScope(platformUserStorageProperties: PlatformUserStorageProperties, userId: UserId, globalScope: GlobalKaliumScope, globalCallManager: GlobalCallManager, globalPreferences: GlobalPrefProvider, globalDatabaseBuilder: GlobalDatabaseBuilder, authenticationScopeProvider: AuthenticationScopeProvider, rootPathsProvider: RootPathsProvider, dataStoragePaths: DataStoragePaths, kaliumConfigs: KaliumConfigs, userStorageProvider: UserStorageProvider, userAuthenticatedNetworkProvider: UserAuthenticatedNetworkProvider, userSessionScopeProvider: UserSessionScopeProvider, networkStateObserver: NetworkStateObserver, logoutCallback: LogoutCallback, userAgent: String, syncShutdownCoordinator: SyncShutdownCoordinator, coreCryptoCentralFactory: suspend (String, ByteArray) -> CoreCryptoCentral = { root, key -> com.wire.kalium.cryptography.coreCryptoCentral(root, key) }): UserSessionScope