feat: new funct for profile

Author: f-arslan

core/data/src/main/kotlin/com/espressodev/gptmap/core/data/AccountService.kt

@@ -11,22 +11,19 @@ typealias RevokeAccessResponse = Response<Boolean>
 typealias UpdatePasswordResponse = Response<Boolean>
 
 interface AccountService {
-
     val currentUser: FirebaseUser
-
-    suspend fun firebaseSignUpWithEmailAndPassword(email: String, password: String, fullName: String): AuthResult
+    val userId: String
+    suspend fun firebaseSignUpWithEmailAndPassword(
+        email: String,
+        password: String,
+        fullName: String
+    ): AuthResult
 
     suspend fun sendEmailVerification(): SendEmailVerificationResponse
-
     suspend fun firebaseSignInWithEmailAndPassword(email: String, password: String): AuthResult
-
     suspend fun reloadFirebaseUser(): ReloadUserResponse
-
     suspend fun updatePassword(password: String): UpdatePasswordResponse
-
     suspend fun sendPasswordResetEmail(email: String): SendPasswordResetEmailResponse
-
     fun signOut()
-
     suspend fun revokeAccess(): RevokeAccessResponse
 }

core/data/src/main/kotlin/com/espressodev/gptmap/core/data/FirestoreService.kt

@@ -1,9 +1,11 @@
 package com.espressodev.gptmap.core.data
 
 import com.espressodev.gptmap.core.model.User
+import kotlinx.coroutines.flow.Flow
 
 interface FirestoreService {
     fun saveUser(user: User)
     suspend fun isUserInDatabase(email: String): Result<Boolean>
     suspend fun getUser(userId: String): User
+    fun getUserFlow(userId: String): Flow<User?>
 }

core/data/src/main/kotlin/com/espressodev/gptmap/core/data/impl/AccountServiceImpl.kt

@@ -6,7 +6,7 @@ import com.espressodev.gptmap.core.data.RevokeAccessResponse
 import com.espressodev.gptmap.core.data.SendEmailVerificationResponse
 import com.espressodev.gptmap.core.data.SendPasswordResetEmailResponse
 import com.espressodev.gptmap.core.data.UpdatePasswordResponse
-import com.espressodev.gptmap.core.model.Exceptions.FirebaseUserIdIsNullException
+import com.espressodev.gptmap.core.model.Exceptions.FirebaseUserIsNullException
 import com.espressodev.gptmap.core.model.Response
 import com.google.firebase.auth.AuthResult
 import com.google.firebase.auth.FirebaseAuth
@@ -18,7 +18,10 @@ class AccountServiceImpl @Inject constructor(
     private val auth: FirebaseAuth,
 ) : AccountService {
     override val currentUser: FirebaseUser
-        get() = auth.currentUser ?: throw FirebaseUserIdIsNullException()
+        get() = auth.currentUser ?: throw FirebaseUserIsNullException()
+
+    override val userId: String
+        get() = currentUser.uid
 
     override suspend fun firebaseSignUpWithEmailAndPassword(
         email: String,
@@ -64,7 +67,7 @@ class AccountServiceImpl @Inject constructor(
         return try {
             auth.currentUser?.updatePassword(password)?.await()
             Response.Success(true)
-        } catch (e: Exception)  {
+        } catch (e: Exception) {
             Response.Failure(e)
         }
     }

core/data/src/main/kotlin/com/espressodev/gptmap/core/data/impl/FirestoreServiceImpl.kt

@@ -3,14 +3,18 @@ package com.espressodev.gptmap.core.data.impl
 import com.espressodev.gptmap.core.data.FirestoreService
 import com.espressodev.gptmap.core.model.Exceptions.FirebaseUserIsNullException
 import com.espressodev.gptmap.core.model.User
+import com.google.firebase.auth.FirebaseAuth
 import com.google.firebase.firestore.FirebaseFirestore
 import com.google.firebase.firestore.FirebaseFirestoreException
+import com.google.firebase.firestore.dataObjects
+import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.tasks.await
 import java.util.concurrent.ExecutionException
 import javax.inject.Inject
 
 class FirestoreServiceImpl @Inject constructor(
     private val firestore: FirebaseFirestore,
+    private val auth: FirebaseAuth,
 ) : FirestoreService {
 
     override fun saveUser(user: User) {
@@ -33,6 +37,9 @@ class FirestoreServiceImpl @Inject constructor(
         getUserDocRef(userId).get().await().toObject(User::class.java)
             ?: throw FirebaseUserIsNullException()
 
+    override fun getUserFlow(userId: String): Flow<User?> =
+        getUserDocRef(userId).dataObjects<User>()
+
     private val userColRef by lazy { firestore.collection(USERS) }
     private fun getUserDocRef(id: String) = userColRef.document(id)
 

core/data/src/main/kotlin/com/espressodev/gptmap/core/data/impl/StorageServiceImpl.kt

@@ -1,14 +1,15 @@
 package com.espressodev.gptmap.core.data.impl
 
 import com.espressodev.gptmap.core.data.StorageService
+import com.espressodev.gptmap.core.model.User
 import com.google.firebase.storage.FirebaseStorage
 import com.google.firebase.storage.StorageException
+import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.tasks.await
 import javax.inject.Inject
 
 class StorageServiceImpl @Inject constructor(private val storage: FirebaseStorage) :
     StorageService {
-
     override suspend fun uploadImage(
         image: ByteArray,
         imageId: String,

core/data/src/main/kotlin/com/espressodev/gptmap/core/data/module/FirebaseModule.kt

@@ -28,6 +28,7 @@ object FirebaseModule {
     @Provides
     fun storage(): FirebaseStorage = Firebase.storage
 
+    @Singleton
     @Provides
-    fun providesIoDispatcher(): CoroutineDispatcher = Dispatchers.IO
+    fun providesIODispatcher(): CoroutineDispatcher = Dispatchers.IO
 }