feat: integrate DiffMapHolder for improved read status management

Author: stopper2408

app/src/main/java/me/ash/reader/domain/service/GoogleReaderRssService.kt

@@ -27,6 +27,7 @@ import kotlinx.coroutines.sync.Semaphore
 import kotlinx.coroutines.sync.withPermit
 import me.ash.reader.R
 import me.ash.reader.domain.data.SyncLogger
+import me.ash.reader.domain.data.DiffMapHolder
 import me.ash.reader.domain.model.account.Account
 import me.ash.reader.domain.model.account.AccountType
 import me.ash.reader.domain.model.account.AccountType.Companion.FreshRSS
@@ -77,6 +78,7 @@ constructor(
     private val workManager: WorkManager,
     private val accountService: AccountService,
     private val syncLogger: SyncLogger,
+    private val diffMapHolder: dagger.Lazy<DiffMapHolder>,
 ) :
     AbstractRssRepository(
         articleDao,
@@ -362,10 +364,13 @@ constructor(
             }
 
             launch {
+                val pendingReadIds = diffMapHolder.get().diffMap.filter { !it.value.isUnread }.keys
+
                 val toBeUnreadLocal =
-                    localReadIds.intersect(remoteUnreadIds.await()).map {
+                    (localReadIds.intersect(remoteUnreadIds.await()).map {
                         accountId spacerDollar it
-                    }
+                    } - pendingReadIds)
+
                 toBeUnreadLocal.chunked(1000).forEach {
                     articleDao.markAsReadByIdSet(
                         accountId = accountId,

app/src/main/java/me/ash/reader/ui/page/adaptive/ArticleListReaderViewModel.kt

@@ -213,14 +213,26 @@ constructor(
     }
 
     fun toggleReadStatus(articleWithFeed: ArticleWithFeed) {
-        viewModelScope.launch(ioDispatcher) {
+        if (diffMapHolder.checkIfUnread(articleWithFeed)) {
+            notificationHelper.cancel(articleWithFeed.article.id)
+        }
+        applicationScope.launch(ioDispatcher) {
             diffMapHolder.updateDiff(articleWithFeed)
             diffMapHolder.writeDiffsToCache()
         }
     }
 
+    fun markAsRead(articleWithFeed: ArticleWithFeed) {
+        notificationHelper.cancel(articleWithFeed.article.id)
+        applicationScope.launch(ioDispatcher) {
+            diffMapHolder.updateDiff(articleWithFeed, isUnread = false)
+            diffMapHolder.writeDiffsToCache()
+        }
+    }
+
     fun markAsReadList(articles: List<ArticleWithFeed>) {
-        viewModelScope.launch(ioDispatcher) {
+        articles.forEach { notificationHelper.cancel(it.article.id) }
+        applicationScope.launch(ioDispatcher) {
             diffMapHolder.updateDiff(articleWithFeed = articles.toTypedArray(), isUnread = false)
             diffMapHolder.writeDiffsToCache()
         }