firebase 交易，您必须返回一个承诺

Question

我试图弄清楚如何从 Angular 6 / typescript 应用程序将事务写入 firebase 数据库。

我用作指导的一个工作示例如下：

const transactions = [];

return db.runTransaction(function(transaction) {
            // const promises = [];
            descriptionsInDB.forEach(dbDescription => {
                if (dbDescription.matched === false) {
                    // item wasn't found, so add the item to the transaction.
                    const phraseItem: PhrasesDB = {
                        query: dbDescription.description,
                        updatedAt: Date.now(),
                        createdAt: Date.now(),
                        workflows: {
                            [workflowId]: true
                        }
                    };
                    const newPhrasesRef = phrasesCol.doc();
                    transactions.push(transaction.set(newPhrasesRef, phraseItem));
                } else {
                    if (dbDescription.data.workflows && dbDescription.data.workflows[workflowId]) {
                        // do nothing, this phrase is already part of the record.
                    } else { // update the workflows that are part of the record.
                        const workflows = { 
                            workflows: {
                                [workflowId]: true
                            }
                         };
                        const phrasesRef = phrasesCol.doc(dbDescription.dbId);
                        transactions.push(transaction.update(phrasesRef, workflows));
                    }
                }
            });

            return Promise.all(transactions); 
        })

我确定的关键部分如下：

1) 创建一个数组来保存您的交易： const transactions = [];

2) 开始事务：return db.runTransactions(function(transaction) {…

3) 使用事务执行数据库查询：transaction.set(newPhraseRef,phraseItem);

4) 将查询返回的交易推送到交易数组：transactions.push(transaction.set(newPhraseRef,phraseItem));

5) 返回一个带有事务数组的承诺：return Promise.all(transaction);

如果我有这个权利，那么我应该能够将这个公式应用于我正在尝试编写的事务，并且它应该可以工作：

        const pendingRef = `Pending/${req.query.inviteId}`;
        const acceptance = {
          'cryptoInvitationAcceptance': req.body.cryptoInvitationAcceptance,
          'reason': (req.body.reason !== undefined ? req.body.reason : '')
        }
return db.runTransaction(function(t) {
          const transArray = [];
          const docRef = db.collection('Pending').doc(req.query.inviteId);
          transArray.push(t.set(docRef, acceptance));
          return Promise.all(transArray);
        }).then(result => {
          console.log('result = ', result);
        }).catch(err => {
          console.log('err = ', err);
        });

但它总是进入 catch 块并打印出消息：

err = 错误：你必须在你的 transaction()-callback 中返回一个 Promise。

但我正在回报一个承诺，不是吗？这行：return Promise.all(transArray) 是我要返回的承诺。没有？

Answer 1

事实证明，这是最好的方法：

      return t.get(pendingDocRef).then(data => {
        t.set(pendingDocRef, acceptance, {merge:true});
      });

get(...) 返回它所要求的承诺，因此 set(...) 不必这样做。

我不喜欢这个。我仍然认为我应该能够自己在事务中进行集合（即没有获取）。

我还发现这种 可以工作：

return t.set(...).commit();

commit() 也返回了一个承诺，但是我得到了非常奇怪的行为：事务一遍又一遍地重复自己，直到它进入 catch 块并出现“事务已过期”的错误。尽管如此，数据会被提交到数据库，所以如果你不介意错误（让它通过），commit() 也可以。

详情见此贴：firebase transaction repeating when committing

Answer 2

请阅读Transaction set() 的文档 - 它不会返回承诺。这可能会使 Firestore SDK 感到困惑，因为您返回的 Promise.all() 包含一系列不是承诺的东西。所以它可能认为你返回了一个错误。

您可能根本不需要从事务处理函数返回任何内容。只需致电set() 即可完成。如果您想通过它返回的承诺pass that value out to the caller of runTransaction，您只需要从您的事务处理程序返回一些东西。

顺便说一句，在您的第一个示例中，您不应该将 Promise 收集到在处理函数之外定义的数组中。如果事务处理程序运行不止一次，这可能会导致问题。正如我链接到的文档所说：

请勿在事务函数中修改应用程序状态。 这样做会引入并发问题，因为事务 函数可以运行多次，不保证在 界面线程。

事务之外的数组将被视为“应用程序状态”，因为它不在函数本身内。