Moves upcoming requirement from existence to current day or later. (#606)
* Moves upcoming requirement from existence to current day or later. * Suppress millis conversion warning (cherry picked from commit c9fddf9e388cff5e4071a89719825dee466deaf4)
This commit is contained in:
parent
3e438a9e87
commit
5e0585d724
@ -12,6 +12,8 @@ import tachiyomi.domain.library.model.LibraryManga
|
|||||||
import tachiyomi.domain.manga.model.Manga
|
import tachiyomi.domain.manga.model.Manga
|
||||||
import tachiyomi.domain.manga.model.MangaUpdate
|
import tachiyomi.domain.manga.model.MangaUpdate
|
||||||
import tachiyomi.domain.manga.repository.MangaRepository
|
import tachiyomi.domain.manga.repository.MangaRepository
|
||||||
|
import java.time.LocalDate
|
||||||
|
import java.time.ZoneId
|
||||||
|
|
||||||
class MangaRepositoryImpl(
|
class MangaRepositoryImpl(
|
||||||
private val handler: DatabaseHandler,
|
private val handler: DatabaseHandler,
|
||||||
@ -73,9 +75,11 @@ class MangaRepositoryImpl(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Suppress("MagicNumber")
|
||||||
override suspend fun getUpcomingManga(statuses: Set<Long>): Flow<List<Manga>> {
|
override suspend fun getUpcomingManga(statuses: Set<Long>): Flow<List<Manga>> {
|
||||||
|
val epochMillis = LocalDate.now().atStartOfDay(ZoneId.systemDefault()).toEpochSecond() * 1000
|
||||||
return handler.subscribeToList {
|
return handler.subscribeToList {
|
||||||
mangasQueries.getUpcomingManga(statuses, MangaMapper::mapManga)
|
mangasQueries.getUpcomingManga(epochMillis, statuses, MangaMapper::mapManga)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -123,7 +123,7 @@ AND _id != :id;
|
|||||||
getUpcomingManga:
|
getUpcomingManga:
|
||||||
SELECT *
|
SELECT *
|
||||||
FROM mangas
|
FROM mangas
|
||||||
WHERE next_update > 0
|
WHERE next_update >= :startOfDay
|
||||||
AND favorite = 1
|
AND favorite = 1
|
||||||
AND status IN :statuses
|
AND status IN :statuses
|
||||||
ORDER BY next_update ASC;
|
ORDER BY next_update ASC;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user