如何在出现错误时中止 Firestore 事务

Mas*_*low 4 transactions promise firebase google-cloud-firestore

runTransaction在 https Cloud 函数(运行 Express)中使用 Firestore方法。我想要的是确保如果任何读取或写入失败,其他事务读取或写入将不会运行或在需要时回滚。

交易

admin.firestore().runTransaction(async (t) => {
  const { uid, artworkUid, tagLabel } = req.body;

  if (!tagLabel) {
    return Promise.reject('Missing parameters: "tagLabel"');
  }

  if (!artworkUid) {
    return Promise.reject('Missing parameters: "artworkUid"');
  }

  if (tagLabel.length < 3) {
    return Promise.reject('The tag must be at least 3 characters long');
  }

  const [ user, artwork ] = await Promise.all([
    getUser(uid),
    getArtwork(artworkUid)
  ]);

  return Promise.all([
    addArtworkTag({
      artwork,
      tagLabel,
      proposer: user
    }, t),
    giveXpFor({
      user,
      action: 'add-artwork-tags',
      type: user.can('add-artwork-tags') ? 'effective' : 'temporary'
    }, t)
  ])
})
.catch(err => res.status(403).send(err))
.then(() => res.status(200).send());
Run Code Online (Sandbox Code Playgroud)

如您所见,addArtworkTaggiveXpFor函数采用tin 参数。

添加艺术品标签

export const addArtworkTag = function(params: { artwork: any, tagLabel: string, proposer: ShadraUser }, t?: FirebaseFirestore.Transaction): Promise<any> {
  const { artwork, tagLabel, proposer } = params;

  if (!artwork || !proposer || typeof tagLabel !== 'string') {
    return Promise.reject('Can\'t add the tag. Bad/missing datas');
  }

  const tag = <any>{
    slug: slugify(tagLabel),
    label: tagLabel,
    status: proposer.can('add-artwork-tags') ? 'validated' : 'proposed',
    proposerUid: proposer.uid
  };

  const tags = artwork.tags || [];
  tags.push(tag);

  const artworkRef = admin.firestore().doc(`artworks/${artwork.uid}`);

  t.set(artworkRef, { tags }, { merge: true });
  return Promise.resolve();
}
Run Code Online (Sandbox Code Playgroud)

我的问题是:如果addArtworkTag函数失败(例如因为参数错误),我如何中止(甚至回滚)事务,所以giveXpFor不会被调用

非常感谢

PS:我认为我误用了事务......我应该做的可能只是使用顺序承诺而不是 Promise.all ,对吧?

Dou*_*son 9

runTransactionAPI 文档指出:

如果事务成功完成或被显式中止(通过 updateFunction 返回失败的 Promise),则 updateFunction 返回的 Promise 将在此处返回。否则,如果交易失败,将返回带有相应失败错误的被拒绝 Promise。

如果交易失败,您所要做的就是返回一个被拒绝的承诺。您在该事务中做了什么并不重要 - 所有这些都将被回滚。