Firebase 10.4.0删除id等于userId的文档报错求助

问题背景 #

使用Firebase ^10.4.0，需要删除messages集合中所有id字段等于指定userId的文档，但触发错误：FIRESTORE (10.4.0) INTERNAL ASSERTION FAILED: Unexpected state。其中createMessage和getMessages方法可正常工作，Firestore数据结构如下：

"messages" > doc.id > 
{
  contentBody: "text",
  createdAt: timestamp,
  id: userId,
  turn: true,
}

错误原因分析 #

你尝试的三种写法都存在核心问题：

• 写法1、2：直接将查询对象（Query）传给deleteDoc()，但deleteDoc()要求参数必须是文档引用（DocumentReference），传入非法参数导致内部断言失败，这是报错的直接原因。
• 写法3：deleteDoc()的参数传递错误，应该传入单个文档的引用doc.ref，而非集合引用或查询快照；同时用forEach执行异步删除会导致无法等待所有删除操作完成，可能出现部分删除的情况。

正确实现代码 #

基础版（适用于文档数量≤500） #

import "../firebase";
import {
  addDoc,
  collection,
  getDocs,
  deleteDoc,
  getFirestore,
  where,
  query,
  serverTimestamp,
  orderBy,
  writeBatch
} from "firebase/firestore";

const db = getFirestore();

export class MessagesDB {
  constructor() {
    this.messagesCollRef = collection(db, "messages");

    this.createMessage = async (msgData) => {
      const newData = {
        id: msgData.id,
        contentBody: msgData.contentBody,
        turn: msgData.turn,
        createdAt: serverTimestamp(),
      };
      await addDoc(this.messagesCollRef, newData);
    };

    this.getMessages = async (userId) => {
      const q = query(
        this.messagesCollRef,
        where("id", "==", userId),
        orderBy("createdAt")
      );
      const data = await getDocs(q).catch((e) => console.log(e));
      return data.docs.map((doc) => ({ ...doc.data(), id: doc.id }));
    };

    this.deleteMessages = async (userId) => {
      const q = query(this.messagesCollRef, where("id", "==", userId));
      const snapshot = await getDocs(q);
      
      if (snapshot.empty) {
        console.log("没有匹配的文档需要删除");
        return;
      }

      // 使用批量操作提升执行效率
      const batch = writeBatch(db);
      snapshot.docs.forEach(doc => {
        batch.delete(doc.ref);
      });

      await batch.commit();
      console.log("所有匹配文档已删除");
    };
  }
}

进阶版（处理超过500个文档的情况） #

Firestore批量操作最多支持500个文档，若需删除的文档数量超过限制，需分批处理：

this.deleteMessages = async (userId) => {
  let hasMoreDocs = true;
  let lastDoc = null;

  while (hasMoreDocs) {
    // 每次查询最多获取500个文档
    const q = lastDoc 
      ? query(
          this.messagesCollRef,
          where("id", "==", userId),
          orderBy("createdAt"),
          startAfter(lastDoc),
          limit(500)
        )
      : query(
          this.messagesCollRef,
          where("id", "==", userId),
          orderBy("createdAt"),
          limit(500)
        );

    const snapshot = await getDocs(q);
    if (snapshot.empty) {
      hasMoreDocs = false;
      break;
    }

    const batch = writeBatch(db);
    snapshot.docs.forEach(doc => {
      batch.delete(doc.ref);
    });
    await batch.commit();

    // 更新最后一个文档标记，用于下一批查询
    lastDoc = snapshot.docs[snapshot.docs.length - 1];
  }

  console.log("所有匹配文档已删除");
};

关键注意点 #

• 必须使用doc.ref获取单个文档的合法引用，作为deleteDoc()或批量操作的参数。
• 批量操作存在500个文档的上限，超过时需分批执行。
• 操作前先判断快照是否为空，避免无意义的执行流程。

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