使Firebase用户到用户通知的脚本

问题描述

（对不起，英语不好） 我正在寻找一种使用户在Android中进行用户通知的方法。 系统必须在数据库中捕获一个新的子事件，读取数据并将通知发送到目的地。

数据库的结构是这样的：

notificationRequests
    $pushid
      message: "You have a new request! Open the app"
      userId: "sadbijasuobru112u4124u21b"      //user destination id

通过在网络上进行一些研究，我发现可以使用主题消息。 因此，我已经在我的LoginActivity中添加了此功能，以便调用MainActivity：

    FirebaseMessaging.getInstance().subscribetoTopic("users_topic$uid")
                    .addOnCompleteListener {
                        Log.d("LoginActivity","User registered")
                    }

该代码有效。我可以从控制台发送通知

就像我之前说过的，我需要自动发送消息。 我已经在网络上找到了此代码，但是它不起作用。

var firebase = require('firebase-admin');
var request = require('request');

var API_KEY = "Firebase Cloud Messaging Server API key"

// Fetch the service account key JSON file contents
var serviceAccount = require("./serviceAccountKey.json");

// Initialize the app with a service account,granting admin privileges
firebase.initializeApp({
  credential: firebase.credential.cert(serviceAccount),databaseURL: "https://appname.firebaseio.com/"
});
ref = firebase.database().ref();

function listenForNotificationRequests() {
  var requests = ref.child('notificationRequests');
  requests.on('child_added',(requestSnapshot) => {
    var request = requestSnapshot.val();
    sendNotificationToUser(
      request.userId,request.message,() => {
        requestSnapshot.ref.remove();
      }
    );
  },(error) => {
    console.error(error);
  });
}

function sendNotificationToUser(userID,message,onSuccess) {
  request({
    url: 'https://fcm.googleapis.com/fcm/send',method: 'POST',headers: {
      'Content-Type' :' application/json','Authorization': 'key='+API_KEY
    },body: JSON.stringify({
      notification: {
        title: message
      },to : '/topics/users_topic'+userID
    })
  },(error,response,body) => {
    if (error) { console.error(error); }
    else if (response.statusCode >= 400) { 
      console.error('HTTP Error: '+response.statusCode+' - '+response.statusMessage); 
    }
    else {
      onSuccess();
    }
  });
}

// start listening
listenForNotificationRequests();

我已经在index.js中实现了用于部署的代码。我还写了整个文件，而不是要求它，但是始终一样。

const functions = require('firebase-functions');

exports.sendNotifications = functions.https.onRequest((request,response) => {
  require('./sendNotifications.js')
})

有什么建议吗？ 感谢海带！

编辑

这是否需要配置计费帐户？如果是，我该如何使用免费计划？

解决方法

这是否需要配置计费帐户？如果是，我该如何使用免费计划？

请参见https://firebase.google.com/support/faq#functions-runtime，但总之：从节点10开始，您将需要输入账单信息以使用Cloud Functions。

您可以在明年年初之前使用Node 8，而无需输入计费信息。

请注意，输入帐单信息并不一定意味着您必须付费，因为Cloud Functions具有相当可观的免费套餐。

,

问题是我正在呼叫外部站点。我这样做解决了这个问题：

const functions = require('firebase-functions');

var firebase = require('firebase-admin');

// Fetch the service account key JSON file contents
var serviceAccount = require("./serviceAccountKey.json");

// Initialize the app with a service account,granting admin privileges
firebase.initializeApp({
  credential: firebase.credential.cert(serviceAccount),databaseURL: "https://appname.firebaseio.com/"
});

exports.sendNotifications = functions.database.ref('/notificationRequest/{pushId}')
  .onCreate( (change,context) => {
    var uid = change.child('userId').val()
    var notificationMessage = change.child('message').val()

    var userTopic = 'users_topic'+uid

    var payload = {
      data: {
        message: notificationMessage
      }
    };

    var options = {
      priority: 'high',timeToLive: 60 * 60 * 24,collapseKey: 'notification'
    };

    firebase.messaging().sendToTopic(userTopic,payload,options)
      // eslint-disable-next-line promise/always-return
      .then((response) => {
        console.log('Done',response);
      })
      .catch((error) => {
        console.log('Error: ',error);
      });

    return change.ref.remove();
  });