如何使用Firebase Cloud Functions实现Firestore匹配逻辑

核心排查点与注意事项 #

• 确认云函数服务账号权限：默认云函数服务账号拥有Firestore全读写权限，若手动修改过IAM规则，需确保cloudfunctions.serviceAccount角色包含datastore.user权限。
• 严格处理异步操作：Firestore查询是异步操作，必须用async/await或Promise链式调用，避免同步逻辑导致查询未完成就执行后续判断。
• 对齐客户端数据结构：集合路径、用户ID字段名（如uid/userId）必须和客户端代码完全一致，否则会出现查询空结果。

可调用函数实现示例 #

以下是完整的添加喜欢+双向匹配检查的可调用函数：

const functions = require("firebase-functions");
const admin = require("firebase-admin");
admin.initializeApp();

exports.addLikeAndCheckMatch = functions.https.onCall(async (data, context) => {
  // 验证用户身份，拦截未登录请求
  if (!context.auth) {
    throw new functions.https.HttpsError("unauthenticated", "用户未登录");
  }

  const currentUserId = context.auth.uid;
  const targetUserId = data.targetUserId;

  // 步骤1：添加当前用户对目标用户的喜欢记录
  await admin.firestore()
    .collection("userLikes")
    .doc(currentUserId)
    .collection("likes")
    .doc(targetUserId)
    .set({ timestamp: admin.firestore.FieldValue.serverTimestamp() });

  // 步骤2：查询目标用户是否已喜欢当前用户
  const targetLikeSnapshot = await admin.firestore()
    .collection("userLikes")
    .doc(targetUserId)
    .collection("likes")
    .doc(currentUserId)
    .get();

  let isMatch = false;
  if (targetLikeSnapshot.exists) {
    isMatch = true;
    // 步骤3：匹配成功，创建双向匹配记录
    await admin.firestore()
      .collection("matches")
      .doc(`${currentUserId}_${targetUserId}`)
      .set({
        users: [currentUserId, targetUserId],
        createdAt: admin.firestore.FieldValue.serverTimestamp()
      });
  }

  return { isMatch };
});

Firestore触发器实现示例 #

若使用Firestore触发器（当用户添加喜欢记录时自动触发匹配检查），需注意触发器路径与数据结构对齐：

const functions = require("firebase-functions");
const admin = require("firebase-admin");
admin.initializeApp();

exports.onLikeCreated = functions.firestore
  .document("userLikes/{currentUserId}/likes/{targetUserId}")
  .onCreate(async (snap, context) => {
    const currentUserId = context.params.currentUserId;
    const targetUserId = context.params.targetUserId;

    // 查询目标用户的喜欢列表中是否存在当前用户
    const targetLikeSnapshot = await admin.firestore()
      .collection("userLikes")
      .doc(targetUserId)
      .collection("likes")
      .doc(currentUserId)
      .get();

    if (targetLikeSnapshot.exists) {
      // 创建匹配记录
      await admin.firestore()
        .collection("matches")
        .doc(`${currentUserId}_${targetUserId}`)
        .set({
          users: [currentUserId, targetUserId],
          createdAt: admin.firestore.FieldValue.serverTimestamp()
        });
    }
  });

常见错误解析 #

• 异步逻辑未处理：直接调用get()而不等待Promise完成，会导致查询结果未返回就执行匹配判断，误判为无匹配。
• 权限配置错误：若云函数服务账号无Firestore读写权限，查询会返回空结果或抛出权限异常，可在Firebase控制台IAM页面检查角色配置。
• 路径/字段不匹配：客户端使用likes/{userId}集合路径，云函数却写成userLikes/{userId}，会导致查询不到数据，必须严格对齐客户端数据结构。

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