hardening code in case of error

Signed-off-by: rapterjet2004 <[email protected]>

Author: rapterjet2004

app/src/main/java/com/nextcloud/talk/chat/ChatActivity.kt

@@ -673,7 +673,7 @@ class ChatActivity :
 
         this.lifecycleScope.launch {
             chatViewModel.getConversationFlow
-                .onEach { conversationModel ->
+                .collect { conversationModel ->
                     currentConversation = conversationModel
                     chatViewModel.updateConversation(
                         currentConversation!!
@@ -701,15 +701,17 @@ class ChatActivity :
                                 conversationModel.lastPinnedId.toString()
                             )
                             .collect { message ->
-                                binding.pinnedMessageContainer.visibility = View.VISIBLE
-                                binding.pinnedMessageComposeView.setContent {
-                                    PinnedMessageView(message)
+                                message?.let {
+                                    binding.pinnedMessageContainer.visibility = View.VISIBLE
+                                    binding.pinnedMessageComposeView.setContent {
+                                        PinnedMessageView(message)
+                                    }
                                 }
                             }
                     } else {
                         binding.pinnedMessageContainer.visibility = View.GONE
                     }
-                }.collect()
+                }
         }
 
         chatViewModel.getRoomViewState.observe(this) { state ->

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

@@ -806,7 +806,7 @@ class ChatViewModel @Inject constructor(
         baseUrl: String,
         token: String,
         messageId: String
-    ): Flow<ChatMessage> =
+    ): Flow<ChatMessage?> =
         flow {
             val messages = chatNetworkDataSource.getContextForChatMessage(
                 credentials = credentials,
@@ -817,8 +817,12 @@ class ChatViewModel @Inject constructor(
                 threadId = null
             )
 
-            val message = messages[0]
-            emit(message.asModel())
+            if (messages.isNotEmpty()) {
+                val message = messages[0]
+                emit(message.asModel())
+            } else {
+                emit(null)
+            }
         }
 
     suspend fun getNumberOfThreadReplies(threadId: Long): Int = chatRepository.getNumberOfThreadReplies(threadId)