Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 897b685c70 |
@@ -146,13 +146,15 @@ class SyncEngine @Inject constructor(
|
|||||||
storeLocalMtime = false))
|
storeLocalMtime = false))
|
||||||
}
|
}
|
||||||
SyncDecision.DELETE_LOCAL -> {
|
SyncDecision.DELETE_LOCAL -> {
|
||||||
accessor.delete(rel)
|
val deleted = accessor.delete(rel)
|
||||||
|
if (!deleted) Timber.w("SyncEngine: DELETE_LOCAL failed (silent) for $rel")
|
||||||
fileStateDao.delete(pair.id, rel)
|
fileStateDao.delete(pair.id, rel)
|
||||||
logEvent(pair.id, SyncEventType.FILE_DELETED, rel, "local", 0)
|
logEvent(pair.id, SyncEventType.FILE_DELETED, rel, "local", 0)
|
||||||
FileOutcome(deleted = 1)
|
FileOutcome(deleted = 1)
|
||||||
}
|
}
|
||||||
SyncDecision.DELETE_REMOTE -> {
|
SyncDecision.DELETE_REMOTE -> {
|
||||||
provider.deleteFile("${pair.remotePath}/$rel")
|
runCatching { provider.deleteFile("${pair.remotePath}/$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)
|
||||||
@@ -283,21 +285,15 @@ internal fun syncDecide(
|
|||||||
}
|
}
|
||||||
|
|
||||||
!localExists && remoteExists -> when {
|
!localExists && remoteExists -> when {
|
||||||
known == null -> if (!hasPriorSyncState) {
|
known == null -> {
|
||||||
// Initial sync: no history at all — remote files are new, download them.
|
// No state record: could be a new remote file OR a file whose state was lost.
|
||||||
|
// Downloading is always safer than deleting — if the user deleted the local
|
||||||
|
// copy intentionally, the state record will still exist (known != null) and
|
||||||
|
// the else-branch below correctly deletes the remote copy.
|
||||||
when (direction) {
|
when (direction) {
|
||||||
SyncDirection.DOWNLOAD_ONLY, SyncDirection.TWO_WAY -> SyncDecision.DOWNLOAD
|
SyncDirection.DOWNLOAD_ONLY, SyncDirection.TWO_WAY -> SyncDecision.DOWNLOAD
|
||||||
else -> SyncDecision.SKIP
|
else -> SyncDecision.SKIP
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
// Pair has been synced before but this file has no state record
|
|
||||||
// (e.g. uploaded before state-tracking was fixed). Treat the same
|
|
||||||
// as a known remote-deletion: apply mirror/keep behavior.
|
|
||||||
when {
|
|
||||||
deleteBehavior == DeleteBehavior.KEEP -> SyncDecision.SKIP
|
|
||||||
direction == SyncDirection.UPLOAD_ONLY || direction == SyncDirection.TWO_WAY -> SyncDecision.DELETE_REMOTE
|
|
||||||
else -> SyncDecision.SKIP
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
else -> when {
|
else -> when {
|
||||||
deleteBehavior == DeleteBehavior.KEEP -> SyncDecision.SKIP
|
deleteBehavior == DeleteBehavior.KEEP -> SyncDecision.SKIP
|
||||||
|
|||||||
@@ -20,7 +20,9 @@ import com.syncflow.MainActivity
|
|||||||
import com.syncflow.R
|
import com.syncflow.R
|
||||||
import com.syncflow.data.db.SyncFileStateDao
|
import com.syncflow.data.db.SyncFileStateDao
|
||||||
import com.syncflow.data.db.SyncPairDao
|
import com.syncflow.data.db.SyncPairDao
|
||||||
|
import com.syncflow.data.db.entities.toDomain
|
||||||
import com.syncflow.domain.model.ScheduleType
|
import com.syncflow.domain.model.ScheduleType
|
||||||
|
import com.syncflow.domain.sync.LocalAccessor
|
||||||
import dagger.hilt.android.AndroidEntryPoint
|
import dagger.hilt.android.AndroidEntryPoint
|
||||||
import kotlinx.coroutines.*
|
import kotlinx.coroutines.*
|
||||||
import kotlinx.coroutines.sync.Mutex
|
import kotlinx.coroutines.sync.Mutex
|
||||||
@@ -224,21 +226,25 @@ class FileWatchService : Service() {
|
|||||||
val known = fileStateDao.getForPair(pairId).associateBy { it.relativePath }
|
val known = fileStateDao.getForPair(pairId).associateBy { it.relativePath }
|
||||||
if (known.isEmpty()) return // Never synced — first sync will be triggered manually
|
if (known.isEmpty()) return // Never synced — first sync will be triggered manually
|
||||||
|
|
||||||
val current = mutableMapOf<String, Long>()
|
val pairEntity = syncPairDao.getById(pairId) ?: return
|
||||||
dir.walk().filter { it.isFile }.forEach { f ->
|
val pair = pairEntity.toDomain()
|
||||||
current[f.relativeTo(dir).path.replace('\\', '/')] = f.lastModified()
|
// Use the same accessor + filters as SyncEngine so hidden/excluded/size-filtered files
|
||||||
}
|
// don't appear as "new" in the catchup scan and trigger a perpetual sync loop.
|
||||||
|
val accessor = if (pair.localPath.startsWith("content://"))
|
||||||
|
LocalAccessor.Saf(Uri.parse(pair.localPath), contentResolver)
|
||||||
|
else
|
||||||
|
LocalAccessor.JavaFile(dir)
|
||||||
|
val current = accessor.walkFiles(pair)
|
||||||
|
|
||||||
val hasNew = current.any { (rel, _) -> rel !in known }
|
val hasNew = current.any { (rel, _) -> rel !in known }
|
||||||
val hasModified = current.any { (rel, mtime) ->
|
val hasModified = current.any { (rel, info) ->
|
||||||
val s = known[rel]; s != null && s.localModifiedAt != null &&
|
val s = known[rel]; s != null && s.localModifiedAt != null &&
|
||||||
s.localModifiedAt.toEpochMilli() != mtime
|
s.localModifiedAt.epochSecond != info.lastModifiedMs / 1000
|
||||||
}
|
}
|
||||||
val hasDeleted = known.keys.any { rel -> rel !in current }
|
val hasDeleted = known.keys.any { rel -> rel !in current }
|
||||||
|
|
||||||
if (hasNew || hasModified || hasDeleted) {
|
if (hasNew || hasModified || hasDeleted) {
|
||||||
Timber.d("FileWatchService: catchup detected changes for pair $pairId, scheduling sync")
|
Timber.d("FileWatchService: catchup detected changes for pair $pairId, scheduling sync")
|
||||||
val pair = syncPairDao.getById(pairId) ?: return
|
|
||||||
// Cancel any debounce that started before our startup cooldown was set
|
// Cancel any debounce that started before our startup cooldown was set
|
||||||
debounceJobs[pairId]?.cancel()
|
debounceJobs[pairId]?.cancel()
|
||||||
debounceJobs.remove(pairId)
|
debounceJobs.remove(pairId)
|
||||||
|
|||||||
+2
-2
@@ -1,2 +1,2 @@
|
|||||||
VERSION_NAME=1.0.32
|
VERSION_NAME=1.0.37
|
||||||
VERSION_CODE=33
|
VERSION_CODE=38
|
||||||
|
|||||||
Reference in New Issue
Block a user