删除Firestore文档时调用GeoQuery.onSnapshot取消订阅报错求助

核心错误原因 #

1. 云函数的无状态本质 #

Firestore的onWrite云函数每次触发（文档创建/删除）都是独立的执行实例，实例间内存完全隔离。你在文档创建时赋值的listener仅存在于那次触发的内存中，当文档删除触发新实例时，listener还是初始的undefined，调用listener()自然会抛出TypeError: listener is not a function。

2. 对云函数生命周期的误解 #

云函数是短生命周期服务，函数执行完成（返回结果后）会被立即回收，你在创建文档时创建的onSnapshot订阅会随实例销毁自动终止，根本无法长期保持监听。所以删除文档时取消订阅的操作本身没有实际意义。

正确实现方案 #

根据你的需求场景，分两种情况处理：

场景1：仅需在文档创建时执行一次GeoQuery查询 #

如果不需要持续监听GeoQuery的变化，只是在文档创建时执行单次查询，直接将onSnapshot替换为get()即可，无需订阅和取消逻辑：

const test = async (change) => {
  if (!change.before.exists && change.after.exists) {
    // 单次查询，获取结果后处理
    const snapshot = await GeoFirestore.collection(...)
        .where("category", "==", ...)
        .near({ center: ..., radius: ... })
        .get();
    // 处理快照数据逻辑
    snapshot.forEach(doc => {
      // ...
    });
  }

  // 文档删除时无需额外操作
}

场景2：需要持续监听GeoQuery（文档存在期间） #

这种场景不适合用onWrite云函数，因为云函数无法长期运行。推荐使用长期运行服务（如Cloud Run、自建服务器）来管理订阅：

• 启动服务后，监听test集合的文档创建/删除事件；
• 用内存Map存储每个文档ID对应的订阅取消函数；
• 文档创建时，创建GeoQuery订阅并将取消函数存入Map；
• 文档删除时，从Map中取出对应取消函数执行，再删除该条目。

示例伪代码：

// 长期运行服务中的逻辑
const activeSubscriptions = new Map();

// 监听test集合的文档变更
firestore.collection("test").onSnapshot(querySnapshot => {
  querySnapshot.docChanges().forEach(change => {
    const docId = change.doc.id;
    if (change.type === "added") {
      // 创建订阅并存储取消函数
      const unsubscribe = GeoFirestore.collection(...)
          .where("category", "==", ...)
          .near({ center: ..., radius: ... })
          .onSnapshot(snapshot => {
            // 处理实时快照逻辑
          });
      activeSubscriptions.set(docId, unsubscribe);
    } else if (change.type === "removed") {
      // 取消订阅并移除记录
      const unsubscribe = activeSubscriptions.get(docId);
      if (unsubscribe) {
        unsubscribe();
        activeSubscriptions.delete(docId);
      }
    }
  });
});

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