Automatically mark messages as delivered when querying channels

Introduced a `MessageDeliveredPlugin` that automatically marks messages as delivered upon a successful `queryChannels` call. This plugin is enabled by default.

Author: andremion

stream-chat-android-client/src/main/java/io/getstream/chat/android/client/ChatClient.kt

@@ -123,6 +123,7 @@ import io.getstream.chat.android.client.persistance.repository.RepositoryFacade
 import io.getstream.chat.android.client.persistance.repository.factory.RepositoryFactory
 import io.getstream.chat.android.client.persistance.repository.noop.NoOpRepositoryFactory
 import io.getstream.chat.android.client.plugin.DependencyResolver
+import io.getstream.chat.android.client.plugin.MessageDeliveredPluginFactory
 import io.getstream.chat.android.client.plugin.Plugin
 import io.getstream.chat.android.client.plugin.factory.PluginFactory
 import io.getstream.chat.android.client.plugin.factory.ThrottlingPluginFactory
@@ -4817,7 +4818,10 @@ internal constructor(
          * @see [Plugin]
          * @see [PluginFactory]
          */
-        protected val pluginFactories: MutableList<PluginFactory> = mutableListOf(ThrottlingPluginFactory)
+        protected val pluginFactories: MutableList<PluginFactory> = mutableListOf(
+            ThrottlingPluginFactory,
+            MessageDeliveredPluginFactory,
+        )
 
         /**
          * Create a [ChatClient] instance based on the current configuration

stream-chat-android-client/src/main/java/io/getstream/chat/android/client/plugin/MessageDeliveredPlugin.kt

@@ -0,0 +1,43 @@
+/*
+ * Copyright (c) 2014-2025 Stream.io Inc. All rights reserved.
+ *
+ * Licensed under the Stream License;
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    https://github.com/GetStream/stream-chat-android/blob/main/LICENSE
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.getstream.chat.android.client.plugin
+
+import io.getstream.chat.android.client.ChatClient
+import io.getstream.chat.android.client.api.models.QueryChannelsRequest
+import io.getstream.chat.android.client.plugin.factory.PluginFactory
+import io.getstream.chat.android.client.receipts.MessageReceiptManager
+import io.getstream.chat.android.models.Channel
+import io.getstream.chat.android.models.User
+import io.getstream.result.Result
+
+/**
+ * A plugin that marks messages as delivered when channels are queried.
+ */
+internal class MessageDeliveredPlugin(
+    chatClient: ChatClient = ChatClient.instance(),
+    private val messageReceiptManager: MessageReceiptManager = chatClient.messageReceiptManager,
+) : Plugin {
+    override suspend fun onQueryChannelsResult(result: Result<List<Channel>>, request: QueryChannelsRequest) {
+        result.onSuccess { channels ->
+            messageReceiptManager.markChannelsAsDelivered(channels)
+        }
+    }
+}
+
+internal object MessageDeliveredPluginFactory : PluginFactory {
+    override fun get(user: User): Plugin = MessageDeliveredPlugin()
+}

stream-chat-android-client/src/test/java/io/getstream/chat/android/client/plugin/MessageDeliveredPluginFactoryTest.kt

@@ -0,0 +1,38 @@
+/*
+ * Copyright (c) 2014-2025 Stream.io Inc. All rights reserved.
+ *
+ * Licensed under the Stream License;
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    https://github.com/GetStream/stream-chat-android/blob/main/LICENSE
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.getstream.chat.android.client.plugin
+
+import io.getstream.chat.android.client.ChatClient
+import org.junit.Test
+import org.junit.jupiter.api.assertInstanceOf
+import org.mockito.kotlin.doReturn
+import org.mockito.kotlin.mock
+
+internal class MessageDeliveredPluginFactoryTest {
+
+    @Test
+    fun `factory should create MessageDeliveredPlugin`() {
+        val mockChatClient = mock<ChatClient> { on { messageReceiptManager } doReturn mock() }
+        object : ChatClient.ChatClientBuilder() {
+            override fun internalBuild(): ChatClient = mockChatClient
+        }.build()
+
+        val actual = MessageDeliveredPluginFactory.get(mock())
+
+        assertInstanceOf<MessageDeliveredPlugin>(actual)
+    }
+}

stream-chat-android-client/src/test/java/io/getstream/chat/android/client/plugin/MessageDeliveredPluginTest.kt

@@ -0,0 +1,70 @@
+/*
+ * Copyright (c) 2014-2025 Stream.io Inc. All rights reserved.
+ *
+ * Licensed under the Stream License;
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    https://github.com/GetStream/stream-chat-android/blob/main/LICENSE
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.getstream.chat.android.client.plugin
+
+import io.getstream.chat.android.client.receipts.MessageReceiptManager
+import io.getstream.chat.android.models.Channel
+import io.getstream.chat.android.randomChannel
+import io.getstream.result.Result
+import kotlinx.coroutines.test.runTest
+import org.junit.Test
+import org.mockito.kotlin.any
+import org.mockito.kotlin.mock
+import org.mockito.kotlin.never
+import org.mockito.kotlin.times
+import org.mockito.kotlin.verify
+import org.mockito.verification.VerificationMode
+
+internal class MessageDeliveredPluginTest {
+
+    @Test
+    fun `on query channels with successful result, should mark channels as delivered`() = runTest {
+        val channels = listOf(randomChannel())
+        val fixture = Fixture()
+        val sut = fixture.get()
+
+        sut.onQueryChannelsResult(result = Result.Success(channels), request = mock())
+
+        fixture.verifyMarkChannelsAsDeliveredCalled(channels = channels)
+    }
+
+    @Test
+    fun `on query channels with failure result, should not mark channels as delivered`() = runTest {
+        val fixture = Fixture()
+        val sut = fixture.get()
+
+        sut.onQueryChannelsResult(result = Result.Failure(mock()), request = mock())
+
+        fixture.verifyMarkChannelsAsDeliveredCalled(never())
+    }
+
+    private class Fixture {
+        private val mockMessageReceiptManager = mock<MessageReceiptManager>()
+
+        fun verifyMarkChannelsAsDeliveredCalled(
+            mode: VerificationMode = times(1),
+            channels: List<Channel>? = null,
+        ) {
+            verify(mockMessageReceiptManager, mode).markChannelsAsDelivered(channels ?: any())
+        }
+
+        fun get() = MessageDeliveredPlugin(
+            chatClient = mock(),
+            messageReceiptManager = mockMessageReceiptManager,
+        )
+    }
+}