Add markForumTopicAsRead support

Author: gdlbo

data/src/main/java/org/monogram/data/chats/ForumTopicsManager.kt

@@ -114,6 +114,11 @@ class ForumTopicsManager(
                 isClosed = topic.info.isClosed,
                 isPinned = topic.isPinned,
                 unreadCount = topic.unreadCount,
+                lastReadInboxMessageId = topic.lastReadInboxMessageId,
+                lastReadOutboxMessageId = topic.lastReadOutboxMessageId,
+                unreadMentionCount = topic.unreadMentionCount,
+                unreadReactionCount = topic.unreadReactionCount,
+                unreadPollVoteCount = topic.unreadPollVoteCount,
                 lastMessageText = preview.text,
                 lastMessageEntities = preview.entities,
                 lastMessageTime = preview.time,
@@ -135,6 +140,11 @@ class ForumTopicsManager(
                     isClosed = topic.info.isClosed,
                     isPinned = topic.isPinned,
                     unreadCount = topic.unreadCount,
+                    lastReadInboxMessageId = topic.lastReadInboxMessageId,
+                    lastReadOutboxMessageId = topic.lastReadOutboxMessageId,
+                    unreadMentionCount = topic.unreadMentionCount,
+                    unreadReactionCount = topic.unreadReactionCount,
+                    unreadPollVoteCount = topic.unreadPollVoteCount,
                     lastMessageText = preview.text,
                     lastMessageTime = preview.time,
                     order = topic.order,

data/src/main/java/org/monogram/data/datasource/remote/ChatRemoteSource.kt

@@ -28,6 +28,7 @@ interface ChatRemoteSource {
     suspend fun toggleChatIsPinned(chatList: TdApi.ChatList, chatId: Long, isPinned: Boolean)
     suspend fun toggleChatIsMarkedAsUnread(chatId: Long, isMarkedAsUnread: Boolean)
     suspend fun markChatAsRead(chatId: Long)
+    suspend fun markForumTopicAsRead(chatId: Long, topicId: Int)
     suspend fun deleteChat(chatId: Long)
     suspend fun leaveChat(chatId: Long)
     suspend fun clearChatHistory(chatId: Long, revoke: Boolean)

data/src/main/java/org/monogram/data/datasource/remote/TdChatRemoteDataSource.kt

@@ -218,6 +218,35 @@ class TdChatRemoteSource(
         }
     }
 
+    override suspend fun markForumTopicAsRead(chatId: Long, topicId: Int) {
+        val topic = coRunCatching {
+            gateway.execute(TdApi.GetForumTopic(chatId, topicId))
+        }.getOrNull()
+
+        topic?.lastMessage?.let { lastMessage ->
+            coRunCatching {
+                gateway.execute(
+                    TdApi.ViewMessages(
+                        chatId,
+                        longArrayOf(lastMessage.id),
+                        TdApi.MessageSourceForumTopicHistory(),
+                        true
+                    )
+                )
+            }
+        }
+
+        coRunCatching {
+            gateway.execute(TdApi.ReadAllForumTopicMentions(chatId, topicId))
+        }
+        coRunCatching {
+            gateway.execute(TdApi.ReadAllForumTopicReactions(chatId, topicId))
+        }
+        coRunCatching {
+            gateway.execute(TdApi.ReadAllForumTopicPollVotes(chatId, topicId))
+        }
+    }
+
     override suspend fun deleteChat(chatId: Long) {
         coRunCatching { gateway.execute(TdApi.DeleteChat(chatId)) }
     }

data/src/main/java/org/monogram/data/db/MonogramDatabase.kt

@@ -60,7 +60,7 @@ import org.monogram.data.db.model.WallpaperEntity
         SponsorEntity::class,
         TextCompositionStyleEntity::class
     ],
-    version = 32,
+    version = 33,
     exportSchema = false
 )
 abstract class MonogramDatabase : RoomDatabase() {

data/src/main/java/org/monogram/data/db/MonogramMigrations.kt

@@ -313,6 +313,29 @@ object MonogramMigrations {
         }
     }
 
