新的云功能和承诺。我尝试在不同的位置添加承诺,但仍然在日志中得到消息。第一,我不确定我应该在哪里添加承诺,第二,我是否应该什么也不回。在调用match(如果条件满足,则创建channel)之后,我不需要执行另一个函数。虽然触发onCreate会有多个用户,所以我想确保每次执行一个用户。
const functions = require('firebase-functions');
const admin = require('firebase-admin')
admin.initializeApp();
//every time user added to liveLooking node
exports.command = functions.database
.ref('liveLooking/{uid}')
.onCreate((snap, context) => {
const uid = context.params.uid
match(uid)
})
function match(uid) {
let m1uid, m2uid
admin.database().ref('liveChannels').transaction((data) => {
//if no existing channels then add user to liveChannels
if (data === null) {
console.log(`${uid} waiting for match`)
return { uid: uid }
}
else {
m1uid = data.uid
m2uid = uid
if (m1uid === m2uid) {
console.log(`$m1uid} tried to match with self!`)
//match user with liveChannel user
} else {
console.log(`matched ${m1uid} with ${m2uid}`)
createChannel(m1uid, m2uid)
return null
}
}
},
(error, committed, snapshot) => {
if (error) {
throw error
}
else {
return {
committed: committed,
snapshot: snapshot
}
}
},
false)
}
function createChannel(uid1, uid2) {
// Add channels for each user matched
const channel_id = uid1+uid2
console.log(`starting channel ${channel_id} with uid1: ${uid1}, uid2: ${uid2}`)
const m_state1 = admin.database().ref(`liveUsers/${uid1}`).set({
channel: channel_id
})
const m_state2 = admin.database().ref(`liveUsers/${uid2}`).set({
channel: channel_id
})
}
编辑1-我尝试将事务更改为使用await,这样它将只在事务之后更改UserLife节点。得到这两个警告。1)应在异步函数“match”的末尾返回一个值。2)在***return Arrow函数应返回一个值。如果use与self匹配,我不会尝试在LiveChannels下更改任何内容。不确定如何修复该警告。3)仍然在日志中获得函数返回未定义的、预期的承诺或值--我认为是命令函数。
async function match(uid) {
let m1uid, m2uid;
let createChannel = false
try {
const transactionResult = await admin
.database()
.ref("liveChannels")
.transaction(
(data) => {
if (data === null) {
console.log(`${uid} waiting for match`)
return { uid: uid }
}
else {
m1uid = data.uid
m2uid = uid
if (m1uid === m2uid) {
console.log(`$m1uid} tried to match with self!`)
***return***
} else {
console.log(`matched ${m1uid} with ${m2uid}`)
createChannel = true
return {}
}
}
},
(error, committed, snapshot) => {
if (error) {
throw error
}
else {
return {
committed: committed,
snapshot: snapshot
}
}
},
false
);
if (transactionResult) {
if (createChannel) {
const channel_id = m1uid + m2uid
console.log(`starting channel ${channel_id} with uid1: ${m1uid}, uid2: ${m2uid}`)
const m_state1 = admin.database().ref(`liveUsers/${m1uid}`).set({
channel: channel_id
})
const m_state2 = admin.database().ref(`liveUsers/${m2uid}`).set({
channel: channel_id
})
return Promise.all([m_state1, m_state2])
}
}
} catch (err) {
throw new Error(err);
}
}
您没有正确管理云功能的生命周期。您需要等待所有异步任务(即对Firebase异步方法的调用)完成后,才能向平台指示它可以清理该函数。这应该通过返回一个Promise来完成,更准确地说,因为您链接了几个异步方法调用,所以应该通过返回promises链来完成。
但是,在您的云功能中还有一个问题,即您编写事务
的方式。事务原子化地修改调用事务的位置(即引用
)处的数据。
在代码中,可以在ref('live channels')
上调用事务,但在事务内部,可以修改其他位置的数据:ref(`liveusers/${uid1}`)
和ref(`liveusers/${uid2}`)
。
这不是正确的方法:如果您希望将所有这些操作封装在一个事务中,则需要在包含您希望更改的所有节点/位置的数据库节点上调用事务,即LiveChannels
、LiveUsers/${uid1}
和LiveUsers/${uid2}
的公共父/祖节点。
如果我没有弄错的话,这三个节点的唯一公共父/祖节点是DB根节点。在DB根节点上调用事务可能不是一个好主意,特别是在有很多用户同时使用应用程序的情况下。您可能应该调整您的数据模型(DB结构)来避免这种情况。
还要注意,不是使用Tansaction的oncomplete
回调来处理它的成功和失败,而是应该使用事务返回的Promise以便在Promise链中正确使用它(请参见第一段)。