CloudFunctions：请求发送两次

Question

我有一个问题，我需要帮助，因为我正在学习。

我有一个保存 Firebase/Firestore 数据的颤振应用，当用户请求友谊时，我将其添加到发件人和目标用户，更改 sendTo 和 sendBy 的 ID。

我的问题是 CloudFunctions 很好地检测到来自不同用户的 2 个集合已更改并通知我 2x（目标用户）。所以代码很好，但应该只通知一次/目标用户

我正在使用 FCM 发送本地通知。

exports.sendRequestNotification = functions.firestore
  .document('users/{userId}/requests/{requestId}')
  .onCreate((snap, context) => {

    const docReq = snap.data()
    /*console.log(docReq)*/

    const sentBy = docReq.sentBy
    const sentTo = docReq.sentTo
    const contentRequest = docReq.code

    if(contentRequest !== null){
        // Get push token user to (receive)
        admin
          .firestore()
          .collection('users')
          .where('userId', '==', sentTo)
          .get()
          .then(querySnapshot => {
            querySnapshot.forEach(userTo => {
              /*console.log(`Found request user to: ${userTo.data().userId}`)*/
              if (userTo.data().pushToken) {
                // Get info user from (sent)
                admin
                  .firestore()
                  .collection('users')
                  .where('userId', '==', sentBy)
                  .get()
                  .then(querySnapshot2 => {
                    querySnapshot2.forEach(userFrom => {
                      /*console.log(`Found request user from: ${userFrom.data().userId}`)*/
                      const payload = {
                        notification: {
                          title: `${userFrom.data().nickname}`,
                          body: contentRequest,
                          badge: '1',
                          sound: 'default'
                        }
                      }
                      // Let push to the target device
                      admin
                        .messaging()
                        .sendToDevice(userTo.data().pushToken, payload)
                        .then(response => {
                          /*console.log('Successfully sent request:', response)*/
                        })
                        .catch(error => {
                          console.log('Error sending request:', error)
                        })
                    })
                  })
              } else {
                console.log('User request or token not found')
              }
            })
          })
        return null
    }
  })

Answer 1

从您的代码中不太清楚为什么它会发送两次通知（因为您检查了userTo.data().userId !== sentBy）。但可以肯定的是，当所有异步操作（get() 和 sendToDevice()）完成时，您不会返回一个解决的 Promise。

我建议你观看官方视频系列 (https://firebase.google.com/docs/functions/video-series/)，它很好地解释了关于为后台函数返回 Promise 的这一点（尤其是标题为“Learn JavaScript Promises”的那些）。

特别是，您会在视频中看到，如果您不返回 Promise，Cloud Function 可能会在异步操作完成之前终止，从而可能导致一些不一致（不合逻辑）的结果。

因此，您应该尝试使用以下改编后的代码，该代码返回承诺链：

exports.sendRequestNotification = functions.firestore
    .document('users/{userId}/requests/{requestId}')
    .onCreate((snap, context) => {

        const db = admin.firestore();

        const docReq = snap.data();
        /*console.log(docReq)*/

        const sentBy = docReq.sentBy;
        const sentTo = docReq.sentTo;

        // Get push token user to (receive)
        return db.collection('users')
            .where('userId', '==', sentTo)
            .get()
            .then(querySnapshot => {

                //We know there is only one document (i.e. one user with this Id), so lets use the docs property
                //See https://firebase.google.com/docs/reference/js/firebase.firestore.QuerySnapshot.html#docs

                const userTo = querySnapshot.docs[0];

                if (userTo.data().pushToken && userTo.data().userId !== sentBy) {
                    // Get info user from (sent)
                    return db.collection('users')
                        .where('userId', '==', sentBy)
                        .get();

                } else {
                    console.log('User request or token not found')
                    throw new Error('User request or token not found');

                }

            })
            .then(querySnapshot => {

                const userFrom = querySnapshot.docs[0];

                const payload = {
                    notification: {
                        title: `${userFrom.data().nickname}`,
                        body: `requestNotify`,
                        badge: '1',
                        sound: 'default'
                    }
                }

                return admin
                    .messaging()
                    .sendToDevice(userTo.data().pushToken, payload);
            })
            .catch(error => {
                console.log('Error:', error);
                return false;
            })

    })