即使在所有地方返回后也"Function returned undefined, expected Promise or value"错误

Question

我是 Node 的新手.js即使在阅读了其他 stackflow 用户提供的教程后，我也在努力应对 Promises。我已经为此度过了一整个晚上，我正在寻求帮助。我收到以下错误" 函数返回未定义，预期的承诺或值"。我的代码如下。我做错了什么？我也怀疑我必须使用 await/async，因为看起来我的代码在没有等待第一次完成的情况下正在运行。

const admin = require('firebase-admin');
const functions = require('firebase-functions');
var db = admin.firestore();
exports.declinedRequest = functions.firestore
.document('requests/{requestId}')
.onUpdate((change, context) => {
  const newValue = change.after.data();
  const status = newValue.status;
  const request = context.params.requestId;
  var registrationToken;
  var message;
  if(status=="created") {
    console.log('Checkpoint1 ',context.params.requestId);
    newValue.friends.forEach(doc => {
      console.log('Checkpoint 2: ', doc);
      var usersRef = db.collection('users');
      var query = usersRef.where('mobile', '==', doc).get()
        .then(snapshotFriend => {
          if (snapshotFriend.empty) {
            console.log('Checkpoint3.');
            return;
          }  
        snapshotFriend.forEach(mobile => {
        registrationToken = mobile.data().fcmToken;
        console.log('FCM token =>', registrationToken);
        if (!registrationToken) {
          console.log('No fcmToken available');
          return;
        }  
         message = {
          notification: {
            body: "Request still available from " + newValue.requesterName,
            sound: "default", 
            badge: 1
            },
          data: {
            requestId: `${request}`
          }
        };
        console.log('FCM token message created');
        }) 
      })
    })
  } else {
    return;
  }
 return admin.messaging().sendToDevice(registrationToken, message)
      .then(function (response) {
        console.log("Successfully sent message:", response)
     })
      .catch(function (error) {
        console.log("Error sending message:", error);
     }) 
})

Answer 1

尝试下面的代码，希望这会起作用。

    const admin = require('firebase-admin');
    const functions = require('firebase-functions');
    const Promise = require('bluebird');
    const _ = require('lodash');
    let db = admin.firestore();
    exports.declinedRequest = functions.firestore
    .document('requests/{requestId}')
    .onUpdate((change, context) => {
        const newValue = change.after.data();
        const status = newValue.status;
        const request = context.params.requestId;
        if (status == "created") {
            console.log('Checkpoint1 ', context.params.requestId);
            allPromises = [];
            newValue.friends.forEach(doc => {
                console.log('Checkpoint 2: ', doc);
                const usersRef = db.collection('users');
                // query for each document return promise.
                allPromises.push(queryForEachDocument(doc,request,usersRef));
            });
            return Promise.all(allPromises);
        } else {
            return Promise.reject / resolve('Whatever you want.');
        }
    })
    function queryForEachDocument(doc,request,usersRef) {
    let promiseInvoices = []
    let registrationToken;
    let message;
    return usersRef.where('mobile', '==', doc).get().then((snapshotFriend) => {
        if (_.isEmpty(snapshotFriend)) {
            console.log('Checkpoint3.');
            return Promise.reject(new Error('Your error'));
        }
        snapshotFriend.forEach(mobile => {
            registrationToken = mobile.data().fcmToken;
            console.log('FCM token =>', registrationToken);
            if (!registrationToken) {
                console.log('No fcmToken available for', newValue.requesterName);
                // Do anything you want to change here.
                return Promise.reject(new Error('No fcmToken available for',newValue.requesterName));
            }
            message = {
                notification: {
                    body: "Request still available from " + newValue.requesterName,
                    sound: "default",
                    badge: 1
                },
                data: {
                    requestId: request
                }
            };
            console.log('FCM token message created');
            // send invoice for each registrationToken
            promiseInvoices.push(sendInvoice(registrationToken, message))
        });
    }).then(() => {
        return Promise.all(promiseInvoices);
    })
    }
    function sendInvoice(registrationToken, message) {
    return admin.messaging().sendToDevice(registrationToken, message)
        .then(function (response) {
            console.log("Successfully sent message:", response)
        })
        .catch(function (error) {
            console.log("Error sending message:", error);
        })
    }