Creepso/NuvioStreaming
1
0
Fork 0
mirror of https://github.com/tapframe/NuvioStreaming.git synced 2026-08-17 21:05:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: skip redundant Trakt watched refresh (NUVIO-MOBILE-Q3)

Browse source
This commit is contained in:
tapframe 2026-08-02 16:35:47 +05:30
parent 15fcb8d25e
commit 7a491570af
2 changed files with 29 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
composeApp/src/commonMain/kotlin/com/nuvio/app/features/watched/WatchedRepository.kt
View file

@ -113,6 +113,11 @@ internal suspend fun <T> watchedProviderRefreshOrNull(
null
}
internal fun extraWatchedKeysChanged(
previous: Set<String>?,
current: Set<String>,
): Boolean = previous.orEmpty() != current
object WatchedRepository {
private data class WatchedRefreshOperation(
val profileId: Int,
@ -1099,7 +1104,10 @@ object WatchedRepository {
adapter.observeExtraWatchedKeys(currentProfileId)
.distinctUntilChanged()
.collectLatest { extraKeys ->
val keysChanged = providerExtraWatchedKeys[providerId] != extraKeys
val keysChanged = extraWatchedKeysChanged(
previous = providerExtraWatchedKeys[providerId],
current = extraKeys,
)
if (keysChanged) {
val freshItems = watchedProviderRefreshOrNull(
refresh = {

20
composeApp/src/commonTest/kotlin/com/nuvio/app/features/watched/WatchedRepositoryTest.kt
View file

@ -14,6 +14,26 @@ import kotlin.test.assertNull
import kotlin.test.assertTrue
class WatchedRepositoryTest {
@Test
fun emptyProviderExtraKeys_doNotTriggerInitialRefresh() {
assertFalse(extraWatchedKeysChanged(previous = null, current = emptySet()))
}
@Test
fun populatedProviderExtraKeys_triggerRefreshFromEmptyState() {
assertTrue(extraWatchedKeysChanged(previous = null, current = setOf("series:tt1:-1:-1")))
}
@Test
fun changedProviderExtraKeys_triggerRefresh() {
assertTrue(
extraWatchedKeysChanged(
previous = setOf("series:tt1:-1:-1"),
current = setOf("series:tt2:-1:-1"),
),
)
}
@Test
fun providerRefreshFailure_isContainedWithoutReplacingState() = runBlocking {
val failure = IllegalStateException("rate limited")