Firebase Cloud Functions遍历Firestore字段并发送FCM通知问题求助

我有一个名为“chats”的Firestore文档，字段以字符串为键、时间戳为值。希望在该文档变更时，通过Firebase Cloud Functions遍历所有字段，将键和值存入数组，再提取特定值通过Firebase Messaging发送通知，但尝试多种写法都没成功。

原代码片段 #

class FieldLoad {
  constructor(timestamp, userUID) {
    this.timestamp = timestamp;
    this.userUID = userUID;
  }
}

const {onDocumentUpdated} = require("firebase-functions/v2/firestore");
// The Firebase Admin SDK to access Firestore.
const {initializeApp} = require("firebase-admin/app");
const admin = require("firebase-admin");
initializeApp();

// ON DOCUMENT CHANGE FUNCTION
exports.messagesNotification = onDocumentUpdated(
    "collection_A/document_A/{collection_B}/chats",
    (change, context) => {
      const afterData = change.after.data();
      const loadArray = [];
      for (const field in afterData) {
        if (Object.prototype.hasOwnProperty.call(afterData, field)) {
          const fieldValue = afterData[field];
          const fieldLoadInstance = new FieldLoad(fieldValue.timestamp, field);
          loadArray.push(fieldLoadInstance);
        }
      }
      const notificationBody =
      loadArray.length > 0 ? loadArray[0].userUID : "No data available";
      const message = {
        notification: {
          title: "Notification Title",
          body: notificationBody,
        },
        token: "<device-token>",
      };
      admin.messaging()
          .send(message)
          .then((response) => {
            console.log("Notification sent successfully:", response);
            return null;
          })
          .catch((error) => {
            console.error("Error sending notification:", error);
            return null;
          });
    });

问题分析与修复方案 #

原代码存在核心问题：未正确处理异步操作、Firestore时间戳对象处理不当、未按时间戳排序取最新数据、缺少数据校验。以下是修复后的代码：

class FieldLoad {
  constructor(timestamp, userUID) {
    // 将Firestore Timestamp转为毫秒数，避免序列化问题
    this.timestamp = timestamp instanceof admin.firestore.Timestamp ? timestamp.toMillis() : timestamp;
    this.userUID = userUID;
  }
}

const { onDocumentUpdated } = require("firebase-functions/v2/firestore");
const { initializeApp } = require("firebase-admin/app");
const admin = require("firebase-admin");
initializeApp();

exports.messagesNotification = onDocumentUpdated(
  "collection_A/document_A/{collection_B}/chats",
  async (change, context) => {
    const afterData = change.after.data();
    if (!afterData) {
      console.log("文档无数据，跳过处理");
      return null;
    }

    const loadArray = [];
    for (const field in afterData) {
      if (Object.prototype.hasOwnProperty.call(afterData, field)) {
        const fieldValue = afterData[field];
        // 校验字段值为Firestore Timestamp类型
        if (fieldValue instanceof admin.firestore.Timestamp) {
          const fieldLoadInstance = new FieldLoad(fieldValue, field);
          loadArray.push(fieldLoadInstance);
        } else {
          console.warn(`字段${field}的值不是Timestamp类型，跳过`);
        }
      }
    }

    if (loadArray.length === 0) {
      console.log("没有有效字段数据");
      return null;
    }

    // 按时间戳降序排序，获取最新的用户UID
    loadArray.sort((a, b) => b.timestamp - a.timestamp);
    const latestUserUID = loadArray[0].userUID;

    const message = {
      notification: {
        title: "新消息通知",
        body: `用户${latestUserUID}发送了消息`,
      },
      token: "<替换为目标设备令牌>", // 建议从用户文档或数据库动态获取
    };

    try {
      const response = await admin.messaging().send(message);
      console.log("通知发送成功:", response);
      return null;
    } catch (error) {
      console.error("发送通知失败:", error);
      return null;
    }
  }
);

关键修复点 #

• 异步操作处理：将函数改为async并使用await等待FCM发送完成，避免Cloud Functions提前终止任务。
• 时间戳处理：将Firestore原生Timestamp对象转为毫秒数，避免直接存储对象导致的序列化或取值异常。
• 数据校验：增加字段值类型校验，确保只处理合法的时间戳字段，过滤无效数据。
• 排序逻辑：对数组按时间戳降序排序，确保提取的是最新变更对应的用户UID。
• 代码可读性优化：用try/catch替代链式then/catch，简化异步错误处理逻辑。

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