我返回一笔交易承诺,它应该在停止函数之前等待交易完成。交易执行得很好,但这个承诺似乎永远不会解决。
我在Firebase控制台中看到,这个函数总是在60秒后超时。
const functions = require('firebase-functions');
const admin = require("firebase-admin");
const db = admin.database();
export let countFollowers = functions.database.ref('followers/{followee}/{follower}').onWrite(event => {
const followee = event.params.followee;
let path = `posts/${followee}/cnt_foll`;
const countRef = db.ref(path);
let out = countRef.transaction(current => {
if (event.data.exists() && !event.data.previous.exists()) {
return (parseInt(current) || 0) + 1;
} else if (!event.data.exists() && event.data.previous.exists()) {
return (parseInt(current) || 0) - 1;
}
});
return out;
});
编辑:
我用以下的“hack”解决了这个问题,我自己创建了一个 Promise,因为无论.transaction
返回什么都不起作用:
return new Promise(function(resolve, reject) {
countRef.transaction(current => {
if (event.data.exists() && !event.data.previous.exists()) {
return (parseInt(current) || 0) + 1;
} else if (!event.data.exists() && event.data.previous.exists()) {
return (parseInt(current) || 0) - 1;
}
}, () => resolve(null));
});
firebase
库本身的问题。 - Michał Pietraszkothen
,它会起作用。例如countRef.transaction(current => { .. }).then(() => { console.log("Transaction finished") })
。 - Christian