fix(auto-upload): work policy

Signed-off-by: alperozturk96 <alper_ozturk@proton.me>

Author: alperozturk96

app/src/main/java/com/nextcloud/client/jobs/BackgroundJobManagerImpl.kt

@@ -511,7 +511,7 @@ internal class BackgroundJobManagerImpl(
 
         workManager.enqueueUniqueWork(
             JOB_IMMEDIATE_FILES_SYNC + "_" + syncedFolderID,
-            ExistingWorkPolicy.APPEND,
+            ExistingWorkPolicy.KEEP,
             request
         )
     }

app/src/main/java/com/nextcloud/client/jobs/autoUpload/AutoUploadWorker.kt

@@ -43,8 +43,11 @@ import com.owncloud.android.operations.UploadFileOperation
 import com.owncloud.android.ui.activity.SettingsActivity
 import com.owncloud.android.utils.theme.ViewThemeUtils
 import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.ensureActive
+import kotlinx.coroutines.isActive
 import kotlinx.coroutines.withContext
 import java.io.File
+import kotlin.coroutines.cancellation.CancellationException
 
 @Suppress("LongParameterList", "TooManyFunctions", "TooGenericExceptionCaught")
 class AutoUploadWorker(
@@ -90,7 +93,7 @@ class AutoUploadWorker(
             val contentUris = inputData.getStringArray(CONTENT_URIS)
 
             if (canExitEarly(contentUris, syncFolderId)) {
-                return Result.retry()
+                return Result.success()
             }
 
             if (powerManagementService.isPowerSavingEnabled) {
@@ -106,6 +109,9 @@ class AutoUploadWorker(
 
             Log_OC.d(TAG, "✅ ${syncedFolder.remotePath} completed")
             Result.success()
+        } catch (e: CancellationException) {
+            Log_OC.w(TAG, "⚠️ Job cancelled")
+            throw e
         } catch (e: Exception) {
             Log_OC.e(TAG, "❌ failed: ${e.message}")
             Result.failure()
@@ -279,7 +285,7 @@ class AutoUploadWorker(
 
         var lastId = 0
 
-        while (true) {
+        while (isActive) {
             val filePathsWithIds = repository.getFilePathsWithIds(syncedFolder, lastId)
 
             if (filePathsWithIds.isEmpty()) {
@@ -289,6 +295,8 @@ class AutoUploadWorker(
             Log_OC.d(TAG, "started, processing batch: lastId=$lastId, count=${filePathsWithIds.size}")
 
             filePathsWithIds.forEachIndexed { batchIndex, (path, id) ->
+                ensureActive()
+
                 val file = File(path)
                 val localPath = file.absolutePath
                 val remotePath = syncFolderHelper.getAutoUploadRemotePath(syncedFolder, file)

app/src/main/java/com/nextcloud/client/jobs/autoUpload/FileSystemRepository.kt

@@ -91,7 +91,7 @@ class FileSystemRepository(
             dao.markFileAsUploaded(localPath, syncedFolderIdStr)
             Log_OC.d(TAG, "Marked file as uploaded: $localPath for syncedFolderId=$syncedFolderIdStr")
         } catch (e: Exception) {
-            Log_OC.e(TAG, "Error marking file as uploaded: ${e.message}", e)
+            Log_OC.e(TAG, "markFileAsHandled(): ${e.message}", e)
         }
     }