trixnity-client/de.connect2x.trixnity.client.store/KeyStore

KeyStore

class KeyStore(outdatedKeysRepository: OutdatedKeysRepository, deviceKeysRepository: DeviceKeysRepository, crossSigningKeysRepository: CrossSigningKeysRepository, keyVerificationStateRepository: KeyVerificationStateRepository, keyChainLinkRepository: KeyChainLinkRepository, secretsRepository: SecretsRepository, secretKeyRequestRepository: SecretKeyRequestRepository, roomKeyRequestRepository: RoomKeyRequestRepository, tm: RepositoryTransactionManager, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock) : Store

Constructors

KeyStore

constructor(outdatedKeysRepository: OutdatedKeysRepository, deviceKeysRepository: DeviceKeysRepository, crossSigningKeysRepository: CrossSigningKeysRepository, keyVerificationStateRepository: KeyVerificationStateRepository, keyChainLinkRepository: KeyChainLinkRepository, secretsRepository: SecretsRepository, secretKeyRequestRepository: SecretKeyRequestRepository, roomKeyRequestRepository: RoomKeyRequestRepository, tm: RepositoryTransactionManager, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock)

Types

SkipOutdatedKeys

object SkipOutdatedKeys : CoroutineContext.Element, CoroutineContext.Key<KeyStore.SkipOutdatedKeys>

This prevents deadlocks when no parallel write transactions are allowed, but a second transaction is needed to update outdated keys.

Functions

addRoomKeyRequest

suspend fun addRoomKeyRequest(request: StoredRoomKeyRequest)

addSecretKeyRequest

suspend fun addSecretKeyRequest(request: StoredSecretKeyRequest)

clearCache

open suspend override fun clearCache()

Only deletes everything, that can be fetched from server.

deleteAll

open suspend override fun deleteAll()

Deletes everything.

deleteCrossSigningKeys

suspend fun deleteCrossSigningKeys(userId: UserId)

deleteDeviceKeys

suspend fun deleteDeviceKeys(userId: UserId)

deleteKeyChainLinksBySignedKey

suspend fun deleteKeyChainLinksBySignedKey(userId: UserId, signedKey: Key.Ed25519Key)

deleteRoomKeyRequest

suspend fun deleteRoomKeyRequest(requestId: String)

deleteSecretKeyRequest

suspend fun deleteSecretKeyRequest(requestId: String)

getAllRoomKeyRequests

suspend fun getAllRoomKeyRequests(): List<StoredRoomKeyRequest>

getAllRoomKeyRequestsFlow

fun getAllRoomKeyRequestsFlow(): Flow<List<StoredRoomKeyRequest>>

getAllSecretKeyRequests

suspend fun getAllSecretKeyRequests(): List<StoredSecretKeyRequest>

getAllSecretKeyRequestsFlow

fun getAllSecretKeyRequestsFlow(): Flow<List<StoredSecretKeyRequest>>

getCrossSigningKeys

fun getCrossSigningKeys(userId: UserId): Flow<Set<StoredCrossSigningKeys>?>

getDeviceKeys

fun getDeviceKeys(userId: UserId): Flow<Map<String, StoredDeviceKeys>?>

getKeyChainLinksBySigningKey

suspend fun getKeyChainLinksBySigningKey(userId: UserId, signingKey: Key.Ed25519Key): Set<KeyChainLink>

getKeyVerificationState

suspend fun getKeyVerificationState(key: Key): KeyVerificationState?

getOutdatedKeys

suspend fun getOutdatedKeys(): Set<UserId>

getOutdatedKeysFlow

fun getOutdatedKeysFlow(): Flow<Set<UserId>>

getSecrets

suspend fun getSecrets(): Map<SecretType, StoredSecret>

getSecretsFlow

fun getSecretsFlow(): Flow<Map<SecretType, StoredSecret>>

init

open suspend fun init(coroutineScope: CoroutineScope)

saveDeviceKeys

suspend fun saveDeviceKeys(userId: UserId, deviceKeys: Map<String, StoredDeviceKeys>)

saveKeyChainLink

suspend fun saveKeyChainLink(keyChainLink: KeyChainLink)

saveKeyVerificationState

suspend fun saveKeyVerificationState(key: Key, state: KeyVerificationState)

updateCrossSigningKeys

suspend fun updateCrossSigningKeys(userId: UserId, updater: suspend (Set<StoredCrossSigningKeys>?) -> Set<StoredCrossSigningKeys>?)

updateDeviceKeys

suspend fun updateDeviceKeys(userId: UserId, updater: suspend (Map<String, StoredDeviceKeys>?) -> Map<String, StoredDeviceKeys>?)

updateOutdatedKeys

suspend fun updateOutdatedKeys(updater: suspend (Set<UserId>) -> Set<UserId>)

updateSecrets

suspend fun updateSecrets(updater: suspend (Map<SecretType, StoredSecret>) -> Map<SecretType, StoredSecret>)