Add getUserDetails()
This commit is contained in:
parent
a6d4cf1369
commit
bb64875bad
1 changed files with 10 additions and 1 deletions
|
@ -9,6 +9,7 @@ import com.google.firebase.firestore.DocumentReference
|
||||||
import com.google.firebase.firestore.FirebaseFirestore
|
import com.google.firebase.firestore.FirebaseFirestore
|
||||||
import com.google.firebase.firestore.ktx.snapshots
|
import com.google.firebase.firestore.ktx.snapshots
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
import kotlinx.coroutines.flow.flow
|
||||||
import kotlinx.coroutines.flow.map
|
import kotlinx.coroutines.flow.map
|
||||||
import kotlinx.coroutines.tasks.await
|
import kotlinx.coroutines.tasks.await
|
||||||
import javax.inject.Inject
|
import javax.inject.Inject
|
||||||
|
@ -41,7 +42,15 @@ class FirebaseUserDAO @Inject constructor(
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun getUserDetails(userId: String): Flow<User> {
|
override fun getUserDetails(userId: String): Flow<User> {
|
||||||
TODO("Not yet implemented")
|
return flow {
|
||||||
|
val snapshot = firestore
|
||||||
|
.collection(FirebaseCollections.USER_COLLECTION)
|
||||||
|
.document(userId)
|
||||||
|
.get()
|
||||||
|
.await()
|
||||||
|
val user = snapshot.toObject(User::class.java)!!
|
||||||
|
emit(user)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
override suspend fun getLoggedInUser(): User {
|
override suspend fun getLoggedInUser(): User {
|
||||||
|
|
Reference in a new issue