change season requests to easier repository

anilist/src/commonMain/kotlin/dev/datlag/aniflow/anilist/PopularNextSeasonRepository.kt

@@ -0,0 +1,100 @@
+package dev.datlag.aniflow.anilist
+
+import com.apollographql.apollo3.ApolloClient
+import com.apollographql.apollo3.api.Optional
+import dev.datlag.aniflow.anilist.common.nextSeason
+import dev.datlag.aniflow.anilist.state.SeasonState
+import dev.datlag.aniflow.anilist.type.MediaSeason
+import dev.datlag.aniflow.anilist.type.MediaSort
+import dev.datlag.aniflow.anilist.type.MediaType
+import kotlinx.coroutines.flow.*
+import kotlinx.datetime.Clock
+
+class PopularNextSeasonRepository(
+    private val apolloClient: ApolloClient,
+    private val nsfw: Flow<Boolean> = flowOf(false),
+) {
+
+    private val page = MutableStateFlow(0)
+    private val type = MutableStateFlow(MediaType.ANIME)
+    private val query = combine(page, type, nsfw.distinctUntilChanged()) { p, t, n ->
+        val (season, year) = Clock.System.now().nextSeason
+
+        Query(
+            page = p,
+            type = t,
+            nsfw = n,
+            season = season,
+            year = year
+        )
+    }
+
+    val popularNextSeason = query.transform {
+        return@transform emitAll(apolloClient.query(it.toGraphQL()).toFlow())
+    }.map {
+        SeasonState.fromGraphQL(it.data)
+    }
+
+    fun nextPage() = page.getAndUpdate {
+        it + 1
+    }
+
+    fun previousPage() = page.getAndUpdate {
+        it - 1
+    }
+
+    fun viewAnime() {
+        type.getAndUpdate {
+            if (it == MediaType.ANIME) {
+                it
+            } else {
+                page.update { 0 }
+                MediaType.ANIME
+            }
+        }
+    }
+
+    fun viewManga() {
+        type.getAndUpdate {
+            if (it == MediaType.MANGA) {
+                it
+            } else {
+                page.update { 0 }
+                MediaType.MANGA
+            }
+        }
+    }
+
+    private data class Query(
+        val page: Int,
+        val type: MediaType,
+        val nsfw: Boolean,
+        val season: MediaSeason,
+        val year: Int
+    ) {
+        fun toGraphQL() = SeasonQuery(
+            page = Optional.present(page),
+            perPage = Optional.present(10),
+            adultContent = if (nsfw) {
+                Optional.absent()
+            } else {
+                Optional.present(nsfw)
+            },
+            type = Optional.present(type),
+            sort = Optional.present(listOf(MediaSort.POPULARITY_DESC)),
+            preventGenres = if (nsfw) {
+                Optional.absent()
+            } else {
+                Optional.present(AdultContent.Genre.allTags)
+            },
+            year = Optional.present(year),
+            season = if (season == MediaSeason.UNKNOWN__) {
+                Optional.absent()
+            } else {
+                Optional.present(season)
+            },
+            statusVersion = Optional.present(2),
+            html = Optional.present(true)
+        )
+    }
+}

anilist/src/commonMain/kotlin/dev/datlag/aniflow/anilist/PopularSeasonRepository.kt

@@ -0,0 +1,87 @@
+package dev.datlag.aniflow.anilist
+
+import com.apollographql.apollo3.ApolloClient
+import com.apollographql.apollo3.api.Optional
+import dev.datlag.aniflow.anilist.state.SeasonState
+import dev.datlag.aniflow.anilist.type.MediaSort
+import dev.datlag.aniflow.anilist.type.MediaType
+import kotlinx.coroutines.flow.*
+
+class PopularSeasonRepository(
+    private val apolloClient: ApolloClient,
+    private val nsfw: Flow<Boolean> = flowOf(false),
+) {
+
+    private val page = MutableStateFlow(0)
+    private val type = MutableStateFlow(MediaType.ANIME)
+    private val query = combine(page, type, nsfw.distinctUntilChanged()) { p, t, n ->
+        Query(
+            page = p,
+            type = t,
+            nsfw = n
+        )
+    }
+
+    val popularThisSeason = query.transform {
+        return@transform emitAll(apolloClient.query(it.toGraphQL()).toFlow())
+    }.map {
+        SeasonState.fromGraphQL(it.data)
+    }
+
+    fun nextPage() = page.getAndUpdate {
+        it + 1
+    }
+
+    fun previousPage() = page.getAndUpdate {
+        it - 1
+    }
+
+    fun viewAnime() {
+        type.getAndUpdate {
+            if (it == MediaType.ANIME) {
+                it
+            } else {
+                page.update { 0 }
+                MediaType.ANIME
+            }
+        }
+    }
+
+    fun viewManga() {
+        type.getAndUpdate {
+            if (it == MediaType.MANGA) {
+                it
+            } else {
+                page.update { 0 }
+                MediaType.MANGA
+            }
+        }
+    }
+
+    private data class Query(
+        val page: Int,
+        val type: MediaType,
+        val nsfw: Boolean
+    ) {
+        fun toGraphQL() = SeasonQuery(
+            page = Optional.present(page),
+            perPage = Optional.present(10),
+            adultContent = if (nsfw) {
+                Optional.absent()
+            } else {
+                Optional.present(nsfw)
+            },
+            type = Optional.present(type),
+            sort = Optional.present(listOf(MediaSort.POPULARITY_DESC)),
+            preventGenres = if (nsfw) {
+                Optional.absent()
+            } else {
+                Optional.present(AdultContent.Genre.allTags)
+            },
+            year = Optional.absent(),
+            season = Optional.absent(),
+            statusVersion = Optional.present(2),
+            html = Optional.present(true)
+        )
+    }
+}