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

NotificationStore

class NotificationStore(notificationRepository: NotificationRepository, notificationUpdateRepository: NotificationUpdateRepository, notificationStateRepository: NotificationStateRepository, tm: RepositoryTransactionManager, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock) : Store

Constructors

NotificationStore

constructor(notificationRepository: NotificationRepository, notificationUpdateRepository: NotificationUpdateRepository, notificationStateRepository: NotificationStateRepository, tm: RepositoryTransactionManager, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock)

Functions

open suspend override fun clearCache()

Only deletes everything, that can be fetched from server.

suspend fun delete(id: String)

open suspend override fun deleteAll()

Deletes everything.

suspend fun deleteByRoomId(roomId: RoomId)

deleteNotificationsByRoomId

suspend fun deleteNotificationsByRoomId(roomId: RoomId)

deleteNotificationStateByRoomId

suspend fun deleteNotificationStateByRoomId(roomId: RoomId)

deleteNotificationUpdatesByRoomId

suspend fun deleteNotificationUpdatesByRoomId(roomId: RoomId)

fun getAll(): Flow<Map<String, Flow<StoredNotification?>>>

fun getAllState(): Flow<Map<RoomId, Flow<StoredNotificationState?>>>

fun getAllUpdates(): Flow<Map<String, Flow<StoredNotificationUpdate?>>>

fun getById(id: String): Flow<StoredNotification?>

open suspend fun init(coroutineScope: CoroutineScope)

suspend fun save(value: StoredNotification)

suspend fun save(id: String, value: StoredNotification?)

suspend fun saveAllUpdates(values: List<StoredNotificationUpdate>)

suspend fun update(id: String, updater: suspend (oldNotification: StoredNotification?) -> StoredNotification?)

suspend fun updateState(roomId: RoomId, updater: suspend (oldNotificationState: StoredNotificationState?) -> StoredNotificationState?)

suspend fun updateUpdate(id: String, updater: suspend (oldNotificationUpdate: StoredNotificationUpdate?) -> StoredNotificationUpdate?)