Node.js Firebase Functions中Async Promise顺序执行问题求助

我明白你现在的困扰——要保证先拿到UID再查询在线状态，但异步操作的顺序总是没按预期来。咱们一步步来修复这个问题：

原代码的核心问题 #

1. getUserID的catch块里写错了变量名（应该返回error而不是err），会导致未定义错误。
2. 在pushNotifications的Promise链中，第一个then里调用getUserStatus(uid)但没有返回它，所以后续的then拿不到状态结果，链式调用直接断了。
3. 你直接console.log(statusOnline)的时候，异步操作还没完成，所以打印的是Promise对象而不是最终的状态值。

修正后的Promise链式调用版本 #

function getUserStatus(uid) {
  let onlineStatus = true;
  console.log('getting the status.........', uid);
  return firestoreDB.collection('userstatus').doc(uid).get()
    .then(doc => {
      if (doc.exists) {
        onlineStatus = doc.data()['online'];
      }
      return onlineStatus;
    })
    .catch(err => {
      console.error('Error getting user status:', err);
      return false; // 出错时返回默认状态，可根据需求调整
    });
}

function getUserID(toId) {
  console.log('get uid function....');
  return admin.auth().getUserByEmail(toId)
    .then((userRecord) => {
      console.log('record :', userRecord);
      const uid = userRecord.uid;
      console.log('uid :', uid);
      return uid;
    })
    .catch((error) => {
      console.log("Error fetching getUserID :", error);
      return null; // 出错时返回null，后续可判断处理
    });
}

exports.pushNotifications = functions.database.ref('/Messages/{messageID}').onWrite(event => {
  console.log('event Data : ', event.after._data);
  const data = event.after._data;
  const fromId = data.from;
  const toId = data.to;
  const message = data.messageText;

  console.log(`${fromId} sent a message to ${toId}`);

  return getUserID(toId)
    .then(uid => {
      if (!uid) {
        throw new Error('Failed to get user ID');
      }
      console.log('got uid', uid);
      // 关键：返回getUserStatus的Promise，让链式调用等待它完成
      return getUserStatus(uid);
    })
    .then(status => {
      console.log('statusOnline : ', status);
      // 这里可以添加推送通知的逻辑，比如根据status判断是否发送
      return status;
    })
    .catch(err => {
      console.error('Error executing the promises', err.message);
      return null;
    });
});

更简洁的async/await版本 #

如果你觉得Promise链式调用有点绕，用async/await会更直观，代码可读性更高：

function getUserStatus(uid) {
  let onlineStatus = true;
  console.log('getting the status.........', uid);
  return firestoreDB.collection('userstatus').doc(uid).get()
    .then(doc => {
      if (doc.exists) {
        onlineStatus = doc.data()['online'];
      }
      return onlineStatus;
    })
    .catch(err => {
      console.error('Error getting user status:', err);
      return false;
    });
}

function getUserID(toId) {
  console.log('get uid function....');
  return admin.auth().getUserByEmail(toId)
    .then((userRecord) => {
      console.log('record :', userRecord);
      return userRecord.uid;
    })
    .catch((error) => {
      console.log("Error fetching getUserID :", error);
      return null;
    });
}

exports.pushNotifications = functions.database.ref('/Messages/{messageID}').onWrite(async (event) => {
  console.log('event Data : ', event.after._data);
  const data = event.after._data;
  const fromId = data.from;
  const toId = data.to;
  const message = data.messageText;

  console.log(`${fromId} sent a message to ${toId}`);

  try {
    // 先等待获取UID
    const uid = await getUserID(toId);
    if (!uid) {
      throw new Error('Failed to get user ID');
    }
    console.log('got uid', uid);
    
    // 再等待获取在线状态
    const statusOnline = await getUserStatus(uid);
    console.log('statusOnline : ', statusOnline);
    
    // 这里添加推送通知的逻辑
    return statusOnline;
  } catch (err) {
    console.error('Error executing the promises', err.message);
    return null;
  }
});

关键修改点说明 #

• 确保每个异步函数都返回Promise：getUserID和getUserStatus本身已经返回Promise了，这是链式调用的基础。
• 在Promise链中返回后续异步操作：第一个then里必须return getUserStatus(uid)，这样Promise链才会等待这个操作完成，把结果传递给下一个then。
• 用async/await简化异步流程：把函数标记为async，然后用await等待每个异步操作完成，代码逻辑和同步代码几乎一致，更易维护。
• 错误处理：在catch块里明确处理错误，避免未捕获的Promise异常导致Functions部署出错。

内容的提问来源于stack exchange，提问作者D Madhu Kiran Raju