如何使用带有 Promise 和 forEach 的 Firebase Cloud Functions？

Question

我在这里尝试做两件事。 1) 向所有员工发送通知。 2）将特定的参考复制到 员工 ID 参考。如果不存在特殊参考，我将复制一般参考。 该程序运行没有错误。事实上它的完美。但有时我会收到通知代码部分的超时错误。

错误：fcm.googleapis.com 网络超时。请再试一次。

将一个引用复制到另一个引用的代码始终有效，从未在那里收到错误。 我觉得这个错误是由于没有正确处理 forEach 的承诺。你能帮我让这段代码完美地执行，并正确放置 Promise 吗？

exports.myFunc = functions.https.onRequest( (request, response) => {

admin.database().ref('/Employees').once('value').then(function(snap) {
    snap.forEach(function (snapshot) {
        var obj = snapshot.val();

        if(obj.department){//only go ahead if dept is present
            console.log(' : ' + obj.department);
            var id, tkid, dept;
            id = obj.empId; tkid = obj.tokenId; dept = obj.department;

            var welcomeStr="hello! Welcom to our Department";

            //================================================================notifications
            var payload = {
                data: {
                  greeting: welcomeStr,
                  to_who: id
                }
              };
                    admin.messaging().sendToDevice(tkid,payload)
                    .then(function(response){
                        console.log("Successfully sent message: ", response);
                    })
                    .catch(function(error){
                            console.log("Error sending message: ", error);
                    })
            //===================================================Ref copying

            var destinationRef = admin.database().ref('/Employees/' + id);//final destination
            var option2Ref = admin.database().ref('/Company/General');//when special doesnt exist
            var option1Ref = admin.database().ref('/Company/Special');//if special exists

            option1.once('value', function(snapshot1){
                if (snapshot1.exists()){//copy from straing from option11 to Employees/id
                    option1.once('value', function(snap)  {
                        destinationRef.set( snap.val(), function(error) {
                            if( error && typeof(console) !== 'undefined' && console.error ) {  console.error(error); }

                            console.log('DONE ....  ' + id);
                        });
                    });
                }

                else{//we need to copy from option2 to Employees/id
                    option2Ref.once('value', function(snap)  {
                        newRef.set( snap.val(), function(error) {
                            if( error && typeof(console) !== 'undefined' && console.error ) {  console.error(error); }

                            console.log('DONE .... ' + id);
                        });
                    });
                }

            });
        }
        else{
            console.log('No Department: ' + obj.dept);
            return;
        }
    });

 });


response.send("WOKAY!");
});

Answer 1

为@ChaseMoskal 答案添加一个非常重要的步骤。 对于将 TypeScript 与 Firebase 一起使用的用户，由于 Firebase 服务器未在 NodeJs 中运行 v8+，因此您很有可能会收到此错误：

“TypeError：snapshots.map is not a function”……就行了：await Promise.all(snapshots.map(handleSnapshot))。

这在您的 tsconfig.json 中可能是 "lib": ["es6"]。在这种情况下，只需将这个小 sn-p 添加到接受的答案中，即可将 Firebase Datasnapshot 放入可与 .map(...) 一起使用的数组中

加长版：

exports.myFunc = functions.https.onRequest(async(request, response) => {
const snapshots = await admin.database().ref('/Employees').once('value')

    var data_snap_arr = [];
        snapshots.forEach(function(child_Snapshot) {
            var stuff = child_Snapshot.val();
            stuff.key = child_Snapshot.key;
            data_snap_arr.push(stuff);

await Promise.all(data_snap_arr.map(handleSnapshot))
response.send("WOKAY!")
})

短版：

exports.myFunc = functions.https.onRequest(async(request, response) => {
const snapshots = await admin.database().ref('/Employees').once('value')

   let data_snap_arr = Object.keys(snapshots.val() || {}) .map(k => snapshots.val()[k]);

await Promise.all(data_snap_arr.map(handleSnapshot))
response.send("WOKAY!")
})

Answer 2

在这里我重写了你的代码，希望能清理复杂的承诺链

dropped promises 是最常见和最难调试的问题之一，我已经看到了我的公平份额

对代码的重要更改：

1. 现代 async 语法

   • 让 promise 组织起来更简洁

2. 使用Promise.all 而不是forEach

   • 这样每一个承诺都在等待而不会被遗忘
   • （希望）所有的承诺都正确返回
   • 所有快照操作都是同时运行的，onRequest 处理程序应该等到它们全部完成后再终止

3. 对once 和set 使用承诺而不是回调

   • 我不太确定这些是什么库
   • 他们似乎接受了基于承诺的用法
   • 所以我消除了回调的使用以支持承诺

4. 请查看 TODO 标记

   • 不太确定 else 块的用途，所以一定要修补它

---

async function handleSnapshot(snapshot) {
  const {empId, tokenId, department} = snapshot.val()

  // only go ahead if dept is present
  if (!department) throw new Error("no department")
  console.log("department:", department)

  //================================================================notifications
  const payload = {
    data: {
      greeting: "Hello! Welcome to our Department",
      to_who: empId
    }
  }
  const response = await admin.messaging().sendToDevice(tokenId, payload)
  console.log("successfully sent message", response)
  //===================================================Ref copying

  const destinationRef = admin.database().ref('/Employees/' + empId) // final destination
  const option2Ref = admin.database().ref('/Company/General') // when special doesnt exist
  const option1Ref = admin.database().ref('/Company/Special') // if special exists

  const snapshot1 = await option1Ref.once("value")

  // copy from string from option1 to Employees/id
  if (snapshot1.exists()) { 
    await destinationRef.set(snapshot1.val())
    console.log("DONE1...", empId)
  }

  // TODO review this block
  // we need to copy from option2 to Employees/id
  else {
    const snapshot2 = await option2Ref.once("value")
    await destinationRef.set(snapshot2.val())
    console.log("DONE2...", empId)
  }
}

exports.myFunc = functions.https.onRequest(async(request, response) => {
  const snapshots = await admin.database().ref('/Employees').once('value')
  await Promise.all(snapshots.map(handleSnapshot))
  response.send("WOKAY!")
})