Android - Firestore бесконечной нумерации страниц со слушателями

Question

Я делаю приложение для Android-чата с базой данных Firebase FireStore. Мне нужно бесконечное разбиение на страницы со слушателями для изменений данных (новый массаж, удаленный массаж ...)

Я нашел сообщение в блоге, написанное на kotlin и, конечно, искалFirebase документации и в конечном итоге с этим кодом:

    // firstTime variable shows if function is called from pagination or initially
    private void addMessagesEventListener(boolean firstTime) {
            // get collection
            CollectionReference messagesCollection =                         chatsCollection.document(chat.getId()).collection(Constants.FIREBASE_MESSAGES_PATH);
    // create query
    Query query = messagesCollection.orderBy("timestamp", Query.Direction.DESCENDING);
    // if NOT first time add startAt
    if (!firstTime) {
        query.startAt(startTimestamp);
    }
    //limit to 20 messages
    query.limit(20).get().addOnSuccessListener(queryDocumentSnapshots -> {
        if (!firstTime) {
            endTimestamp = startTimestamp;
        }
        startTimestamp = (long) queryDocumentSnapshots.getDocuments().get(queryDocumentSnapshots.size() - 1).get("timestamp");

        Query innerQuery = messagesCollection.orderBy("timestamp").startAt(startTimestamp);
        if(!firstTime) {
            innerQuery.endBefore(endTimestamp);
        }
        ListenerRegistration listener = innerQuery
                .addSnapshotListener((queryDocumentSnapshots1, e) -> {
                    if (e != null) {
                        Log.w(TAG, "listen:error", e);
                        return;
                    }

                    for (DocumentChange dc : queryDocumentSnapshots1.getDocumentChanges()) {
                        Message message = dc.getDocument().toObject(Message.class);
                        switch (dc.getType()) {
                            case ADDED:
                                // add new message to list
                                messageListAdapter.addMessage(message);
                                if (firstTime) {
                                    messagesList.smoothScrollToPosition(0);
                                }
                                break;
                            case REMOVED:
                                // remove message from list
                                messageListAdapter.removeMessage(message);
                                break;
                        }
                    }
                });
        listeners.add(listener);
    });
}

Теперь код предполагает сохранить слушателей 1-й для первых 20 сообщений и новых сообщений, 2-й для сообщений от 20-40 и т. д., но это не такработает по какой-то причине.Я что-то пропустил?

Проблема в том, что строка startTimestamp = (long) queryDocumentSnapshots.getDocuments().get(queryDocumentSnapshots.size() - 1).get("timestamp"); всегда получает один и тот же результат.Я пытался даже с documentSnapshot вместо отметки времени, тот же результат.

Заранее спасибо.

Answer 1

Я нашел ошибку. Рабочий код:

private void addMessagesEventListener(boolean firstTime) {
    CollectionReference messagesCollection = chatsCollection.document(chat.getId()).collection(Constants.FIREBASE_MESSAGES_PATH);
    Query query = messagesCollection.orderBy("timestamp", Query.Direction.DESCENDING);
    if (!firstTime) {
        query = query.startAt(startListen);
    }
    query.limit(20).get().addOnSuccessListener(queryDocumentSnapshots -> {
        if (!firstTime) {
            endListen = startListen;
        }
        startListen = queryDocumentSnapshots.getDocuments().get(queryDocumentSnapshots.size() - 1);

        Query innerQuery = messagesCollection.orderBy("timestamp").startAt(startListen);
        if(!firstTime) {
            innerQuery = innerQuery.endBefore(endListen);
        }
        ListenerRegistration listener = innerQuery
                .addSnapshotListener((queryDocumentSnapshots1, e) -> {
                    if (e != null) {
                        Log.w("SASA", "listen:error", e);
                        return;
                    }

                    for (DocumentChange dc : queryDocumentSnapshots1.getDocumentChanges()) {
                        Message message = dc.getDocument().toObject(Message.class);
                        switch (dc.getType()) {
                            case ADDED:
                                // add new message to list
                                messageListAdapter.addMessage(message);
                                if (firstTime) {
                                    messagesList.smoothScrollToPosition(0);
                                }
                                break;
                            case REMOVED:
                                // remove message from list
                                messageListAdapter.removeMessage(message);
                                break;
                        }
                    }
                });
        listeners.add(listener);
    });
}

