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

RoomStateStore

class RoomStateStore(roomStateRepository: RoomStateRepository, tm: RepositoryTransactionManager, contentMappings: EventContentSerializerMappings, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock) : Store

Constructors

constructor(roomStateRepository: RoomStateRepository, tm: RepositoryTransactionManager, contentMappings: EventContentSerializerMappings, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock)

Functions

open suspend override fun clearCache()

Only deletes everything, that can be fetched from server.

open suspend override fun deleteAll()

Deletes everything.

suspend fun deleteByRoomId(roomId: RoomId)

fun <C : StateEventContent> get(roomId: RoomId, eventContentClass: KClass<C>): Flow<Map<String, Flow<ClientEvent.StateBaseEvent<C>?>>>

inline fun <C : StateEventContent> RoomStateStore.get(roomId: RoomId): Flow<Map<String, Flow<ClientEvent.StateBaseEvent<C>?>>>

suspend fun <C : StateEventContent> getByRooms(roomIds: Set<RoomId>, eventContentClass: KClass<C>, stateKey: String): List<ClientEvent.StateBaseEvent<C>>

inline suspend fun <C : StateEventContent> RoomStateStore.getByRooms(roomIds: Set<RoomId>, stateKey: String = ""): List<ClientEvent.StateBaseEvent<C>>

fun <C : StateEventContent> getByStateKey(roomId: RoomId, eventContentClass: KClass<C>, stateKey: String): Flow<ClientEvent.StateBaseEvent<C>?>

inline fun <C : StateEventContent> RoomStateStore.getByStateKey(roomId: RoomId, stateKey: String = ""): Flow<ClientEvent.StateBaseEvent<C>?>

getContentByStateKey

inline fun <C : StateEventContent> RoomStateStore.getContentByStateKey(roomId: RoomId, stateKey: String = ""): Flow<C?>

open suspend fun init(coroutineScope: CoroutineScope)

suspend fun RoomStateStore.members(roomId: RoomId, memberships: Set<Membership>): Set<UserId>

suspend fun RoomStateStore.membersCount(roomId: RoomId, membership: Membership, vararg moreMemberships: Membership): Long

suspend fun save(event: ClientEvent.StateBaseEvent<*>, skipWhenAlreadyPresent: Boolean = false)