Add ChatClientDatabase, DateConverter, and ChatClientRepository for message receipt management

Author: andremion

stream-chat-android-client/src/main/java/io/getstream/chat/android/client/persistence/db/ChatClientDatabase.kt

@@ -0,0 +1,56 @@
+/*
+ * 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.persistence.db
+
+import android.content.Context
+import androidx.room.Database
+import androidx.room.Room
+import androidx.room.RoomDatabase
+import androidx.room.TypeConverters
+import androidx.sqlite.db.SupportSQLiteDatabase
+import io.getstream.chat.android.client.persistence.db.converter.DateConverter
+import io.getstream.chat.android.client.persistence.db.dao.MessageReceiptDao
+import io.getstream.chat.android.client.persistence.db.entity.MessageReceiptEntity
+
+@Database(
+    entities = [MessageReceiptEntity::class],
+    version = 1,
+    exportSchema = false,
+)
+@TypeConverters(
+    DateConverter::class,
+)
+internal abstract class ChatClientDatabase : RoomDatabase() {
+    abstract fun messageReceiptDao(): MessageReceiptDao
+
+    companion object {
+        fun build(context: Context) = Room.databaseBuilder(
+            context = context.applicationContext,
+            klass = ChatClientDatabase::class.java,
+            name = "stream_chat_client.db",
+        )
+            .fallbackToDestructiveMigration()
+            .addCallback(
+                object : Callback() {
+                    override fun onOpen(db: SupportSQLiteDatabase) {
+                        db.execSQL("PRAGMA synchronous = NORMAL")
+                    }
+                },
+            )
+            .build()
+    }
+}

stream-chat-android-client/src/main/java/io/getstream/chat/android/client/persistence/db/converter/DateConverter.kt

@@ -0,0 +1,28 @@
+/*
+ * 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.persistence.db.converter
+
+import androidx.room.TypeConverter
+import java.util.Date
+
+internal class DateConverter {
+    @TypeConverter
+    fun fromDb(value: Long?): Date? = value?.let(::Date)
+
+    @TypeConverter
+    fun toDb(date: Date?): Long? = date?.time
+}

stream-chat-android-client/src/main/java/io/getstream/chat/android/client/persistence/repository/ChatClientRepository.kt

@@ -0,0 +1,34 @@
+/*
+ * 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.persistence.repository
+
+import io.getstream.chat.android.client.persistence.db.ChatClientDatabase
+
+internal class ChatClientRepository(
+    private val messageReceiptRepository: MessageReceiptRepository,
+) : MessageReceiptRepository by messageReceiptRepository {
+
+    suspend fun clear() {
+        messageReceiptRepository.clearMessageReceipts()
+    }
+
+    companion object {
+        fun from(database: ChatClientDatabase) = ChatClientRepository(
+            messageReceiptRepository = MessageReceiptRepository(database),
+        )
+    }
+}

stream-chat-android-client/src/test/java/io/getstream/chat/android/client/persistence/repository/ChatClientRepositoryTest.kt

@@ -0,0 +1,47 @@
+/*
+ * 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.persistence.repository
+
+import kotlinx.coroutines.test.runTest
+import org.junit.Test
+import org.mockito.Mockito.mock
+import org.mockito.kotlin.verifyBlocking
+
+internal class ChatClientRepositoryTest {
+
+    @Test
+    fun `should clear repositories`() = runTest {
+        val fixture = Fixture()
+        val sut = fixture.get()
+
+        sut.clear()
+
+        fixture.verifyRepositoriesCleared()
+    }
+
+    private class Fixture {
+        private val mockMessageReceiptRepository = mock<MessageReceiptRepository>()
+
+        fun verifyRepositoriesCleared() {
+            verifyBlocking(mockMessageReceiptRepository) { clearMessageReceipts() }
+        }
+
+        fun get() = ChatClientRepository(
+            messageReceiptRepository = mockMessageReceiptRepository,
+        )
+    }
+}