Ошибка была в query = query.startAt(startListen) и innerQuery = innerQuery.endBefore(endListen)

• startListen и endListen имеют тип DocumentSnapshot
• Я использую sortedList в своем адаптере

Вы должны добавить

private void detachListeners() {
    for(ListenerRegistration registration : listeners) {
        registration.remove();
    }
}

в onDestroy, чтобы отключить всех слушателей.

Код прослушивает добавление новых сообщений и удаление старых.

Answer 2

попробуйте это

 @Override
 public void onStart() {
        super.onStart();

        loadFirstQuery();
 }


    public void loadFirstQuery() {


        if (firebaseAuth.getCurrentUser() != null) {

            contentListDashboard.clear();

            String currentUserId = firebaseAuth.getCurrentUser().getUid();              

            // what we do when recycler reach bottom
            recyclerProfileDashboard.addOnScrollListener(new RecyclerView.OnScrollListener() {
               @Override
               public void onScrolled(@NonNull RecyclerView recyclerView, int dx, int dy) {
                   super.onScrolled(recyclerView, dx, dy);

                   // horizontal
                   //Boolean reachBottom = !recyclerView.canScrollHorizontally(-1);

                   // for vertical recycler
                   Boolean reachBottom = !recyclerView.canScrollVertically(-1);


                   if (reachBottom) {
                       loadMorePost(); // do load more post
                   }
               }
           });

            // RETRIEVING FIRST Query
            Query firstQuery = firebaseFirestore
                    .collection("ProfileDashboard")
                    .document(currentUserId)
                    .collection("ProfileInfo")
                    .orderBy("timestamp", Query.Direction.DESCENDING)
                    .limit(20);    

            firstQuery.addSnapshotListener(new EventListener<QuerySnapshot>() {
                @Override
                public void onEvent(QuerySnapshot documentSnapshots, FirebaseFirestoreException e) {

                    if (!documentSnapshots.isEmpty()) {
                        // please add if doc not empty
                        if (isFirstPageFirstLoad) {
                            lastVisible = documentSnapshots.getDocuments().get(documentSnapshots.size() - 1); // array 0, 1, 2
                        }

                        for (DocumentChange doc : documentSnapshots.getDocumentChanges()) {

                            if (doc.getType() == DocumentChange.Type.ADDED) {

                                //String postId = doc.getDocument().getId();
                                contentProfileDashboard = doc.getDocument().toObject(ContentProfileDashboard.class);   


                                // if first page firest load true
                                if (isFirstPageFirstLoad) {
                                    contentListDashboard.add(contentProfileDashboard);
                                } else {
                                    contentListDashboard.add(0, contentProfileDashboard);
                                }


                                // fire the event
                                adapterProfileDashboard.notifyDataSetChanged();
                            }
                        }

                        isFirstPageFirstLoad = false;
                    }
                }
            });
        }
    }

   // Method to load more post
   public void loadMorePost() {

        if (firebaseAuth.getCurrentUser() != null) {

            String currentUserId = firebaseAuth.getCurrentUser().getUid();

            Query nextQuery = firebaseFirestore
                    .collection("ProfileDashboard")
                    .document(currentUserId)
                    .collection("ProfileInfo")
                    .orderBy("timestamp", Query.Direction.DESCENDING)
                    .startAfter(lastVisible)
                    .limit(20);

            nextQuery.addSnapshotListener(new EventListener<QuerySnapshot>() {
                @Override
                public void onEvent(QuerySnapshot documentSnapshots, FirebaseFirestoreException e) {

                    if (!documentSnapshots.isEmpty()) {

                        lastVisible = documentSnapshots.getDocuments().get(documentSnapshots.size() - 1);
                        for (DocumentChange doc : documentSnapshots.getDocumentChanges()) {

                            if (doc.getType() == DocumentChange.Type.ADDED) {

                                //String postId = doc.getDocument().getId();
                                // contentSeen = doc.getDocument().toObject(ContentProfile.class);
                                // contentList.add(contentSeen);

                                contentProfileDashboard = doc.getDocument().toObject(ContentProfileDashboard.class);
                                contentListDashboard.add(contentProfileDashboard);

                                //adapterSeen.notifyDataSetChanged();
                                adapterProfileDashboard.notifyDataSetChanged();

                            }
                        }
                    }
                }
            });
        }
   }

любой вопрос?