Sync notes feature

Fix bug in syncing notes

Author: VIPlearner

app/build.gradle.kts

@@ -32,13 +32,30 @@ android {
         }
     }
 
+    signingConfigs {
+//        get {
+//            keyAlias = project.property("RELEASE_KEY_ALIAS").toString()
+//            keyPassword = project.property("RELEASE_KEY_PASSWORD").toString()
+//            storeFile = file(project.property("RELEASE_STORE_FILE").toString())
+//            storePassword = project.property("RELEASE_STORE_PASSWORD").toString()
+//        }
+
+        create("release") {
+            keyAlias = project.property("RELEASE_KEY_ALIAS").toString()
+            keyPassword = project.property("RELEASE_KEY_PASSWORD").toString()
+            storeFile = file(project.property("RELEASE_STORE_FILE").toString())
+            storePassword = project.property("RELEASE_STORE_PASSWORD").toString()
+        }
+    }
+
     buildTypes {
         release {
             isMinifyEnabled = false
             proguardFiles(
                 getDefaultProguardFile("proguard-android-optimize.txt"),
                 "proguard-rules.pro"
             )
+            signingConfig = signingConfigs.getByName("release")
         }
     }
     compileOptions {
@@ -74,6 +91,9 @@ dependencies {
     implementation(project(":feature:single_note:data"))
     implementation(project(":feature:single_note:domain"))
     implementation(project(":feature:single_note:presentation"))
+    implementation(project(":feature:settings:data"))
+    implementation(project(":feature:settings:domain"))
+    implementation(project(":feature:settings:presentation"))
     implementation(libs.core.ktx)
     implementation(libs.lifecycle.runtime.ktx)
     implementation(libs.hilt)

app/src/main/java/com/viplearner/notes/MainActivity.kt

@@ -9,11 +9,7 @@ import androidx.activity.compose.rememberLauncherForActivityResult
 import androidx.activity.compose.setContent
 import androidx.activity.result.IntentSenderRequest
 import androidx.activity.result.contract.ActivityResultContracts
-import androidx.compose.material3.Text
-import androidx.compose.runtime.Composable
 import androidx.compose.runtime.DisposableEffect
-import androidx.compose.ui.Modifier
-import androidx.compose.ui.tooling.preview.Preview
 import androidx.lifecycle.lifecycleScope
 import com.example.compose.NotesTheme
 import com.facebook.CallbackManager
@@ -162,20 +158,4 @@ class MainActivity : ComponentActivity() {
         callbackManager.onActivityResult(requestCode, resultCode, data)
         super.onActivityResult(requestCode, resultCode, data)
     }
-}
-
-@Composable
-fun Greeting(name: String, modifier: Modifier = Modifier) {
-    Text(
-        text = "Hello $name!",
-        modifier = modifier
-    )
-}
-
-@Preview(showBackground = true)
-@Composable
-fun GreetingPreview() {
-    NotesTheme {
-        Greeting("Android")
-    }
 }

common/data/local/src/main/java/com/viplearner/common/data/local/datastore/NotesDataStoreRepositoryImpl.kt

@@ -69,10 +69,29 @@ class NotesDataStoreRepositoryImpl @Inject constructor (
             }
     }
 
-    override suspend fun savePrivateKey(privateKey: String) {
+    override suspend fun savePrivateKey(value: String) {
         prefsDataStore.edit { preferences ->
-            preferences[NotesDataStorePreferenceKeys.PRIVATE_KEY] = privateKey
+            preferences[NotesDataStorePreferenceKeys.PRIVATE_KEY] = value
         }
     }
 
+    override suspend fun getSyncState(): Flow<Boolean> {
+        return  prefsDataStore.data
+            .catch { exception ->
+                // dataStore.data throws an IOException when an error is encountered when reading data
+                if (exception is IOException) {
+                    emit(emptyPreferences())
+                } else {
+                    throw exception
+                }
+            }.map { preferences ->
+                preferences[NotesDataStorePreferenceKeys.SYNC_STATE]?:false
+            }
+    }
+
+    override suspend fun setSyncState(value: Boolean) {
+        prefsDataStore.edit { preferences ->
+            preferences[NotesDataStorePreferenceKeys.SYNC_STATE] = value
+        }
+    }
 }

common/data/local/src/main/java/com/viplearner/common/data/local/dto/Note.kt

@@ -10,7 +10,7 @@ data class Note(
     @PrimaryKey @ColumnInfo(name = "uuid") val uuid: String = UUID.randomUUID().toString(),
     @ColumnInfo(name = "title") val title: String,
     @ColumnInfo(name = "content") val content: String,
-    @ColumnInfo(name = "timeLastEdited") val timeLastEdited: Long,
+    @ColumnInfo(name = "timeLastEdited") var timeLastEdited: Long,
     @ColumnInfo(name = "isPinned", defaultValue = "0") var isPinned: Boolean,
     @ColumnInfo(name = "isDeleted", defaultValue = "false") var isDeleted: Boolean = false
 )

