Compare commits
6 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 21d8f0dca2 | |||
| 3d7a8b5f3d | |||
| 1d6a80e43d | |||
| a9322d3214 | |||
| 5f45a344b7 | |||
| e237555222 |
@@ -7,17 +7,28 @@ import androidx.activity.enableEdgeToEdge
|
|||||||
import androidx.appcompat.app.AppCompatActivity
|
import androidx.appcompat.app.AppCompatActivity
|
||||||
import androidx.biometric.BiometricManager
|
import androidx.biometric.BiometricManager
|
||||||
import androidx.biometric.BiometricManager.Authenticators.BIOMETRIC_STRONG
|
import androidx.biometric.BiometricManager.Authenticators.BIOMETRIC_STRONG
|
||||||
|
import androidx.biometric.BiometricManager.Authenticators.BIOMETRIC_WEAK
|
||||||
import androidx.biometric.BiometricManager.Authenticators.DEVICE_CREDENTIAL
|
import androidx.biometric.BiometricManager.Authenticators.DEVICE_CREDENTIAL
|
||||||
import androidx.biometric.BiometricPrompt
|
import androidx.biometric.BiometricPrompt
|
||||||
import androidx.compose.foundation.background
|
import androidx.compose.foundation.background
|
||||||
|
import androidx.compose.foundation.layout.Arrangement
|
||||||
import androidx.compose.foundation.layout.Box
|
import androidx.compose.foundation.layout.Box
|
||||||
|
import androidx.compose.foundation.layout.Column
|
||||||
|
import androidx.compose.foundation.layout.Spacer
|
||||||
import androidx.compose.foundation.layout.fillMaxSize
|
import androidx.compose.foundation.layout.fillMaxSize
|
||||||
import androidx.compose.material3.CircularProgressIndicator
|
import androidx.compose.foundation.layout.height
|
||||||
|
import androidx.compose.foundation.layout.size
|
||||||
|
import androidx.compose.material.icons.Icons
|
||||||
|
import androidx.compose.material.icons.filled.Lock
|
||||||
|
import androidx.compose.material3.Button
|
||||||
|
import androidx.compose.material3.Icon
|
||||||
import androidx.compose.material3.MaterialTheme
|
import androidx.compose.material3.MaterialTheme
|
||||||
import androidx.compose.material3.Surface
|
import androidx.compose.material3.Surface
|
||||||
|
import androidx.compose.material3.Text
|
||||||
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.unit.dp
|
||||||
import androidx.core.content.ContextCompat
|
import androidx.core.content.ContextCompat
|
||||||
import androidx.core.splashscreen.SplashScreen.Companion.installSplashScreen
|
import androidx.core.splashscreen.SplashScreen.Companion.installSplashScreen
|
||||||
import androidx.lifecycle.lifecycleScope
|
import androidx.lifecycle.lifecycleScope
|
||||||
@@ -36,6 +47,7 @@ class MainActivity : AppCompatActivity() {
|
|||||||
@Inject lateinit var appPreferences: AppPreferences
|
@Inject lateinit var appPreferences: AppPreferences
|
||||||
|
|
||||||
private var isLocked by mutableStateOf(false)
|
private var isLocked by mutableStateOf(false)
|
||||||
|
private var showRetry by mutableStateOf(false)
|
||||||
|
|
||||||
override fun onCreate(savedInstanceState: Bundle?) {
|
override fun onCreate(savedInstanceState: Bundle?) {
|
||||||
installSplashScreen()
|
installSplashScreen()
|
||||||
@@ -47,13 +59,18 @@ class MainActivity : AppCompatActivity() {
|
|||||||
SyncFlowNavGraph(rememberNavController())
|
SyncFlowNavGraph(rememberNavController())
|
||||||
}
|
}
|
||||||
if (isLocked) {
|
if (isLocked) {
|
||||||
LockOverlay()
|
LockOverlay(
|
||||||
LaunchedEffect(Unit) {
|
showRetry = showRetry,
|
||||||
showBiometricPrompt(onSuccess = { isLocked = false })
|
onRetry = { triggerBiometric() },
|
||||||
|
)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
override fun onResume() {
|
||||||
|
super.onResume()
|
||||||
|
if (isLocked) triggerBiometric()
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun onStop() {
|
override fun onStop() {
|
||||||
@@ -62,51 +79,86 @@ class MainActivity : AppCompatActivity() {
|
|||||||
lifecycleScope.launch {
|
lifecycleScope.launch {
|
||||||
if (appPreferences.biometricLockEnabled.first() && canAuthenticate()) {
|
if (appPreferences.biometricLockEnabled.first() && canAuthenticate()) {
|
||||||
isLocked = true
|
isLocked = true
|
||||||
|
showRetry = false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun canAuthenticate(): Boolean {
|
private fun triggerBiometric() {
|
||||||
val authenticators = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.R)
|
showRetry = false
|
||||||
BIOMETRIC_STRONG or DEVICE_CREDENTIAL
|
val authenticators = bestAuthenticators()
|
||||||
else
|
|
||||||
BIOMETRIC_STRONG
|
|
||||||
return BiometricManager.from(this).canAuthenticate(authenticators) ==
|
|
||||||
BiometricManager.BIOMETRIC_SUCCESS
|
|
||||||
}
|
|
||||||
|
|
||||||
private fun showBiometricPrompt(onSuccess: () -> Unit) {
|
|
||||||
val executor = ContextCompat.getMainExecutor(this)
|
val executor = ContextCompat.getMainExecutor(this)
|
||||||
val prompt = BiometricPrompt(this, executor, object : BiometricPrompt.AuthenticationCallback() {
|
val prompt = BiometricPrompt(this, executor, object : BiometricPrompt.AuthenticationCallback() {
|
||||||
override fun onAuthenticationSucceeded(result: BiometricPrompt.AuthenticationResult) {
|
override fun onAuthenticationSucceeded(result: BiometricPrompt.AuthenticationResult) {
|
||||||
onSuccess()
|
isLocked = false
|
||||||
|
showRetry = false
|
||||||
|
}
|
||||||
|
override fun onAuthenticationError(errorCode: Int, errString: CharSequence) {
|
||||||
|
// Show the Unlock button so the user can tap to retry manually
|
||||||
|
showRetry = true
|
||||||
|
}
|
||||||
|
override fun onAuthenticationFailed() {
|
||||||
|
// Wrong biometric — BiometricPrompt retries automatically
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
val promptInfo = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.R) {
|
val promptInfo = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.R) {
|
||||||
BiometricPrompt.PromptInfo.Builder()
|
BiometricPrompt.PromptInfo.Builder()
|
||||||
.setTitle("Unlock SyncFlow")
|
.setTitle("Unlock SyncFlow")
|
||||||
.setSubtitle("Confirm your identity to continue")
|
.setSubtitle("Use fingerprint or PIN")
|
||||||
.setAllowedAuthenticators(BIOMETRIC_STRONG or DEVICE_CREDENTIAL)
|
.setAllowedAuthenticators(authenticators)
|
||||||
.build()
|
.build()
|
||||||
} else {
|
} else {
|
||||||
BiometricPrompt.PromptInfo.Builder()
|
BiometricPrompt.PromptInfo.Builder()
|
||||||
.setTitle("Unlock SyncFlow")
|
.setTitle("Unlock SyncFlow")
|
||||||
.setSubtitle("Confirm your identity to continue")
|
.setSubtitle("Use fingerprint")
|
||||||
.setNegativeButtonText("Cancel")
|
.setNegativeButtonText("Cancel")
|
||||||
.build()
|
.build()
|
||||||
}
|
}
|
||||||
prompt.authenticate(promptInfo)
|
prompt.authenticate(promptInfo)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private fun bestAuthenticators(): Int {
|
||||||
|
if (Build.VERSION.SDK_INT < Build.VERSION_CODES.R) return BIOMETRIC_STRONG
|
||||||
|
val bm = BiometricManager.from(this)
|
||||||
|
// Prefer strong+credential; fall back to weak+credential so side-sensor phones work
|
||||||
|
return if (bm.canAuthenticate(BIOMETRIC_STRONG or DEVICE_CREDENTIAL) == BiometricManager.BIOMETRIC_SUCCESS)
|
||||||
|
BIOMETRIC_STRONG or DEVICE_CREDENTIAL
|
||||||
|
else
|
||||||
|
BIOMETRIC_WEAK or DEVICE_CREDENTIAL
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun canAuthenticate(): Boolean {
|
||||||
|
if (Build.VERSION.SDK_INT < Build.VERSION_CODES.R)
|
||||||
|
return BiometricManager.from(this).canAuthenticate(BIOMETRIC_STRONG) == BiometricManager.BIOMETRIC_SUCCESS
|
||||||
|
val bm = BiometricManager.from(this)
|
||||||
|
return bm.canAuthenticate(BIOMETRIC_STRONG or DEVICE_CREDENTIAL) == BiometricManager.BIOMETRIC_SUCCESS ||
|
||||||
|
bm.canAuthenticate(BIOMETRIC_WEAK or DEVICE_CREDENTIAL) == BiometricManager.BIOMETRIC_SUCCESS
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Composable
|
@Composable
|
||||||
private fun LockOverlay() {
|
private fun LockOverlay(showRetry: Boolean, onRetry: () -> Unit) {
|
||||||
Box(
|
Box(
|
||||||
modifier = Modifier
|
modifier = Modifier
|
||||||
.fillMaxSize()
|
.fillMaxSize()
|
||||||
.background(MaterialTheme.colorScheme.background),
|
.background(MaterialTheme.colorScheme.background),
|
||||||
contentAlignment = Alignment.Center,
|
contentAlignment = Alignment.Center,
|
||||||
) {
|
) {
|
||||||
CircularProgressIndicator()
|
Column(
|
||||||
|
horizontalAlignment = Alignment.CenterHorizontally,
|
||||||
|
verticalArrangement = Arrangement.spacedBy(12.dp),
|
||||||
|
) {
|
||||||
|
Icon(Icons.Default.Lock, null, modifier = Modifier.size(56.dp), tint = MaterialTheme.colorScheme.primary)
|
||||||
|
Text("SyncFlow is locked", style = MaterialTheme.typography.titleMedium)
|
||||||
|
if (showRetry) {
|
||||||
|
Button(onClick = onRetry) { Text("Unlock") }
|
||||||
|
} else {
|
||||||
|
Text(
|
||||||
|
"Use fingerprint or PIN to unlock",
|
||||||
|
style = MaterialTheme.typography.bodySmall,
|
||||||
|
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,6 +4,6 @@ import androidx.room.TypeConverter
|
|||||||
import java.time.Instant
|
import java.time.Instant
|
||||||
|
|
||||||
class DbConverters {
|
class DbConverters {
|
||||||
@TypeConverter fun fromInstant(v: Instant?): Long? = v?.epochSecond
|
@TypeConverter fun fromInstant(v: Instant?): Long? = v?.toEpochMilli()
|
||||||
@TypeConverter fun toInstant(v: Long?): Instant? = v?.let { Instant.ofEpochSecond(it) }
|
@TypeConverter fun toInstant(v: Long?): Instant? = v?.let { Instant.ofEpochMilli(it) }
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,6 +3,8 @@ package com.syncflow.data.db
|
|||||||
import androidx.room.Database
|
import androidx.room.Database
|
||||||
import androidx.room.RoomDatabase
|
import androidx.room.RoomDatabase
|
||||||
import androidx.room.TypeConverters
|
import androidx.room.TypeConverters
|
||||||
|
import androidx.room.migration.Migration
|
||||||
|
import androidx.sqlite.db.SupportSQLiteDatabase
|
||||||
import com.syncflow.data.db.entities.*
|
import com.syncflow.data.db.entities.*
|
||||||
|
|
||||||
@Database(
|
@Database(
|
||||||
@@ -13,11 +15,21 @@ import com.syncflow.data.db.entities.*
|
|||||||
SyncConflictEntity::class,
|
SyncConflictEntity::class,
|
||||||
SyncEventEntity::class,
|
SyncEventEntity::class,
|
||||||
],
|
],
|
||||||
version = 2,
|
version = 3,
|
||||||
exportSchema = true,
|
exportSchema = true,
|
||||||
)
|
)
|
||||||
@TypeConverters(DbConverters::class)
|
@TypeConverters(DbConverters::class)
|
||||||
abstract class SyncDatabase : RoomDatabase() {
|
abstract class SyncDatabase : RoomDatabase() {
|
||||||
|
|
||||||
|
companion object {
|
||||||
|
// Wipe file states: timestamps were stored as epoch-seconds, now epoch-millis.
|
||||||
|
// All previously saved states are wrong so we drop and re-learn on next sync.
|
||||||
|
val MIGRATION_2_3 = object : Migration(2, 3) {
|
||||||
|
override fun migrate(db: SupportSQLiteDatabase) {
|
||||||
|
db.execSQL("DELETE FROM sync_file_states")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
abstract fun cloudAccountDao(): CloudAccountDao
|
abstract fun cloudAccountDao(): CloudAccountDao
|
||||||
abstract fun syncPairDao(): SyncPairDao
|
abstract fun syncPairDao(): SyncPairDao
|
||||||
abstract fun syncFileStateDao(): SyncFileStateDao
|
abstract fun syncFileStateDao(): SyncFileStateDao
|
||||||
|
|||||||
@@ -132,7 +132,10 @@ open class WebDavProvider(protected val account: CloudAccount) : CloudProvider {
|
|||||||
val req = Request.Builder().url(url(remotePath)).method("PROPFIND", PROPFIND_BODY).header("Depth", "0").build()
|
val req = Request.Builder().url(url(remotePath)).method("PROPFIND", PROPFIND_BODY).header("Depth", "0").build()
|
||||||
client.newCall(req).execute().use { resp ->
|
client.newCall(req).execute().use { resp ->
|
||||||
if (resp.code != 207) throw Exception("HTTP ${resp.code}")
|
if (resp.code != 207) throw Exception("HTTP ${resp.code}")
|
||||||
parsePropfind(resp.body?.string() ?: "", remotePath.substringBeforeLast('/'))
|
// Depth:0 returns exactly the requested resource as the single response entry.
|
||||||
|
// parsePropfind normally drops the first entry (the parent dir) for Depth:1
|
||||||
|
// directory listings, so pass dropFirst=false here.
|
||||||
|
parsePropfind(resp.body?.string() ?: "", remotePath.substringBeforeLast('/'), dropFirst = false)
|
||||||
.firstOrNull() ?: throw Exception("File not found")
|
.firstOrNull() ?: throw Exception("File not found")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -153,7 +156,7 @@ open class WebDavProvider(protected val account: CloudAccount) : CloudProvider {
|
|||||||
|
|
||||||
protected fun url(path: String) = "$baseUrl/${path.trimStart('/')}"
|
protected fun url(path: String) = "$baseUrl/${path.trimStart('/')}"
|
||||||
|
|
||||||
private fun parsePropfind(xml: String, parentPath: String): List<RemoteFile> {
|
private fun parsePropfind(xml: String, parentPath: String, dropFirst: Boolean = true): List<RemoteFile> {
|
||||||
val results = mutableListOf<RemoteFile>()
|
val results = mutableListOf<RemoteFile>()
|
||||||
try {
|
try {
|
||||||
val factory = XmlPullParserFactory.newInstance()
|
val factory = XmlPullParserFactory.newInstance()
|
||||||
@@ -192,7 +195,7 @@ open class WebDavProvider(protected val account: CloudAccount) : CloudProvider {
|
|||||||
eventType = parser.next()
|
eventType = parser.next()
|
||||||
}
|
}
|
||||||
} catch (_: Exception) {}
|
} catch (_: Exception) {}
|
||||||
return results.drop(1) // drop the parent folder itself
|
return if (dropFirst) results.drop(1) else results
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun parseHttpDate(value: String): Instant = try {
|
private fun parseHttpDate(value: String): Instant = try {
|
||||||
|
|||||||
@@ -21,9 +21,8 @@ object AppModule {
|
|||||||
@Provides @Singleton
|
@Provides @Singleton
|
||||||
fun provideDatabase(@ApplicationContext ctx: Context): SyncDatabase =
|
fun provideDatabase(@ApplicationContext ctx: Context): SyncDatabase =
|
||||||
Room.databaseBuilder(ctx, SyncDatabase::class.java, "syncflow.db")
|
Room.databaseBuilder(ctx, SyncDatabase::class.java, "syncflow.db")
|
||||||
// Only fall back to destructive migration for very old dev builds (v1).
|
|
||||||
// All future version bumps must include a proper Migration object.
|
|
||||||
.fallbackToDestructiveMigrationFrom(1)
|
.fallbackToDestructiveMigrationFrom(1)
|
||||||
|
.addMigrations(SyncDatabase.MIGRATION_2_3)
|
||||||
.build()
|
.build()
|
||||||
|
|
||||||
@Provides fun provideCloudAccountDao(db: SyncDatabase): CloudAccountDao = db.cloudAccountDao()
|
@Provides fun provideCloudAccountDao(db: SyncDatabase): CloudAccountDao = db.cloudAccountDao()
|
||||||
|
|||||||
@@ -63,7 +63,13 @@ sealed class LocalAccessor {
|
|||||||
|
|
||||||
class Saf(private val treeUri: Uri, private val resolver: ContentResolver) : LocalAccessor() {
|
class Saf(private val treeUri: Uri, private val resolver: ContentResolver) : LocalAccessor() {
|
||||||
|
|
||||||
|
// Populated by walkFiles so openInputStream can skip the re-query for files that
|
||||||
|
// already exist locally (uploads). Root-level files are the common failure case
|
||||||
|
// when findDocUri re-queries: the cache sidesteps the issue entirely.
|
||||||
|
private val docIdCache = mutableMapOf<String, String>()
|
||||||
|
|
||||||
override fun walkFiles(pair: SyncPair): Map<String, LocalFileInfo> {
|
override fun walkFiles(pair: SyncPair): Map<String, LocalFileInfo> {
|
||||||
|
docIdCache.clear()
|
||||||
val rootDocId = DocumentsContract.getTreeDocumentId(treeUri)
|
val rootDocId = DocumentsContract.getTreeDocumentId(treeUri)
|
||||||
val childrenUri = DocumentsContract.buildChildDocumentsUriUsingTree(treeUri, rootDocId)
|
val childrenUri = DocumentsContract.buildChildDocumentsUriUsingTree(treeUri, rootDocId)
|
||||||
return cursorWalk(childrenUri, "", pair)
|
return cursorWalk(childrenUri, "", pair)
|
||||||
@@ -110,6 +116,7 @@ sealed class LocalAccessor {
|
|||||||
if (ext in excludeExts) continue
|
if (ext in excludeExts) continue
|
||||||
if (size !in minBytes..maxBytes) continue
|
if (size !in minBytes..maxBytes) continue
|
||||||
result[rel] = LocalFileInfo(rel, size, modified)
|
result[rel] = LocalFileInfo(rel, size, modified)
|
||||||
|
docIdCache[rel] = docId
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -117,7 +124,10 @@ sealed class LocalAccessor {
|
|||||||
}
|
}
|
||||||
|
|
||||||
override fun openInputStream(relativePath: String): InputStream? {
|
override fun openInputStream(relativePath: String): InputStream? {
|
||||||
val docUri = findDocUri(relativePath) ?: return null
|
val docUri = docIdCache[relativePath]
|
||||||
|
?.let { DocumentsContract.buildDocumentUriUsingTree(treeUri, it) }
|
||||||
|
?: findDocUri(relativePath)
|
||||||
|
?: return null
|
||||||
return resolver.openInputStream(docUri)
|
return resolver.openInputStream(docUri)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -155,8 +165,15 @@ sealed class LocalAccessor {
|
|||||||
}
|
}
|
||||||
|
|
||||||
override fun delete(relativePath: String): Boolean {
|
override fun delete(relativePath: String): Boolean {
|
||||||
val docUri = findDocUri(relativePath) ?: return false
|
val docUri = docIdCache[relativePath]
|
||||||
return DocumentsContract.deleteDocument(resolver, docUri)
|
?.let { DocumentsContract.buildDocumentUriUsingTree(treeUri, it) }
|
||||||
|
?: findDocUri(relativePath)
|
||||||
|
?: return false
|
||||||
|
return try {
|
||||||
|
DocumentsContract.deleteDocument(resolver, docUri)
|
||||||
|
} catch (e: Exception) {
|
||||||
|
false
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun lastModifiedMs(relativePath: String): Long {
|
override fun lastModifiedMs(relativePath: String): Long {
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import com.syncflow.data.db.SyncFileStateDao
|
|||||||
import com.syncflow.data.db.SyncPairDao
|
import com.syncflow.data.db.SyncPairDao
|
||||||
import com.syncflow.data.db.entities.SyncConflictEntity
|
import com.syncflow.data.db.entities.SyncConflictEntity
|
||||||
import com.syncflow.data.db.entities.SyncEventEntity
|
import com.syncflow.data.db.entities.SyncEventEntity
|
||||||
|
import com.syncflow.data.db.entities.SyncFileStateEntity
|
||||||
import com.syncflow.data.providers.CloudProvider
|
import com.syncflow.data.providers.CloudProvider
|
||||||
import com.syncflow.domain.model.ConflictStrategy
|
import com.syncflow.domain.model.ConflictStrategy
|
||||||
import com.syncflow.domain.model.DeleteBehavior
|
import com.syncflow.domain.model.DeleteBehavior
|
||||||
@@ -68,39 +69,44 @@ class SyncEngine @Inject constructor(
|
|||||||
.associateBy { it.path.removePrefix(pair.remotePath).trimStart('/') }
|
.associateBy { it.path.removePrefix(pair.remotePath).trimStart('/') }
|
||||||
val localFiles = accessor.walkFiles(pair)
|
val localFiles = accessor.walkFiles(pair)
|
||||||
|
|
||||||
var uploaded = 0; var downloaded = 0; var deleted = 0; var skipped = 0; var failed = 0; var conflicts = 0
|
|
||||||
var bytesTransferred = 0L
|
|
||||||
val newStates = mutableListOf<com.syncflow.data.db.entities.SyncFileStateEntity>()
|
|
||||||
|
|
||||||
val allPaths = (localFiles.keys + remoteFiles.keys + knownStates.keys).toSet()
|
val allPaths = (localFiles.keys + remoteFiles.keys + knownStates.keys).toSet()
|
||||||
|
val hasPriorSyncState = knownStates.isNotEmpty()
|
||||||
val semaphore = Semaphore(4)
|
val semaphore = Semaphore(4)
|
||||||
|
|
||||||
coroutineScope {
|
// Each async block returns its outcome; no shared mutable state across coroutines.
|
||||||
|
data class FileOutcome(
|
||||||
|
val uploaded: Int = 0, val downloaded: Int = 0, val deleted: Int = 0,
|
||||||
|
val skipped: Int = 0, val failed: Int = 0, val conflicts: Int = 0,
|
||||||
|
val bytesTransferred: Long = 0L,
|
||||||
|
val newState: SyncFileStateEntity? = null,
|
||||||
|
)
|
||||||
|
|
||||||
|
val outcomes: List<FileOutcome> = coroutineScope {
|
||||||
allPaths.map { rel ->
|
allPaths.map { rel ->
|
||||||
async {
|
async {
|
||||||
semaphore.withPermit {
|
semaphore.withPermit {
|
||||||
val local = localFiles[rel]
|
val local = localFiles[rel]
|
||||||
val remote = remoteFiles[rel]
|
val remote = remoteFiles[rel]
|
||||||
val known = knownStates[rel]
|
val known = knownStates[rel]
|
||||||
val decision = decide(pair.syncDirection, pair.conflictStrategy, pair.deleteBehavior, local, remote, known)
|
val decision = syncDecide(pair.syncDirection, pair.conflictStrategy, pair.deleteBehavior, local, remote, known, hasPriorSyncState)
|
||||||
|
|
||||||
when (decision) {
|
when (decision) {
|
||||||
SyncDecision.UPLOAD -> {
|
SyncDecision.UPLOAD -> {
|
||||||
|
var uploadedRemoteFile: RemoteFile? = null
|
||||||
val bytes = runCatching {
|
val bytes = runCatching {
|
||||||
|
ensureRemoteDirs(provider, pair.remotePath, rel)
|
||||||
accessor.openInputStream(rel)?.use { stream ->
|
accessor.openInputStream(rel)?.use { stream ->
|
||||||
provider.uploadFile(stream, "${pair.remotePath}/$rel", local!!.sizeBytes) { }
|
uploadedRemoteFile = provider.uploadFile(stream, "${pair.remotePath}/$rel", local!!.sizeBytes) { }.getOrThrow()
|
||||||
}
|
}
|
||||||
local!!.sizeBytes
|
local!!.sizeBytes
|
||||||
}.getOrElse { e ->
|
}.getOrElse { e ->
|
||||||
Timber.e(e, "Upload failed: $rel")
|
Timber.e(e, "Upload failed: $rel")
|
||||||
failed++
|
|
||||||
logEvent(pair.id, SyncEventType.FILE_SKIPPED, rel, e.message, 0)
|
logEvent(pair.id, SyncEventType.FILE_SKIPPED, rel, e.message, 0)
|
||||||
return@withPermit
|
return@withPermit FileOutcome(failed = 1)
|
||||||
}
|
}
|
||||||
uploaded++
|
|
||||||
bytesTransferred += bytes
|
|
||||||
newStates += buildState(pair.id, rel, local!!, remote)
|
|
||||||
logEvent(pair.id, SyncEventType.FILE_UPLOADED, rel, null, bytes)
|
logEvent(pair.id, SyncEventType.FILE_UPLOADED, rel, null, bytes)
|
||||||
|
FileOutcome(uploaded = 1, bytesTransferred = bytes,
|
||||||
|
newState = buildState(pair.id, rel, local!!, remoteAfterTransfer = uploadedRemoteFile))
|
||||||
}
|
}
|
||||||
SyncDecision.DOWNLOAD -> {
|
SyncDecision.DOWNLOAD -> {
|
||||||
val bytes = runCatching {
|
val bytes = runCatching {
|
||||||
@@ -110,29 +116,31 @@ class SyncEngine @Inject constructor(
|
|||||||
remote!!.sizeBytes
|
remote!!.sizeBytes
|
||||||
}.getOrElse { e ->
|
}.getOrElse { e ->
|
||||||
Timber.e(e, "Download failed: $rel")
|
Timber.e(e, "Download failed: $rel")
|
||||||
failed++
|
|
||||||
logEvent(pair.id, SyncEventType.FILE_SKIPPED, rel, e.message, 0)
|
logEvent(pair.id, SyncEventType.FILE_SKIPPED, rel, e.message, 0)
|
||||||
return@withPermit
|
return@withPermit FileOutcome(failed = 1)
|
||||||
}
|
}
|
||||||
downloaded++
|
// Read the actual local mtime written by the OS/SAF after download.
|
||||||
bytesTransferred += bytes
|
val localMtime = runCatching { accessor.lastModifiedMs(rel) }
|
||||||
newStates += buildState(pair.id, rel, null, remote)
|
.getOrDefault(System.currentTimeMillis()).takeIf { it > 0L }
|
||||||
|
?: System.currentTimeMillis()
|
||||||
logEvent(pair.id, SyncEventType.FILE_DOWNLOADED, rel, null, bytes)
|
logEvent(pair.id, SyncEventType.FILE_DOWNLOADED, rel, null, bytes)
|
||||||
|
FileOutcome(downloaded = 1, bytesTransferred = bytes,
|
||||||
|
newState = buildState(pair.id, rel,
|
||||||
|
LocalFileInfo(rel, remote!!.sizeBytes, localMtime), remoteAfterTransfer = remote))
|
||||||
}
|
}
|
||||||
SyncDecision.DELETE_LOCAL -> {
|
SyncDecision.DELETE_LOCAL -> {
|
||||||
accessor.delete(rel)
|
accessor.delete(rel)
|
||||||
fileStateDao.delete(pair.id, rel)
|
fileStateDao.delete(pair.id, rel)
|
||||||
deleted++
|
|
||||||
logEvent(pair.id, SyncEventType.FILE_DELETED, rel, "local", 0)
|
logEvent(pair.id, SyncEventType.FILE_DELETED, rel, "local", 0)
|
||||||
|
FileOutcome(deleted = 1)
|
||||||
}
|
}
|
||||||
SyncDecision.DELETE_REMOTE -> {
|
SyncDecision.DELETE_REMOTE -> {
|
||||||
provider.deleteFile("${pair.remotePath}/$rel")
|
provider.deleteFile("${pair.remotePath}/$rel")
|
||||||
fileStateDao.delete(pair.id, rel)
|
fileStateDao.delete(pair.id, rel)
|
||||||
deleted++
|
|
||||||
logEvent(pair.id, SyncEventType.FILE_DELETED, rel, "remote", 0)
|
logEvent(pair.id, SyncEventType.FILE_DELETED, rel, "remote", 0)
|
||||||
|
FileOutcome(deleted = 1)
|
||||||
}
|
}
|
||||||
SyncDecision.CONFLICT -> {
|
SyncDecision.CONFLICT -> {
|
||||||
conflicts++
|
|
||||||
conflictDao.insert(SyncConflictEntity(
|
conflictDao.insert(SyncConflictEntity(
|
||||||
syncPairId = pair.id,
|
syncPairId = pair.id,
|
||||||
relativePath = rel,
|
relativePath = rel,
|
||||||
@@ -144,31 +152,96 @@ class SyncEngine @Inject constructor(
|
|||||||
detectedAt = Instant.now(),
|
detectedAt = Instant.now(),
|
||||||
))
|
))
|
||||||
logEvent(pair.id, SyncEventType.CONFLICT_DETECTED, rel, null, 0)
|
logEvent(pair.id, SyncEventType.CONFLICT_DETECTED, rel, null, 0)
|
||||||
|
FileOutcome(conflicts = 1)
|
||||||
|
}
|
||||||
|
SyncDecision.SKIP -> {
|
||||||
|
// Save state whenever both sides are present and state is absent or
|
||||||
|
// incomplete (post-upload null metadata). Without a baseline record,
|
||||||
|
// a subsequent local deletion would look like an unseen remote file
|
||||||
|
// and be re-downloaded instead of triggering DELETE_REMOTE.
|
||||||
|
val saveState = local != null && remote != null && (
|
||||||
|
known == null ||
|
||||||
|
known.remoteModifiedAt == null || known.localModifiedAt == null
|
||||||
|
)
|
||||||
|
if (saveState) {
|
||||||
|
FileOutcome(skipped = 1, newState = buildState(pair.id, rel, local, remoteAfterTransfer = remote))
|
||||||
|
} else {
|
||||||
|
FileOutcome(skipped = 1)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
SyncDecision.SKIP -> skipped++
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}.awaitAll()
|
}.awaitAll()
|
||||||
}
|
}
|
||||||
|
|
||||||
fileStateDao.upsertAll(newStates)
|
fileStateDao.upsertAll(outcomes.mapNotNull { it.newState })
|
||||||
return SyncResult(uploaded, downloaded, deleted, skipped, failed, conflicts, bytesTransferred)
|
return SyncResult(
|
||||||
|
uploaded = outcomes.sumOf { it.uploaded },
|
||||||
|
downloaded = outcomes.sumOf { it.downloaded },
|
||||||
|
deleted = outcomes.sumOf { it.deleted },
|
||||||
|
skipped = outcomes.sumOf { it.skipped },
|
||||||
|
failedFiles = outcomes.sumOf { it.failed },
|
||||||
|
conflicts = outcomes.sumOf { it.conflicts },
|
||||||
|
bytesTransferred = outcomes.sumOf { it.bytesTransferred },
|
||||||
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun decide(
|
private suspend fun ensureRemoteDirs(provider: CloudProvider, remotePairPath: String, rel: String) {
|
||||||
|
val parts = rel.replace('\\', '/').split('/')
|
||||||
|
var currentPath = remotePairPath
|
||||||
|
for (part in parts.dropLast(1)) {
|
||||||
|
currentPath = "$currentPath/$part"
|
||||||
|
provider.createDirectory(currentPath).onFailure { e ->
|
||||||
|
Timber.w("MKCOL $currentPath: ${e.message}")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun buildState(
|
||||||
|
pairId: Long,
|
||||||
|
rel: String,
|
||||||
|
local: LocalFileInfo?,
|
||||||
|
remoteAfterTransfer: RemoteFile?,
|
||||||
|
) = SyncFileStateEntity(
|
||||||
|
syncPairId = pairId,
|
||||||
|
relativePath = rel,
|
||||||
|
localModifiedAt = local?.lastModifiedMs?.let { Instant.ofEpochMilli(it) },
|
||||||
|
localSizeBytes = local?.sizeBytes ?: 0L,
|
||||||
|
localHash = null,
|
||||||
|
remoteModifiedAt = remoteAfterTransfer?.modifiedAt,
|
||||||
|
remoteSizeBytes = remoteAfterTransfer?.sizeBytes ?: 0L,
|
||||||
|
remoteEtag = remoteAfterTransfer?.etag,
|
||||||
|
lastSyncedAt = Instant.now(),
|
||||||
|
syncedHash = null,
|
||||||
|
)
|
||||||
|
|
||||||
|
private suspend fun logEvent(pairId: Long, type: SyncEventType, file: String?, msg: String?, bytes: Long) {
|
||||||
|
eventDao.insert(SyncEventEntity(syncPairId = pairId, timestamp = Instant.now(), eventType = type, filePath = file, message = msg, bytesTransferred = bytes))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Top-level so unit tests can call it directly without instantiating SyncEngine.
|
||||||
|
internal fun syncDecide(
|
||||||
direction: SyncDirection,
|
direction: SyncDirection,
|
||||||
conflictStrategy: ConflictStrategy,
|
conflictStrategy: ConflictStrategy,
|
||||||
deleteBehavior: DeleteBehavior,
|
deleteBehavior: DeleteBehavior,
|
||||||
local: LocalFileInfo?,
|
local: LocalFileInfo?,
|
||||||
remote: RemoteFile?,
|
remote: RemoteFile?,
|
||||||
known: com.syncflow.data.db.entities.SyncFileStateEntity?,
|
known: SyncFileStateEntity?,
|
||||||
): SyncDecision {
|
hasPriorSyncState: Boolean = false,
|
||||||
|
): SyncDecision {
|
||||||
val localExists = local != null
|
val localExists = local != null
|
||||||
val remoteExists = remote != null
|
val remoteExists = remote != null
|
||||||
|
|
||||||
val localChanged = known == null || (localExists && local!!.lastModifiedMs != known.localModifiedAt?.toEpochMilli())
|
// Treat null known timestamps as "not yet recorded" — don't treat as changed.
|
||||||
val remoteChanged = known == null || (remoteExists && remote!!.etag != known.remoteEtag && remote.modifiedAt != known.remoteModifiedAt)
|
// The SKIP reconciliation pass will fill them in on the next sync.
|
||||||
|
val localChanged = known == null ||
|
||||||
|
(localExists && known.localModifiedAt != null &&
|
||||||
|
local!!.lastModifiedMs != known.localModifiedAt.toEpochMilli())
|
||||||
|
val remoteChanged = known == null ||
|
||||||
|
(remoteExists && known.remoteModifiedAt != null &&
|
||||||
|
(remote!!.etag != known.remoteEtag || remote.modifiedAt != known.remoteModifiedAt))
|
||||||
|
|
||||||
return when {
|
return when {
|
||||||
!localExists && !remoteExists -> SyncDecision.SKIP
|
!localExists && !remoteExists -> SyncDecision.SKIP
|
||||||
@@ -186,10 +259,22 @@ class SyncEngine @Inject constructor(
|
|||||||
}
|
}
|
||||||
|
|
||||||
!localExists && remoteExists -> when {
|
!localExists && remoteExists -> when {
|
||||||
known == null -> when (direction) {
|
known == null -> if (!hasPriorSyncState) {
|
||||||
|
// Initial sync: no history at all — remote files are new, download them.
|
||||||
|
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
|
||||||
direction == SyncDirection.UPLOAD_ONLY || direction == SyncDirection.TWO_WAY -> SyncDecision.DELETE_REMOTE
|
direction == SyncDirection.UPLOAD_ONLY || direction == SyncDirection.TWO_WAY -> SyncDecision.DELETE_REMOTE
|
||||||
@@ -220,29 +305,6 @@ class SyncEngine @Inject constructor(
|
|||||||
}
|
}
|
||||||
else -> SyncDecision.SKIP
|
else -> SyncDecision.SKIP
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
private fun buildState(
|
|
||||||
pairId: Long,
|
|
||||||
rel: String,
|
|
||||||
local: LocalFileInfo?,
|
|
||||||
remote: RemoteFile?,
|
|
||||||
) = com.syncflow.data.db.entities.SyncFileStateEntity(
|
|
||||||
syncPairId = pairId,
|
|
||||||
relativePath = rel,
|
|
||||||
localModifiedAt = local?.lastModifiedMs?.let { Instant.ofEpochMilli(it) },
|
|
||||||
localSizeBytes = local?.sizeBytes ?: 0L,
|
|
||||||
localHash = null,
|
|
||||||
remoteModifiedAt = remote?.modifiedAt,
|
|
||||||
remoteSizeBytes = remote?.sizeBytes ?: 0L,
|
|
||||||
remoteEtag = remote?.etag,
|
|
||||||
lastSyncedAt = Instant.now(),
|
|
||||||
syncedHash = null,
|
|
||||||
)
|
|
||||||
|
|
||||||
private suspend fun logEvent(pairId: Long, type: SyncEventType, file: String?, msg: String?, bytes: Long) {
|
|
||||||
eventDao.insert(SyncEventEntity(syncPairId = pairId, timestamp = Instant.now(), eventType = type, filePath = file, message = msg, bytesTransferred = bytes))
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
enum class SyncDecision { UPLOAD, DOWNLOAD, DELETE_LOCAL, DELETE_REMOTE, CONFLICT, SKIP }
|
enum class SyncDecision { UPLOAD, DOWNLOAD, DELETE_LOCAL, DELETE_REMOTE, CONFLICT, SKIP }
|
||||||
|
|||||||
@@ -1,9 +1,11 @@
|
|||||||
package com.syncflow.ui.home
|
package com.syncflow.ui.home
|
||||||
|
|
||||||
|
import androidx.compose.foundation.BorderStroke
|
||||||
import androidx.compose.foundation.clickable
|
import androidx.compose.foundation.clickable
|
||||||
import androidx.compose.foundation.layout.*
|
import androidx.compose.foundation.layout.*
|
||||||
import androidx.compose.foundation.lazy.LazyColumn
|
import androidx.compose.foundation.lazy.LazyColumn
|
||||||
import androidx.compose.foundation.lazy.items
|
import androidx.compose.foundation.lazy.items
|
||||||
|
import androidx.compose.foundation.shape.RoundedCornerShape
|
||||||
import androidx.compose.material.icons.Icons
|
import androidx.compose.material.icons.Icons
|
||||||
import androidx.compose.material.icons.filled.*
|
import androidx.compose.material.icons.filled.*
|
||||||
import androidx.compose.material.icons.outlined.*
|
import androidx.compose.material.icons.outlined.*
|
||||||
@@ -11,11 +13,12 @@ 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.text.font.FontWeight
|
import androidx.compose.ui.graphics.Color
|
||||||
import androidx.compose.ui.unit.dp
|
import androidx.compose.ui.unit.dp
|
||||||
import androidx.hilt.navigation.compose.hiltViewModel
|
import androidx.hilt.navigation.compose.hiltViewModel
|
||||||
import com.syncflow.data.db.entities.SyncPairEntity
|
import com.syncflow.data.db.entities.SyncPairEntity
|
||||||
import com.syncflow.domain.model.SyncStatus
|
import com.syncflow.domain.model.SyncStatus
|
||||||
|
import java.time.Duration
|
||||||
import java.time.Instant
|
import java.time.Instant
|
||||||
import java.time.ZoneId
|
import java.time.ZoneId
|
||||||
import java.time.format.DateTimeFormatter
|
import java.time.format.DateTimeFormatter
|
||||||
@@ -58,43 +61,100 @@ private fun SyncPairCard(
|
|||||||
onSync: () -> Unit,
|
onSync: () -> Unit,
|
||||||
onToggle: () -> Unit,
|
onToggle: () -> Unit,
|
||||||
) {
|
) {
|
||||||
ElevatedCard(
|
val accentColor = pair.lastSyncResult.accentColor
|
||||||
modifier = Modifier.fillMaxWidth().clickable(onClick = onClick),
|
|
||||||
elevation = CardDefaults.elevatedCardElevation(defaultElevation = 2.dp),
|
Card(
|
||||||
|
modifier = Modifier
|
||||||
|
.fillMaxWidth()
|
||||||
|
.clickable(onClick = onClick),
|
||||||
|
shape = RoundedCornerShape(16.dp),
|
||||||
|
border = BorderStroke(1.dp, MaterialTheme.colorScheme.outline),
|
||||||
|
colors = CardDefaults.cardColors(containerColor = MaterialTheme.colorScheme.surface),
|
||||||
) {
|
) {
|
||||||
Column(modifier = Modifier.padding(16.dp)) {
|
Row(modifier = Modifier.fillMaxWidth()) {
|
||||||
|
// Colored left accent bar
|
||||||
|
Box(
|
||||||
|
modifier = Modifier
|
||||||
|
.width(3.dp)
|
||||||
|
.height(IntrinsicSize.Min)
|
||||||
|
.defaultMinSize(minHeight = 80.dp),
|
||||||
|
) {
|
||||||
|
Box(
|
||||||
|
modifier = Modifier
|
||||||
|
.fillMaxHeight()
|
||||||
|
.width(3.dp),
|
||||||
|
) {
|
||||||
|
Surface(
|
||||||
|
modifier = Modifier.fillMaxSize(),
|
||||||
|
color = accentColor,
|
||||||
|
) {}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Column(modifier = Modifier.padding(start = 12.dp, top = 12.dp, end = 12.dp, bottom = 12.dp)) {
|
||||||
Row(verticalAlignment = Alignment.CenterVertically) {
|
Row(verticalAlignment = Alignment.CenterVertically) {
|
||||||
Column(modifier = Modifier.weight(1f)) {
|
Column(modifier = Modifier.weight(1f)) {
|
||||||
Text(pair.name, style = MaterialTheme.typography.titleMedium, fontWeight = FontWeight.SemiBold)
|
|
||||||
Spacer(Modifier.height(2.dp))
|
|
||||||
Text(
|
Text(
|
||||||
pair.localPath.takeLast(40),
|
pair.name,
|
||||||
|
style = MaterialTheme.typography.titleMedium,
|
||||||
|
)
|
||||||
|
Spacer(Modifier.height(2.dp))
|
||||||
|
val localShortName = pair.localPath.toDisplayPath()
|
||||||
|
Text(
|
||||||
|
localShortName,
|
||||||
|
style = MaterialTheme.typography.bodySmall,
|
||||||
|
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
|
)
|
||||||
|
Spacer(Modifier.height(2.dp))
|
||||||
|
Row(verticalAlignment = Alignment.CenterVertically) {
|
||||||
|
Icon(
|
||||||
|
Icons.Default.ArrowForward,
|
||||||
|
contentDescription = null,
|
||||||
|
modifier = Modifier.size(12.dp),
|
||||||
|
tint = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
|
)
|
||||||
|
Spacer(Modifier.width(4.dp))
|
||||||
|
Text(
|
||||||
|
pair.remotePath,
|
||||||
style = MaterialTheme.typography.bodySmall,
|
style = MaterialTheme.typography.bodySmall,
|
||||||
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
Switch(checked = pair.isEnabled, onCheckedChange = { onToggle() })
|
|
||||||
}
|
}
|
||||||
Spacer(Modifier.height(10.dp))
|
Switch(
|
||||||
|
checked = pair.isEnabled,
|
||||||
|
onCheckedChange = { onToggle() },
|
||||||
|
)
|
||||||
|
}
|
||||||
|
Spacer(Modifier.height(8.dp))
|
||||||
Row(
|
Row(
|
||||||
verticalAlignment = Alignment.CenterVertically,
|
verticalAlignment = Alignment.CenterVertically,
|
||||||
horizontalArrangement = Arrangement.spacedBy(8.dp),
|
horizontalArrangement = Arrangement.spacedBy(8.dp),
|
||||||
) {
|
) {
|
||||||
StatusChip(pair.lastSyncResult)
|
StatusPill(pair.lastSyncResult)
|
||||||
if (pair.pendingConflicts > 0) {
|
if (pair.pendingConflicts > 0) {
|
||||||
AssistChip(
|
Surface(
|
||||||
onClick = {},
|
shape = RoundedCornerShape(50),
|
||||||
label = { Text("${pair.pendingConflicts} conflicts") },
|
color = MaterialTheme.colorScheme.errorContainer,
|
||||||
leadingIcon = { Icon(Icons.Default.Warning, null, Modifier.size(16.dp)) },
|
) {
|
||||||
colors = AssistChipDefaults.assistChipColors(
|
Row(
|
||||||
containerColor = MaterialTheme.colorScheme.errorContainer,
|
modifier = Modifier.padding(horizontal = 8.dp, vertical = 4.dp),
|
||||||
),
|
verticalAlignment = Alignment.CenterVertically,
|
||||||
|
horizontalArrangement = Arrangement.spacedBy(4.dp),
|
||||||
|
) {
|
||||||
|
Icon(Icons.Default.Warning, null, Modifier.size(12.dp), tint = MaterialTheme.colorScheme.error)
|
||||||
|
Text(
|
||||||
|
"${pair.pendingConflicts} conflicts",
|
||||||
|
style = MaterialTheme.typography.labelSmall,
|
||||||
|
color = MaterialTheme.colorScheme.error,
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
Spacer(Modifier.weight(1f))
|
Spacer(Modifier.weight(1f))
|
||||||
pair.lastSyncAt?.let { at ->
|
pair.lastSyncAt?.let { at ->
|
||||||
Text(
|
Text(
|
||||||
at.formatRelative(),
|
at.toRelativeString(),
|
||||||
style = MaterialTheme.typography.labelSmall,
|
style = MaterialTheme.typography.labelSmall,
|
||||||
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
)
|
)
|
||||||
@@ -105,24 +165,37 @@ private fun SyncPairCard(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Composable
|
@Composable
|
||||||
private fun StatusChip(status: SyncStatus) {
|
private fun StatusPill(status: SyncStatus) {
|
||||||
val (icon, label, color) = when (status) {
|
val (icon, label) = when (status) {
|
||||||
SyncStatus.SUCCESS -> Triple(Icons.Default.CheckCircle, "Synced", MaterialTheme.colorScheme.primaryContainer)
|
SyncStatus.SUCCESS -> Pair(Icons.Default.CheckCircle, "Synced")
|
||||||
SyncStatus.SYNCING -> Triple(Icons.Default.Sync, "Syncing…", MaterialTheme.colorScheme.secondaryContainer)
|
SyncStatus.SYNCING -> Pair(Icons.Default.Sync, "Syncing…")
|
||||||
SyncStatus.FAILED -> Triple(Icons.Default.Error, "Failed", MaterialTheme.colorScheme.errorContainer)
|
SyncStatus.FAILED -> Pair(Icons.Default.Error, "Failed")
|
||||||
SyncStatus.CONFLICT -> Triple(Icons.Default.Warning, "Conflict", MaterialTheme.colorScheme.tertiaryContainer)
|
SyncStatus.CONFLICT -> Pair(Icons.Default.Warning, "Conflict")
|
||||||
SyncStatus.PARTIAL -> Triple(Icons.Default.WarningAmber, "Partial", MaterialTheme.colorScheme.tertiaryContainer)
|
SyncStatus.PARTIAL -> Pair(Icons.Default.WarningAmber, "Partial")
|
||||||
SyncStatus.IDLE -> Triple(Icons.Outlined.Circle, "Idle", MaterialTheme.colorScheme.surfaceVariant)
|
SyncStatus.IDLE -> Pair(Icons.Outlined.Circle, "Idle")
|
||||||
|
}
|
||||||
|
val containerColor = status.accentColor
|
||||||
|
val contentColor = when (status) {
|
||||||
|
SyncStatus.IDLE -> MaterialTheme.colorScheme.onSurfaceVariant
|
||||||
|
else -> MaterialTheme.colorScheme.surface
|
||||||
|
}
|
||||||
|
Surface(
|
||||||
|
shape = RoundedCornerShape(50),
|
||||||
|
color = containerColor.copy(alpha = 0.15f),
|
||||||
|
) {
|
||||||
|
Row(
|
||||||
|
modifier = Modifier.padding(horizontal = 8.dp, vertical = 4.dp),
|
||||||
|
verticalAlignment = Alignment.CenterVertically,
|
||||||
|
horizontalArrangement = Arrangement.spacedBy(4.dp),
|
||||||
|
) {
|
||||||
|
Icon(icon, null, Modifier.size(12.dp), tint = containerColor)
|
||||||
|
Text(label, style = MaterialTheme.typography.labelSmall, color = containerColor)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
AssistChip(
|
|
||||||
onClick = {},
|
|
||||||
label = { Text(label) },
|
|
||||||
leadingIcon = { Icon(icon, null, Modifier.size(16.dp)) },
|
|
||||||
colors = AssistChipDefaults.assistChipColors(containerColor = color),
|
|
||||||
)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Composable
|
@Composable
|
||||||
@@ -132,15 +205,49 @@ private fun EmptyState(modifier: Modifier = Modifier, onAdd: () -> Unit) {
|
|||||||
horizontalAlignment = Alignment.CenterHorizontally,
|
horizontalAlignment = Alignment.CenterHorizontally,
|
||||||
verticalArrangement = Arrangement.Center,
|
verticalArrangement = Arrangement.Center,
|
||||||
) {
|
) {
|
||||||
Icon(Icons.Outlined.CloudSync, null, modifier = Modifier.size(80.dp), tint = MaterialTheme.colorScheme.primary)
|
Icon(
|
||||||
|
Icons.Outlined.CloudSync,
|
||||||
|
null,
|
||||||
|
modifier = Modifier.size(100.dp),
|
||||||
|
tint = MaterialTheme.colorScheme.primary.copy(alpha = 0.4f),
|
||||||
|
)
|
||||||
Spacer(Modifier.height(16.dp))
|
Spacer(Modifier.height(16.dp))
|
||||||
Text("No sync pairs yet", style = MaterialTheme.typography.titleLarge, fontWeight = FontWeight.Medium)
|
Text("No sync pairs yet", style = MaterialTheme.typography.titleLarge)
|
||||||
Spacer(Modifier.height(8.dp))
|
Spacer(Modifier.height(8.dp))
|
||||||
Text("Tap + to create your first sync", style = MaterialTheme.typography.bodyMedium, color = MaterialTheme.colorScheme.onSurfaceVariant)
|
Text(
|
||||||
|
"Tap + to create your first sync",
|
||||||
|
style = MaterialTheme.typography.bodyMedium,
|
||||||
|
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
|
)
|
||||||
Spacer(Modifier.height(24.dp))
|
Spacer(Modifier.height(24.dp))
|
||||||
Button(onClick = onAdd) { Text("Add Sync Pair") }
|
FilledTonalButton(onClick = onAdd) { Text("Add Sync Pair") }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private val fmt = DateTimeFormatter.ofLocalizedDateTime(FormatStyle.SHORT)
|
private val SyncStatus.accentColor: Color
|
||||||
private fun Instant.formatRelative(): String = fmt.format(atZone(ZoneId.systemDefault()))
|
@Composable get() = when (this) {
|
||||||
|
SyncStatus.SUCCESS -> MaterialTheme.colorScheme.primary
|
||||||
|
SyncStatus.SYNCING -> MaterialTheme.colorScheme.secondary
|
||||||
|
SyncStatus.FAILED -> MaterialTheme.colorScheme.error
|
||||||
|
SyncStatus.CONFLICT,
|
||||||
|
SyncStatus.PARTIAL -> MaterialTheme.colorScheme.tertiary
|
||||||
|
SyncStatus.IDLE -> MaterialTheme.colorScheme.outline
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun String.toDisplayPath(): String {
|
||||||
|
// For SAF content:// URIs, decode the last path segment (e.g. primary%3ASyncFlowTest → SyncFlowTest)
|
||||||
|
val decoded = java.net.URLDecoder.decode(this, "UTF-8")
|
||||||
|
return decoded.trimEnd('/').substringAfterLast('/').substringAfterLast(':').ifEmpty { decoded }
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun Instant.toRelativeString(): String {
|
||||||
|
val diff = Duration.between(this, Instant.now()).abs()
|
||||||
|
return when {
|
||||||
|
diff.toMinutes() < 1 -> "Just now"
|
||||||
|
diff.toMinutes() < 60 -> "${diff.toMinutes()} min ago"
|
||||||
|
diff.toHours() < 24 -> "${diff.toHours()} hr ago"
|
||||||
|
diff.toDays() == 1L -> "Yesterday"
|
||||||
|
else -> DateTimeFormatter.ofLocalizedDate(FormatStyle.SHORT)
|
||||||
|
.format(atZone(ZoneId.systemDefault()))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -6,8 +6,15 @@ import androidx.compose.animation.fadeOut
|
|||||||
import androidx.compose.animation.scaleIn
|
import androidx.compose.animation.scaleIn
|
||||||
import androidx.compose.animation.scaleOut
|
import androidx.compose.animation.scaleOut
|
||||||
import androidx.compose.foundation.ExperimentalFoundationApi
|
import androidx.compose.foundation.ExperimentalFoundationApi
|
||||||
|
import androidx.compose.foundation.layout.Row
|
||||||
|
import androidx.compose.foundation.layout.Spacer
|
||||||
import androidx.compose.foundation.layout.fillMaxSize
|
import androidx.compose.foundation.layout.fillMaxSize
|
||||||
import androidx.compose.foundation.layout.padding
|
import androidx.compose.foundation.layout.padding
|
||||||
|
import androidx.compose.foundation.layout.size
|
||||||
|
import androidx.compose.foundation.layout.width
|
||||||
|
import androidx.compose.foundation.layout.WindowInsets
|
||||||
|
import androidx.compose.foundation.layout.statusBars
|
||||||
|
import androidx.compose.foundation.layout.windowInsetsPadding
|
||||||
import androidx.compose.foundation.pager.HorizontalPager
|
import androidx.compose.foundation.pager.HorizontalPager
|
||||||
import androidx.compose.foundation.pager.rememberPagerState
|
import androidx.compose.foundation.pager.rememberPagerState
|
||||||
import androidx.compose.material.icons.Icons
|
import androidx.compose.material.icons.Icons
|
||||||
@@ -19,8 +26,11 @@ import androidx.compose.material.icons.outlined.Sync
|
|||||||
import androidx.compose.material3.*
|
import androidx.compose.material3.*
|
||||||
import androidx.compose.runtime.Composable
|
import androidx.compose.runtime.Composable
|
||||||
import androidx.compose.runtime.rememberCoroutineScope
|
import androidx.compose.runtime.rememberCoroutineScope
|
||||||
|
import androidx.compose.ui.Alignment
|
||||||
import androidx.compose.ui.Modifier
|
import androidx.compose.ui.Modifier
|
||||||
import androidx.compose.ui.text.font.FontWeight
|
import androidx.compose.ui.res.painterResource
|
||||||
|
import androidx.compose.ui.unit.dp
|
||||||
|
import com.syncflow.R
|
||||||
import com.syncflow.ui.home.HomeScreen
|
import com.syncflow.ui.home.HomeScreen
|
||||||
import com.syncflow.ui.settings.SettingsScreen
|
import com.syncflow.ui.settings.SettingsScreen
|
||||||
import kotlinx.coroutines.launch
|
import kotlinx.coroutines.launch
|
||||||
@@ -38,11 +48,26 @@ fun MainShell(
|
|||||||
|
|
||||||
Scaffold(
|
Scaffold(
|
||||||
topBar = {
|
topBar = {
|
||||||
TopAppBar(
|
CenterAlignedTopAppBar(
|
||||||
title = { Text("SyncFlow", fontWeight = FontWeight.Bold) },
|
title = {
|
||||||
colors = TopAppBarDefaults.topAppBarColors(
|
Row(verticalAlignment = Alignment.CenterVertically) {
|
||||||
|
Icon(
|
||||||
|
painter = painterResource(id = R.drawable.ic_sync),
|
||||||
|
contentDescription = null,
|
||||||
|
modifier = Modifier.size(20.dp),
|
||||||
|
tint = MaterialTheme.colorScheme.primary,
|
||||||
|
)
|
||||||
|
Spacer(Modifier.width(8.dp))
|
||||||
|
Text(
|
||||||
|
"SyncFlow",
|
||||||
|
style = MaterialTheme.typography.titleLarge,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
},
|
||||||
|
colors = TopAppBarDefaults.centerAlignedTopAppBarColors(
|
||||||
containerColor = MaterialTheme.colorScheme.surface,
|
containerColor = MaterialTheme.colorScheme.surface,
|
||||||
),
|
),
|
||||||
|
modifier = Modifier.windowInsetsPadding(WindowInsets.statusBars),
|
||||||
)
|
)
|
||||||
},
|
},
|
||||||
bottomBar = {
|
bottomBar = {
|
||||||
@@ -81,6 +106,8 @@ fun MainShell(
|
|||||||
text = { Text("Add Sync") },
|
text = { Text("Add Sync") },
|
||||||
icon = { Icon(Icons.Default.Add, null) },
|
icon = { Icon(Icons.Default.Add, null) },
|
||||||
onClick = onAddPair,
|
onClick = onAddPair,
|
||||||
|
containerColor = MaterialTheme.colorScheme.primary,
|
||||||
|
contentColor = MaterialTheme.colorScheme.onPrimary,
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -3,16 +3,24 @@ package com.syncflow.ui.pairdetail
|
|||||||
import androidx.compose.foundation.layout.*
|
import androidx.compose.foundation.layout.*
|
||||||
import androidx.compose.foundation.lazy.LazyColumn
|
import androidx.compose.foundation.lazy.LazyColumn
|
||||||
import androidx.compose.foundation.lazy.items
|
import androidx.compose.foundation.lazy.items
|
||||||
|
import androidx.compose.foundation.shape.RoundedCornerShape
|
||||||
import androidx.compose.material.icons.Icons
|
import androidx.compose.material.icons.Icons
|
||||||
import androidx.compose.material.icons.filled.*
|
import androidx.compose.material.icons.filled.*
|
||||||
|
import androidx.compose.material.icons.outlined.Circle
|
||||||
import androidx.compose.material3.*
|
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.draw.clip
|
||||||
|
import androidx.compose.ui.graphics.Color
|
||||||
import androidx.compose.ui.unit.dp
|
import androidx.compose.ui.unit.dp
|
||||||
import androidx.hilt.navigation.compose.hiltViewModel
|
import androidx.hilt.navigation.compose.hiltViewModel
|
||||||
import com.syncflow.data.db.entities.SyncEventEntity
|
import com.syncflow.data.db.entities.SyncEventEntity
|
||||||
|
import com.syncflow.data.db.entities.SyncPairEntity
|
||||||
import com.syncflow.domain.model.SyncEventType
|
import com.syncflow.domain.model.SyncEventType
|
||||||
|
import com.syncflow.domain.model.SyncStatus
|
||||||
|
import java.time.Duration
|
||||||
|
import java.time.Instant
|
||||||
import java.time.ZoneId
|
import java.time.ZoneId
|
||||||
import java.time.format.DateTimeFormatter
|
import java.time.format.DateTimeFormatter
|
||||||
import java.time.format.FormatStyle
|
import java.time.format.FormatStyle
|
||||||
@@ -36,7 +44,10 @@ fun PairDetailScreen(
|
|||||||
title = { Text("Delete sync pair?") },
|
title = { Text("Delete sync pair?") },
|
||||||
text = { Text("This removes the pair and all sync history. Files are NOT deleted.") },
|
text = { Text("This removes the pair and all sync history. Files are NOT deleted.") },
|
||||||
confirmButton = {
|
confirmButton = {
|
||||||
TextButton(onClick = { vm.delete(); onBack() }, colors = ButtonDefaults.textButtonColors(contentColor = MaterialTheme.colorScheme.error)) {
|
TextButton(
|
||||||
|
onClick = { vm.delete(); onBack() },
|
||||||
|
colors = ButtonDefaults.textButtonColors(contentColor = MaterialTheme.colorScheme.error),
|
||||||
|
) {
|
||||||
Text("Delete")
|
Text("Delete")
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
@@ -60,8 +71,12 @@ fun PairDetailScreen(
|
|||||||
LazyColumn(
|
LazyColumn(
|
||||||
modifier = Modifier.padding(padding),
|
modifier = Modifier.padding(padding),
|
||||||
contentPadding = PaddingValues(16.dp),
|
contentPadding = PaddingValues(16.dp),
|
||||||
verticalArrangement = Arrangement.spacedBy(8.dp),
|
verticalArrangement = Arrangement.spacedBy(12.dp),
|
||||||
) {
|
) {
|
||||||
|
item {
|
||||||
|
pair?.let { p -> StatusBanner(p) }
|
||||||
|
}
|
||||||
|
|
||||||
item {
|
item {
|
||||||
pair?.let { p ->
|
pair?.let { p ->
|
||||||
InfoCard(p.localPath, p.remotePath, p.syncDirection.name, p.scheduleType.name)
|
InfoCard(p.localPath, p.remotePath, p.syncDirection.name, p.scheduleType.name)
|
||||||
@@ -85,8 +100,22 @@ fun PairDetailScreen(
|
|||||||
}
|
}
|
||||||
|
|
||||||
item {
|
item {
|
||||||
Text("Activity", style = MaterialTheme.typography.titleSmall, color = MaterialTheme.colorScheme.primary)
|
Row(
|
||||||
HorizontalDivider(modifier = Modifier.padding(vertical = 4.dp))
|
verticalAlignment = Alignment.CenterVertically,
|
||||||
|
modifier = Modifier.padding(top = 4.dp),
|
||||||
|
) {
|
||||||
|
Box(
|
||||||
|
modifier = Modifier
|
||||||
|
.width(3.dp)
|
||||||
|
.height(16.dp)
|
||||||
|
.clip(RoundedCornerShape(2.dp)),
|
||||||
|
) {
|
||||||
|
Surface(color = MaterialTheme.colorScheme.primary, modifier = Modifier.fillMaxSize()) {}
|
||||||
|
}
|
||||||
|
Spacer(Modifier.width(8.dp))
|
||||||
|
Text("Activity", style = MaterialTheme.typography.titleSmall)
|
||||||
|
}
|
||||||
|
HorizontalDivider(modifier = Modifier.padding(top = 4.dp))
|
||||||
}
|
}
|
||||||
|
|
||||||
if (events.isEmpty()) {
|
if (events.isEmpty()) {
|
||||||
@@ -105,24 +134,84 @@ fun PairDetailScreen(
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Composable
|
@Composable
|
||||||
private fun InfoCard(localPath: String, remotePath: String, direction: String, schedule: String) {
|
private fun StatusBanner(pair: SyncPairEntity) {
|
||||||
ElevatedCard(modifier = Modifier.fillMaxWidth()) {
|
val (icon, label, containerColor) = when (pair.lastSyncResult) {
|
||||||
Column(modifier = Modifier.padding(16.dp), verticalArrangement = Arrangement.spacedBy(6.dp)) {
|
SyncStatus.SUCCESS -> Triple(Icons.Default.CheckCircle, "Synced", MaterialTheme.colorScheme.primaryContainer)
|
||||||
InfoRow(Icons.Default.PhoneAndroid, "Local", localPath)
|
SyncStatus.SYNCING -> Triple(Icons.Default.Sync, "Syncing…", MaterialTheme.colorScheme.secondaryContainer)
|
||||||
InfoRow(Icons.Default.Cloud, "Remote", remotePath)
|
SyncStatus.FAILED -> Triple(Icons.Default.Error, "Failed", MaterialTheme.colorScheme.errorContainer)
|
||||||
InfoRow(Icons.Default.SwapHoriz, "Direction", direction)
|
SyncStatus.CONFLICT -> Triple(Icons.Default.Warning, "Conflict", MaterialTheme.colorScheme.tertiaryContainer)
|
||||||
InfoRow(Icons.Default.Schedule, "Schedule", schedule)
|
SyncStatus.PARTIAL -> Triple(Icons.Default.WarningAmber,"Partial", MaterialTheme.colorScheme.tertiaryContainer)
|
||||||
|
SyncStatus.IDLE -> Triple(Icons.Outlined.Circle, "Idle", MaterialTheme.colorScheme.surfaceVariant)
|
||||||
|
}
|
||||||
|
Surface(
|
||||||
|
color = containerColor,
|
||||||
|
shape = RoundedCornerShape(16.dp),
|
||||||
|
modifier = Modifier.fillMaxWidth(),
|
||||||
|
) {
|
||||||
|
Row(
|
||||||
|
modifier = Modifier.padding(16.dp),
|
||||||
|
verticalAlignment = Alignment.CenterVertically,
|
||||||
|
) {
|
||||||
|
Icon(icon, null, modifier = Modifier.size(40.dp))
|
||||||
|
Spacer(Modifier.width(16.dp))
|
||||||
|
Column {
|
||||||
|
Text(label, style = MaterialTheme.typography.titleMedium)
|
||||||
|
pair.lastSyncAt?.let {
|
||||||
|
Text(it.toRelativeString(), style = MaterialTheme.typography.bodySmall)
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Composable
|
@Composable
|
||||||
private fun InfoRow(icon: androidx.compose.ui.graphics.vector.ImageVector, label: String, value: String) {
|
private fun InfoCard(localPath: String, remotePath: String, direction: String, schedule: String) {
|
||||||
Row(verticalAlignment = Alignment.CenterVertically) {
|
Card(
|
||||||
Icon(icon, null, Modifier.size(16.dp), tint = MaterialTheme.colorScheme.primary)
|
modifier = Modifier.fillMaxWidth(),
|
||||||
|
shape = RoundedCornerShape(16.dp),
|
||||||
|
border = androidx.compose.foundation.BorderStroke(1.dp, MaterialTheme.colorScheme.outline),
|
||||||
|
colors = CardDefaults.cardColors(containerColor = MaterialTheme.colorScheme.surface),
|
||||||
|
) {
|
||||||
|
Column(modifier = Modifier.padding(16.dp), verticalArrangement = Arrangement.spacedBy(8.dp)) {
|
||||||
|
InfoRow(Icons.Default.PhoneAndroid, "Local", localPath.toDisplayPath())
|
||||||
|
HorizontalDivider(color = MaterialTheme.colorScheme.outline.copy(alpha = 0.5f))
|
||||||
|
InfoRow(Icons.Default.Cloud, "Remote", remotePath)
|
||||||
|
HorizontalDivider(color = MaterialTheme.colorScheme.outline.copy(alpha = 0.5f))
|
||||||
|
Row {
|
||||||
|
InfoRow(Icons.Default.SwapHoriz, "Direction", direction, modifier = Modifier.weight(1f))
|
||||||
|
InfoRow(Icons.Default.Schedule, "Schedule", schedule, modifier = Modifier.weight(1f))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Composable
|
||||||
|
private fun InfoRow(
|
||||||
|
icon: androidx.compose.ui.graphics.vector.ImageVector,
|
||||||
|
label: String,
|
||||||
|
value: String,
|
||||||
|
modifier: Modifier = Modifier,
|
||||||
|
) {
|
||||||
|
Row(verticalAlignment = Alignment.CenterVertically, modifier = modifier) {
|
||||||
|
Surface(
|
||||||
|
shape = RoundedCornerShape(8.dp),
|
||||||
|
color = MaterialTheme.colorScheme.primaryContainer,
|
||||||
|
modifier = Modifier.size(28.dp),
|
||||||
|
) {
|
||||||
|
Box(contentAlignment = Alignment.Center) {
|
||||||
|
Icon(
|
||||||
|
icon,
|
||||||
|
null,
|
||||||
|
Modifier.size(16.dp),
|
||||||
|
tint = MaterialTheme.colorScheme.onPrimaryContainer,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
Spacer(Modifier.width(8.dp))
|
Spacer(Modifier.width(8.dp))
|
||||||
Text("$label: ", style = MaterialTheme.typography.labelMedium)
|
Column {
|
||||||
Text(value, style = MaterialTheme.typography.bodySmall, modifier = Modifier.weight(1f))
|
Text(label, style = MaterialTheme.typography.labelSmall, color = MaterialTheme.colorScheme.onSurfaceVariant)
|
||||||
|
Text(value, style = MaterialTheme.typography.bodySmall)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -130,38 +219,65 @@ private fun InfoRow(icon: androidx.compose.ui.graphics.vector.ImageVector, label
|
|||||||
private fun EventRow(event: SyncEventEntity) {
|
private fun EventRow(event: SyncEventEntity) {
|
||||||
val fmt = DateTimeFormatter.ofLocalizedTime(FormatStyle.SHORT)
|
val fmt = DateTimeFormatter.ofLocalizedTime(FormatStyle.SHORT)
|
||||||
val zone = ZoneId.systemDefault()
|
val zone = ZoneId.systemDefault()
|
||||||
val (icon, tint) = eventIcon(event.eventType)
|
val dotColor = eventColor(event.eventType)
|
||||||
Row(
|
Row(
|
||||||
modifier = Modifier.fillMaxWidth().padding(vertical = 2.dp),
|
modifier = Modifier.fillMaxWidth().padding(vertical = 4.dp),
|
||||||
verticalAlignment = Alignment.CenterVertically,
|
verticalAlignment = Alignment.CenterVertically,
|
||||||
) {
|
) {
|
||||||
Icon(icon, null, Modifier.size(16.dp), tint = tint)
|
// Colored dot indicator
|
||||||
Spacer(Modifier.width(8.dp))
|
Surface(
|
||||||
|
shape = RoundedCornerShape(50),
|
||||||
|
color = dotColor,
|
||||||
|
modifier = Modifier.size(8.dp),
|
||||||
|
) {}
|
||||||
|
Spacer(Modifier.width(10.dp))
|
||||||
Column(modifier = Modifier.weight(1f)) {
|
Column(modifier = Modifier.weight(1f)) {
|
||||||
Text(event.filePath ?: event.message ?: event.eventType.name, style = MaterialTheme.typography.bodySmall)
|
Text(
|
||||||
|
event.filePath ?: event.message ?: event.eventType.name,
|
||||||
|
style = MaterialTheme.typography.bodySmall,
|
||||||
|
)
|
||||||
event.message?.takeIf { event.filePath != null }?.let {
|
event.message?.takeIf { event.filePath != null }?.let {
|
||||||
Text(it, style = MaterialTheme.typography.labelSmall, color = MaterialTheme.colorScheme.onSurfaceVariant)
|
Text(
|
||||||
|
it,
|
||||||
|
style = MaterialTheme.typography.labelSmall,
|
||||||
|
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
|
)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Text(fmt.format(event.timestamp.atZone(zone)), style = MaterialTheme.typography.labelSmall, color = MaterialTheme.colorScheme.onSurfaceVariant)
|
Text(
|
||||||
|
fmt.format(event.timestamp.atZone(zone)),
|
||||||
|
style = MaterialTheme.typography.labelSmall,
|
||||||
|
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
|
)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Composable
|
@Composable
|
||||||
private fun eventIcon(type: SyncEventType): Pair<androidx.compose.ui.graphics.vector.ImageVector, androidx.compose.ui.graphics.Color> {
|
private fun eventColor(type: SyncEventType): Color = when (type) {
|
||||||
val green = MaterialTheme.colorScheme.primary
|
SyncEventType.SYNC_STARTED -> MaterialTheme.colorScheme.primary
|
||||||
val red = MaterialTheme.colorScheme.error
|
SyncEventType.SYNC_COMPLETED -> MaterialTheme.colorScheme.primary
|
||||||
val orange = MaterialTheme.colorScheme.tertiary
|
SyncEventType.SYNC_FAILED -> MaterialTheme.colorScheme.error
|
||||||
val grey = MaterialTheme.colorScheme.onSurfaceVariant
|
SyncEventType.FILE_UPLOADED -> MaterialTheme.colorScheme.secondary
|
||||||
return when (type) {
|
SyncEventType.FILE_DOWNLOADED -> MaterialTheme.colorScheme.secondary
|
||||||
SyncEventType.SYNC_STARTED -> Pair(Icons.Default.PlayArrow, green)
|
SyncEventType.FILE_DELETED -> MaterialTheme.colorScheme.tertiary
|
||||||
SyncEventType.SYNC_COMPLETED -> Pair(Icons.Default.CheckCircle, green)
|
SyncEventType.FILE_SKIPPED -> MaterialTheme.colorScheme.onSurfaceVariant
|
||||||
SyncEventType.SYNC_FAILED -> Pair(Icons.Default.Error, red)
|
SyncEventType.CONFLICT_DETECTED -> MaterialTheme.colorScheme.tertiary
|
||||||
SyncEventType.FILE_UPLOADED -> Pair(Icons.Default.Upload, green)
|
SyncEventType.CONFLICT_RESOLVED -> MaterialTheme.colorScheme.primary
|
||||||
SyncEventType.FILE_DOWNLOADED -> Pair(Icons.Default.Download, green)
|
}
|
||||||
SyncEventType.FILE_DELETED -> Pair(Icons.Default.Delete, orange)
|
|
||||||
SyncEventType.FILE_SKIPPED -> Pair(Icons.Default.SkipNext, grey)
|
private fun String.toDisplayPath(): String {
|
||||||
SyncEventType.CONFLICT_DETECTED -> Pair(Icons.Default.Warning, orange)
|
val decoded = java.net.URLDecoder.decode(this, "UTF-8")
|
||||||
SyncEventType.CONFLICT_RESOLVED -> Pair(Icons.Default.CheckCircle, green)
|
return decoded.trimEnd('/').substringAfterLast('/').substringAfterLast(':').ifEmpty { decoded }
|
||||||
|
}
|
||||||
|
|
||||||
|
private fun Instant.toRelativeString(): String {
|
||||||
|
val diff = Duration.between(this, Instant.now()).abs()
|
||||||
|
return when {
|
||||||
|
diff.toMinutes() < 1 -> "Just now"
|
||||||
|
diff.toMinutes() < 60 -> "${diff.toMinutes()} min ago"
|
||||||
|
diff.toHours() < 24 -> "${diff.toHours()} hr ago"
|
||||||
|
diff.toDays() == 1L -> "Yesterday"
|
||||||
|
else -> DateTimeFormatter.ofLocalizedDate(FormatStyle.SHORT)
|
||||||
|
.format(atZone(ZoneId.systemDefault()))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,14 +1,17 @@
|
|||||||
package com.syncflow.ui.settings
|
package com.syncflow.ui.settings
|
||||||
|
|
||||||
|
import androidx.compose.foundation.BorderStroke
|
||||||
import androidx.compose.foundation.layout.*
|
import androidx.compose.foundation.layout.*
|
||||||
import androidx.compose.foundation.lazy.LazyColumn
|
import androidx.compose.foundation.lazy.LazyColumn
|
||||||
import androidx.compose.foundation.lazy.items
|
import androidx.compose.foundation.lazy.items
|
||||||
|
import androidx.compose.foundation.shape.RoundedCornerShape
|
||||||
import androidx.compose.material.icons.Icons
|
import androidx.compose.material.icons.Icons
|
||||||
import androidx.compose.material.icons.filled.*
|
import androidx.compose.material.icons.filled.*
|
||||||
import androidx.compose.material3.*
|
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.draw.clip
|
||||||
import androidx.compose.ui.unit.dp
|
import androidx.compose.ui.unit.dp
|
||||||
import androidx.hilt.navigation.compose.hiltViewModel
|
import androidx.hilt.navigation.compose.hiltViewModel
|
||||||
import com.syncflow.data.db.entities.CloudAccountEntity
|
import com.syncflow.data.db.entities.CloudAccountEntity
|
||||||
@@ -45,15 +48,18 @@ fun SettingsScreen(
|
|||||||
verticalArrangement = Arrangement.spacedBy(8.dp),
|
verticalArrangement = Arrangement.spacedBy(8.dp),
|
||||||
) {
|
) {
|
||||||
item {
|
item {
|
||||||
Row(verticalAlignment = Alignment.CenterVertically) {
|
SectionHeader(title = "Cloud Accounts")
|
||||||
Text("Cloud Accounts", style = MaterialTheme.typography.titleMedium, modifier = Modifier.weight(1f))
|
Spacer(Modifier.height(4.dp))
|
||||||
|
Row(
|
||||||
|
modifier = Modifier.fillMaxWidth(),
|
||||||
|
horizontalArrangement = Arrangement.End,
|
||||||
|
) {
|
||||||
FilledTonalButton(onClick = onAddAccount) {
|
FilledTonalButton(onClick = onAddAccount) {
|
||||||
Icon(Icons.Default.Add, null, Modifier.size(18.dp))
|
Icon(Icons.Default.Add, null, Modifier.size(18.dp))
|
||||||
Spacer(Modifier.width(6.dp))
|
Spacer(Modifier.width(6.dp))
|
||||||
Text("Add Account")
|
Text("Add Account")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
HorizontalDivider(modifier = Modifier.padding(vertical = 4.dp))
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if (accounts.isEmpty()) {
|
if (accounts.isEmpty()) {
|
||||||
@@ -63,9 +69,22 @@ fun SettingsScreen(
|
|||||||
horizontalAlignment = Alignment.CenterHorizontally,
|
horizontalAlignment = Alignment.CenterHorizontally,
|
||||||
verticalArrangement = Arrangement.spacedBy(8.dp),
|
verticalArrangement = Arrangement.spacedBy(8.dp),
|
||||||
) {
|
) {
|
||||||
Icon(Icons.Default.CloudOff, null, Modifier.size(48.dp), tint = MaterialTheme.colorScheme.onSurfaceVariant)
|
Icon(
|
||||||
Text("No accounts yet", style = MaterialTheme.typography.bodyMedium, color = MaterialTheme.colorScheme.onSurfaceVariant)
|
Icons.Default.CloudOff,
|
||||||
Text("Add a cloud account to start syncing", style = MaterialTheme.typography.bodySmall, color = MaterialTheme.colorScheme.onSurfaceVariant)
|
null,
|
||||||
|
Modifier.size(48.dp),
|
||||||
|
tint = MaterialTheme.colorScheme.onSurfaceVariant.copy(alpha = 0.5f),
|
||||||
|
)
|
||||||
|
Text(
|
||||||
|
"No accounts yet",
|
||||||
|
style = MaterialTheme.typography.bodyMedium,
|
||||||
|
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
|
)
|
||||||
|
Text(
|
||||||
|
"Add a cloud account to start syncing",
|
||||||
|
style = MaterialTheme.typography.bodySmall,
|
||||||
|
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
|
)
|
||||||
OutlinedButton(onClick = onAddAccount) {
|
OutlinedButton(onClick = onAddAccount) {
|
||||||
Icon(Icons.Default.Add, null, Modifier.size(16.dp))
|
Icon(Icons.Default.Add, null, Modifier.size(16.dp))
|
||||||
Spacer(Modifier.width(6.dp))
|
Spacer(Modifier.width(6.dp))
|
||||||
@@ -80,11 +99,17 @@ fun SettingsScreen(
|
|||||||
}
|
}
|
||||||
|
|
||||||
item {
|
item {
|
||||||
Spacer(Modifier.height(16.dp))
|
Spacer(Modifier.height(8.dp))
|
||||||
Text("Security", style = MaterialTheme.typography.titleMedium)
|
SectionHeader(title = "Security")
|
||||||
HorizontalDivider(modifier = Modifier.padding(vertical = 4.dp))
|
Spacer(Modifier.height(4.dp))
|
||||||
|
Card(
|
||||||
|
modifier = Modifier.fillMaxWidth(),
|
||||||
|
shape = RoundedCornerShape(16.dp),
|
||||||
|
border = BorderStroke(1.dp, MaterialTheme.colorScheme.outline),
|
||||||
|
colors = CardDefaults.cardColors(containerColor = MaterialTheme.colorScheme.surface),
|
||||||
|
) {
|
||||||
Row(
|
Row(
|
||||||
modifier = Modifier.fillMaxWidth().padding(vertical = 4.dp),
|
modifier = Modifier.fillMaxWidth().padding(16.dp),
|
||||||
verticalAlignment = Alignment.CenterVertically,
|
verticalAlignment = Alignment.CenterVertically,
|
||||||
) {
|
) {
|
||||||
Column(modifier = Modifier.weight(1f)) {
|
Column(modifier = Modifier.weight(1f)) {
|
||||||
@@ -98,22 +123,78 @@ fun SettingsScreen(
|
|||||||
Switch(checked = biometricEnabled, onCheckedChange = { vm.setBiometricLock(it) })
|
Switch(checked = biometricEnabled, onCheckedChange = { vm.setBiometricLock(it) })
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
item {
|
item {
|
||||||
Spacer(Modifier.height(16.dp))
|
Spacer(Modifier.height(8.dp))
|
||||||
Text("About", style = MaterialTheme.typography.titleMedium)
|
SectionHeader(title = "About")
|
||||||
HorizontalDivider(modifier = Modifier.padding(vertical = 4.dp))
|
Spacer(Modifier.height(4.dp))
|
||||||
Text("SyncFlow v${com.syncflow.BuildConfig.VERSION_NAME} — Free, no subscription.", style = MaterialTheme.typography.bodySmall)
|
Card(
|
||||||
Text("Open source. No ads. No tracking.", style = MaterialTheme.typography.bodySmall, color = MaterialTheme.colorScheme.onSurfaceVariant)
|
modifier = Modifier.fillMaxWidth(),
|
||||||
|
shape = RoundedCornerShape(16.dp),
|
||||||
|
border = BorderStroke(1.dp, MaterialTheme.colorScheme.outline),
|
||||||
|
colors = CardDefaults.cardColors(containerColor = MaterialTheme.colorScheme.surface),
|
||||||
|
) {
|
||||||
|
Column(modifier = Modifier.padding(16.dp), verticalArrangement = Arrangement.spacedBy(4.dp)) {
|
||||||
|
Text(
|
||||||
|
"SyncFlow v${com.syncflow.BuildConfig.VERSION_NAME} — Free, no subscription.",
|
||||||
|
style = MaterialTheme.typography.bodySmall,
|
||||||
|
)
|
||||||
|
Text(
|
||||||
|
"Open source. No ads. No tracking.",
|
||||||
|
style = MaterialTheme.typography.bodySmall,
|
||||||
|
color = MaterialTheme.colorScheme.onSurfaceVariant,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Composable
|
||||||
|
private fun SectionHeader(title: String) {
|
||||||
|
Row(verticalAlignment = Alignment.CenterVertically) {
|
||||||
|
Box(
|
||||||
|
modifier = Modifier
|
||||||
|
.width(3.dp)
|
||||||
|
.height(16.dp)
|
||||||
|
.clip(RoundedCornerShape(2.dp)),
|
||||||
|
) {
|
||||||
|
Surface(color = MaterialTheme.colorScheme.primary, modifier = Modifier.fillMaxSize()) {}
|
||||||
|
}
|
||||||
|
Spacer(Modifier.width(8.dp))
|
||||||
|
Text(
|
||||||
|
title,
|
||||||
|
style = MaterialTheme.typography.titleMedium,
|
||||||
|
color = MaterialTheme.colorScheme.onBackground,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@Composable
|
@Composable
|
||||||
private fun AccountCard(acct: CloudAccountEntity, onDelete: () -> Unit) {
|
private fun AccountCard(acct: CloudAccountEntity, onDelete: () -> Unit) {
|
||||||
ElevatedCard(modifier = Modifier.fillMaxWidth()) {
|
Card(
|
||||||
|
modifier = Modifier.fillMaxWidth(),
|
||||||
|
shape = RoundedCornerShape(16.dp),
|
||||||
|
border = BorderStroke(1.dp, MaterialTheme.colorScheme.outline),
|
||||||
|
colors = CardDefaults.cardColors(containerColor = MaterialTheme.colorScheme.surface),
|
||||||
|
) {
|
||||||
Row(modifier = Modifier.padding(12.dp), verticalAlignment = Alignment.CenterVertically) {
|
Row(modifier = Modifier.padding(12.dp), verticalAlignment = Alignment.CenterVertically) {
|
||||||
Icon(providerIcon(acct.providerType), null, Modifier.size(32.dp), tint = MaterialTheme.colorScheme.primary)
|
// Icon with primaryContainer background
|
||||||
|
Surface(
|
||||||
|
shape = RoundedCornerShape(12.dp),
|
||||||
|
color = MaterialTheme.colorScheme.primaryContainer,
|
||||||
|
modifier = Modifier.size(40.dp),
|
||||||
|
) {
|
||||||
|
Box(contentAlignment = Alignment.Center) {
|
||||||
|
Icon(
|
||||||
|
providerIcon(acct.providerType),
|
||||||
|
null,
|
||||||
|
Modifier.size(22.dp),
|
||||||
|
tint = MaterialTheme.colorScheme.onPrimaryContainer,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
Spacer(Modifier.width(12.dp))
|
Spacer(Modifier.width(12.dp))
|
||||||
Column(modifier = Modifier.weight(1f)) {
|
Column(modifier = Modifier.weight(1f)) {
|
||||||
Text(acct.displayName, style = MaterialTheme.typography.bodyMedium)
|
Text(acct.displayName, style = MaterialTheme.typography.bodyMedium)
|
||||||
|
|||||||
@@ -2,8 +2,27 @@ package com.syncflow.ui.theme
|
|||||||
|
|
||||||
import androidx.compose.ui.graphics.Color
|
import androidx.compose.ui.graphics.Color
|
||||||
|
|
||||||
val SyncBlue = Color(0xFF2196F3)
|
// Primary — indigo
|
||||||
val SyncGreen = Color(0xFF4CAF50)
|
val Indigo600 = Color(0xFF4F46E5)
|
||||||
val SyncOrange = Color(0xFFFF9800)
|
val Indigo900 = Color(0xFF312E81)
|
||||||
val SyncRed = Color(0xFFF44336)
|
val Indigo100 = Color(0xFFE0E7FF)
|
||||||
val SyncPurple = Color(0xFF9C27B0)
|
val Indigo50 = Color(0xFFEEF2FF)
|
||||||
|
|
||||||
|
// Secondary — teal
|
||||||
|
val Teal600 = Color(0xFF0D9488)
|
||||||
|
val Teal100 = Color(0xFFCCFBF1)
|
||||||
|
|
||||||
|
// Tertiary — amber
|
||||||
|
val Amber500 = Color(0xFFF59E0B)
|
||||||
|
val Amber100 = Color(0xFFFEF3C7)
|
||||||
|
|
||||||
|
// Neutrals
|
||||||
|
val Slate50 = Color(0xFFF8FAFC)
|
||||||
|
val Slate100 = Color(0xFFF1F5F9)
|
||||||
|
val Slate200 = Color(0xFFE2E8F0)
|
||||||
|
val Slate600 = Color(0xFF475569)
|
||||||
|
val Slate900 = Color(0xFF0F172A)
|
||||||
|
|
||||||
|
// Semantic
|
||||||
|
val GreenSuccess = Color(0xFF16A34A)
|
||||||
|
val RedError = Color(0xFFDC2626)
|
||||||
|
|||||||
@@ -1,50 +1,77 @@
|
|||||||
package com.syncflow.ui.theme
|
package com.syncflow.ui.theme
|
||||||
|
|
||||||
import android.app.Activity
|
import android.app.Activity
|
||||||
import android.os.Build
|
|
||||||
import androidx.compose.foundation.isSystemInDarkTheme
|
import androidx.compose.foundation.isSystemInDarkTheme
|
||||||
import androidx.compose.material3.*
|
import androidx.compose.material3.*
|
||||||
import androidx.compose.runtime.Composable
|
import androidx.compose.runtime.Composable
|
||||||
import androidx.compose.runtime.SideEffect
|
import androidx.compose.runtime.SideEffect
|
||||||
import androidx.compose.ui.graphics.toArgb
|
import androidx.compose.ui.graphics.Color
|
||||||
import androidx.compose.ui.platform.LocalContext
|
|
||||||
import androidx.compose.ui.platform.LocalView
|
import androidx.compose.ui.platform.LocalView
|
||||||
|
import androidx.compose.ui.text.TextStyle
|
||||||
|
import androidx.compose.ui.text.font.FontWeight
|
||||||
|
import androidx.compose.ui.unit.sp
|
||||||
import androidx.core.view.WindowCompat
|
import androidx.core.view.WindowCompat
|
||||||
|
|
||||||
private val LightColors = lightColorScheme(
|
private val LightColors = lightColorScheme(
|
||||||
primary = SyncBlue,
|
primary = Indigo600,
|
||||||
onPrimary = androidx.compose.ui.graphics.Color.White,
|
onPrimary = Color.White,
|
||||||
secondary = SyncGreen,
|
primaryContainer = Indigo100,
|
||||||
tertiary = SyncPurple,
|
onPrimaryContainer = Indigo900,
|
||||||
|
secondary = Teal600,
|
||||||
|
onSecondary = Color.White,
|
||||||
|
secondaryContainer = Teal100,
|
||||||
|
tertiary = Amber500,
|
||||||
|
tertiaryContainer = Amber100,
|
||||||
|
background = Slate50,
|
||||||
|
surface = Color.White,
|
||||||
|
surfaceVariant = Slate100,
|
||||||
|
onSurfaceVariant = Slate600,
|
||||||
|
error = RedError,
|
||||||
|
errorContainer = Color(0xFFFEE2E2),
|
||||||
|
outline = Slate200,
|
||||||
)
|
)
|
||||||
|
|
||||||
private val DarkColors = darkColorScheme(
|
private val DarkColors = darkColorScheme(
|
||||||
primary = SyncBlue,
|
primary = Color(0xFF818CF8),
|
||||||
secondary = SyncGreen,
|
onPrimary = Indigo900,
|
||||||
tertiary = SyncPurple,
|
primaryContainer = Color(0xFF3730A3),
|
||||||
|
onPrimaryContainer = Indigo100,
|
||||||
|
secondary = Color(0xFF2DD4BF),
|
||||||
|
onSecondary = Color(0xFF003731),
|
||||||
|
secondaryContainer = Color(0xFF00504A),
|
||||||
|
tertiary = Amber500,
|
||||||
|
tertiaryContainer = Color(0xFF92400E),
|
||||||
|
background = Color(0xFF0F0F1A),
|
||||||
|
surface = Color(0xFF1A1A2E),
|
||||||
|
surfaceVariant = Color(0xFF252538),
|
||||||
|
onSurfaceVariant = Color(0xFF94A3B8),
|
||||||
|
error = Color(0xFFF87171),
|
||||||
|
errorContainer = Color(0xFF7F1D1D),
|
||||||
|
outline = Color(0xFF334155),
|
||||||
|
)
|
||||||
|
|
||||||
|
private val AppTypography = Typography(
|
||||||
|
titleLarge = TextStyle(fontWeight = FontWeight.Bold, fontSize = 22.sp, letterSpacing = (-0.5).sp),
|
||||||
|
titleMedium = TextStyle(fontWeight = FontWeight.SemiBold, fontSize = 16.sp, letterSpacing = (-0.25).sp),
|
||||||
|
titleSmall = TextStyle(fontWeight = FontWeight.SemiBold, fontSize = 14.sp, letterSpacing = 0.sp),
|
||||||
|
labelMedium = TextStyle(fontWeight = FontWeight.Medium, fontSize = 12.sp, letterSpacing = 0.1.sp),
|
||||||
|
labelSmall = TextStyle(fontWeight = FontWeight.Medium, fontSize = 11.sp, letterSpacing = 0.1.sp),
|
||||||
)
|
)
|
||||||
|
|
||||||
@Composable
|
@Composable
|
||||||
fun SyncFlowTheme(
|
fun SyncFlowTheme(
|
||||||
darkTheme: Boolean = isSystemInDarkTheme(),
|
darkTheme: Boolean = isSystemInDarkTheme(),
|
||||||
dynamicColor: Boolean = true,
|
|
||||||
content: @Composable () -> Unit,
|
content: @Composable () -> Unit,
|
||||||
) {
|
) {
|
||||||
val colorScheme = when {
|
val colorScheme = if (darkTheme) DarkColors else LightColors
|
||||||
dynamicColor && Build.VERSION.SDK_INT >= Build.VERSION_CODES.S -> {
|
|
||||||
val ctx = LocalContext.current
|
|
||||||
if (darkTheme) dynamicDarkColorScheme(ctx) else dynamicLightColorScheme(ctx)
|
|
||||||
}
|
|
||||||
darkTheme -> DarkColors
|
|
||||||
else -> LightColors
|
|
||||||
}
|
|
||||||
val view = LocalView.current
|
val view = LocalView.current
|
||||||
if (!view.isInEditMode) {
|
if (!view.isInEditMode) {
|
||||||
SideEffect {
|
SideEffect {
|
||||||
val window = (view.context as Activity).window
|
val window = (view.context as Activity).window
|
||||||
window.statusBarColor = colorScheme.primary.toArgb()
|
WindowCompat.setDecorFitsSystemWindows(window, false)
|
||||||
|
window.statusBarColor = android.graphics.Color.TRANSPARENT
|
||||||
WindowCompat.getInsetsController(window, view).isAppearanceLightStatusBars = !darkTheme
|
WindowCompat.getInsetsController(window, view).isAppearanceLightStatusBars = !darkTheme
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
MaterialTheme(colorScheme = colorScheme, typography = Typography(), content = content)
|
MaterialTheme(colorScheme = colorScheme, typography = AppTypography, content = content)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,8 @@
|
|||||||
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
<shape xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
|
<gradient
|
||||||
|
android:type="linear"
|
||||||
|
android:angle="135"
|
||||||
|
android:startColor="#312E81"
|
||||||
|
android:endColor="#6366F1"/>
|
||||||
|
</shape>
|
||||||
@@ -0,0 +1,13 @@
|
|||||||
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
<vector xmlns:android="http://schemas.android.com/apk/res/android"
|
||||||
|
android:width="108dp"
|
||||||
|
android:height="108dp"
|
||||||
|
android:viewportWidth="24"
|
||||||
|
android:viewportHeight="24">
|
||||||
|
<path
|
||||||
|
android:fillColor="#FFFFFF"
|
||||||
|
android:pathData="M12,4V1L8,5l4,4V6c3.31,0 6,2.69 6,6 0,1.01-0.25,1.97-0.7,2.8l1.46,1.46C19.54,15.03 20,13.57 20,12c0-4.42-3.58-8-8-8z"/>
|
||||||
|
<path
|
||||||
|
android:fillColor="#FFFFFF"
|
||||||
|
android:pathData="M12,18c-3.31,0-6,-2.69-6,-6 0,-1.01 0.25,-1.97 0.7,-2.8L5.24,7.74C4.46,8.97 4,10.43 4,12c0,4.42 3.58,8 8,8v3l4,-4-4,-4v3z"/>
|
||||||
|
</vector>
|
||||||
@@ -1,5 +1,5 @@
|
|||||||
<?xml version="1.0" encoding="utf-8"?>
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
<background android:drawable="@color/ic_launcher_background"/>
|
<background android:drawable="@drawable/ic_launcher_background"/>
|
||||||
<foreground android:drawable="@drawable/ic_sync"/>
|
<foreground android:drawable="@drawable/ic_launcher_foreground"/>
|
||||||
</adaptive-icon>
|
</adaptive-icon>
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<?xml version="1.0" encoding="utf-8"?>
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
<background android:drawable="@color/ic_launcher_background"/>
|
<background android:drawable="@drawable/ic_launcher_background"/>
|
||||||
<foreground android:drawable="@drawable/ic_sync"/>
|
<foreground android:drawable="@drawable/ic_launcher_foreground"/>
|
||||||
</adaptive-icon>
|
</adaptive-icon>
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<?xml version="1.0" encoding="utf-8"?>
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
<background android:drawable="@color/ic_launcher_background"/>
|
<background android:drawable="@drawable/ic_launcher_background"/>
|
||||||
<foreground android:drawable="@drawable/ic_sync"/>
|
<foreground android:drawable="@drawable/ic_launcher_foreground"/>
|
||||||
</adaptive-icon>
|
</adaptive-icon>
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<?xml version="1.0" encoding="utf-8"?>
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
<background android:drawable="@color/ic_launcher_background"/>
|
<background android:drawable="@drawable/ic_launcher_background"/>
|
||||||
<foreground android:drawable="@drawable/ic_sync"/>
|
<foreground android:drawable="@drawable/ic_launcher_foreground"/>
|
||||||
</adaptive-icon>
|
</adaptive-icon>
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<?xml version="1.0" encoding="utf-8"?>
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
<background android:drawable="@color/ic_launcher_background"/>
|
<background android:drawable="@drawable/ic_launcher_background"/>
|
||||||
<foreground android:drawable="@drawable/ic_sync"/>
|
<foreground android:drawable="@drawable/ic_launcher_foreground"/>
|
||||||
</adaptive-icon>
|
</adaptive-icon>
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<?xml version="1.0" encoding="utf-8"?>
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
<background android:drawable="@color/ic_launcher_background"/>
|
<background android:drawable="@drawable/ic_launcher_background"/>
|
||||||
<foreground android:drawable="@drawable/ic_sync"/>
|
<foreground android:drawable="@drawable/ic_launcher_foreground"/>
|
||||||
</adaptive-icon>
|
</adaptive-icon>
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<?xml version="1.0" encoding="utf-8"?>
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
<background android:drawable="@color/ic_launcher_background"/>
|
<background android:drawable="@drawable/ic_launcher_background"/>
|
||||||
<foreground android:drawable="@drawable/ic_sync"/>
|
<foreground android:drawable="@drawable/ic_launcher_foreground"/>
|
||||||
</adaptive-icon>
|
</adaptive-icon>
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<?xml version="1.0" encoding="utf-8"?>
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
<background android:drawable="@color/ic_launcher_background"/>
|
<background android:drawable="@drawable/ic_launcher_background"/>
|
||||||
<foreground android:drawable="@drawable/ic_sync"/>
|
<foreground android:drawable="@drawable/ic_launcher_foreground"/>
|
||||||
</adaptive-icon>
|
</adaptive-icon>
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<?xml version="1.0" encoding="utf-8"?>
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
<background android:drawable="@color/ic_launcher_background"/>
|
<background android:drawable="@drawable/ic_launcher_background"/>
|
||||||
<foreground android:drawable="@drawable/ic_sync"/>
|
<foreground android:drawable="@drawable/ic_launcher_foreground"/>
|
||||||
</adaptive-icon>
|
</adaptive-icon>
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<?xml version="1.0" encoding="utf-8"?>
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
|
||||||
<background android:drawable="@color/ic_launcher_background"/>
|
<background android:drawable="@drawable/ic_launcher_background"/>
|
||||||
<foreground android:drawable="@drawable/ic_sync"/>
|
<foreground android:drawable="@drawable/ic_launcher_foreground"/>
|
||||||
</adaptive-icon>
|
</adaptive-icon>
|
||||||
|
|||||||
@@ -0,0 +1,164 @@
|
|||||||
|
package com.syncflow.domain.sync
|
||||||
|
|
||||||
|
import com.syncflow.data.db.entities.SyncFileStateEntity
|
||||||
|
import com.syncflow.domain.model.*
|
||||||
|
import org.junit.Assert.assertEquals
|
||||||
|
import org.junit.Test
|
||||||
|
import java.time.Instant
|
||||||
|
|
||||||
|
class SyncDecideTest {
|
||||||
|
|
||||||
|
private val MS = 1_716_000_000_000L
|
||||||
|
private val MS2 = MS + 5_000L
|
||||||
|
|
||||||
|
private fun local(ms: Long = MS, size: Long = 100L) = LocalFileInfo("test.txt", size, ms)
|
||||||
|
|
||||||
|
private fun remote(ms: Long = MS, etag: String? = "abc", size: Long = 100L) =
|
||||||
|
RemoteFile(
|
||||||
|
path = "path/test.txt", name = "test.txt", isDirectory = false,
|
||||||
|
sizeBytes = size, modifiedAt = Instant.ofEpochMilli(ms),
|
||||||
|
etag = etag, mimeType = null,
|
||||||
|
)
|
||||||
|
|
||||||
|
private fun state(localMs: Long? = MS, remoteMs: Long? = MS, etag: String? = "abc") =
|
||||||
|
SyncFileStateEntity(
|
||||||
|
syncPairId = 1L, relativePath = "test.txt",
|
||||||
|
localModifiedAt = localMs?.let { Instant.ofEpochMilli(it) },
|
||||||
|
localSizeBytes = 100L, localHash = null,
|
||||||
|
remoteModifiedAt = remoteMs?.let { Instant.ofEpochMilli(it) },
|
||||||
|
remoteSizeBytes = 100L, remoteEtag = etag,
|
||||||
|
lastSyncedAt = Instant.now(), syncedHash = null,
|
||||||
|
)
|
||||||
|
|
||||||
|
private fun decide(
|
||||||
|
local: LocalFileInfo?, remote: RemoteFile?, known: SyncFileStateEntity? = null,
|
||||||
|
dir: SyncDirection = SyncDirection.TWO_WAY,
|
||||||
|
conflict: ConflictStrategy = ConflictStrategy.KEEP_NEWEST,
|
||||||
|
delete: DeleteBehavior = DeleteBehavior.MIRROR,
|
||||||
|
hasPriorState: Boolean = known != null,
|
||||||
|
) = syncDecide(dir, conflict, delete, local, remote, known, hasPriorState)
|
||||||
|
|
||||||
|
// ── first sync (no known state) ───────────────────────────────────────────
|
||||||
|
|
||||||
|
@Test fun `first sync both exist local newer uploads`() =
|
||||||
|
assertEquals(SyncDecision.UPLOAD, decide(local(MS2), remote(MS)))
|
||||||
|
|
||||||
|
@Test fun `first sync both exist remote newer downloads`() =
|
||||||
|
assertEquals(SyncDecision.DOWNLOAD, decide(local(MS), remote(MS2)))
|
||||||
|
|
||||||
|
@Test fun `first sync local only TWO_WAY uploads`() =
|
||||||
|
assertEquals(SyncDecision.UPLOAD, decide(local(), null))
|
||||||
|
|
||||||
|
@Test fun `first sync remote only TWO_WAY downloads`() =
|
||||||
|
assertEquals(SyncDecision.DOWNLOAD, decide(null, remote()))
|
||||||
|
|
||||||
|
// ── after upload: remote metadata null in state ───────────────────────────
|
||||||
|
|
||||||
|
@Test fun `second sync after upload remote metadata null skips`() {
|
||||||
|
// State saved after upload: local mtime known, remote unknown (null).
|
||||||
|
val known = state(localMs = MS, remoteMs = null, etag = null)
|
||||||
|
// Remote listing shows a new mtime (server assigned), but we treat null as "no change".
|
||||||
|
assertEquals(SyncDecision.SKIP, decide(local(MS), remote(MS2), known))
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test fun `after upload local changed again re-uploads`() {
|
||||||
|
val known = state(localMs = MS, remoteMs = null, etag = null)
|
||||||
|
assertEquals(SyncDecision.UPLOAD, decide(local(MS2), remote(MS2), known))
|
||||||
|
}
|
||||||
|
|
||||||
|
// ── after download: local mtime recorded ─────────────────────────────────
|
||||||
|
|
||||||
|
@Test fun `second sync fully recorded skips`() {
|
||||||
|
val known = state(localMs = MS, remoteMs = MS, etag = "abc")
|
||||||
|
assertEquals(SyncDecision.SKIP, decide(local(MS), remote(MS, etag = "abc"), known))
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test fun `remote changed after download downloads`() {
|
||||||
|
val known = state(localMs = MS, remoteMs = MS, etag = "abc")
|
||||||
|
assertEquals(SyncDecision.DOWNLOAD, decide(local(MS), remote(MS2, etag = "xyz"), known))
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test fun `local changed after download uploads`() {
|
||||||
|
val known = state(localMs = MS, remoteMs = MS, etag = "abc")
|
||||||
|
assertEquals(SyncDecision.UPLOAD, decide(local(MS2), remote(MS, etag = "abc"), known))
|
||||||
|
}
|
||||||
|
|
||||||
|
// ── epoch-millis precision ────────────────────────────────────────────────
|
||||||
|
|
||||||
|
@Test fun `same millisecond timestamp treated as unchanged`() {
|
||||||
|
val ts = 1_716_393_136_789L
|
||||||
|
assertEquals(SyncDecision.SKIP,
|
||||||
|
decide(local(ts), remote(ts, etag = "e"), state(localMs = ts, remoteMs = ts, etag = "e")))
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test fun `1ms difference detected as local change`() {
|
||||||
|
val ts = 1_716_393_136_789L
|
||||||
|
assertEquals(SyncDecision.UPLOAD,
|
||||||
|
decide(local(ts + 1), remote(ts, etag = "e"), state(localMs = ts, remoteMs = ts, etag = "e")))
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test fun `epoch-second stored value differs from millis comparison`() {
|
||||||
|
// If we stored 1716393136 (seconds) and compare to 1716393136000 (millis) they differ →
|
||||||
|
// This was the original bug — now we store millis so they should match.
|
||||||
|
val ms = 1_716_393_136_000L // exact second boundary, no sub-second component
|
||||||
|
assertEquals(SyncDecision.SKIP,
|
||||||
|
decide(local(ms), remote(ms, etag = "e"), state(localMs = ms, remoteMs = ms, etag = "e")))
|
||||||
|
}
|
||||||
|
|
||||||
|
// ── delete behaviour ──────────────────────────────────────────────────────
|
||||||
|
|
||||||
|
@Test fun `local exists remote deleted TWO_WAY MIRROR deletes local`() =
|
||||||
|
assertEquals(SyncDecision.DELETE_LOCAL, decide(local(), null, state(), delete = DeleteBehavior.MIRROR))
|
||||||
|
|
||||||
|
@Test fun `local exists remote deleted KEEP skips`() =
|
||||||
|
assertEquals(SyncDecision.SKIP, decide(local(), null, state(), delete = DeleteBehavior.KEEP))
|
||||||
|
|
||||||
|
@Test fun `remote deleted UPLOAD_ONLY skips local deletion`() =
|
||||||
|
assertEquals(SyncDecision.SKIP,
|
||||||
|
decide(local(), null, state(), dir = SyncDirection.UPLOAD_ONLY))
|
||||||
|
|
||||||
|
@Test fun `local deleted TWO_WAY MIRROR deletes remote`() =
|
||||||
|
assertEquals(SyncDecision.DELETE_REMOTE, decide(null, remote(), state(), delete = DeleteBehavior.MIRROR))
|
||||||
|
|
||||||
|
@Test fun `local deleted TWO_WAY KEEP skips`() =
|
||||||
|
assertEquals(SyncDecision.SKIP, decide(null, remote(), state(), delete = DeleteBehavior.KEEP))
|
||||||
|
|
||||||
|
@Test fun `local deleted DOWNLOAD_ONLY skips remote deletion`() =
|
||||||
|
assertEquals(SyncDecision.SKIP,
|
||||||
|
decide(null, remote(), state(), dir = SyncDirection.DOWNLOAD_ONLY))
|
||||||
|
|
||||||
|
// ── local deleted, no state record (uploaded in broken version) ──────────
|
||||||
|
|
||||||
|
@Test fun `local deleted no known state but pair has prior history deletes remote`() =
|
||||||
|
// hasPriorState=true means the pair has been synced before; file has no state
|
||||||
|
// because it was uploaded when getFileMetadata was broken. Should still mirror deletion.
|
||||||
|
assertEquals(SyncDecision.DELETE_REMOTE,
|
||||||
|
decide(null, remote(), known = null, delete = DeleteBehavior.MIRROR, hasPriorState = true))
|
||||||
|
|
||||||
|
@Test fun `initial sync remote only no prior state downloads`() =
|
||||||
|
assertEquals(SyncDecision.DOWNLOAD,
|
||||||
|
decide(null, remote(), known = null, hasPriorState = false))
|
||||||
|
|
||||||
|
// ── first-seen SKIP saves baseline so later deletions are detected ────────
|
||||||
|
|
||||||
|
@Test fun `first sync both exist same mtime uploads local wins tie`() =
|
||||||
|
assertEquals(SyncDecision.UPLOAD, decide(local(MS), remote(MS, etag = "abc")))
|
||||||
|
|
||||||
|
@Test fun `after first-seen skip local deleted deletes remote`() {
|
||||||
|
// Simulate: first sync saw both sides identical → SKIP (state saved by engine).
|
||||||
|
// Then local file deleted → known is now present → DELETE_REMOTE.
|
||||||
|
val known = state(localMs = MS, remoteMs = MS, etag = "abc")
|
||||||
|
assertEquals(SyncDecision.DELETE_REMOTE,
|
||||||
|
decide(null, remote(MS, etag = "abc"), known, delete = DeleteBehavior.MIRROR))
|
||||||
|
}
|
||||||
|
|
||||||
|
// ── directions ────────────────────────────────────────────────────────────
|
||||||
|
|
||||||
|
@Test fun `UPLOAD_ONLY ignores remote changes`() =
|
||||||
|
assertEquals(SyncDecision.SKIP,
|
||||||
|
decide(local(MS), remote(MS2, etag = "new"), state(), dir = SyncDirection.UPLOAD_ONLY))
|
||||||
|
|
||||||
|
@Test fun `DOWNLOAD_ONLY ignores local changes`() =
|
||||||
|
assertEquals(SyncDecision.SKIP,
|
||||||
|
decide(local(MS2), remote(MS, etag = "abc"), state(), dir = SyncDirection.DOWNLOAD_ONLY))
|
||||||
|
}
|
||||||
+2
-2
@@ -1,2 +1,2 @@
|
|||||||
VERSION_NAME=1.0.3
|
VERSION_NAME=1.0.13
|
||||||
VERSION_CODE=4
|
VERSION_CODE=14
|
||||||
|
|||||||
Reference in New Issue
Block a user