logic/com.wire.kalium.logic.data.prekey/PreKeyDataSource

PreKeyDataSource

internal class PreKeyDataSource(preKeyApi: PreKeyApi, proteusClientProvider: ProteusClientProvider, provideCurrentClientId: CurrentClientIdProvider, prekeyDAO: PrekeyDAO, clientDAO: ClientDAO, metadataDAO: MetadataDAO, preKeyListMapper: PreKeyListMapper = MapperProvider.preKeyListMapper(), preKeyMapper: PreKeyMapper = MapperProvider.preyKeyMapper()) : PreKeyRepository, CryptoSessionMapper

Constructors

PreKeyDataSource

constructor(preKeyApi: PreKeyApi, proteusClientProvider: ProteusClientProvider, provideCurrentClientId: CurrentClientIdProvider, prekeyDAO: PrekeyDAO, clientDAO: ClientDAO, metadataDAO: MetadataDAO, preKeyListMapper: PreKeyListMapper = MapperProvider.preKeyListMapper(), preKeyMapper: PreKeyMapper = MapperProvider.preyKeyMapper())

Functions

establishSessions

open suspend override fun establishSessions(proteusContext: ProteusCoreCryptoContext, missingContactClients: Map<UserId, List<ClientId>>): Either<CoreFailure, UsersWithoutSessions>

fetchRemotelyAvailablePrekeys

open suspend override fun fetchRemotelyAvailablePrekeys(): Either<CoreFailure, List<Int>>

Fetches the IDs of the prekeys currently available on the backend.

forceInsertMostRecentPreKeyId

open suspend override fun forceInsertMostRecentPreKeyId(newId: Int): Either<StorageFailure, Unit>

Forces the insert of the ID of the most recent "rolling" prekey that was generated. Useful

generateNewLastResortKey

open suspend override fun generateNewLastResortKey(): Either<ProteusFailure, PreKeyCrypto>

Also known as "last prekey", it's the prekey that the backend will share with other clients when it runs out of prekeys for this client. For "rolling" prekeys, see generateNewPreKeysAuto.

generateNewPreKeysAuto

open suspend override fun generateNewPreKeysAuto(keysCount: Int): Either<ProteusFailure, List<PreKeyCrypto>>

Generates rolling prekeys, with Core Crypto automatically selecting the next available prekey ID. The generated prekeys can be uploaded to the backend and shared with other clients in order to initialise a new conversation with this client.

getMapOfSessionIdsToPreKeysAndMarkNullClientsAsInvalid

open override fun getMapOfSessionIdsToPreKeysAndMarkNullClientsAsInvalid(preKeyInfoMap: Map<String, Map<String, Map<String, PreKeyDTO?>>>): FilteredRecipient

lastPreKeyRefillCheckInstantFlow

open override fun lastPreKeyRefillCheckInstantFlow(): Flow<Instant?>

Observes the last pre-key check instant.

mostRecentPreKeyId

open suspend override fun mostRecentPreKeyId(): Either<StorageFailure, Int>

Returns the ID of the most recent "rolling" prekey that was generated.

preKeysOfClientsByQualifiedUsers

internal suspend fun preKeysOfClientsByQualifiedUsers(qualifiedIdsMap: Map<UserId, List<ClientId>>): Either<NetworkFailure, ListPrekeysResponse>

setLastPreKeyRefillCheckInstant

open suspend override fun setLastPreKeyRefillCheckInstant(instant: Instant): Either<StorageFailure, Unit>

Sets the last prekey refill check date.

updateMostRecentPreKeyId

open suspend override fun updateMostRecentPreKeyId(newId: Int): Either<StorageFailure, Unit>

Updates the ID of the most recent "rolling" prekey that was generated.

uploadNewPrekeyBatch

open suspend override fun uploadNewPrekeyBatch(batch: List<PreKeyCrypto>): Either<CoreFailure, Unit>

Uploads a batch of prekeys to the backend, so they become available for other clients to start sessions with this client.