Firebase onSnapshot监听added类型返回已有集合问题求助

Firestore的onSnapshot默认首次触发时会返回集合内所有文档，这是设计特性。要实现仅监听重启后新增的文档，有两种可靠方案：

方案一：基于时间戳过滤（推荐） #

给每个orders文档添加一个createdAt字段，存储文档创建时的服务器时间戳。监听时只查询当前启动时间之后创建的文档：

const { getFirestore, serverTimestamp } = require("firebase/firestore");

const db = getFirestore();
// 记录当前启动时间，作为过滤起点
const startTime = serverTimestamp();

const observer = db.collection("orders")
  .where("createdAt", ">", startTime)
  .onSnapshot((querySnapshot) => {
    querySnapshot.docChanges().forEach((change) => {
      if (change.type === "added") {
        console.log("新增文档:", change.doc.data());
      }
    });
  });

注意：需要确保所有新创建的orders文档都正确设置createdAt字段，比如创建时：

db.collection("orders").add({
  // 其他业务字段
  createdAt: serverTimestamp()
});

方案二：记录最后处理位置 #

如果无法修改文档结构，可以在本地（比如文件）或数据库中记录最后处理的文档ID/时间戳，重启后从该位置开始监听：

const { getFirestore, query, orderBy, startAfter } = require("firebase/firestore");
const fs = require("fs");
const LAST_PROCESSED_PATH = "./last-processed.txt";

const db = getFirestore();

// 读取上次记录的最后文档ID
let lastDocId = null;
try {
  lastDocId = fs.readFileSync(LAST_PROCESSED_PATH, "utf8");
} catch (e) {}

// 构建查询：按文档ID排序，从上次最后一个文档之后开始
let ordersQuery = db.collection("orders").orderBy("__name__");
if (lastDocId) {
  const lastDoc = await db.collection("orders").doc(lastDocId).get();
  ordersQuery = query(ordersQuery, startAfter(lastDoc));
}

const observer = ordersQuery.onSnapshot((querySnapshot) => {
  querySnapshot.docChanges().forEach((change) => {
    if (change.type === "added") {
      console.log("新增文档:", change.doc.data());
      // 更新本地记录的最后文档ID
      fs.writeFileSync(LAST_PROCESSED_PATH, change.doc.id);
    }
  });
});

这种方案需要处理本地文件的读写异常，适合无法修改文档结构的场景，但可靠性略低于时间戳方案。

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