Firebase Cloud Function 向同一设备发送多个相同的通知答案

【问题标题】：Firebase Cloud Function sends multiple of the same notification to the same devicesFirebase Cloud Function 向同一设备发送多个相同的通知
【发布时间】：2018-08-27 09:24:12
【问题描述】：

我有一个 firebase 云功能，当新的“紧急情况”添加到数据库时，它应该向最近的 5 部手机发送通知。我编写的代码确实会向最近的 5 部手机发送通知，但它会一遍又一遍地发送相同的通知。当我的用户登录或注销时，情况会变得更糟，因为它会发送更多。我很困惑为什么我的云功能不只是运行一次然后终止。

这是我的云功能的代码：

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

exports.sendPushNotificationAdded = functions.database.ref('/emergencies/{id}').onCreate(event => {
    return admin.database().ref('/tokens').on('value', function(snapshot) {
        var efarArray = snapshotToArray(snapshot, event.data.child('latitude').val(), event.data.child('longitude').val());
        efarArray.sort(function(a, b) {
            return a.distance - b.distance;
        });
        var payload = {
            notification: {
                title: "NEW EMERGANCY!",
                body: "Message from Patient: " + event.data.child('other_info').val(),
                //badge: '1',
                sound: 'default',
            }
        };
        var options = {
          priority: "high",
          timeToLive: 0
        };
        tokens_to_send_to = [];
        if(efarArray.length >= 5){
            //only send to the 5 closest efars
            for (var i = 4; i >= 0; i--) {
                tokens_to_send_to.push(efarArray[i].token);
            }
        }else{
            for (var i = efarArray.length - 1; i >= 0; i--) {
                tokens_to_send_to.push(efarArray[i].token);
            }
        }
        //TODO: send a messaged back to patient if no efars respond or are found?
        return admin.messaging().sendToDevice(tokens_to_send_to, payload, options).then(response => {

        });
    });
});

//code for function below from https://ilikekillnerds.com/2017/05/convert-firebase-database-snapshotcollection-array-javascript/
function snapshotToArray(snapshot, incoming_latitude, incoming_longitude) {
    var returnArr = [];

    snapshot.forEach(function(childSnapshot) {
        var distance_to_efar = distance(childSnapshot.child('latitude').val(), childSnapshot.child('longitude').val(), incoming_latitude, incoming_longitude);
        var item = {
            latitude: childSnapshot.child('latitude').val(), 
            longitude: childSnapshot.child('longitude').val(),
            token: childSnapshot.key,
            distance: distance_to_efar
        };

        returnArr.push(item);
    });

    return returnArr;
};

如果需要更多说明或代码，请告诉我。我一直被困在这上面......

【问题讨论】：

标签： android firebase firebase-cloud-messaging google-cloud-functions

【解决方案1】：

请勿将 on() 与 Cloud Functions 一起使用。这几乎从来都不是正确的使用方法，因为它添加了一个侦听器，可以在数据库更改时多次调用该侦听器。使用once() 获取单个快照并采取行动。

此外，您必须从函数返回一个 promise，该函数在该函数中的所有异步工作完成时解析。 on() 不返回承诺，因此您的函数也没有这样做。

您可能想研究一些official sample code 并遵循那里建立的模式。

【讨论】：