Merge pull request #89 from meowarex/dev

Fix offline Shader + Lyric Seeking

.version

@@ -1 +1 @@
-1.1.6
+1.1.5

Manager/app/build.gradle.kts

@@ -31,8 +31,8 @@ android {
     defaultConfig {
         minSdk = 24
         targetSdk = 36
-        versionCode = 68
-        versionName = "1.1.6"
+        versionCode = 67
+        versionName = "1.1.5"
 
         vectorDrawables {
             useSupportLibrary = true

Manager/app/src/main/kotlin/com/meowarex/rlmobile/network/services/RLMobileGithubService.kt

@@ -39,14 +39,10 @@ class RadiantLyricsGithubService(
     /**
      * Fetches manager self-update releases.
      */
-    suspend fun getManagerReleases(force: Boolean = false): ApiResponse<List<GithubRelease>> =
+    suspend fun getManagerReleases(): ApiResponse<List<GithubRelease>> =
         http.request {
             url("https://api.github.com/repos/${BuildConfig.PATCHES_REPO_OWNER}/${BuildConfig.PATCHES_REPO_NAME}/releases")
-            if (force) {
-                header(HttpHeaders.CacheControl, "no-cache")
-            } else {
-                header(HttpHeaders.CacheControl, "public, max-age=60, s-maxage=60")
-            }
+            header(HttpHeaders.CacheControl, "public, max-age=60, s-maxage=60")
         }
 
     /**
@@ -70,18 +66,10 @@ class RadiantLyricsGithubService(
     /**
      * Fetches a page of commits (paginated). Used by the Home screen's commit list.
      */
-    suspend fun getCommits(
-        page: Int,
-        perPage: Int = 30,
-        force: Boolean = false,
-    ): ApiResponse<List<com.meowarex.rlmobile.network.models.GithubCommit>> =
+    suspend fun getCommits(page: Int, perPage: Int = 30): ApiResponse<List<com.meowarex.rlmobile.network.models.GithubCommit>> =
         http.request {
             url("https://api.github.com/repos/${BuildConfig.PATCHES_REPO_OWNER}/${BuildConfig.PATCHES_REPO_NAME}/commits?per_page=$perPage&page=${page + 1}")
-            if (force) {
-                header(HttpHeaders.CacheControl, "no-cache")
-            } else {
-                header(HttpHeaders.CacheControl, "public, max-age=120, s-maxage=120")
-            }
+            header(HttpHeaders.CacheControl, "public, max-age=120, s-maxage=120")
         }
 
     companion object {

Manager/app/src/main/kotlin/com/meowarex/rlmobile/network/utils/CommitsPagingSource.kt

@@ -7,8 +7,6 @@ import com.meowarex.rlmobile.network.services.RadiantLyricsGithubService
 
 class CommitsPagingSource(
     private val github: RadiantLyricsGithubService,
-    /** Bypasses the http response cache */
-    private val force: Boolean = false,
 ) : PagingSource<Int, GithubCommit>() {
     private val seenShas = mutableSetOf<String>()
     private val seenTitles = mutableSetOf<String>()
@@ -21,8 +19,7 @@ class CommitsPagingSource(
 
     override suspend fun load(params: LoadParams<Int>): LoadResult<Int, GithubCommit> {
         val page = params.key ?: 0
-        // Only the first page skips the cache
-        return when (val r = github.getCommits(page, force = force && page == 0)) {
+        return when (val r = github.getCommits(page)) {
             is ApiResponse.Success -> LoadResult.Page(
                 data = r.data.filter { commit ->
                     val title = commit.commit.message.lineSequence().first().trim()

Manager/app/src/main/kotlin/com/meowarex/rlmobile/ui/legacy/screens/home/HomeScreen.kt

@@ -15,7 +15,6 @@ import androidx.compose.ui.Alignment
 import androidx.compose.ui.Modifier
 import androidx.compose.ui.draw.clip
 import androidx.compose.ui.graphics.asImageBitmap
-import androidx.compose.ui.graphics.graphicsLayer
 import androidx.compose.ui.graphics.painter.BitmapPainter
 import androidx.activity.ComponentActivity
 import androidx.compose.ui.platform.LocalContext
@@ -58,8 +57,6 @@ class HomeScreen : Screen, Parcelable {
         val activity = LocalContext.current as ComponentActivity
         val updater = koinViewModel<UpdaterViewModel>(viewModelStoreOwner = activity)
         val managerUpdateAvailable = updater.targetVersion != null
-        val refreshing = model.refreshing
-        val refreshAngle = rememberRefreshAngle()
 
         LifecycleResumeEffect(Unit) {
             model.refresh(delay = true)
@@ -71,19 +68,10 @@ class HomeScreen : Screen, Parcelable {
                 TopAppBar(
                     title = { Text(stringResource(R.string.navigation_home)) },
                     actions = {
-                        IconButton(
-                            onClick = {
-                                model.refresh(force = true)
-                                updater.checkForUpdates(force = true)
-                            },
-                            enabled = !refreshing,
-                        ) {
+                        IconButton(onClick = { model.refresh() }) {
                             Icon(
                                 painterResource(R.drawable.ic_refresh),
                                 contentDescription = stringResource(R.string.navigation_refresh),
-                                modifier = Modifier.graphicsLayer {
-                                    rotationZ = if (refreshing) refreshAngle() else 0f
-                                },
                             )
                         }
                         if (managerUpdateAvailable) {

Manager/app/src/main/kotlin/com/meowarex/rlmobile/ui/screens/home/HomeModel.kt

@@ -34,9 +34,6 @@ import com.meowarex.rlmobile.ui.util.TidalVersion
 import com.meowarex.rlmobile.ui.widgets.managerupdate.VersionDelta
 import com.meowarex.rlmobile.util.*
 import kotlinx.coroutines.*
-import kotlinx.coroutines.flow.MutableStateFlow
-import kotlinx.coroutines.flow.flatMapLatest
-import kotlinx.coroutines.flow.update
 import kotlinx.coroutines.sync.Mutex
 import kotlinx.coroutines.sync.withLock
 import kotlinx.serialization.json.Json
@@ -56,22 +53,9 @@ class HomeModel(
     var managerUpdateDeltas by mutableStateOf<List<VersionDelta>?>(null)
         private set
 
-    /** Whether a user-initiated refresh is currently in flight */
-    var refreshing by mutableStateOf(false)
-        private set
-
-    // Bumped by every forced refresh, which restarts the pager with a fresh (cache-skipping) source.
-    // Without this the commit list would stay pinned to whatever it loaded on process start.
-    private val commitsGeneration = MutableStateFlow(0)
-
-    @OptIn(ExperimentalCoroutinesApi::class)
-    val commits = commitsGeneration
-        .flatMapLatest { generation ->
-            Pager(PagingConfig(pageSize = 30)) {
-                CommitsPagingSource(github, force = generation > 0)
-            }.flow
-        }
-        .cachedIn(screenModelScope)
+    val commits = Pager(PagingConfig(pageSize = 30)) {
+        CommitsPagingSource(github)
+    }.flow.cachedIn(screenModelScope)
 
     private val refreshingLock = Mutex()
     private var remoteDataJson: RLBuildInfo? = null
@@ -180,10 +164,7 @@ class HomeModel(
         )
     }
 
-    /**
-     * @param delay Waits a moment before starting
-     */
-    fun refresh(delay: Boolean = false, force: Boolean = false) = screenModelScope.launchIO {
+    fun refresh(delay: Boolean = false) = screenModelScope.launchIO {
         if (refreshingLock.isLocked) return@launchIO
         if (delay) {
             delay(250)
@@ -191,32 +172,26 @@ class HomeModel(
         }
 
         refreshingLock.withLock {
-            if (force) mainThread { refreshing = true }
-            try {
-                val pkg = fetchInstalled()
-                // Skip the remote fetch entirely when offline
-                val online = application.isOnline()
-                if (online && (force || remoteDataJson == null)) {
-                    fetchRemoteData(force)
-                }
-                // Offline the reload would only replace the visible list with a load error
-                if (force && online) commitsGeneration.update { it + 1 }
+            val pkg = fetchInstalled()
+            // Skip the remote fetch entirely when offline
+            val online = application.isOnline()
+            if (online) {
+                val remote = async(Dispatchers.IO) { if (remoteDataJson == null) fetchRemoteData() }
+                remote.await()
+            }
 
-                val install = pkg?.toInstallData()
-                val latest = remoteDataJson?.tidalVersionCode
-                val offlineRepatchReady = hasOfflineRepatchAssets()
+            val install = pkg?.toInstallData()
+            val latest = remoteDataJson?.tidalVersionCode
+            val offlineRepatchReady = hasOfflineRepatchAssets()
 
-                mainThread {
-                    state = HomeState.Loaded(
-                        install = install,
-                        latestTidalVersionCode = latest,
-                        offline = !online,
-                        offlineRepatchReady = offlineRepatchReady,
-                    )
-                    maybeCheckManagerUpdate(pkg)
-                }
-            } finally {
-                if (force) mainThread { refreshing = false }
+            mainThread {
+                state = HomeState.Loaded(
+                    install = install,
+                    latestTidalVersionCode = latest,
+                    offline = !online,
+                    offlineRepatchReady = offlineRepatchReady,
+                )
+                maybeCheckManagerUpdate(pkg)
             }
         }
     }
@@ -308,9 +283,9 @@ class HomeModel(
             paths.hasCachedSmaliPatches(info.data.patchesVersion)
     }
 
-    private suspend fun fetchRemoteData(force: Boolean = false) {
+    private suspend fun fetchRemoteData() {
         val release = try {
-            github.getLatestRelease(force).fold(
+            github.getLatestRelease().fold(
                 success = { it },
                 fail = { Log.w(BuildConfig.TAG, "Failed to fetch latest release", it); return },
             )
@@ -324,7 +299,7 @@ class HomeModel(
             ?.browserDownloadUrl
             ?: return
 
-        github.getBuildInfo(dataJsonUrl, force).fold(
+        github.getBuildInfo(dataJsonUrl).fold(
             success = { remoteDataJson = it },
             fail = { Log.w(BuildConfig.TAG, "Failed to fetch build info", it) },
         )

Manager/app/src/main/kotlin/com/meowarex/rlmobile/ui/screens/home/HomeScreen.kt

@@ -3,11 +3,6 @@ package com.meowarex.rlmobile.ui.screens.home
 import android.os.Parcelable
 import androidx.activity.ComponentActivity
 import androidx.compose.animation.AnimatedVisibility
-import androidx.compose.animation.core.LinearEasing
-import androidx.compose.animation.core.animateFloat
-import androidx.compose.animation.core.infiniteRepeatable
-import androidx.compose.animation.core.rememberInfiniteTransition
-import androidx.compose.animation.core.tween
 import androidx.compose.foundation.Image
 import androidx.compose.foundation.basicMarquee
 import androidx.compose.foundation.interaction.MutableInteractionSource
@@ -19,7 +14,6 @@ import androidx.compose.ui.Alignment
 import androidx.compose.ui.Modifier
 import androidx.compose.ui.draw.clip
 import androidx.compose.ui.graphics.asImageBitmap
-import androidx.compose.ui.graphics.graphicsLayer
 import androidx.compose.ui.graphics.painter.BitmapPainter
 import androidx.compose.ui.input.nestedscroll.nestedScroll
 import androidx.compose.ui.platform.LocalContext
@@ -76,8 +70,6 @@ class HomeScreen : Screen, Parcelable {
         val activity = LocalContext.current as ComponentActivity
         val updater = koinViewModel<UpdaterViewModel>(viewModelStoreOwner = activity)
         val managerUpdateAvailable = updater.targetVersion != null
-        val refreshing = model.refreshing
-        val refreshAngle = rememberRefreshAngle()
 
         LifecycleResumeEffect(Unit) {
             model.refresh(delay = true)
@@ -94,14 +86,7 @@ class HomeScreen : Screen, Parcelable {
                             icon = painterResource(R.drawable.ic_refresh),
                             contentDescription = stringResource(R.string.navigation_refresh),
                             subtle = true,
-                            enabled = !refreshing,
-                            onClick = {
-                                model.refresh(force = true)
-                                updater.checkForUpdates(force = true)
-                            },
-                            modifier = Modifier.graphicsLayer {
-                                rotationZ = if (refreshing) refreshAngle() else 0f
-                            },
+                            onClick = { model.refresh() },
                         )
                         if (managerUpdateAvailable) {
                             RadiantIconButton(
@@ -379,18 +364,3 @@ private fun HeroContainer(
         Column(modifier = Modifier.fillMaxWidth(), content = content)
     }
 }
-
-/**
- * Refresh Spinner thing
- */
-@Composable
-internal fun rememberRefreshAngle(): () -> Float {
-    val transition = rememberInfiniteTransition(label = "RefreshSpin")
-    val angle by transition.animateFloat(
-        initialValue = 0f,
-        targetValue = 360f,
-        animationSpec = infiniteRepeatable(tween(900, easing = LinearEasing)),
-        label = "RefreshSpinAngle",
-    )
-    return { angle }
-}

Manager/app/src/main/kotlin/com/meowarex/rlmobile/ui/widgets/updater/UpdaterViewModel.kt

@@ -37,29 +37,17 @@ class UpdaterViewModel(
         field = MutableStateFlow(null)
     val isWorking: StateFlow<Boolean>
         field = MutableStateFlow(false)
-    val isChecking: StateFlow<Boolean>
-        field = MutableStateFlow(false)
 
     private var targetApkUrl: String? = null
 
     init {
-        checkForUpdates()
-    }
-
-    /**
-     * Re-runs the update check
-     */
-    fun checkForUpdates(force: Boolean = false) = viewModelScope.launchIO {
-        if (!isChecking.compareAndSet(expect = false, update = true))
-            return@launchIO
-
-        try {
-            fetchInfo(force)
-        } catch (t: Throwable) {
-            Log.e(BuildConfig.TAG, "Failed to check for updates!", t)
-            mainThread { application.showToast(R.string.updater_check_fail) }
-        } finally {
-            isChecking.value = false
+        viewModelScope.launchIO {
+            try {
+                fetchInfo()
+            } catch (t: Throwable) {
+                Log.e(BuildConfig.TAG, "Failed to check for updates!", t)
+                mainThread { application.showToast(R.string.updater_check_fail) }
+            }
         }
     }
 
@@ -154,14 +142,14 @@ class UpdaterViewModel(
      * then finds the latest release based on the largest semantic version extracted from the tag name (`v1.0.0`),
      * and populates the state to show to the user.
      */
-    private suspend fun fetchInfo(force: Boolean = false) {
+    private suspend fun fetchInfo() {
         Log.d(BuildConfig.TAG, "Checking for updates...")
 
         val currentVersion = SemVer.parseOrNull(BuildConfig.VERSION_NAME)
             ?: throw Error("Failed to parse current app version")
 
         // Fetch releases from GitHub (60s local cache)
-        val releases = github.getManagerReleases(force).getOrThrow()
+        val releases = github.getManagerReleases().getOrThrow()
 
         // Find the latest release by parsed version
         val (version, release, apkUrl) = releases
@@ -183,14 +171,12 @@ class UpdaterViewModel(
             return
         }
 
-        Log.d(BuildConfig.TAG, "Found an update! $version $apkUrl")
-        val newVersion = version.toString()
+        Log.d(BuildConfig.TAG, "Found an update! $targetVersion $targetApkUrl")
         mainThread {
-            val alreadyKnown = targetVersion == newVersion
             targetReleaseUrl = release.htmlUrl
-            targetVersion = newVersion
+            targetVersion = version.toString()
             targetApkUrl = apkUrl
-            if (!alreadyKnown) showDialog = true
+            showDialog = true
         }
     }