Сообщения чата не загружаются должным образом

Question

Я пытался создать систему сообщений чата, но старые сообщения, кажется, все еще остаются при вызове новых сообщений.

Кто-нибудь может помочь? Кроме того, иногда, когда создается новый пользователь, и он общается с другим пользователем. Сообщения от другого пользователя не отражаются в чате нового пользователя.

override func viewWillAppear(_ animated: Bool) {
            super.viewWillAppear(animated)
            navigationItem.title = "Chat"
            DispatchQueue.global(qos:.userInteractive).async {
                DispatchQueue.main.async {
                    self.loadPosts()
                    self.loadPostsReceivedMessage()
                }
            }
        }

    //Get Message sent
       func loadPosts() {
            let senderIDNumber = Auth.auth().currentUser?.uid
            let chatsRef = db.collection("chats").order(by: "timestamp", descending: false)
            chatsRef.whereField("senderID", isEqualTo: senderIDNumber!).whereField("receiverID", isEqualTo: receiverIDNumber)
                .addSnapshotListener { querySnapshot, error in
                    guard let documents = querySnapshot?.documents else {
                        print("Error fetching documents: \(error!)")
                        return
                    }
                    for document in documents {
                        let messageText = document.data()["message"] as? String
                        let senderIDNumber = document.data()["senderID"] as? String
                        let receiverIDNumber = document.data()["receiverID"] as? String
                        let timestamp = document.data()["timestamp"] as? String
                        guard let sender = document.data()["sender"] as? String else {return}
                       // let conversationsCounter = document.data()["conversationsCounter"] as? Int
                        guard let profileUrl = document.data()["profileUrl"] as? String else { return}
                        let chat = Chat(messageTextString: messageText!, senderIDNumber: senderIDNumber!, receiverIDNumber: receiverIDNumber!, timeStampString: timestamp!, profileImageUrl: profileUrl, senderString: sender)
        self.chats.append(chat)
        print(self.chats)
        self.collectionView.reloadData()
        }
        }
        }


        //Get message received
        func loadPostsReceivedMessage() {
           /* let uid = Auth.auth().currentUser?.uid
            let ref = Database.database().reference()
            ref.child("users").child(uid!).observeSingleEvent(of: .value, with: { (snapshot) in
                if let dic = snapshot.value as? [String: AnyObject]{
                    let currentUser = dic["username"] as? String
                    let senderIDNumber = Auth.auth().currentUser?.uid
                } */
                    let chatsRef = db.collection("chats").order(by: "timestamp", descending: false)
                    print("thecurrentreceiver"+senderString)
                    print("thecurrentsender"+receiverIDNumber)
            chatsRef.whereField("receiverID", isEqualTo: senderString).whereField("sender", isEqualTo: receiverIDNumber)
                        .addSnapshotListener { querySnapshot, error in
                            guard let documents = querySnapshot?.documents else {
                                print("Error fetching documents: \(error!)")
                                return
                            }
                            for document in documents {
                                let messageText = document.data()["message"] as? String
                                let senderIDNumber = document.data()["senderID"] as? String
                                let receiverIDNumber = document.data()["receiverID"] as? String
                                let timestamp = document.data()["timestamp"] as? String
                                // let conversationsCounter = document.data()["conversationsCounter"] as? Int
                                guard let profileUrl = document.data()["profileUrl"] as? String else { return}
                                guard let sender = document.data()["sender"] as? String else {return}
                                let chat = Chat(messageTextString: messageText!, senderIDNumber: senderIDNumber!, receiverIDNumber: receiverIDNumber!, timeStampString: timestamp!,profileImageUrl: profileUrl, senderString: sender)
                                print("whatisthemessage"+messageText!)
                                self.chats.append(chat)
                                print(self.chats)
                                self.chats.sort{$0.timestamp < $1.timestamp}
                                self.collectionView.reloadData()
                            }
                    }
        }

Answer 1

Вы используете addSnapshotListener, что означает, что ваш обратный вызов вызывается каждый раз, когда что-то релевантное в базе данных изменяется. И когда это происходит, вы перебираете все документы, соответствующие вашему запросу, и добавляете их в свой вид. Это означает, что при наличии нескольких изменений вы добавляете большинство сообщений несколько раз.

Существует два распространенных решения:

1. Очистить представление при каждом вызове.
2. Изменять представление для изменений можно только при каждом вызове обратного вызова.

Мы будем использовать # 2 ниже, так как он более эффективен. Обратите внимание, что я обрабатываю только новые сообщения, чтобы упростить задачу. По мере того, как вы будете делать ваше приложение более полным, вам также придется обрабатывать другие типы изменений, например, когда пользователь удаляет или обновляет сообщение чата.

let chatsRef = db.collection ("chats").order (by: "timestamp", descending: false)
chatsRef.whereField ("senderID", isEqualTo: senderIDNumber!)
  .whereField ("receiverID", isEqualTo: receiverIDNumber)
  .addSnapshotListener {
    querySnapshot,
    error in guard let documentChanges = querySnapshot?.documentChanges else {
        print ("Error fetching documents: \(error!)")
        return
    }
    for documentChange in documentChanges {
      if (documentChange.type == .added) {
        let data = documentChange.document.data ()
        let messageText = data["message"] as? String
        let senderIDNumber = data["senderID"] as? String
        let receiverIDNumber = data["receiverID"] as? String
        let timestamp = data["timestamp"] as? String
        ...

        let chat = Chat (
            messageTextString : messageText!,
            senderIDNumber : senderIDNumber!,
            receiverIDNumber : receiverIDNumber!,
            timeStampString : timestamp!,
            profileImageUrl : profileUrl,
            senderString : sender
        )
        self.chats.append (chat)
        print (self.chats)
        self.collectionView.reloadData ()
    }
  }
}

Подробнее об этом см. в ответ на изменения в документации Firebase.