如何在单独的存储库MVVM中传递Firestore SnapshotListener提供的实时数据

如何解决如何在单独的存储库MVVM中传递Firestore SnapshotListener提供的实时数据

经过数小时的尝试和搜索，我仍然感到困惑，希望有人能帮助我。 我正在尝试通过ViewModel从Firestore（使用SnapshotListener）获取实时更新到我的Activity，但是我的所有尝试都失败了。下面是我当前的设置-尝试更新存储库中的LiveData并将其移交给View模型...

我的问题： 我的Firestore集合中有UserData（位于文档内）。我尝试在运行时使用observeUserData（）函数侦听当前用户的更改。此功能（有关文档更改）提供的数据应通过我的ViewModel发送到我的Activiy。如果我在Firestore中对用户文档进行了某些更改，则SnapshotListener会按预期触发，但是更新未达到我的ViewModel，因此也没有达到我的Activity。

有人可以帮我存档吗？我现在看到的唯一解决方案是在ViewModel中添加SnapshotListener，但据我所知这是不好的做法？ 非常感谢。

Firestore存储库

object FirestoreService {    
    val db = FirebaseFirestore.getInstance()
    val userDataLiveData = MutableLiveData<UserData>()


    fun observeUserData(userId: String) {
        try {
            db.collection("userData").document(userId).addSnapshotListener{ documentSnapshot: DocumentSnapshot?,firebaseFirestoreException: FirebaseFirestoreException? ->
                firebaseFirestoreException?.let {
                    Log.e(TAG,firebaseFirestoreException.toString())
                    return@addSnapshotListener
                }

                val data = documentSnapshot?.toUserData()

                data?.let {
                    Log.d(TAG,"post new value")
                    userDataLiveData.postValue(data)
                }
            }
        } catch (e: Exception) {
            Log.e(TAG,"Error getting user data",e)
        }
    }

ViewModel

class MyViewModel (private val uid : String) : ViewModel() {
    private var _userData = MutableLiveData<UserData>()
    val userData: LiveData<UserData> = _userData

    fun getUserData() {
        Log.d(TAG,"getUserData called")
        FirestoreService.observeUserData(uid)
        var data = FirestoreService.userDataLiveData
        _userData = data
    }
}

活动

//ViewModel Setup
val factory = MyViewModelFactory(user.uid.toString())
val viewModel = ViewModelProvider(this,factory).get(MyViewModel::class.java)

//Initialize UserData
viewModel.getUserData()
viewModel.userData.observe(this,Observer {
    userData = it
    Log.d(TAG,userData.toString())
})

解决方法

您需要先初始化viewModel

lateinit var userViewModel : MyViewModel

userViewModel = new ViewModelProvider(this).get(MyViewModel::class.java)

然后在userViewModel上使用getViewLifeCycleOwner方法，然后观察将具有userDataModel的LiveData

onChanged（）方法将是您可以在userDataModel中访问方法（getter和setter）的地方

,

没有任何侦听器，这是一种更简单的方法。首先，添加此依赖项：

implementation "org.jetbrains.kotlinx:kotlinx-coroutines-play-services:1.3.9"

然后可以说您拥有以下存储库：

inteface FirestoreService {
    fun sendUserData(uid: String): LiveData<String> // Or whatever it should emit
}

发出实时数据的实现可能如下：

class FirestoreServiceImpl : FireStoreService {
    val db = FirebaseFirestore.getInstance()

    fun sendUserData(uid: String): LiveData<String> = liveData {
        val mySnapshot = db.collection("userData)".document(userId).await()
        emit(mySnapshot?.toUserData)
    }
}

如果要在viewModel中调用此方法，最好将LiveData更改为Flow

fun sendUserData(uid: String): Flow<String> = flow {
    val mySnapshot = db.collection("userData)".document(userId).await()
    emit(mySnapshot?.toUserData)
}

在ViewModel中，您可以这样做：

val myInput = "TestUUID"

val myUserID = sendUserData(myInput).asLiveData()

然后，最后是片段/活动：

yourViewModel.myUserID.observe(viewLifecycleOwner) {
   // do stuff here
} 

,

谢谢大家的答复-幸运的是我发现了我的问题。

我认为我混合了太多来自不同“指南” /“方法”的内容-幸运的是，我发现道格·史蒂文森（Doug Stevenson）的精彩演讲在下面使我无法参与其中：

https://www.youtube.com/watch?v=WXc4adLMDqk

谢谢你道格：）