diff --git a/data/src/main/java/tachiyomi/data/manga/MangaRepositoryImpl.kt b/data/src/main/java/tachiyomi/data/manga/MangaRepositoryImpl.kt index e1c3b8210..bdc9a3533 100644 --- a/data/src/main/java/tachiyomi/data/manga/MangaRepositoryImpl.kt +++ b/data/src/main/java/tachiyomi/data/manga/MangaRepositoryImpl.kt @@ -12,6 +12,8 @@ import tachiyomi.domain.library.model.LibraryManga import tachiyomi.domain.manga.model.Manga import tachiyomi.domain.manga.model.MangaUpdate import tachiyomi.domain.manga.repository.MangaRepository +import java.time.LocalDate +import java.time.ZoneId class MangaRepositoryImpl( private val handler: DatabaseHandler, @@ -73,9 +75,11 @@ class MangaRepositoryImpl( } } + @Suppress("MagicNumber") override suspend fun getUpcomingManga(statuses: Set): Flow> { + val epochMillis = LocalDate.now().atStartOfDay(ZoneId.systemDefault()).toEpochSecond() * 1000 return handler.subscribeToList { - mangasQueries.getUpcomingManga(statuses, MangaMapper::mapManga) + mangasQueries.getUpcomingManga(epochMillis, statuses, MangaMapper::mapManga) } } diff --git a/data/src/main/sqldelight/tachiyomi/data/mangas.sq b/data/src/main/sqldelight/tachiyomi/data/mangas.sq index bcc786260..bfdacfbb7 100644 --- a/data/src/main/sqldelight/tachiyomi/data/mangas.sq +++ b/data/src/main/sqldelight/tachiyomi/data/mangas.sq @@ -123,7 +123,7 @@ AND _id != :id; getUpcomingManga: SELECT * FROM mangas -WHERE next_update > 0 +WHERE next_update >= :startOfDay AND favorite = 1 AND status IN :statuses ORDER BY next_update ASC;