Firebase onCall函数嵌套Promise返回失败及子集合获取问题求助

我帮你分析下你遇到的问题，然后给你一个能正常工作的实现方案。

核心问题：forEach不支持异步等待 #

你写的三段代码都踩了同一个坑——forEach循环不会等待内部的异步操作完成。当你在forEach里用async/await获取集合文档时，循环本身会直接执行完所有迭代（但里面的异步请求还在后台处理），然后代码就跳到res(cols)或者return cols的步骤，这时候cols数组还没被填充数据，导致返回的结果不符合预期，最终触发了Firebase模糊的Error: internal错误。

逐个看你代码的具体问题 #

1. exports.rs：没必要用new Promise包裹整个逻辑（函数本身已经是async的了），而且forEach的异步操作还没完成就调用了res(cols)，返回的是空数组。
2. exports.requiresServices：同样是forEach的异步操作没等待，直接return了还没填充数据的cols。
3. exports.getRequiredServices：second函数的Promise没有正确resolve，forEach的异步没处理，而且then里的调用逻辑错误（没有把collections传给second函数）。

正确的实现代码 #

用async/await结合map和Promise.all来处理异步操作，确保所有数据都收集完成后再返回：

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();

exports.getRequiredServices = functions.https.onCall(async (data, context) => {
  // 先验证必要参数，避免空引用错误
  if (!data.user_id) {
    throw new functions.https.HttpsError('invalid-argument', 'Missing user_id parameter');
  }

  try {
    const requiredRef = admin.firestore().collection('required_services').doc(data.user_id);
    
    // 获取指定文档下的所有子集合
    const collections = await requiredRef.getCollections();
    
    // 遍历每个子集合，获取所有文档，用map返回Promise数组，再用Promise.all等待全部完成
    const allDocs = await Promise.all(
      collections.map(async (collection) => {
        const snapshot = await collection.get();
        // 将每个文档转换为包含ID和数据的对象，可选添加集合ID标识所属子集合
        return snapshot.docs.map(doc => ({
          collectionId: collection.id,
          id: doc.id,
          data: doc.data()
        }));
      })
    );

    // 把二维数组扁平化（如果需要返回平铺的文档列表），或者直接返回嵌套结构
    const flattenedDocs = allDocs.flat();
    console.log('Successfully fetched all docs:', flattenedDocs);
    return flattenedDocs;
  } catch (error) {
    // 捕获并处理错误，返回明确的错误信息给客户端
    console.error('Error fetching required services:', error);
    throw new functions.https.HttpsError('internal', 'Failed to fetch required services', error.message);
  }
});

为什么这个代码能正常工作？ #

• 用map替代forEach：map会返回每个异步操作的Promise，而Promise.all()会等待所有Promise都执行完成，确保所有子集合的文档都被获取到。
• 明确的错误处理：用try/catch捕获异常，并且抛出Firebase标准的HttpsError，这样客户端能收到清晰的错误原因，而不是模糊的internal错误。
• 逻辑清晰的async/await：避免了嵌套的then回调，代码可读性更高，也更容易追踪异步流程。

内容的提问来源于stack exchange，提问作者Adriel Werlich