Parcourir la source

Limit updates to 250 most recent chapters

Still limits to things within the past 3 months though.

Closes #9554
arkon il y a 1 an
Parent
commit
4c65c2311e

+ 2 - 2
data/src/main/java/tachiyomi/data/updates/UpdatesRepositoryImpl.kt

@@ -19,9 +19,9 @@ class UpdatesRepositoryImpl(
         }
     }
 
-    override fun subscribeAll(after: Long): Flow<List<UpdatesWithRelations>> {
+    override fun subscribeAll(after: Long, limit: Long): Flow<List<UpdatesWithRelations>> {
         return databaseHandler.subscribeToList {
-            updatesViewQueries.updates(after, updateWithRelationMapper)
+            updatesViewQueries.getRecentUpdates(after, limit, updateWithRelationMapper)
         }
     }
 

+ 3 - 2
data/src/main/sqldelight/tachiyomi/view/updatesView.sq

@@ -20,10 +20,11 @@ WHERE favorite = 1
 AND date_fetch > date_added
 ORDER BY date_fetch DESC;
 
-updates:
+getRecentUpdates:
 SELECT *
 FROM updatesView
-WHERE dateUpload > :after;
+WHERE dateUpload > :after
+LIMIT :limit;
 
 getUpdatesByReadStatus:
 SELECT *

+ 2 - 4
domain/src/main/java/tachiyomi/domain/updates/interactor/GetUpdates.kt

@@ -13,10 +13,8 @@ class GetUpdates(
         return repository.awaitWithRead(read, after)
     }
 
-    fun subscribe(calendar: Calendar): Flow<List<UpdatesWithRelations>> = subscribe(calendar.time.time)
-
-    fun subscribe(after: Long): Flow<List<UpdatesWithRelations>> {
-        return repository.subscribeAll(after)
+    fun subscribe(calendar: Calendar): Flow<List<UpdatesWithRelations>> {
+        return repository.subscribeAll(calendar.time.time, limit = 250)
     }
 
     fun subscribe(read: Boolean, after: Long): Flow<List<UpdatesWithRelations>> {

+ 1 - 1
domain/src/main/java/tachiyomi/domain/updates/repository/UpdatesRepository.kt

@@ -7,7 +7,7 @@ interface UpdatesRepository {
 
     suspend fun awaitWithRead(read: Boolean, after: Long): List<UpdatesWithRelations>
 
-    fun subscribeAll(after: Long): Flow<List<UpdatesWithRelations>>
+    fun subscribeAll(after: Long, limit: Long): Flow<List<UpdatesWithRelations>>
 
     fun subscribeWithRead(read: Boolean, after: Long): Flow<List<UpdatesWithRelations>>
 }