如何使用MVVM模式從Firestore檢索資料

我正在按照 MVVM 贊助人創建一個 android 應用程式，目的是從 Firebase 集合中檢索資料。

在應用此模式之前，我進行了概念驗證，并且能夠從 Firebase 集合中檢索資料。但是一旦我應用了 MVVM，我就無法從該集合中獲取資料，我的螢屏也沒有顯示任何內容。我無法從存盤庫中回傳要繪制在螢屏上的資料。

這是我的代碼：

模型：

data class PotatoesData(
    val modifiedDate: String,
    var potatoes: List<Potato>
) 

data class Potato(
    val type: String,
    val site: String
)

狀態：

data class PotatoesState(
    val isLoading: Boolean = false,
    val potatoes: List<Potato> = emptyList(),
    val error: String = ""
)

模型視圖：

@HiltViewModel
class PotatoesViewModel @Inject constructor(
    private val getPotatoesDataUseCase: GetPotatoesData
) : ViewModel() {

    private val _state = mutableStateOf(PotatoesState())
    val state: State<PotatoesState> = _state

    init {
        getPotatoes()
    }

    private fun getPotatoes() {

        getPotatoesDataUseCase().onEach { result ->
            when (result) {
                is Resource.Success -> {
                    _state.value = PotatoesState(potatoes = result.data?.potatoes ?: emptyList())
                }
                is Resource.Error   -> {
                    _state.value = PotatoesState(
                        error = result.message ?: "An unexpected error occurred"
                    )
                }
                is Resource.Loading -> {
                    _state.value = PotatoesState(isLoading = true)
                }
            }
        }.launchIn(viewModelScope)
    }
}

用例：

class GetPotatoesData @Inject constructor(
    private val repository: PotatoRepository
) {
    operator fun invoke(): Flow<Resource<PotatoesData>> = flow {
        try {
            emit(Resource.Loading())
            val potatoes = repository.getPotatoesData()
            emit(Resource.Success(potatoes))
        } catch (e: IOException) {
            emit(Resource.Error("Couldn't reach server. Check your internet connection."))
        }
    }
}

存盤庫實作：

class PotatoRepositoryImpl : PotatoRepository {

    override suspend fun getPotatoesData(): PotatoesData {

        var potatoes = PotatoesData("TEST", emptyList())

        FirestoreProvider.getLastPotatoes(
            { potatoesData ->
                if (potatoesData != null) {
                    potatoes = potatoesData 
                }
            },
            { 
                potatoes 
            }
        )

        return potatoes 
    }
}

Firestore 提供商：

object FirestoreProvider {

    private val incidentsRef = FirebaseFirestore.getInstance().collection(FirestoreCollection.POTATOES.key)

    fun getLastPotatoes(
        success: (potatoesData: PotatoesData?) -> Unit,
        failure: () -> Unit
    ) {

        val query: Query = orderBy(FirestoreField.CREATED_DATE, Query.Direction.DESCENDING).limit(1)
        val querySnapshot: Task<QuerySnapshot> = query.get()

        querySnapshot
            .addOnSuccessListener {
                if (!querySnapshot.result.isEmpty) {
                    val document = querySnapshot.result.documents[0]
                    val potatoesDataDB: PotatoesDataDto? = document.toObject(PotatoesDataDto::class.java)
                    potatoesDataDB?.let {
                        success(potatoesDataDB.toPotatoesData())
                    } ?: run {
                        success(null)
                    }
                } else {
                    success(null)
                }
            }
            .addOnFailureListener {
                failure()
            }
    }

    private fun orderBy(field: FirestoreField, direction: Query.Direction): Query {

        return incidentsRef.orderBy(field.key, direction)
    }

}

我很感激任何形式的幫助！提前致謝！

uj5u.com熱心網友回復：

我認為該錯誤與您處理 Firestore 回呼的方式有關。in FirestoreProvider：回呼將在函式getLastPotatoes回傳之后觸發。嘗試使該函式掛起并用于suspendCoroutine等待回呼并回傳其結果。它看起來像：

suspend fun getLastPotatoes() = suspendCoroutine <PotatoesData?> { continuation ->

    val query: Query = orderBy(FirestoreField.CREATED_DATE, Query.Direction.DESCENDING).limit(1)
    val querySnapshot: Task<QuerySnapshot> = query.get()

    querySnapshot
        .addOnSuccessListener {
            if (!querySnapshot.result.isEmpty) {
                val document = querySnapshot.result.documents[0]
                val potatoesDataDB: PotatoesDataDto? = document.toObject(PotatoesDataDto::class.java)
                potatoesDataDB?.let {
                    continuation.resume(potatoesDataDB.toPotatoesData())
                } ?: run {
                    continuation.resume(null)
                }
            } else {
                continuation.resume(null)
            }
        }
        .addOnFailureListener {
            continuation.resumeWithException(...)
        }
}

suspendCoroutine掛起它執行的協程，直到我們決定通過呼叫適當的方法繼續 - Continuation.resume...。

在您的PotatoRepositoryImpl：

override suspend fun getPotatoesData(): PotatoesData {

    var potatoes = PotatoesData("TEST", emptyList())

    try {
        val potatoesData = FirestoreProvider.getLastPotatoes()
        if (potatoesData != null) {
            potatoes = potatoesData
        }
    } catch (e: Exception) {
        // handle Exception
    }
   
    return potatoes 
}

標籤：安卓 火力基地 科特林 谷歌云firestore kotlin 协程

上一篇：尚未創建Firebase應用程式-呼叫Firebase.initializeApp()

下一篇：Firestore（NoSQL）中“JOIN”的有效替代方法是什么？