chore: synchronize chat message event stream with chats in history controller for top level update

Signed-off-by: Brandon McAnsh <git@bmcreations.dev>

Author: bmc08gt

api/src/main/java/com/getcode/network/ConversationController.kt

@@ -131,6 +131,7 @@ class ConversationStreamController @Inject constructor(
                 val updates = result.getOrNull() ?: return@result
                 val (messages, pointers) = updates
 
+                historyController.updateChatWithMessages(chat, messages)
                 val messagesWithContent = messages.map {
                     messageWithContentMapper.map(chat.id to it)
                 }

api/src/main/java/com/getcode/network/HistoryController.kt

@@ -83,22 +83,26 @@ class HistoryController @Inject constructor(
             chat = _chats.value?.find { it.id == chatId },
             onMessagesFetched = { messages ->
                 val chat = _chats.value?.find { it.id == chatId } ?: return@ChatMessagePagingSource
-                val updatedMessages = (chat.messages + messages).distinctBy { it.id }
-                val updatedChat = chat.copy(messages = updatedMessages)
-                val chats = _chats.value?.map {
-                    if (it.id == updatedChat.id) {
-                        updatedChat
-                    } else {
-                        it
-                    }
-                }
-                _chats.update { chats }
+                updateChatWithMessages(chat, messages)
             }
         ).also {
             pagerMap[chatId] = it
         }
     }
 
+    fun updateChatWithMessages(chat: Chat, messages: List<ChatMessage>) {
+        val updatedMessages = (chat.messages + messages).distinctBy { it.id }
+        val updatedChat = chat.copy(messages = updatedMessages)
+        val chats = _chats.value?.map {
+            if (it.id == updatedChat.id) {
+                updatedChat
+            } else {
+                it
+            }
+        }
+        _chats.update { chats }
+    }
+
     fun chatFlow(chatId: ID) =
         chatFlows[chatId] ?: chatMessagePager(chatId).flow.cachedIn(GlobalScope).also {
             chatFlows[chatId] = it