common/data/remote/src/main/java/com/viplearner/common/data/remote/fb_database_repository/DatabaseRepositoryImpl.kt

@@ -55,4 +55,7 @@ class DatabaseRepositoryImpl @Inject constructor(
             note.toNote()
         )
     }
+
+    override suspend fun observeNotes(uid: String) =
+        databaseService.observeNotes(uid)
 }

common/data/remote/src/main/java/com/viplearner/common/data/remote/service/DatabaseService.kt

@@ -10,8 +10,12 @@ import com.google.firebase.database.ktx.database
 import com.google.firebase.ktx.Firebase
 import com.viplearner.common.data.remote.di.IoDispatcher
 import com.viplearner.common.data.remote.dto.Note
+import com.viplearner.common.data.remote.mapper.toNoteEntity
 import com.viplearner.common.domain.datastore.NotesDataStoreRepository
 import kotlinx.coroutines.CoroutineDispatcher
+import kotlinx.coroutines.channels.awaitClose
+import kotlinx.coroutines.flow.callbackFlow
+import kotlinx.coroutines.tasks.await
 import javax.inject.Inject
 
 class DatabaseService @Inject constructor(
@@ -51,6 +55,27 @@ class DatabaseService @Inject constructor(
         return src.task
     }
 
+    fun observeNotes(uid: String) = callbackFlow{
+        trySend(loadAllNotesTask(uid).await().children.mapNotNull {
+            it.getValue(Note::class.java)?.toNoteEntity()
+        })
+        val listener = object : ValueEventListener {
+            override fun onCancelled(error: DatabaseError) {}
+
+            override fun onDataChange(snapshot: DataSnapshot) {
+                val notes = mutableListOf<Note>()
+                snapshot.children.forEach { child ->
+                    child.getValue(Note::class.java)?.let { note ->
+                        notes.add(note)
+                    }
+                }
+                trySend(notes.map { note -> note.toNoteEntity() })
+            }
+        }
+        refToPath("users/$uid/notes").addValueEventListener(listener)
+        awaitClose { refToPath("users/$uid/notes").removeEventListener(listener) }
+    }
+
     fun updateNote(uid: String, note: Note) {
         refToPath("users/$uid/notes/${note.uuid}").setValue(note)
     }

common/domain/src/main/java/com/viplearner/common/domain/datastore/NotesDataStorePreferenceKeys.kt

@@ -1,10 +1,12 @@
 package com.viplearner.common.domain.datastore
 
+import androidx.datastore.preferences.core.booleanPreferencesKey
 import androidx.datastore.preferences.core.stringPreferencesKey
 
 object NotesDataStorePreferenceKeys {
     const val NOTES_DATASTORE_PREFERENCES = "nomba_datastore_prefs"
 
     val USER_DATA = stringPreferencesKey("user_data")
     val PRIVATE_KEY = stringPreferencesKey("private_key")
+    val SYNC_STATE = booleanPreferencesKey("sync_state")
 }

common/domain/src/main/java/com/viplearner/common/domain/datastore/NotesDataStoreRepository.kt

@@ -18,4 +18,6 @@ interface NotesDataStoreRepository {
     suspend fun clearUserData()
     suspend fun getPrivateKey(): Flow<String>
     suspend fun savePrivateKey(privateKey: String)
+    suspend fun getSyncState(): Flow<Boolean>
+    suspend fun setSyncState(value: Boolean)
 }

common/domain/src/main/java/com/viplearner/common/domain/extensions/StringExt.kt

@@ -0,0 +1,12 @@
+package com.viplearner.common.domain.extensions
+
+fun String?.isValidUrl(): Boolean {
+    try {
+        if (this == null) return false
+        val url = java.net.URL(this)
+        url.toURI()
+        return true
+    } catch (e: Exception) {
+        return false
+    }
+}

common/domain/src/main/java/com/viplearner/common/domain/firebase_database_repository/DatabaseRepository.kt

@@ -1,11 +1,13 @@
 package com.viplearner.common.domain.firebase_database_repository
 
 import com.viplearner.common.domain.entity.NoteEntity
+import kotlinx.coroutines.flow.Flow
 
 
 interface DatabaseRepository {
     suspend fun loadAllNotes(uid: String): List<NoteEntity>
     suspend fun loadNote(uid: String, uuid: String): NoteEntity?
     suspend fun saveNotes(uid: String, notes : List<NoteEntity>)
     suspend fun updateNote(uid: String, note: NoteEntity)
+    suspend fun observeNotes(uid: String): Flow<List<NoteEntity>>
 }