Я прошел через решение Дуга Стивенсона для нумерации страниц для Firestore с использованием шаблонов архитектуры Android, представленных на https://github.com/CodingDoug/firebase-jetpack. Меня беспокоит то, как я могу заставить эту работу работать в режиме реального времени с использованием компонентов архитектуры Android.Я попытался найти решение, которое описано ниже, но есть некоторые проблемы с ним.Я попытался заставить нумерацию страниц работать в режиме реального времени, создав FirestoreBoundaryCallback: -
class FirestoreBoundaryCallback<T>(
private val baseQuery: Query,
private val factory: FirestoreQueryDataSource.Factory,
private val lifecycleOwner: LifecycleOwner): PagedList.BoundaryCallback<QueryItemOrException<T>>() {
private val allLiveData = mutableListOf<FirebaseQueryLiveData>()
private val mutableLoadingState = MutableLiveData<LoadingState>()
val loadingState: LiveData<LoadingState>
get() = mutableLoadingState
override fun onZeroItemsLoaded() {
allLiveData.clear()
mutableLoadingState.value = LoadingState.LOADING_INITIAL
val query = baseQuery.limit(50)
val liveData = FirebaseQueryLiveData(query)
liveData.observe(lifecycleOwner, Observer {
mergeAllDocs()
if (mutableLoadingState.value != LoadingState.LOADED) {
mutableLoadingState.value = LoadingState.LOADED
}
})
allLiveData.add(liveData)
}
override fun onItemAtEndLoaded(itemAtEnd: QueryItemOrException<T>) {
if (allLiveData.isNotEmpty() && allLiveData.last().value?.data?.documents?.isNotEmpty() == true) {
val lastDocument = allLiveData.last().value?.data?.documents?.last()
if (lastDocument != null) {
val query = baseQuery.startAfter(lastDocument).limit(50)
val liveData = FirebaseQueryLiveData(query)
mutableLoadingState.value = LoadingState.LOADING_MORE
liveData.observe(lifecycleOwner, Observer {
mergeAllDocs()
if (mutableLoadingState.value != LoadingState.LOADED) {
mutableLoadingState.value = LoadingState.LOADED
}
})
allLiveData.add(liveData)
}
}
}
fun mergeAllDocs() {
val items = mutableListOf<DocumentSnapshot>()
allLiveData.forEach{
val docs = it.value?.data?.documents
if (docs != null) {
items.addAll(docs)
}
}
factory.setItems(items)
}
override fun onItemAtFrontLoaded(itemAtFront: QueryItemOrException<T>) {
}
}
И затем я изменил FirestoreQueryDataSource следующим образом: -
class FirestoreQueryDataSource private constructor(
private val documentSnapshots: List<DocumentSnapshot>
) : PageKeyedDataSource<PageKey, DocumentSnapshot>() {
companion object {
private const val TAG = "FirestoreQueryDataSrc"
}
class Factory(private val query: Query, private val source: Source) : DataSource.Factory<PageKey, DocumentSnapshot>() {
val sourceLiveData = MutableLiveData<FirestoreQueryDataSource>()
var documentSnapshots: List<DocumentSnapshot> = mutableListOf()
fun setItems(items: List<DocumentSnapshot>) {
sourceLiveData.value?.invalidate()
documentSnapshots = items
sourceLiveData.postValue(FirestoreQueryDataSource(documentSnapshots))
}
override fun create(): DataSource<PageKey, DocumentSnapshot> {
val dataSource = FirestoreQueryDataSource(documentSnapshots)
sourceLiveData.postValue(dataSource)
return dataSource
}
}
override fun loadInitial(
params: LoadInitialParams<PageKey>,
callback: LoadInitialCallback<PageKey, DocumentSnapshot>) {
val firstPageDocSnapshots = documentSnapshots.take(params.requestedLoadSize)
val nextPageKey = getNextPageKey(firstPageDocSnapshots)
callback.onResult(firstPageDocSnapshots, null, nextPageKey)
}
override fun loadAfter(
params: LoadParams<PageKey>,
callback: LoadCallback<PageKey, DocumentSnapshot>) {
val startAfterIndex = documentSnapshots.indexOf(params.key.startAfterDoc)
var endIndex = startAfterIndex + params.requestedLoadSize
if (endIndex > documentSnapshots.size) {
endIndex = documentSnapshots.size - 1;
}
val afterInitialPageDocs = documentSnapshots.subList(startAfterIndex, endIndex)
val nextPageKey = getNextPageKey(afterInitialPageDocs)
callback.onResult(afterInitialPageDocs, nextPageKey)
}
override fun loadBefore(
params: LoadParams<PageKey>,
callback: LoadCallback<PageKey, DocumentSnapshot>) {
// The paging here only understands how to append new items to the
// results, not prepend items from earlier pages.
callback.onResult(emptyList(), null)
}
private fun getNextPageKey(documents: List<DocumentSnapshot>): PageKey? {
return if (documents.isNotEmpty()) {
PageKey(documents.last())
} else {
null
}
}
}
data class PageKey(val startAfterDoc: DocumentSnapshot)
В моей ViewModel,вот что я возвращаю: -
val sourceFactory = FirestoreQueryDataSource.Factory(query, Source.DEFAULT)
val deserializedDataSourceFactory = sourceFactory.map { snapshot ->
try {
val item = QueryItem(Deserializer.deserialize(snapshot, Record::class.java), snapshot.id)
item.item.id = snapshot.id
QueryItemOrException(item, null)
} catch (e: Exception) {
Log.e(TAG, "Error while deserializing order", e)
QueryItemOrException<PosOrder>(null, e)
}
}
val boundaryCallback = FirestoreBoundaryCallback<Record>(query, sourceFactory, lifecycleOwner)
val livePagedList = LivePagedListBuilder(deserializedDataSourceFactory, 30)
.setFetchExecutor(executors.cpuExecutorService)
.setBoundaryCallback(boundaryCallback)
.build()
return Listing(
pagedList = livePagedList,
loadingState = boundaryCallback.loadingState,
refresh = {
sourceFactory.sourceLiveData.value?.invalidate()
}
)
Производительность не очень хорошая, и я также обеспокоен тем, что при вставке новой записи первая страница потеряет свою последнюю запись (так как ограничение установлено дляпервый запрос) и вторая страница будет продолжать ПОСЛЕ последней записи более старой первой страницы.Какой будет правильный способ разбивки данных о брандмауэрах на Android с помощью обновлений в реальном времени?