amir
c60eb8d27b
Build & Release APK / build (push) Has been cancelled
- SyncEngine: accepts onProgress callback — emits uploaded/downloaded/ deleted/bytes counts atomically as each file completes - SyncWorker: streams progress to WorkManager data so the UI can poll it live; reports per-run counters in the completion notification; adds pause/resume support - HomeViewModel/PairDetailViewModel: subscribe to live WorkManager progress and surface it via SyncProgress state - SyncPairEntity/SyncPairDao/SyncDatabase: persist last-run counters (uploaded, downloaded, deleted, bytesTransferred) in the DB with a Room migration (v3→v4) - AppModule: provides WorkManager as an injectable singleton - .gitignore: add .kotlin/ to exclude compiler session files Security: no new issues — all logging via Timber (debug-only), DB queries use Room parameterized API, file sharing via FileProvider. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
46 lines
1.6 KiB
Kotlin
46 lines
1.6 KiB
Kotlin
package com.syncflow.data.db
|
|
|
|
import androidx.room.Database
|
|
import androidx.room.RoomDatabase
|
|
import androidx.room.TypeConverters
|
|
import androidx.room.migration.Migration
|
|
import androidx.sqlite.db.SupportSQLiteDatabase
|
|
import com.syncflow.data.db.entities.*
|
|
|
|
@Database(
|
|
entities = [
|
|
CloudAccountEntity::class,
|
|
SyncPairEntity::class,
|
|
SyncFileStateEntity::class,
|
|
SyncConflictEntity::class,
|
|
SyncEventEntity::class,
|
|
],
|
|
version = 4,
|
|
exportSchema = true,
|
|
)
|
|
@TypeConverters(DbConverters::class)
|
|
abstract class SyncDatabase : RoomDatabase() {
|
|
|
|
companion object {
|
|
val MIGRATION_2_3 = object : Migration(2, 3) {
|
|
override fun migrate(db: SupportSQLiteDatabase) {
|
|
db.execSQL("DELETE FROM sync_file_states")
|
|
}
|
|
}
|
|
|
|
val MIGRATION_3_4 = object : Migration(3, 4) {
|
|
override fun migrate(db: SupportSQLiteDatabase) {
|
|
db.execSQL("ALTER TABLE sync_pairs ADD COLUMN lastSyncUploaded INTEGER NOT NULL DEFAULT 0")
|
|
db.execSQL("ALTER TABLE sync_pairs ADD COLUMN lastSyncDownloaded INTEGER NOT NULL DEFAULT 0")
|
|
db.execSQL("ALTER TABLE sync_pairs ADD COLUMN lastSyncDeleted INTEGER NOT NULL DEFAULT 0")
|
|
db.execSQL("ALTER TABLE sync_pairs ADD COLUMN lastSyncBytesTransferred INTEGER NOT NULL DEFAULT 0")
|
|
}
|
|
}
|
|
}
|
|
abstract fun cloudAccountDao(): CloudAccountDao
|
|
abstract fun syncPairDao(): SyncPairDao
|
|
abstract fun syncFileStateDao(): SyncFileStateDao
|
|
abstract fun syncConflictDao(): SyncConflictDao
|
|
abstract fun syncEventDao(): SyncEventDao
|
|
}
|