Feature/sync foundation

app/src/main/AndroidManifest.xml

@@ -3,6 +3,7 @@
     xmlns:tools="http://schemas.android.com/tools">
 
     <application
+        android:name=".App"
         android:allowBackup="true"
         android:dataExtractionRules="@xml/data_extraction_rules"
         android:fullBackupContent="@xml/backup_rules"
@@ -11,16 +12,16 @@
         android:roundIcon="@mipmap/ic_launcher_round"
         android:supportsRtl="true"
         android:theme="@style/Theme.Notes">
+
         <activity
             android:name=".MainActivity"
             android:exported="true"
             android:theme="@style/Theme.Notes">
             <intent-filter>
                 <action android:name="android.intent.action.MAIN" />
-
                 <category android:name="android.intent.category.LAUNCHER" />
             </intent-filter>
         </activity>
     </application>
 
-</manifest>
+</manifest>

data/src/main/java/com/itlab/data/dao/NoteDao.kt

@@ -11,7 +11,7 @@ import kotlinx.coroutines.flow.Flow
 
 @Dao
 interface NoteDao {
-    @Query("SELECT * FROM notes ORDER BY updatedAt DESC")
+    @Query("SELECT * FROM notes WHERE isDeleted = 0 ORDER BY updatedAt DESC")
     fun getAllNotes(): Flow<List<NoteEntity>>
 
     @Query("SELECT * FROM notes WHERE id = :noteId")
@@ -20,6 +20,15 @@ interface NoteDao {
     @Query("SELECT * FROM notes WHERE folderId = :folderId ORDER BY updatedAt DESC")
     fun getNotesByFolder(folderId: String): Flow<List<NoteEntity>>
 
+    @Query("SELECT * FROM notes WHERE isSynced = 0 AND isDeleted = 0")
+    suspend fun getUnsyncedNotes(): List<NoteEntity>
+
+    @Query("SELECT * FROM notes WHERE isDeleted = 1")
+    suspend fun getDeletedNotes(): List<NoteEntity>
+
+    @Query("DELETE FROM notes WHERE id = :id")
+    suspend fun hardDeleteById(id: String)
+
     @Insert
     suspend fun insert(note: NoteEntity)
 
@@ -31,7 +40,4 @@ interface NoteDao {
 
     @Insert(onConflict = OnConflictStrategy.REPLACE)
     suspend fun insertAll(notes: List<NoteEntity>)
-
-    @Query("SELECT * FROM notes WHERE isSynced = 0")
-    suspend fun getUnsyncedNotes(): List<NoteEntity>
 }

data/src/main/java/com/itlab/data/entity/FolderEntity.kt

@@ -10,5 +10,7 @@ data class FolderEntity(
     val name: String,
     val createdAt: Instant,
     val updatedAt: Instant,
+    val isSynced: Boolean = false,
+    val isDeleted: Boolean = false,
     val metadata: Map<String, String>,
 )

data/src/main/java/com/itlab/data/entity/MediaEntity.kt

@@ -25,5 +25,6 @@ data class MediaEntity(
     val remoteUrl: String?,
     val localPath: String?,
     val mimeType: String,
+    val isSynced: Boolean = false,
     val size: Long? = null,
 )

data/src/main/java/com/itlab/data/entity/NoteEntity.kt

@@ -16,5 +16,6 @@ data class NoteEntity(
     val tags: String? = null,
     val isFavorite: Boolean = false,
     val isSynced: Boolean = false,
+    val isDeleted: Boolean = false,
     val summary: String? = null,
 )

domain/src/main/java/com/itlab/domain/cloud/CloudDataSource.kt

@@ -0,0 +1,34 @@
+package com.itlab.domain.cloud
+
+import kotlinx.datetime.Instant
+import java.io.File
+
+interface CloudDataSource {
+    suspend fun listNoteMetadata(userId: String): Result<List<CloudNoteMetadata>>
+
+    suspend fun downloadNote(key: String): Result<String>
+
+    suspend fun uploadNote(
+        key: String,
+        json: String,
+    ): Result<Unit>
+
+    suspend fun deleteNote(key: String): Result<Unit>
+
+    suspend fun uploadMedia(
+        key: String,
+        file: File,
+    ): Result<Unit>
+
+    suspend fun downloadMedia(
+        key: String,
+        destination: File,
+    ): Result<Unit>
+
+    suspend fun deleteMedia(key: String): Result<Unit>
+}
+
+data class CloudNoteMetadata(
+    val key: String,
+    val updatedAt: Instant,
+)

domain/src/main/java/com/itlab/domain/cloud/SyncManager.kt

@@ -0,0 +1,25 @@
+package com.itlab.domain.cloud
+
+import kotlinx.coroutines.flow.StateFlow
+
+interface SyncManager {
+    val syncState: StateFlow<SyncState>
+
+    suspend fun sync(userId: String)
+
+    suspend fun pushChanges(userId: String)
+
+    suspend fun pullUpdates(userId: String)
+}
+
+sealed class SyncState {
+    object Idle : SyncState()
+
+    object Syncing : SyncState()
+
+    data class Error(
+        val message: String,
+    ) : SyncState()
+
+    object Success : SyncState()
+}

domain/src/main/java/com/itlab/domain/model/Note.kt

@@ -15,6 +15,7 @@ data class Note(
     val tags: Set<String> = emptySet(),
     val isFavorite: Boolean = false,
     val summary: String? = null,
+    val syncStatus: SyncStatus = SyncStatus.PENDING,
 )
 
 @Serializable
@@ -62,3 +63,10 @@ enum class TextFormat {
     MARKDOWN,
     HTML,
 }
+
+enum class SyncStatus {
+    SYNCED,
+    PENDING,
+    SYNCING,
+    ERROR,
+}

gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,5 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionSha256Sum=60ea723356d81263e8002fec0fcf9e2b0eee0c0850c7a3d7ab0a63f2ccc601f3
 distributionUrl=https\://services.gradle.org/distributions/gradle-9.4.0-bin.zip
 networkTimeout=10000
 validateDistributionUrl=true