bbara/Purefin
1
0
Fork 0
mirror of https://github.com/bbara04/Purefin.git synced 2026-07-23 19:26:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(repository): reorder state updates to prevent empty intermediate states

Browse Source
This commit is contained in:
Barnabas Balogh
2026-06-22 20:30:31 +02:00
parent 8c758e8262
commit f0a7828613
1 changed files with 32 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
data/src/main/java/hu/bbara/purefin/data/catalog/InMemoryAppContentRepository.kt
View File

@@ -329,15 +329,6 @@ class InMemoryAppContentRepository @Inject constructor(
} }
if (suggestionsItems == null) return@run if (suggestionsItems == null) return@run
suggestionsState.value = suggestionsItems.mapNotNull { item ->
when (item.type) {
BaseItemKind.MOVIE -> Media.MovieMedia(movieId = item.id)
BaseItemKind.EPISODE -> Media.EpisodeMedia(episodeId = item.id, seriesId = item.seriesId!!)
else -> throw UnsupportedOperationException("Unsupported item type: ${item.type}")
}
}
// Upsert full details so the home viewmodel can look up each item.
suggestionsItems.forEach { item -> suggestionsItems.forEach { item ->
when (item.type) { when (item.type) {
BaseItemKind.MOVIE -> onlineMediaRepository.upsertMovies(listOf(item.toMovie(url))) BaseItemKind.MOVIE -> onlineMediaRepository.upsertMovies(listOf(item.toMovie(url)))
@@ -345,6 +336,14 @@ class InMemoryAppContentRepository @Inject constructor(
else -> {} else -> {}
} }
} }
suggestionsState.value = suggestionsItems.mapNotNull { item ->
when (item.type) {
BaseItemKind.MOVIE -> Media.MovieMedia(movieId = item.id)
BaseItemKind.EPISODE -> Media.EpisodeMedia(episodeId = item.id, seriesId = item.seriesId!!)
else -> throw UnsupportedOperationException("Unsupported item type: ${item.type}")
}
}
} }
private suspend fun loadContinueWatching() = singleFlight.run("AppContent:loadContinueWatching") { private suspend fun loadContinueWatching() = singleFlight.run("AppContent:loadContinueWatching") {
@@ -362,14 +361,12 @@ class InMemoryAppContentRepository @Inject constructor(
} }
if (continueWatchingItems == null) return@run if (continueWatchingItems == null) return@run
continueWatchingState.value = continueWatchingItems.mapNotNull { item -> // Upsert full details BEFORE publishing the new row, so the
when (item.type) { // home viewmodel's `combine` of this flow with the local media
BaseItemKind.MOVIE -> Media.MovieMedia(movieId = item.id) // repository never observes an empty intermediate state. If we
BaseItemKind.EPISODE -> Media.EpisodeMedia(episodeId = item.id, seriesId = item.seriesId!!) // assigned continueWatchingState first, the new episode/movie IDs
else -> throw UnsupportedOperationException("Unsupported item type: ${item.type}") // would be unresolvable for a single emission and the Continue
} // Watching section would briefly drop from the home screen.
}
continueWatchingItems.forEach { item -> continueWatchingItems.forEach { item ->
when (item.type) { when (item.type) {
BaseItemKind.MOVIE -> onlineMediaRepository.upsertMovies(listOf(item.toMovie(url))) BaseItemKind.MOVIE -> onlineMediaRepository.upsertMovies(listOf(item.toMovie(url)))
@@ -377,6 +374,14 @@ class InMemoryAppContentRepository @Inject constructor(
else -> {} else -> {}
} }
} }
continueWatchingState.value = continueWatchingItems.mapNotNull { item ->
when (item.type) {
BaseItemKind.MOVIE -> Media.MovieMedia(movieId = item.id)
BaseItemKind.EPISODE -> Media.EpisodeMedia(episodeId = item.id, seriesId = item.seriesId!!)
else -> throw UnsupportedOperationException("Unsupported item type: ${item.type}")
}
}
} }
private suspend fun loadNextUp() = singleFlight.run("AppContent:loadNextUp") { private suspend fun loadNextUp() = singleFlight.run("AppContent:loadNextUp") {
@@ -394,13 +399,19 @@ class InMemoryAppContentRepository @Inject constructor(
} }
if (nextUpItems == null) return@run if (nextUpItems == null) return@run
nextUpState.value = nextUpItems.map { item -> // Upsert full details BEFORE publishing the new row, so the
Media.EpisodeMedia(episodeId = item.id, seriesId = item.seriesId!!) // home viewmodel's `combine` of this flow with the local media
} // repository never observes an empty intermediate state. If we
// assigned nextUpState first, the new episode IDs would be
// unresolvable for a single emission and the Next Up section
// would briefly drop from the home screen.
nextUpItems.forEach { item -> nextUpItems.forEach { item ->
onlineMediaRepository.upsertEpisodes(listOf(item.toEpisode(url))) onlineMediaRepository.upsertEpisodes(listOf(item.toEpisode(url)))
} }
nextUpState.value = nextUpItems.map { item ->
Media.EpisodeMedia(episodeId = item.id, seriesId = item.seriesId!!)
}
} }
private suspend fun loadLatestLibraryContent() = singleFlight.run("AppContent:loadLatestLibraryContent") { private suspend fun loadLatestLibraryContent() = singleFlight.run("AppContent:loadLatestLibraryContent") {