Firebase async/await 未从 foreach 循环返回完整结果

Question

我正在努力让它正常工作。我的 nodejs 后端有这个功能

let data = [];
let lists = [];
var userId = request.params.userId;
var coll = db.collection("forms");
var query = coll.where("formUser", "==", userId);
await query.get().then(function (querySnapshot) {
    querySnapshot.forEach(function (doc) {
        var forms = doc.data();
        var listIDs = doc.data().formLists;

        listIDs.forEach(listId => {
            db.collection("lists").where("listId", "==", listId).get().then(function (snapshot) {
                snapshot.forEach(function (d) {
                    lists.push({ "id": d.data().listId, "text": d.data().listName });
                });
            });
        });
        forms.formLists = lists;
        data.push(forms);
    });
});

由于某种原因，第二个循环不只是工作，数据的结果来自第一个循环，如果我将相同的函数放在我的 javascript 前端，我会得到带有 listIDs 结果的完整数据。

有什么想法吗？

Answer 1

添加单个await 并不会突然让其下的所有代码同步运行。在你做的时候，结合await 和then 通常也是一种反模式。我建议您在掌握异步行为之前远离async / await，并坚持使用then 并在此之前明确处理承诺。

如果您共享的代码在 Cloud Functions 中运行，则您需要返回一个在所有异步（读取和写入）操作完成后解析的 promise。由于您有很多这样的操作，您需要将从它们获得的所有承诺捕获到一个数组中，然后使用Promise.all() 作为返回值：

var userId = request.params.userId;
var coll = db.collection("forms");
var query = coll.where("formUser", "==", userId);
return query.get().then(function (querySnapshot) { // ?
    let promises = []; // ?
    querySnapshot.forEach(function (doc) {
        var forms = doc.data();
        var listIDs = doc.data().formLists;

        listIDs.forEach(listId => {
            promises.push(db.collection("lists").where("listId", "==", listId).get()); // ?
        });
    });
    return Promise.all(promises).then(function (snapshot) { // ?
        return snapshot.map((d) => {
            return { "id": d.data().listId, "text": d.data().listName };
        });
    });
});

Answer 2

因此，对于那些在如此复杂的数据结构中苦苦挣扎的人来说，这就是我所做的：

        let data = [];
        let forms = [];
        let lists = [];
        var userId = request.params.userId;
        var coll = db.collection("forms");
        var query = coll.where("formUser", "==", userId);
        await query.get().then(function (querySnapshot) {
            querySnapshot.forEach(function (doc) {
                forms.push(doc.data());
            });
        });

        for (let index = 0; index < forms.length; index++) {
            const element = forms[index];
            var listIDs = element.formLists;
            for (const listId of listIDs) {
                await db.collection("lists").where("listId", "==", listId).get().then(function (snapshot) {
                    snapshot.forEach(function (d) {
                        lists.push({ "id": d.data().listId, "text": d.data().listName });
                    });
                });
            }
            element.formLists = lists;
            data.push(element);
        }
                            
        response.status(200).send(data); // pass your data to UI