feat: downloads storage manager tab

app/src/main/java/app/gamenative/data/AmazonGame.kt

@@ -43,6 +43,9 @@ data class AmazonGame(
     @ColumnInfo("is_installed")
     val isInstalled: Boolean = false,
 
+    @ColumnInfo(name = "partial_install", defaultValue = "0")
+    val partialInstall: Boolean = false,
+
     @ColumnInfo("install_path")
     val installPath: String = "",
 

app/src/main/java/app/gamenative/data/DownloadInfo.kt

@@ -189,6 +189,40 @@ data class DownloadInfo(
         }
     }
 
+    /**
+     * Returns the recent download speed in bytes per second, or null if there is
+     * not enough sample data yet.
+     */
+    fun getCurrentDownloadSpeed(windowSeconds: Int = 10): Long? {
+        if (!isActive) return null
+
+        val now = System.currentTimeMillis()
+        val cutoff = now - windowSeconds * 1000L
+        val samples = speedSamples.toTypedArray().filter { it.timeMs >= cutoff }.toList()
+        if (samples.size < 2) {
+            return emaSpeedBytesPerSec.takeIf { hasEmaSpeed && it > 0.0 }?.toLong()
+        }
+
+        val first = samples.first()
+        val last = samples.last()
+        val elapsedMs = last.timeMs - first.timeMs
+        if (elapsedMs <= 0L) {
+            return emaSpeedBytesPerSec.takeIf { hasEmaSpeed && it > 0.0 }?.toLong()
+        }
+
+        val bytesDelta = last.bytes - first.bytes
+        if (bytesDelta <= 0L) {
+            return emaSpeedBytesPerSec.takeIf { hasEmaSpeed && it > 0.0 }?.toLong()
+        }
+
+        val bytesPerSecond = bytesDelta.toDouble() / (elapsedMs.toDouble() / 1000.0)
+        if (bytesPerSecond <= 0.0 || bytesPerSecond.isNaN() || bytesPerSecond.isInfinite()) {
+            return emaSpeedBytesPerSec.takeIf { hasEmaSpeed && it > 0.0 }?.toLong()
+        }
+
+        return bytesPerSecond.toLong()
+    }
+
     /**
      * Returns an ETA in milliseconds based on recent download speed, or null if
      * there is not enough information yet (e.g. just started) or download is inactive.

app/src/main/java/app/gamenative/data/EpicGame.kt

@@ -38,6 +38,9 @@ data class EpicGame(
     @ColumnInfo("is_installed")
     val isInstalled: Boolean = false,
 
+    @ColumnInfo(name = "partial_install", defaultValue = "0")
+    val partialInstall: Boolean = false,
+
     @ColumnInfo("install_path")
     val installPath: String = "",
 

app/src/main/java/app/gamenative/data/GOGGame.kt

@@ -30,6 +30,9 @@ data class GOGGame(
     @ColumnInfo("is_installed")
     val isInstalled: Boolean = false,
 
+    @ColumnInfo(name = "partial_install", defaultValue = "0")
+    val partialInstall: Boolean = false,
+
     @ColumnInfo("install_path")
     val installPath: String = "",
 

app/src/main/java/app/gamenative/db/PluviaDatabase.kt

@@ -50,7 +50,7 @@ const val DATABASE_NAME = "pluvia.db"
         AmazonGame::class,
         DownloadingAppInfo::class
     ],
-    version = 13,
+    version = 14,
     // For db migration, visit https://developer.android.com/training/data-storage/room/migrating-db-versions for more information
     exportSchema = true, // It is better to handle db changes carefully, as GN is getting much more users.
     autoMigrations = [
@@ -60,6 +60,7 @@ const val DATABASE_NAME = "pluvia.db"
         AutoMigration(from = 10, to = 11),
         AutoMigration(from = 11, to = 12),
         AutoMigration(from = 12, to = 13), // Added amazon_games table
+        AutoMigration(from = 13, to = 14), // Added partial_install column to epic_games, gog_games, amazon_games
     ]
 )
 @TypeConverters(

app/src/main/java/app/gamenative/db/dao/AmazonGameDao.kt

@@ -29,12 +29,21 @@ interface AmazonGameDao {
     @Query("SELECT * FROM amazon_games ORDER BY title ASC")
     suspend fun getAllAsList(): List<AmazonGame>
 
+    @Query("SELECT * FROM amazon_games WHERE is_installed = 0")
+    suspend fun getNonInstalledGames(): List<AmazonGame>
+
+    @Query("SELECT * FROM amazon_games WHERE partial_install = 1")
+    suspend fun getPartialDownloads(): List<AmazonGame>
+
+    @Query("UPDATE amazon_games SET partial_install = 1, install_path = :installPath WHERE product_id = :productId")
+    suspend fun markAsPartialInstall(productId: String, installPath: String)
+
     @Query(
-        "UPDATE amazon_games SET is_installed = 1, install_path = :path, install_size = :size, version_id = :versionId WHERE product_id = :productId",
+        "UPDATE amazon_games SET is_installed = 1, partial_install = 0, install_path = :path, install_size = :size, version_id = :versionId WHERE product_id = :productId",
     )
     suspend fun markAsInstalled(productId: String, path: String, size: Long, versionId: String)
 
-    @Query("UPDATE amazon_games SET is_installed = 0, install_path = '', install_size = 0, version_id = '' WHERE product_id = :productId")
+    @Query("UPDATE amazon_games SET is_installed = 0, partial_install = 0, install_path = '', install_size = 0, version_id = '' WHERE product_id = :productId")
     suspend fun markAsUninstalled(productId: String)
 
     @Query("UPDATE amazon_games SET download_size = :size WHERE product_id = :productId")
@@ -71,6 +80,7 @@ interface AmazonGameDao {
                 newGame.copy(
                     appId = existing.appId,  // Keep the existing appId
                     isInstalled = existing.isInstalled,
+                    partialInstall = existing.partialInstall,
                     installPath = existing.installPath,
                     installSize = existing.installSize,
                     versionId = existing.versionId,

app/src/main/java/app/gamenative/db/dao/DownloadingAppInfoDao.kt

@@ -11,15 +11,15 @@ interface DownloadingAppInfoDao {
     @Insert(onConflict = OnConflictStrategy.REPLACE)
     suspend fun insert(appInfo: DownloadingAppInfo)
 
+    @Query("SELECT * FROM downloading_app_info")
+    suspend fun getAll(): List<DownloadingAppInfo>
+
     @Query("SELECT * FROM downloading_app_info WHERE appId = :appId")
     suspend fun getDownloadingApp(appId: Int): DownloadingAppInfo?
 
     @Query("DELETE from downloading_app_info WHERE appId = :appId")
     suspend fun deleteApp(appId: Int)
 
-    @Query("SELECT * FROM downloading_app_info")
-    suspend fun getAll(): List<DownloadingAppInfo>
-
     @Query("DELETE from downloading_app_info")
     suspend fun deleteAll()
 }

app/src/main/java/app/gamenative/db/dao/EpicGameDao.kt

@@ -31,7 +31,7 @@ interface EpicGameDao {
     @Delete
     suspend fun delete(game: EpicGame)
 
-    @Query("UPDATE epic_games SET is_installed = 0, install_path='',install_size = 0 WHERE id = :appId")
+    @Query("UPDATE epic_games SET is_installed = 0, partial_install = 0, install_path='',install_size = 0 WHERE id = :appId")
     suspend fun uninstall(appId: Int)
 
     @Query("DELETE FROM epic_games WHERE id = :appId")
@@ -53,9 +53,15 @@ interface EpicGameDao {
     @Query("SELECT * FROM epic_games WHERE is_dlc = 0 AND namespace != 'ue' AND namespace != '89efe5924d3d467c839449ab6ab52e7f' ORDER BY title ASC")
     fun getAll(): Flow<List<EpicGame>>
 
+    @Query("SELECT * FROM epic_games WHERE is_dlc = 0 AND namespace != 'ue' AND namespace != '89efe5924d3d467c839449ab6ab52e7f' ORDER BY title ASC")
+    suspend fun getAllAsList(): List<EpicGame>
+
     @Query("SELECT * FROM epic_games WHERE is_installed = :isInstalled ORDER BY title ASC")
     fun getByInstallStatus(isInstalled: Boolean): Flow<List<EpicGame>>
 
+    @Query("SELECT * FROM epic_games WHERE partial_install = 1")
+    suspend fun getPartialDownloads(): List<EpicGame>
+
     @Query("SELECT * FROM epic_games WHERE base_game_app_name = (SELECT catalog_id FROM epic_games WHERE id = :appId)")
     fun getDLCForTitle(appId: Int): Flow<List<EpicGame>>
 
@@ -92,6 +98,7 @@ interface EpicGameDao {
                 newGame.copy(
                     id = existingGame.id,
                     isInstalled = existingGame.isInstalled,
+                    partialInstall = existingGame.partialInstall,
                     installPath = existingGame.installPath,
                     installSize = existingGame.installSize,
                     lastPlayed = existingGame.lastPlayed,

app/src/main/java/app/gamenative/db/dao/GOGGameDao.kt

@@ -43,6 +43,12 @@ interface GOGGameDao {
     @Query("SELECT * FROM gog_games WHERE is_installed = :isInstalled AND exclude = 0 ORDER BY title ASC")
     fun getByInstallStatus(isInstalled: Boolean): Flow<List<GOGGame>>
 
+    @Query("SELECT * FROM gog_games WHERE is_installed = 0 AND exclude = 0")
+    suspend fun getNonInstalledGames(): List<GOGGame>
+
+    @Query("SELECT * FROM gog_games WHERE partial_install = 1 AND exclude = 0")
+    suspend fun getPartialDownloads(): List<GOGGame>
+
     @Query("SELECT * FROM gog_games WHERE exclude = 0 AND title LIKE '%' || :searchQuery || '%' ORDER BY title ASC")
     fun searchByTitle(searchQuery: String): Flow<List<GOGGame>>
 
@@ -67,6 +73,7 @@ interface GOGGameDao {
                 // Preserve installation status, path, and size from existing game
                 val gameToInsert = newGame.copy(
                     isInstalled = existingGame.isInstalled,
+                    partialInstall = existingGame.partialInstall,
                     installPath = existingGame.installPath,
                     installSize = existingGame.installSize,
                     lastPlayed = existingGame.lastPlayed,

app/src/main/java/app/gamenative/db/dao/SteamAppDao.kt

@@ -35,6 +35,17 @@ interface SteamAppDao {
         // borrowedCode: Int = ELicenseFlags.Borrowed.code(),
     ): Flow<List<SteamApp>>
 
+    @Query(
+        "SELECT * FROM steam_app " +
+            "WHERE id != 480 " +
+            "AND package_id != :invalidPkgId " +
+            "AND type != 0 " +
+            "ORDER BY LOWER(name)",
+    )
+    suspend fun getAllOwnedAppsAsList(
+        invalidPkgId: Int = INVALID_PKG_ID,
+    ): List<SteamApp>
+
     @Query("SELECT * FROM steam_app WHERE received_pics = 0 AND package_id != :invalidPkgId AND owner_account_id = :ownerId")
     fun getAllOwnedAppsWithoutPICS(
         ownerId: Int,

app/src/main/java/app/gamenative/service/SteamService.kt

@@ -564,6 +564,15 @@ class SteamService : Service(), IChallengeUrlChanged {
             return downloadJobs[appId]
         }
 
+        fun getActiveDownloads(): Map<Int, DownloadInfo> = HashMap(downloadJobs)
+
+        suspend fun getPartialDownloads(): List<Int> {
+            return instance?.downloadingAppInfoDao?.getAll()
+                ?.map { it.appId }
+                ?.filter { appId -> !downloadJobs.containsKey(appId) }
+                ?: emptyList()
+        }
+
         fun isAppInstalled(appId: Int): Boolean {
             return MarkerUtils.hasMarker(getAppDirPath(appId), Marker.DOWNLOAD_COMPLETE_MARKER)
         }

app/src/main/java/app/gamenative/service/amazon/AmazonConstants.kt

@@ -51,16 +51,26 @@ object AmazonConstants {
     // ── SDK / Launcher channel ──────────────────────────────────────────────
     const val LAUNCHER_CHANNEL_ID = "87d38116-4cbf-4af0-a371-a5b498975346"
 
+    fun internalAmazonGamesPath(context: Context): String {
+        val path = Paths.get(context.dataDir.path, "Amazon").toString()
+        File(path).mkdirs()
+        return path
+    }
+
+    fun externalAmazonGamesPath(): String {
+        val path = Paths.get(PrefManager.externalStoragePath, "Amazon", "games").toString()
+        File(path).mkdirs()
+        return path
+    }
+
     fun defaultAmazonGamesPath(context: Context): String {
         return if (PrefManager.useExternalStorage && File(PrefManager.externalStoragePath).exists()) {
-            val path = Paths.get(PrefManager.externalStoragePath, "Amazon", "games").toString()
+            val path = externalAmazonGamesPath()
             Timber.i("Amazon using external storage: $path")
-            File(path).mkdirs()
             path
         } else {
-            val path = Paths.get(context.dataDir.path, "Amazon").toString()
+            val path = internalAmazonGamesPath(context)
             Timber.i("Amazon using internal storage: $path")
-            File(path).mkdirs()
             path
         }
     }

app/src/main/java/app/gamenative/service/amazon/AmazonDownloadManager.kt

@@ -54,6 +54,9 @@ class AmazonDownloadManager @Inject constructor(
             File(installPath).mkdirs()
             MarkerUtils.addMarker(installPath, Marker.DOWNLOAD_IN_PROGRESS_MARKER)
 
+            // Mark as partial install in DB so Downloads screen can detect it
+            amazonManager.markAsPartialInstall(productId, installPath)
+
             // Helper to cleanup marker on early failure
             fun cleanupOnFailure() {
                 MarkerUtils.removeMarker(installPath, Marker.DOWNLOAD_IN_PROGRESS_MARKER)

app/src/main/java/app/gamenative/service/amazon/AmazonManager.kt

@@ -57,6 +57,21 @@ class AmazonManager @Inject constructor(
         amazonGameDao.getAllAsList()
     }
 
+    /** Return non-installed Amazon games from DB. */
+    suspend fun getNonInstalledGames(): List<AmazonGame> = withContext(Dispatchers.IO) {
+        amazonGameDao.getNonInstalledGames()
+    }
+
+    /** Return games with partial_install = true from DB. */
+    suspend fun getPartialDownloads(): List<AmazonGame> = withContext(Dispatchers.IO) {
+        amazonGameDao.getPartialDownloads()
+    }
+
+    /** Mark a game as partially installed (download started but not complete). */
+    suspend fun markAsPartialInstall(productId: String, installPath: String) = withContext(Dispatchers.IO) {
+        amazonGameDao.markAsPartialInstall(productId, installPath)
+    }
+
     /** Mark a game as installed and persist install metadata. */
     suspend fun markInstalled(productId: String, installPath: String, installSize: Long, versionId: String = "") =
         withContext(Dispatchers.IO) {

app/src/main/java/app/gamenative/service/amazon/AmazonService.kt

@@ -357,6 +357,16 @@ class AmazonService : Service() {
         fun getDownloadInfo(productId: String): DownloadInfo? =
             getInstance()?.activeDownloads?.get(productId)
 
+        fun getActiveDownloads(): Map<String, DownloadInfo> =
+            getInstance()?.activeDownloads?.let { HashMap(it) } ?: emptyMap()
+
+        suspend fun getPartialDownloads(context: Context): List<String> {
+            val instance = getInstance() ?: return emptyList()
+            return instance.amazonManager.getPartialDownloads()
+                .map { it.productId }
+                .filter { !instance.activeDownloads.containsKey(it) }
+        }
+
         /** Returns the active [DownloadInfo] for [appId], or null if not downloading. */
         fun getDownloadInfoByAppId(appId: Int): DownloadInfo? {
             val productId = getProductIdByAppId(appId) ?: return null

app/src/main/java/app/gamenative/service/epic/EpicDownloadManager.kt

@@ -83,6 +83,9 @@ class EpicDownloadManager @Inject constructor(
             File(installPath).mkdirs()
             MarkerUtils.addMarker(installPath, Marker.DOWNLOAD_IN_PROGRESS_MARKER)
 
+            // Mark as partial install in DB so Downloads screen can detect it
+            epicManager.updateGame(game.copy(partialInstall = true, installPath = installPath))
+
             // Emit download started event so UI can attach progress listeners
             val gameId = game.id
             app.gamenative.PluviaApp.events.emitJava(
@@ -345,6 +348,7 @@ class EpicDownloadManager @Inject constructor(
             try {
                 val updatedGame = game.copy(
                     isInstalled = true,
+                    partialInstall = false,
                     installPath = installPath,
                     installSize = totalInstalledSize,
                 )
@@ -362,6 +366,7 @@ class EpicDownloadManager @Inject constructor(
             downloadInfo.updateStatusMessage("Complete")
             // Ensure bytes-based progress shows 100% completion
             downloadInfo.updateBytesDownloaded(downloadInfo.getTotalExpectedBytes() - downloadInfo.getBytesDownloaded())
+            downloadInfo.clearPersistedBytesDownloaded(installPath)
             downloadInfo.setProgress(1.0f)
             downloadInfo.setActive(false)
             downloadInfo.emitProgressChange()

app/src/main/java/app/gamenative/service/epic/EpicManager.kt

@@ -336,7 +336,7 @@ class EpicManager @Inject constructor(
                     }
 
                     // Skip invalid platform (such as Android versions)
-                    if(platforms.isNotEmpty() && !platforms.contains("Win32") && !platforms.contains("Windows")){ 
+                    if(platforms.isNotEmpty() && !platforms.contains("Win32") && !platforms.contains("Windows")){
                         Timber.tag("Epic").d("Skipping due to invalid platform: $appName (namespace=$namespace, sandbox=$sandboxType)")
                         continue
                     }
@@ -718,6 +718,12 @@ class EpicManager @Inject constructor(
         }
     }
 
+    suspend fun getPartialDownloads(): List<EpicGame> {
+        return withContext(Dispatchers.IO) {
+            epicGameDao.getPartialDownloads()
+        }
+    }
+
     /**
      * Start background sync (called after login)
      */

app/src/main/java/app/gamenative/service/epic/EpicService.kt

@@ -179,6 +179,16 @@ class EpicService : Service() {
             return getInstance()?.activeDownloads?.get(appId)
         }
 
+        fun getActiveDownloads(): Map<Int, DownloadInfo> =
+            getInstance()?.activeDownloads?.let { HashMap(it) } ?: emptyMap()
+
+        suspend fun getPartialDownloads(): List<Int> {
+            val instance = getInstance() ?: return emptyList()
+            return instance.epicManager.getPartialDownloads()
+                .map { it.id }
+                .filter { appId -> !instance.activeDownloads.containsKey(appId) }
+        }
+
         suspend fun deleteGame(context: Context, appId: Int): Result<Unit> {
             val instance = getInstance()
             if (instance == null) {
@@ -369,6 +379,12 @@ class EpicService : Service() {
                 gameId = appId,
                 downloadingAppIds = CopyOnWriteArrayList<Int>(),
             )
+            downloadInfo.setPersistencePath(installPath)
+
+            val persistedBytes = downloadInfo.loadPersistedBytesDownloaded(installPath)
+            if (persistedBytes > 0L) {
+                downloadInfo.initializeBytesDownloaded(persistedBytes)
+            }
 
             instance.activeDownloads[appId] = downloadInfo
             downloadInfo.setActive(true)