时间戳

首页 > 解决方案 > 在 Firebase 函数中为实时数据库使用 onWrite 触发器

firebase - 在 Firebase 函数中为实时数据库使用 onWrite 触发器

问题描述

我使用 dart 和 firebase 后端设计了一个颤振应用程序。我想在用户创建、删除或更新数据库中的任何内容时触发。我了解onCreate、onRemoved和onUpdate方法。我在 firebase 云函数中编写了一个 javascript 代码。我需要在触发发生时发送通知。我不想使用 3 个不同的触发器。我只想使用 onWrite 触发器。

这是我的数据库。

在此处输入图像描述

有四个部门，分别称为comp、civil、lect和mech。我想在单个 onWrite 触发器中发生数据库更改时触发！

我的第一个问题是，我想区分它是从onWrite触发器创建、删除还是更新。我知道它将触发所有 3 个事件。但是我该如何区分呢？

这是我的 onCreate 代码...

exports.noticeAddedComp = functions.database.ref('main/notices/comp/{id}').onCreate( async evt =>  {

var token = ['dxnfr3dq6_Y:APA91bHavtoP62l296qzVoBhzQJbMFA']
const payload = {
    notification:{
        title : 'Message from Cloud',
        body : 'This is your body',
        sound : 'default'
    },
    data:{
    message : 'Thi is new Push',
    click_action : 'FLUTTER_NOTIFICATION_CLICK',
    }
};
        await admin.messaging().sendToDevice(token,payload);

});

上面的代码正在工作。但它适用于 onCreate。

我的第二个问题是，我需要为四个部门编写四个 onWrite 触发代码吗？

标签： firebaseflutterfirebase-realtime-databasedartgoogle-cloud-functions

解决方案

您可以使用change.before和change.after属性来确定节点是在onWrite处理程序中创建、删除还是更新：

exports.noticeAddedComp = functions.database.ref('main/notices/comp/{id}')
.onWrite( async (change, context) =>  {
  if (!change.before.exists()) console.log("New node: "+change.after.key);
  if (!change.after.exists()) console.log("Deleted node: "+change.before.key);
  if (change.before.exists() && change.after.exists()) console.log("Updated node: "+change.after.key)
  ...
});

您可以通过在其路径中包含另一个参数来一次将云函数附加到所有部门：

exports.noticeAddedComp = functions.database.ref('main/notices/{dept}/{id}')
.onWrite( async (change, context) =>  {
  console.log("Triggered for department: "+context.params.dept);
  ...
})

推荐阅读