Firebase Functions Realtime Database OnCreate跨路径数据同步咨询

原有代码存在的问题 #

• 触发器监听路径配置错误：当前监听/roles根路径的创建事件，仅会在整个/roles节点首次生成时触发一次，后续新增子节点不会触发，无法满足每次有新角色数据写入的监听需求。
• 混用了Realtime Database与Firestore的API：你使用的doc()是Firestore的节点获取方法，Realtime Database对应方法为ref()，原代码调用API会直接报错。
• 用户ID提取逻辑错误：snapshot是DataSnapshot实例，不能直接通过下标取字段值，你写入的角色数据中用户ID存储在user字段下，需要从snapshot.val()的返回值中提取。
• 数据覆盖风险：直接调用set()方法会完全覆盖/user/${userId}节点下的所有原有数据，若用户节点下还存储其他业务数据会导致数据丢失。

修正后代码 #

// 请确保你已经在文件顶部完成了admin SDK的初始化
const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();

// 监听/roles下的所有新子节点创建事件
exports.syncRoleToUser = functions.database.ref('/roles/{roleId}')
    .onCreate((snapshot, context) => {
      const roleData = snapshot.val();
      // 从写入的角色数据中提取用户ID
      const userId = roleData.user;
      // 获取对应用户节点的引用
      const userRef = admin.database().ref(`/user/${userId}`);

      // 第二个参数{merge: true}表示合并数据，不覆盖用户原有其他数据
      return userRef.set(roleData, { merge: true });
      
      // 如果你只需要同步notification字段到用户节点，可替换为下面的写法：
      // return userRef.child('notification').set(roleData.notification);
    });

补充说明 #

如果你的业务需求是将角色数据写入用户节点下的指定子路径，而非整个用户根节点，可以修改ref路径调整写入位置，避免不必要的数据覆盖。

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