comment out generalUIFlow and removeMessageFlow

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

Author: mahibi

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

@@ -1097,13 +1097,13 @@ class ChatActivity :
         //     }
         //     .launchIn(lifecycleScope)
 
-        this.lifecycleScope.launch {
-            chatViewModel.getRemoveMessageFlow
-                .onEach {
-                    removeMessageById(it.id)
-                }
-                .collect()
-        }
+        // this.lifecycleScope.launch {
+        //     chatViewModel.getRemoveMessageFlow
+        //         .onEach {
+        //             removeMessageById(it.id)
+        //         }
+        //         .collect()
+        // }
 
         this.lifecycleScope.launch {
             chatViewModel.getUpdateMessageFlow
@@ -1130,19 +1130,19 @@ class ChatActivity :
                 .collect()
         }
 
-        this.lifecycleScope.launch {
-            chatViewModel.getGeneralUIFlow.onEach { key ->
-                when (key) {
-                    NO_OFFLINE_MESSAGES_FOUND -> {
-                        binding.progressBar.visibility = View.GONE
-                        binding.messagesListView.visibility = View.GONE
-                        binding.offline.root.visibility = View.VISIBLE
-                    }
-
-                    else -> {}
-                }
-            }.collect()
-        }
+        // this.lifecycleScope.launch {
+        //     chatViewModel.getGeneralUIFlow.onEach { key ->
+        //         when (key) {
+        //             NO_OFFLINE_MESSAGES_FOUND -> {
+        //                 binding.progressBar.visibility = View.GONE
+        //                 binding.messagesListView.visibility = View.GONE
+        //                 binding.offline.root.visibility = View.VISIBLE
+        //             }
+        //
+        //             else -> {}
+        //         }
+        //     }.collect()
+        // }
 
         this.lifecycleScope.launch {
             chatViewModel.mediaPlayerSeekbarObserver.onEach { msg ->

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

@@ -40,13 +40,13 @@ interface ChatMessageRepository : LifecycleAwareManager {
 
     val lastReadMessageFlow: Flow<Int>
 
-    /**
-     * 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.
-     */
-    val generalUIFlow: Flow<String>
+    // /**
+    //  * 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.
+    //  */
+    // val generalUIFlow: Flow<String>
 
-    val removeMessageFlow: Flow<ChatMessage>
+    // val removeMessageFlow: Flow<ChatMessage>
 
     fun initData(currentUser: User, credentials: String, urlForChatting: String, roomToken: String, threadId: Long?)
 

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

@@ -102,16 +102,16 @@ class OfflineFirstChatRepository @Inject constructor(
     private val _lastReadMessageFlow:
         MutableSharedFlow<Int> = MutableSharedFlow()
 
-    override val generalUIFlow: Flow<String>
-        get() = _generalUIFlow
-
-    private val _generalUIFlow: MutableSharedFlow<String> = MutableSharedFlow()
-
-    override val removeMessageFlow: Flow<ChatMessage>
-        get() = _removeMessageFlow
+    // override val generalUIFlow: Flow<String>
+    //     get() = _generalUIFlow
+    //
+    // private val _generalUIFlow: MutableSharedFlow<String> = MutableSharedFlow()
 
-    private val _removeMessageFlow:
-        MutableSharedFlow<ChatMessage> = MutableSharedFlow()
+    // override val removeMessageFlow: Flow<ChatMessage>
+    //     get() = _removeMessageFlow
+    //
+    // private val _removeMessageFlow:
+    //     MutableSharedFlow<ChatMessage> = MutableSharedFlow()
 
     private var newXChatLastCommonRead: Int? = null
     private var itIsPaused = false
@@ -191,7 +191,7 @@ class OfflineFirstChatRepository @Inject constructor(
                 } else if (!weAlreadyHaveSomeOfflineMessages) {
                     Log.d(TAG, "An online request for newest 100 messages is made because offline chat is empty")
                     if (networkMonitor.isOnline.value.not()) {
-                        _generalUIFlow.emit(ChatActivity.NO_OFFLINE_MESSAGES_FOUND)
+                        // _generalUIFlow.emit(ChatActivity.NO_OFFLINE_MESSAGES_FOUND)
                     }
                 } else {
                     Log.d(
@@ -1024,7 +1024,6 @@ class OfflineFirstChatRepository @Inject constructor(
 
     override suspend fun deleteTempMessage(chatMessage: ChatMessage) {
         chatDao.deleteTempChatMessages(internalConversationId, listOf(chatMessage.referenceId.orEmpty()))
-        _removeMessageFlow.emit(chatMessage)
     }
 
     override suspend fun pinMessage(credentials: String, url: String, pinUntil: Int): Flow<ChatMessage?> =

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

@@ -221,7 +221,7 @@ class ChatViewModel @Inject constructor(
     //         _chatMessageViewState.value = ChatMessageErrorState
     //     }
 
-    val getRemoveMessageFlow = chatRepository.removeMessageFlow
+    // val getRemoveMessageFlow = chatRepository.removeMessageFlow
 
     val getUpdateMessageFlow = chatRepository.updateMessageFlow
 
@@ -236,7 +236,7 @@ class ChatViewModel @Inject constructor(
             _getRoomViewState.value = GetRoomErrorState
         }
 
-    val getGeneralUIFlow = chatRepository.generalUIFlow
+    // val getGeneralUIFlow = chatRepository.generalUIFlow
 
     sealed interface ViewState