Firestore引用字段与被引用文档删除后的处理策略

// index.js (Cloud Functions)
const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();
const db = admin.firestore();

/**
 * 当用户文档被删除时，自动清理所有指向该用户的文章引用。
 * 假设文章文档有一个 'authorRef' 字段，指向用户文档。
 */
exports.onUserDeleteCleanupPosts = functions.firestore
    .document('users/{userId}')
    .onDelete(async (snap, context) => {
        const userId = context.params.userId;
        const userRef = snap.ref; // 被删除用户的DocumentReference

        console.log(`用户 ${userId} 被删除，开始清理相关文章引用。`);

        try {
            // 查询所有 'posts' 集合中 'authorRef' 字段指向该用户的文档
            const referencingPostsSnapshot = await db.collection('posts')
                .where('authorRef', '==', userRef)
                .get();

            if (referencingPostsSnapshot.empty) {
                console.log(`没有文章引用用户 ${userId}。`);
                return null;
            }

            const batch = db.batch();
            referencingPostsSnapshot.forEach(doc => {
                // 选项1: 将引用字段设置为 null
                batch.update(doc.ref, { authorRef: null });
                // 选项2: 如果业务逻辑需要，可以删除整个引用文档
                // batch.delete(doc.ref);
                console.log(`更新文章 ${doc.id} 的 authorRef 为 null。`);
            });

            await batch.commit();
            console.log(`成功清理了 ${referencingPostsSnapshot.size} 篇引用用户 ${userId} 的文章。`);
            return null;
        } catch (error) {
            console.error(`清理用户 ${userId} 引用时发生错误:`, error);
            return null;
        }
    });

// 假设监听一个 'posts' 集合，并检查其中的 'authorRef' 字段
db.collection("posts").addSnapshotListener((value, error) -> {
    if (error != null) {
        System.err.println("Listen failed:" + error);
        return;
    }

    for (DocumentChange dc : value.getDocumentChanges()) {
        if (dc.getType() == DocumentChange.Type.ADDED || dc.getType() == DocumentChange.Type.MODIFIED) {
            DocumentReference authorRef = dc.getDocument().getDocumentReference("authorRef");
            if (authorRef != null) {
                authorRef.get().addOnCompleteListener(task -> {
                    if (task.isSuccessful()) {
                        DocumentSnapshot authorSnapshot = task.getResult();
                        if (!authorSnapshot.exists()) {
                            // 发现悬空引用：authorRef 指向的文档不存在
                            System.out.println("发现悬空引用！文章ID: " + dc.getDocument().getId() + 
                                               ", 引用作者ID: " + authorRef.getId());
                            // 此时可以执行清理操作，例如将 authorRef 设为 null
                            // db.collection("posts").document(dc.getDocument().getId())
                            //     .update("authorRef", FieldValue.delete()); // 或 FieldValue.delete()
                        } else {
                            // 引用有效，可以继续处理
                            // System.out.println("引用有效，作者姓名: " + authorSnapshot.getString("name"));
                        }
                    } else {
                        System.err.println("获取引用文档失败: " + task.getException());
                    }
                });
            }
        }
    }
});