taking into account redactions and updating the message list

domains/store/src/main/kotlin/app/dapk/st/domain/sync/RoomPersistence.kt

@@ -27,10 +27,10 @@ internal class RoomPersistence(
     private val coroutineDispatchers: CoroutineDispatchers,
 ) : RoomStore {
 
-    override suspend fun persist(roomId: RoomId, state: RoomState) {
+    override suspend fun persist(roomId: RoomId, events: List<RoomEvent>) {
         coroutineDispatchers.withIoContext {
             database.transaction {
-                state.events.forEach {
+                events.forEach {
                     database.roomEventQueries.insertRoomEvent(roomId, it)
                 }
             }
@@ -38,9 +38,16 @@ internal class RoomPersistence(
     }
 
     override suspend fun remove(rooms: List<RoomId>) {
-        coroutineDispatchers
-        database.roomEventQueries.transaction {
-            rooms.forEach { database.roomEventQueries.remove(it.value) }
+        coroutineDispatchers.withIoContext {
+            database.roomEventQueries.transaction {
+                rooms.forEach { database.roomEventQueries.remove(it.value) }
+            }
+        }
+    }
+
+    override suspend fun remove(eventId: EventId) {
+        coroutineDispatchers.withIoContext {
+            database.roomEventQueries.removeEvent(eventId.value)
         }
     }
 

domains/store/src/main/sqldelight/app/dapk/db/model/RoomEvent.sq

@@ -36,4 +36,8 @@ LIMIT 100;
 
 remove:
 DELETE FROM dbRoomEvent
-WHERE room_id = ?;
+WHERE room_id = ?;
+
+removeEvent:
+DELETE FROM dbRoomEvent
+WHERE event_id = ?;

matrix/services/sync/src/main/kotlin/app/dapk/st/matrix/sync/RoomState.kt

@@ -35,6 +35,7 @@ sealed class RoomEvent {
         @SerialName("meta") override val meta: MessageMeta,
         @SerialName("encrypted_content") val encryptedContent: MegOlmV1? = null,
         @SerialName("edited") val edited: Boolean = false,
+        @SerialName("redacted") val redacted: Boolean = false,
     ) : RoomEvent() {
 
         @Serializable

matrix/services/sync/src/main/kotlin/app/dapk/st/matrix/sync/Store.kt

@@ -7,8 +7,9 @@ import kotlinx.coroutines.flow.Flow
 
 interface RoomStore {
 
-    suspend fun persist(roomId: RoomId, state: RoomState)
+    suspend fun persist(roomId: RoomId, events: List<RoomEvent>)
     suspend fun remove(rooms: List<RoomId>)
+    suspend fun remove(eventId: EventId)
     suspend fun retrieve(roomId: RoomId): RoomState?
     fun latest(roomId: RoomId): Flow<RoomState>
     suspend fun insertUnread(roomId: RoomId, eventIds: List<EventId>)

matrix/services/sync/src/main/kotlin/app/dapk/st/matrix/sync/internal/sync/RoomDataSource.kt

@@ -1,9 +1,7 @@
 package app.dapk.st.matrix.sync.internal.sync
 
-import app.dapk.st.matrix.common.MatrixLogTag
-import app.dapk.st.matrix.common.MatrixLogger
-import app.dapk.st.matrix.common.RoomId
-import app.dapk.st.matrix.common.matrixLog
+import app.dapk.st.matrix.common.*
+import app.dapk.st.matrix.sync.RoomEvent
 import app.dapk.st.matrix.sync.RoomState
 import app.dapk.st.matrix.sync.RoomStore
 
@@ -26,7 +24,7 @@ class RoomDataSource(
             logger.matrixLog(MatrixLogTag.SYNC, "no changes, not persisting")
         } else {
             roomCache[roomId] = newState
-            roomStore.persist(roomId, newState)
+            roomStore.persist(roomId, newState.events)
         }
     }
 
@@ -34,4 +32,35 @@ class RoomDataSource(
         roomsLeft.forEach { roomCache.remove(it) }
         roomStore.remove(roomsLeft)
     }
+
+    suspend fun redact(roomId: RoomId, event: EventId) {
+        val eventToRedactFromCache = roomCache[roomId]?.events?.find { it.eventId == event }
+        val redactedEvent = when {
+            eventToRedactFromCache != null -> {
+                eventToRedactFromCache.redact().also { redacted ->
+                    val cachedRoomState = roomCache[roomId]
+                    requireNotNull(cachedRoomState)
+                    roomCache[roomId] = cachedRoomState.replaceEvent(eventToRedactFromCache, redacted)
+                }
+            }
+
+            else -> roomStore.findEvent(event)?.redact()
+        }
+
+        redactedEvent?.let { roomStore.persist(roomId, listOf(it)) }
+    }
+}
+
+private fun RoomEvent.redact() = when (this) {
+    is RoomEvent.Image -> RoomEvent.Message(this.eventId, this.utcTimestamp, "Redacted", this.author, this.meta, redacted = true)
+    is RoomEvent.Message -> RoomEvent.Message(this.eventId, this.utcTimestamp, "Redacted", this.author, this.meta, redacted = true)
+    is RoomEvent.Reply -> RoomEvent.Message(this.eventId, this.utcTimestamp, "Redacted", this.author, this.meta, redacted = true)
+}
+
+private fun RoomState.replaceEvent(old: RoomEvent, new: RoomEvent): RoomState {
+    val updatedEvents = this.events.toMutableList().apply {
+        remove(old)
+        add(new)
+    }
+    return this.copy(events = updatedEvents)
 }

matrix/services/sync/src/main/kotlin/app/dapk/st/matrix/sync/internal/sync/RoomProcessor.kt

@@ -21,6 +21,10 @@ internal class RoomProcessor(
         val members = roomToProcess.apiSyncRoom.collectMembers(roomToProcess.userCredentials)
         roomMembersService.insert(roomToProcess.roomId, members)
 
+        roomToProcess.apiSyncRoom.timeline.apiTimelineEvents.filterIsInstance<ApiTimelineEvent.RoomRedcation>().forEach {
+            roomDataSource.redact(roomToProcess.roomId, it.redactedId)
+        }
+
         val previousState = roomDataSource.read(roomToProcess.roomId)
 
         val (newEvents, distinctEvents) = timelineEventsProcessor.process(

matrix/services/sync/src/main/kotlin/app/dapk/st/matrix/sync/internal/sync/SyncReducer.kt

@@ -61,8 +61,6 @@ internal class SyncReducer(
             }
         }
 
-        roomDataSource.remove(roomsLeft)
-
         return ReducerResult(
             newRooms,
             (apiRoomsToProcess + roomsWithSideEffects).awaitAll().filterNotNull(),