对如何在 http Firebase Cloud Function 中正确使用 promises 感到困惑

Question

我不熟悉将 Firebase 的云功能与 http 触发功能结合使用，我对如何正确终止该功能感到困惑。我不确定我是否应该使用 res.sendStatus、返回承诺，或两者兼而有之。

我的函数的目标是遍历集合 'communities' 中的几个文档。每个 community 都有一个文档集合，我在其中查询具有最高值 'hotScore' 的文档。然后，我将包含该文档的 iOS 推送通知发送到一个主题（该给定社区中的所有用户）。

不幸的是，当代码为运行（例如 Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client 和 Unhandled rejection 时，我遇到了几个错误。我很喜欢这是由于我在处理函数终止方面的疏忽，尽管我对到目前为止看过的在线资源感到困惑。有人介意朝正确的方向看看我的 code/pointing 我吗？非常感谢！

exports.sendNotificationTrendingPost = functions.https.onRequest(async (req, res) => {
  //Get communities collection from Firestore
  return admin.firestore().collection('communities').get().then((communities) => {
    var communityPromises = [];
    //Loop through each community
    communities.forEach((community) => {
      let communityID = community.get('communityID');
      let communityName = community.get('name');
      //Get the post with the highest hotScore
      let communityPromise = admin.firestore().collection('communities').doc(communityID).collection('posts').orderBy('hotScore', 'desc').limit(1).get().then((posts) => {
        let hottestPost = posts[0];
        let postID = hottestPost.get('postID');
        let postText = hottestPost.get('text');
        let currentDate = Date.now() / 1000;
        var message;
        //Verify that the hottest post was posted in the past 24 hours
        if (hottestPost.get('date') > (currentDate - 86400)) {
          //Build the notification text (shortening if too long)
          let shortenedPostText = postText.substring(0,60);
          var textEnd = '';
          if (postText.length > 60) {
            textEnd = '...';
          }
          let notificationText = 'Trending post on ' + communityName + ': ' + shortenedPostText + textEnd;
          //Build the push notification
          message = {
            apns: {
              headers: {
                'apns-push-type': 'alert'
              },
              payload: {
                aps: {
                  alert: {
                    body: notificationText,
                  },
                },
                postID: postID,
              },
            },
            topic: communityID
          }
        }
        //Send the message and return the promise
        if (message === null) {
          return null;
        } else {
          return admin.messaging().send(message);
        }
      })
      .catch(error => {
        console.log(error);
        res.status(500).send(error);
      })
      if (communityPromise !== null) {
        communityPromises.push(communityPromise);
      }
    })
    res.sendStatus(200);
    return Promise.all(communityPromises);
  })
  .catch(error => {
    console.log(error);
    res.status(500).send(error);
  })
})

Answer 1

正如 samthecodingman 所建议的，在您的情况下使用 async/await 会更好，因为它会简化代码并使其更易于阅读。

以下更改应该可以解决问题（未经测试）。请注意我们如何使用社区名称数组来将名称从一个循环传递到另一个循环。这是有效的，因为对于 Promise.all()，返回值按照通过的承诺的顺序排列，而不管完成顺序如何。

exports.sendNotificationTrendingPost = functions.https.onRequest(async (req, res) => {

    try {

        const db = admin.firestore();

        const communitiesQuerySnap = await db.collection('communities').get();

        const communityPromises = [];
        const communityNames = [];

        communitiesQuerySnap.forEach((community) => {
            let communityID = community.get('communityID');
            let communityName = community.get('name');
            communityNames.push(communityName);
            communityPromises.push(db.collection('communities').doc(communityID).collection('posts').orderBy('hotScore', 'desc').limit(1).get())
        });

        const postsQuerySnapArray = await Promise.all(communityPromises);

        const messagePromises = [];
        postsQuerySnapArray.forEach((postsQuerySnap, index) => {
            const hottestPost = postsQuerySnap.docs[0];
            const postID = hottestPost.get('postID');
            const postText = hottestPost.get('text');
            const currentDate = Date.now() / 1000;
            let message;

            if (hottestPost.get('date') > (currentDate - 86400)) {
                //Build the notification text (shortening if too long)
                let shortenedPostText = postText.substring(0, 60);
                var textEnd = '';
                if (postText.length > 60) {
                    textEnd = '...';
                }

                const communityName = communityNames[index];  // The two Arrays postsQuerySnapArray and communityName have the same order, because Promise.all keeps the order.

                let notificationText = 'Trending post on ' + communityName + ': ' + shortenedPostText + textEnd;
                //Build the push notification
                message = {
                    apns: {
                        headers: {
                            'apns-push-type': 'alert'
                        },
                        payload: {
                            aps: {
                                alert: {
                                    body: notificationText,
                                },
                            },
                            postID: postID,
                        },
                    },
                    topic: communityID
                }
                messagePromises.push(admin.messaging().send(message));
            }
        })

        await Promise.all(messagePromises);
        res.status(200).send({ result: "completed" }); // Or res.end()

    } catch (error) {
        console.log(error);
        res.status(500).send(error);
    }

});

对如何在 http Firebase Cloud Function 中正确使用 promises 感到困惑

Confused on how to properly use promises in http Firebase Cloud Function

node.js

firebase

google-cloud-functions

firebase-cloud-messaging