+    val MIGRATION_32_33 = object : Migration(32, 33) {
+        override fun migrate(db: SupportSQLiteDatabase) {
+            db.addColumn("topics", "lastReadInboxMessageId", "INTEGER NOT NULL DEFAULT 0")
+            db.addColumn("topics", "lastReadOutboxMessageId", "INTEGER NOT NULL DEFAULT 0")
+            db.addColumn("topics", "unreadMentionCount", "INTEGER NOT NULL DEFAULT 0")
+            db.addColumn("topics", "unreadReactionCount", "INTEGER NOT NULL DEFAULT 0")
+            db.addColumn("topics", "unreadPollVoteCount", "INTEGER NOT NULL DEFAULT 0")
+
+            db.execSQL(
+                """
+                UPDATE `messages`
+                SET `mediaFileId` = 0,
+                    `mediaPath` = NULL,
+                    `mediaThumbnailPath` = NULL
+                WHERE `mediaFileId` != 0
+                   OR `mediaPath` IS NOT NULL
+                   OR `mediaThumbnailPath` IS NOT NULL
+                """.trimIndent()
+            )
+            db.execSQL("DELETE FROM `sticker_paths`")
+        }
+    }
+
     private fun SupportSQLiteDatabase.addColumn(table: String, column: String, definition: String) {
         execSQL("ALTER TABLE `$table` ADD COLUMN `$column` $definition")
     }

data/src/main/java/org/monogram/data/db/model/TopicEntity.kt

@@ -12,6 +12,11 @@ data class TopicEntity(
     val isClosed: Boolean,
     val isPinned: Boolean,
     val unreadCount: Int,
+    val lastReadInboxMessageId: Long = 0L,
+    val lastReadOutboxMessageId: Long = 0L,
+    val unreadMentionCount: Int = 0,
+    val unreadReactionCount: Int = 0,
+    val unreadPollVoteCount: Int = 0,
     val lastMessageText: String,
     val lastMessageTime: String,
     val order: Long,

data/src/main/java/org/monogram/data/di/dataModule.kt

@@ -260,7 +260,8 @@ val dataModule = module {
                 MonogramMigrations.MIGRATION_28_29,
                 MonogramMigrations.MIGRATION_29_30,
                 MonogramMigrations.MIGRATION_30_31,
-                MonogramMigrations.MIGRATION_31_32
+                MonogramMigrations.MIGRATION_31_32,
+                MonogramMigrations.MIGRATION_32_33
             )
             .build()
     }

data/src/main/java/org/monogram/data/repository/ChatsListRepositoryImpl.kt

@@ -813,6 +813,12 @@ class ChatsListRepositoryImpl(
         )
     }
 
+    override suspend fun markForumTopicAsRead(chatId: Long, topicId: Int) {
+        chatRemoteSource.markForumTopicAsRead(chatId, topicId)
+        forumTopicsManager.getForumTopics(chatId = chatId, limit = 100)
+        refreshChat(chatId)
+    }
+
     override fun clearChatHistory(chatId: Long, revoke: Boolean) {
         scope.launch(dispatchers.io) {
             chatRemoteSource.clearChatHistory(chatId, revoke)

domain/src/main/java/org/monogram/domain/models/TopicModel.kt

@@ -9,6 +9,11 @@ data class TopicModel(
     val isClosed: Boolean = false,
     val isPinned: Boolean = false,
     val unreadCount: Int = 0,
+    val lastReadInboxMessageId: Long = 0L,
+    val lastReadOutboxMessageId: Long = 0L,
+    val unreadMentionCount: Int = 0,
+    val unreadReactionCount: Int = 0,
+    val unreadPollVoteCount: Int = 0,
     val lastMessageText: String = "",
     val lastMessageEntities: List<MessageEntity> = emptyList(),
     val lastMessageTime: String = "",

domain/src/main/java/org/monogram/domain/repository/ForumTopicsRepository.kt

@@ -14,4 +14,6 @@ interface ForumTopicsRepository {
         offsetForumTopicId: Int = 0,
         limit: Int = 20
     ): List<TopicModel>
-}
+
+    suspend fun markForumTopicAsRead(chatId: Long, topicId: Int)
+}