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)
如您所见,addArtworkTag和giveXpFor函数采用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 ,对吧?
如果事务成功完成或被显式中止(通过 updateFunction 返回失败的 Promise),则 updateFunction 返回的 Promise 将在此处返回。否则,如果交易失败,将返回带有相应失败错误的被拒绝 Promise。
如果交易失败,您所要做的就是返回一个被拒绝的承诺。您在该事务中做了什么并不重要 - 所有这些都将被回滚。
| 归档时间: |
|
| 查看次数: |
2792 次 |
| 最近记录: |