fix(player): new episode duplication

urFate · Jan 17, 2025 · 1858891 · 1858891
1 parent f0fd645
commit 1858891
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/app/src/main/java/org/shirabox/app/ui/activity/player/PlayerViewModel.kt b/app/src/main/java/org/shirabox/app/ui/activity/player/PlayerViewModel.kt
@@ -82,6 +82,7 @@ class PlayerViewModel @AssistedInject constructor(
                     content = Util.mapEntityToContent(content),
                     contentUid = content.uid,
                     cachedEpisodes = cachedEpisodes,
+                    team = team,
                     range = cachedEpisodes.last().episode.inc()..Int.MAX_VALUE
                 )
             }

diff --git a/data/src/main/java/org/shirabox/data/EpisodesHelper.kt b/data/src/main/java/org/shirabox/data/EpisodesHelper.kt
@@ -4,6 +4,7 @@ import kotlinx.coroutines.flow.catch
 import kotlinx.coroutines.flow.collectLatest
 import kotlinx.coroutines.flow.emitAll
 import kotlinx.coroutines.flow.emptyFlow
+import kotlinx.coroutines.flow.map
 import org.shirabox.core.db.AppDatabase
 import org.shirabox.core.entity.EpisodeEntity
 import org.shirabox.core.model.Content
@@ -28,12 +29,17 @@ class EpisodesHelper(private val db: AppDatabase) {
         repository: AbstractContentRepository,
         content: Content,
         contentUid: Long,
+        team: String? = null,
         cachedEpisodes: List<EpisodeEntity>,
         range: IntRange
     ) {
         repository.searchEpisodesInRange(content, range).catch {
             it.printStackTrace()
             emitAll(emptyFlow())
+        }.map { results ->
+            team?.let {
+                results.filter { episode -> episode.actingTeamName == it }
+            } ?: results
         }.collectLatest {
             cacheEpisodes(it, cachedEpisodes, contentUid)
         }