rough implementation of library update marking as read

nekomangaorg · Oct 11, 2020 · 0e72e69 · 0e72e69
1 parent 8e70821
commit 0e72e69
Showing 1 changed file with 26 additions and 5 deletions.
diff --git a/app/src/main/java/eu/kanade/tachiyomi/data/library/LibraryUpdateService.kt b/app/src/main/java/eu/kanade/tachiyomi/data/library/LibraryUpdateService.kt
@@ -404,11 +404,14 @@ class LibraryUpdateService(
             // add mdlist tracker if manga in library has it missing
             val tracks = db.getTracks(manga).executeAsBlocking()
             if (tracks.isEmpty() || !tracks.any { it.sync_id == trackManager.mdList.id }) {
-                val tracks = db.getTracks(manga).executeAsBlocking()
-                if (tracks.isEmpty() || !tracks.any { it.sync_id == trackManager.mdList.id }) {
-                    val track = trackManager.mdList.createInitialTracker(manga)
-                    db.insertTrack(track).executeAsBlocking()
-                }
+                val track = trackManager.mdList.createInitialTracker(manga)
+                db.insertTrack(track).executeAsBlocking()
+                tracks.add(track)
+            }
+            tracks.firstOrNull { it.sync_id == trackManager.mdList.id }?.apply {
+                val refreshedTrack = trackManager.mdList.refresh(this)
+                db.insertTrack(refreshedTrack).executeAsBlocking()
+                copyPersonalFrom(refreshedTrack)
             }
 
             if (fetchedChapters.isNotEmpty()) {
@@ -457,6 +460,24 @@ class LibraryUpdateService(
             } else {
                 updateMissingChapterCount(manga)
             }
+            if (preferences.markChaptersReadFromMDList()) {
+                tracks.firstOrNull { it.sync_id == trackManager.mdList.id }?.let {
+                    if (FollowStatus.fromInt(it.status) == FollowStatus.READING) {
+                        val chapters = db.getChapters(manga).executeAsBlocking()
+                        val filteredChp = chapters.filter { chp -> chp.chapter_number.toInt() <= it.last_chapter_read && !chp.read }
+                        if (filteredChp.isNotEmpty()) {
+                            filteredChp.forEach {
+                                it.read = true
+                            }
+                            db.updateChaptersProgress(filteredChp).executeAsBlocking()
+
+                            if (preferences.removeAfterMarkedAsRead()) {
+                                downloadManager.deleteChapters(filteredChp, manga, source)
+                            }
+                        }
+                    }
+                }
+            }
             return hasDownloads
         } catch (e: Exception) {
             if (e !is CancellationException) {