update pinned messages by system messages

Signed-off-by: Marcel Hibbe <dev@mhibbe.de>

Author: mahibi

app/src/main/java/com/nextcloud/talk/chat/data/ChatMessageRepository.kt

@@ -40,6 +40,8 @@ interface ChatMessageRepository : LifecycleAwareManager {
 
     val lastReadMessageFlow: Flow<Int>
 
+    val roomRefreshFlow: Flow<Unit>
+
     // /**
     //  * Used for informing the user of the underlying processing behind offline support, [String] is the key
     //  * which is handled in a switch statement in ChatActivity.

app/src/main/java/com/nextcloud/talk/chat/data/network/OfflineFirstChatRepository.kt

@@ -99,6 +99,11 @@ class OfflineFirstChatRepository @Inject constructor(
     private val _lastReadMessageFlow:
         MutableSharedFlow<Int> = MutableSharedFlow()
 
+    override val roomRefreshFlow: Flow<Unit>
+        get() = _roomRefreshFlow
+
+    private val _roomRefreshFlow: MutableSharedFlow<Unit> = MutableSharedFlow()
+
     // override val generalUIFlow: Flow<String>
     //     get() = _generalUIFlow
     //
@@ -729,6 +734,7 @@ class OfflineFirstChatRepository @Inject constructor(
     }
 
     private suspend fun handleSystemMessagesThatAffectDatabase(messagesJson: List<ChatMessageJson>) {
+        var hasPinnedMessageChange = false
         messagesJson.forEach { messageJson ->
             when (messageJson.systemMessageType) {
                 ChatMessage.SystemMessageType.REACTION,
@@ -754,9 +760,13 @@ class OfflineFirstChatRepository @Inject constructor(
                     chatBlocksDao.deleteChatBlocksOlderThan(internalConversationId, messageJson.id)
                 }
 
+                ChatMessage.SystemMessageType.MESSAGE_PINNED,
+                ChatMessage.SystemMessageType.MESSAGE_UNPINNED -> hasPinnedMessageChange = true
+
                 else -> {}
             }
         }
+        if (hasPinnedMessageChange) _roomRefreshFlow.emit(Unit)
     }
 
     // the parent message is always the newest state, no matter how old the system message is.

app/src/main/java/com/nextcloud/talk/chat/viewmodels/ChatViewModel.kt

@@ -77,6 +77,7 @@ import kotlinx.coroutines.flow.StateFlow
 import kotlinx.coroutines.flow.asSharedFlow
 import kotlinx.coroutines.flow.catch
 import kotlinx.coroutines.flow.combine
+import kotlinx.coroutines.flow.debounce
 import kotlinx.coroutines.flow.distinctUntilChanged
 import kotlinx.coroutines.flow.distinctUntilChangedBy
 import kotlinx.coroutines.flow.filterNotNull
@@ -438,6 +439,7 @@ class ChatViewModel @AssistedInject constructor(
         observeMessages()
         observeMediaPlayerProgressForCompose()
         observePinnedMessage()
+        observeRoomRefresh()
     }
 
     private fun observeMediaPlayerProgressForCompose() {
@@ -569,6 +571,13 @@ class ChatViewModel @AssistedInject constructor(
             .launchIn(viewModelScope)
     }
 
+    private fun observeRoomRefresh() {
+        chatRepository.roomRefreshFlow
+            .debounce(ROOM_REFRESH_DEBOUNCE_MS)
+            .onEach { getRoom(chatRoomToken) }
+            .launchIn(viewModelScope)
+    }
+
     // val lastCommonReadMessageId = getLastCommonReadFlow.first()
 
     // ------------------------------
@@ -1747,6 +1756,7 @@ class ChatViewModel @AssistedInject constructor(
         const val HTTP_CODE_OK: Int = 200
         private const val WEBSOCKET_CONNECT_TIMEOUT_MS = 3000L
         private const val WEBSOCKET_POLL_INTERVAL_MS = 50L
+        private const val ROOM_REFRESH_DEBOUNCE_MS = 500L
     }
 
     sealed class OutOfOfficeUIState {