utkarshdalal · utkarshdalal · Mar 28, 2026 · Mar 12, 2026 · Mar 12, 2026 · Mar 13, 2026
diff --git a/app/schemas/app.gamenative.db.PluviaDatabase/14.json b/app/schemas/app.gamenative.db.PluviaDatabase/14.json
diff --git a/app/src/main/java/app/gamenative/data/AmazonGame.kt b/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 = "",
 

diff --git a/app/src/main/java/app/gamenative/data/EpicGame.kt b/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 = "",
 

diff --git a/app/src/main/java/app/gamenative/data/GOGGame.kt b/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 = "",
 

diff --git a/app/src/main/java/app/gamenative/db/PluviaDatabase.kt b/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(

@@ -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 WHERE product_id = :productId")
+    suspend fun markAsPartialInstall(productId: 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,

@@ -11,6 +11,9 @@ 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?
 

@@ -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,

@@ -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")
+    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,

@@ -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,

@@ -548,6 +548,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)
         }

@@ -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
         }
     }

diff --git a/app/src/main/java/app/gamenative/service/amazon/AmazonDownloadManager.kt b/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)
+
             // Helper to cleanup marker on early failure
             fun cleanupOnFailure() {
                 MarkerUtils.removeMarker(installPath, Marker.DOWNLOAD_IN_PROGRESS_MARKER)

@@ -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) = withContext(Dispatchers.IO) {
+        amazonGameDao.markAsPartialInstall(productId)
+    }
+
     /** Mark a game as installed and persist install metadata. */
     suspend fun markInstalled(productId: String, installPath: String, installSize: Long, versionId: String = "") =
         withContext(Dispatchers.IO) {

@@ -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

@@ -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))
+
             // 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,
                 )

@@ -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)
      */

@@ -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) {

@@ -379,6 +379,12 @@ class GOGDownloadManager @Inject constructor(
             installPath.mkdirs()
             MarkerUtils.addMarker(installPath.absolutePath, Marker.DOWNLOAD_IN_PROGRESS_MARKER)
 
+            // Mark as partial install in DB so Downloads screen can detect it
+            val currentGame = gogManager.getGameFromDbById(gameId)
+            if (currentGame != null) {
+                gogManager.updateGame(currentGame.copy(partialInstall = true))
+            }
+
             downloadInfo.updateStatusMessage("Downloading chunks...")
 
             val chunkCacheDir = File(installPath, ".gog_chunks")
@@ -500,7 +506,7 @@ class GOGDownloadManager @Inject constructor(
             val game = gogManager.getGameFromDbById(gameId)
             if (game != null) {
                 val installSize = calculateDirectorySize(installPath)
-                gogManager.updateGame(game.copy(isInstalled = true, installPath = installPath.absolutePath, installSize = installSize))
+                gogManager.updateGame(game.copy(isInstalled = true, partialInstall = false, installPath = installPath.absolutePath, installSize = installSize))
                 Timber.tag("GOG").i("Updated database: game marked as installed, size: ${installSize / 1_000_000} MB")
             } else {
                 Timber.tag("GOG").w("Game $gameId not found in database, skipping DB update")

@@ -112,6 +112,10 @@ class GOGManager @Inject constructor(
         }
     }
 
+    suspend fun getPartialDownloads(): List<GOGGame> {
+        return withContext(Dispatchers.IO) { gogGameDao.getPartialDownloads() }
+    }
+
     suspend fun insertGame(game: GOGGame) {
         withContext(Dispatchers.IO) {
             gogGameDao.insert(game)
@@ -492,13 +496,11 @@ class GOGManager @Inject constructor(
                 MarkerUtils.removeMarker(installPath, Marker.DOWNLOAD_COMPLETE_MARKER)
                 MarkerUtils.removeMarker(installPath, Marker.DOWNLOAD_IN_PROGRESS_MARKER)
 
-                if (wasInstalled) {
-                    val game = getGameFromDbById(gameId)
-                    if (game != null) {
-                        val updatedGame = game.copy(isInstalled = false, installPath = "")
-                        gogGameDao.update(updatedGame)
-                        Timber.d("Updated database: game marked as not installed")
-                    }
+                val game = getGameFromDbById(gameId)
+                if (game != null && (wasInstalled || game.partialInstall)) {
+                    val updatedGame = game.copy(isInstalled = false, partialInstall = false, installPath = "")
+                    gogGameDao.update(updatedGame)
+                    Timber.d("Updated database: game marked as not installed")
                 }
 
                 withContext(Dispatchers.Main) {

@@ -194,6 +194,16 @@ class GOGService : Service() {
             return getInstance()?.activeDownloads?.get(gameId)
         }
 
+        fun getActiveDownloads(): Map<String, DownloadInfo> =
+            getInstance()?.activeDownloads?.let { HashMap(it) } ?: emptyMap()
+
+        suspend fun getPartialDownloads(): List<String> {
+            val instance = getInstance() ?: return emptyList()
+            return instance.gogManager.getPartialDownloads()
+                .map { it.id }
+                .filter { gameId -> !instance.activeDownloads.containsKey(gameId) }
+        }
+
         fun cleanupDownload(gameId: String) {
             getInstance()?.activeDownloads?.remove(gameId)
         }