Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 69d4257a18 | |||
| 683169e8b7 | |||
| 77d56ee6be |
@@ -58,6 +58,7 @@ enum class ConflictStrategy(val label: String) {
|
|||||||
enum class DeleteBehavior(val label: String, val description: String) {
|
enum class DeleteBehavior(val label: String, val description: String) {
|
||||||
MIRROR("Mirror deletions", "Delete on target when deleted on source"),
|
MIRROR("Mirror deletions", "Delete on target when deleted on source"),
|
||||||
KEEP("Keep deleted files", "Never delete — only add/update"),
|
KEEP("Keep deleted files", "Never delete — only add/update"),
|
||||||
|
ARCHIVE("Archive deleted", "Move files deleted from phone to _Deleted/ folder on remote"),
|
||||||
}
|
}
|
||||||
|
|
||||||
enum class ScheduleType(val label: String) {
|
enum class ScheduleType(val label: String) {
|
||||||
|
|||||||
@@ -34,6 +34,17 @@ class SyncEngine @Inject constructor(
|
|||||||
@ApplicationContext private val context: Context,
|
@ApplicationContext private val context: Context,
|
||||||
) {
|
) {
|
||||||
suspend fun sync(pair: SyncPair, provider: CloudProvider): SyncResult {
|
suspend fun sync(pair: SyncPair, provider: CloudProvider): SyncResult {
|
||||||
|
if (!pair.localPath.startsWith("content://") &&
|
||||||
|
pair.syncDirection != SyncDirection.UPLOAD_ONLY) {
|
||||||
|
val canonical = runCatching { File(pair.localPath).canonicalPath }.getOrElse { pair.localPath }
|
||||||
|
if (canonical == "/storage/emulated/0") {
|
||||||
|
val msg = "Local folder is the storage root — Android blocks writes here. Use Upload Only direction, or select a subfolder."
|
||||||
|
syncPairDao.updateSyncResult(pair.id, Instant.now(), SyncStatus.FAILED, 0)
|
||||||
|
logEvent(pair.id, SyncEventType.SYNC_FAILED, null, msg, 0)
|
||||||
|
return SyncResult(failedFiles = 1, error = Exception(msg))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
syncPairDao.updateStatus(pair.id, SyncStatus.SYNCING)
|
syncPairDao.updateStatus(pair.id, SyncStatus.SYNCING)
|
||||||
logEvent(pair.id, SyncEventType.SYNC_STARTED, null, null, 0)
|
logEvent(pair.id, SyncEventType.SYNC_STARTED, null, null, 0)
|
||||||
|
|
||||||
@@ -156,10 +167,20 @@ class SyncEngine @Inject constructor(
|
|||||||
FileOutcome(deleted = 1)
|
FileOutcome(deleted = 1)
|
||||||
}
|
}
|
||||||
SyncDecision.DELETE_REMOTE -> {
|
SyncDecision.DELETE_REMOTE -> {
|
||||||
|
if (pair.deleteBehavior == DeleteBehavior.ARCHIVE) {
|
||||||
|
val archivePath = "${pair.remotePath}/_Deleted/$rel"
|
||||||
|
runCatching {
|
||||||
|
ensureRemoteDirs(provider, "${pair.remotePath}/_Deleted", rel)
|
||||||
|
provider.moveFile("${pair.remotePath}/$rel", archivePath).getOrThrow()
|
||||||
|
}.onFailure { e -> Timber.e(e, "SyncEngine: ARCHIVE failed for $rel") }
|
||||||
|
fileStateDao.delete(pair.id, rel)
|
||||||
|
logEvent(pair.id, SyncEventType.FILE_DELETED, rel, "archived", 0)
|
||||||
|
} else {
|
||||||
runCatching { provider.deleteFile("${pair.remotePath}/$rel") }
|
runCatching { provider.deleteFile("${pair.remotePath}/$rel") }
|
||||||
.onFailure { e -> Timber.e(e, "SyncEngine: DELETE_REMOTE failed for $rel") }
|
.onFailure { e -> Timber.e(e, "SyncEngine: DELETE_REMOTE failed for $rel") }
|
||||||
fileStateDao.delete(pair.id, rel)
|
fileStateDao.delete(pair.id, rel)
|
||||||
logEvent(pair.id, SyncEventType.FILE_DELETED, rel, "remote", 0)
|
logEvent(pair.id, SyncEventType.FILE_DELETED, rel, "remote", 0)
|
||||||
|
}
|
||||||
FileOutcome(deleted = 1)
|
FileOutcome(deleted = 1)
|
||||||
}
|
}
|
||||||
SyncDecision.CONFLICT -> {
|
SyncDecision.CONFLICT -> {
|
||||||
|
|||||||
@@ -1,5 +1,8 @@
|
|||||||
package com.syncflow.ui.addpair
|
package com.syncflow.ui.addpair
|
||||||
|
|
||||||
|
import android.content.Intent
|
||||||
|
import androidx.activity.compose.rememberLauncherForActivityResult
|
||||||
|
import androidx.activity.result.contract.ActivityResultContracts
|
||||||
import androidx.compose.animation.AnimatedVisibility
|
import androidx.compose.animation.AnimatedVisibility
|
||||||
import androidx.compose.foundation.clickable
|
import androidx.compose.foundation.clickable
|
||||||
import androidx.compose.foundation.layout.*
|
import androidx.compose.foundation.layout.*
|
||||||
@@ -12,6 +15,7 @@ import androidx.compose.material3.*
|
|||||||
import androidx.compose.runtime.*
|
import androidx.compose.runtime.*
|
||||||
import androidx.compose.ui.Alignment
|
import androidx.compose.ui.Alignment
|
||||||
import androidx.compose.ui.Modifier
|
import androidx.compose.ui.Modifier
|
||||||
|
import androidx.compose.ui.platform.LocalContext
|
||||||
import androidx.compose.ui.text.font.FontWeight
|
import androidx.compose.ui.text.font.FontWeight
|
||||||
import androidx.compose.ui.text.input.ImeAction
|
import androidx.compose.ui.text.input.ImeAction
|
||||||
import androidx.compose.ui.text.input.KeyboardType
|
import androidx.compose.ui.text.input.KeyboardType
|
||||||
@@ -28,9 +32,20 @@ fun AddPairScreen(onDone: () -> Unit, vm: AddPairViewModel = hiltViewModel()) {
|
|||||||
val s by vm.state.collectAsState()
|
val s by vm.state.collectAsState()
|
||||||
LaunchedEffect(s.done) { if (s.done) onDone() }
|
LaunchedEffect(s.done) { if (s.done) onDone() }
|
||||||
|
|
||||||
|
val context = LocalContext.current
|
||||||
var showRemoteBrowser by remember { mutableStateOf(false) }
|
var showRemoteBrowser by remember { mutableStateOf(false) }
|
||||||
var showLocalBrowser by remember { mutableStateOf(false) }
|
var showLocalBrowser by remember { mutableStateOf(false) }
|
||||||
|
|
||||||
|
val safLauncher = rememberLauncherForActivityResult(ActivityResultContracts.OpenDocumentTree()) { uri ->
|
||||||
|
if (uri != null) {
|
||||||
|
context.contentResolver.takePersistableUriPermission(
|
||||||
|
uri,
|
||||||
|
Intent.FLAG_GRANT_READ_URI_PERMISSION or Intent.FLAG_GRANT_WRITE_URI_PERMISSION,
|
||||||
|
)
|
||||||
|
vm.update { copy(localPath = uri.toString()) }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if (showLocalBrowser) {
|
if (showLocalBrowser) {
|
||||||
LocalBrowserDialog(
|
LocalBrowserDialog(
|
||||||
initialPath = s.localPath.ifBlank { "" },
|
initialPath = s.localPath.ifBlank { "" },
|
||||||
@@ -105,7 +120,8 @@ fun AddPairScreen(onDone: () -> Unit, vm: AddPairViewModel = hiltViewModel()) {
|
|||||||
|
|
||||||
Spacer(Modifier.height(4.dp))
|
Spacer(Modifier.height(4.dp))
|
||||||
|
|
||||||
// Local folder
|
// Local folder — tap opens Android system picker (SAF), same as Autosync
|
||||||
|
Column {
|
||||||
Box(modifier = Modifier.fillMaxWidth()) {
|
Box(modifier = Modifier.fillMaxWidth()) {
|
||||||
OutlinedTextField(
|
OutlinedTextField(
|
||||||
value = uriToDisplay(s.localPath), onValueChange = {},
|
value = uriToDisplay(s.localPath), onValueChange = {},
|
||||||
@@ -115,7 +131,15 @@ fun AddPairScreen(onDone: () -> Unit, vm: AddPairViewModel = hiltViewModel()) {
|
|||||||
readOnly = true, singleLine = true, modifier = Modifier.fillMaxWidth(),
|
readOnly = true, singleLine = true, modifier = Modifier.fillMaxWidth(),
|
||||||
placeholder = { Text("Tap to choose folder…") },
|
placeholder = { Text("Tap to choose folder…") },
|
||||||
)
|
)
|
||||||
Box(modifier = Modifier.matchParentSize().clickable { showLocalBrowser = true })
|
Box(modifier = Modifier.matchParentSize().clickable { safLauncher.launch(null) })
|
||||||
|
}
|
||||||
|
TextButton(
|
||||||
|
onClick = { showLocalBrowser = true },
|
||||||
|
modifier = Modifier.align(Alignment.End),
|
||||||
|
contentPadding = PaddingValues(horizontal = 8.dp, vertical = 0.dp),
|
||||||
|
) {
|
||||||
|
Text("Browse manually", style = MaterialTheme.typography.labelSmall)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Remote folder
|
// Remote folder
|
||||||
|
|||||||
@@ -263,13 +263,23 @@ fun LocalBrowserDialog(
|
|||||||
}
|
}
|
||||||
|
|
||||||
// ── Select button ────────────────────────────────────────────
|
// ── Select button ────────────────────────────────────────────
|
||||||
|
val isStorageRoot = currentPath.absolutePath == STORAGE_ROOT.absolutePath
|
||||||
Surface(tonalElevation = 4.dp, modifier = Modifier.fillMaxWidth()) {
|
Surface(tonalElevation = 4.dp, modifier = Modifier.fillMaxWidth()) {
|
||||||
Column {
|
Column {
|
||||||
|
if (isStorageRoot) {
|
||||||
|
Text(
|
||||||
|
"Android blocks writes to the storage root — please open a subfolder first",
|
||||||
|
style = MaterialTheme.typography.bodySmall,
|
||||||
|
color = MaterialTheme.colorScheme.error,
|
||||||
|
modifier = Modifier.padding(horizontal = 20.dp, vertical = 8.dp),
|
||||||
|
)
|
||||||
|
}
|
||||||
Button(
|
Button(
|
||||||
onClick = { onSelect(currentPath.absolutePath) },
|
onClick = { onSelect(currentPath.absolutePath) },
|
||||||
|
enabled = !isStorageRoot,
|
||||||
modifier = Modifier
|
modifier = Modifier
|
||||||
.fillMaxWidth()
|
.fillMaxWidth()
|
||||||
.padding(start = 16.dp, top = 12.dp, end = 16.dp, bottom = 12.dp)
|
.padding(start = 16.dp, top = 4.dp, end = 16.dp, bottom = 12.dp)
|
||||||
.height(52.dp),
|
.height(52.dp),
|
||||||
shape = RoundedCornerShape(14.dp),
|
shape = RoundedCornerShape(14.dp),
|
||||||
) {
|
) {
|
||||||
|
|||||||
+2
-2
@@ -1,2 +1,2 @@
|
|||||||
VERSION_NAME=1.0.52
|
VERSION_NAME=1.0.55
|
||||||
VERSION_CODE=53
|
VERSION_CODE=56
|
||||||
|
|||||||
Reference in New Issue
Block a user