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

OlmCryptoStore

class OlmCryptoStore(olmAccountRepository: OlmAccountRepository, olmForgetFallbackKeyAfterRepository: OlmForgetFallbackKeyAfterRepository, olmSessionRepository: OlmSessionRepository, inboundMegolmSessionRepository: InboundMegolmSessionRepository, inboundMegolmMessageIndexRepository: InboundMegolmMessageIndexRepository, outboundMegolmSessionRepository: OutboundMegolmSessionRepository, tm: RepositoryTransactionManager, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock) : Store

Constructors

constructor(olmAccountRepository: OlmAccountRepository, olmForgetFallbackKeyAfterRepository: OlmForgetFallbackKeyAfterRepository, olmSessionRepository: OlmSessionRepository, inboundMegolmSessionRepository: InboundMegolmSessionRepository, inboundMegolmMessageIndexRepository: InboundMegolmMessageIndexRepository, outboundMegolmSessionRepository: OutboundMegolmSessionRepository, tm: RepositoryTransactionManager, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock)

Properties

notBackedUpInboundMegolmSessions

val notBackedUpInboundMegolmSessions: StateFlow<Map<InboundMegolmSessionRepositoryKey, StoredInboundMegolmSession>>

Functions

open suspend override fun clearCache()

Only deletes everything, that can be fetched from server.

open suspend override fun deleteAll()

Deletes everything.

getForgetFallbackKeyAfter

suspend fun getForgetFallbackKeyAfter(): Flow<Instant?>

getInboundMegolmSession

fun getInboundMegolmSession(sessionId: String, roomId: RoomId): Flow<StoredInboundMegolmSession?>

suspend fun getOlmAccount(): String?

getOutboundMegolmSession

suspend fun getOutboundMegolmSession(roomId: RoomId): StoredOutboundMegolmSession?

open suspend override fun init(coroutineScope: CoroutineScope)

updateForgetFallbackKeyAfter

suspend fun updateForgetFallbackKeyAfter(updater: suspend (Instant?) -> Instant?)

updateInboundMegolmMessageIndex

suspend fun updateInboundMegolmMessageIndex(sessionId: String, roomId: RoomId, messageIndex: Long, updater: suspend (oldMegolmSessionIndex: StoredInboundMegolmMessageIndex?) -> StoredInboundMegolmMessageIndex?)

updateInboundMegolmSession

suspend fun updateInboundMegolmSession(sessionId: String, roomId: RoomId, updater: suspend (oldInboundMegolmSession: StoredInboundMegolmSession?) -> StoredInboundMegolmSession?)

updateOlmAccount

suspend fun updateOlmAccount(updater: suspend (String?) -> String)

updateOlmSessions

suspend fun updateOlmSessions(senderKey: KeyValue.Curve25519KeyValue, updater: suspend (oldSessions: Set<StoredOlmSession>?) -> Set<StoredOlmSession>?)

updateOutboundMegolmSession

suspend fun updateOutboundMegolmSession(roomId: RoomId, updater: suspend (oldOutboundMegolmSession: StoredOutboundMegolmSession?) -> StoredOutboundMegolmSession?)

waitForInboundMegolmSession

suspend fun OlmCryptoStore.waitForInboundMegolmSession(roomId: RoomId, sessionId: String, firstKnownIndexLessThen: Long? = null, onNotExisting: suspend CoroutineScope.() -> Unit? = null)