用于制作 firebase 用户到用户通知的脚本
Script for making firebase user to user notifications
(抱歉英语不好)
我正在寻找一种在 Android 中向用户发送通知的方法。
系统必须在数据库中捕获新的子事件,读取数据并将通知发送到目的地。
数据库的结构是这样的:
notificationRequests
$pushid
message: "You have a new request! Open the app"
userId: "sadbijasuobru112u4124u21b" //user destination id
通过在网络上进行一些研究,我发现了使用主题消息的可能性。
所以,在调用 MainActivity 之前,我在我的 LoginActivity 中添加了这个:
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 中为 deployng 实现了这段代码。我也写了整个文件而不是要求它,但它总是一样的。
const functions = require('firebase-functions');
exports.sendNotifications = functions.https.onRequest((request, response) => {
require('./sendNotifications.js')
})
有什么建议吗?
谢谢你的海带!
编辑
这需要配置结算帐户吗?如果是,我怎样才能使用免费计划?
Does this need a billing account configurated? If yes, how can i make it with the free plan?
参见 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();
});
(抱歉英语不好) 我正在寻找一种在 Android 中向用户发送通知的方法。 系统必须在数据库中捕获新的子事件,读取数据并将通知发送到目的地。
数据库的结构是这样的:
notificationRequests
$pushid
message: "You have a new request! Open the app"
userId: "sadbijasuobru112u4124u21b" //user destination id
通过在网络上进行一些研究,我发现了使用主题消息的可能性。 所以,在调用 MainActivity 之前,我在我的 LoginActivity 中添加了这个:
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 中为 deployng 实现了这段代码。我也写了整个文件而不是要求它,但它总是一样的。
const functions = require('firebase-functions');
exports.sendNotifications = functions.https.onRequest((request, response) => {
require('./sendNotifications.js')
})
有什么建议吗? 谢谢你的海带!
编辑
这需要配置结算帐户吗?如果是,我怎样才能使用免费计划?
Does this need a billing account configurated? If yes, how can i make it with the free plan?
参见 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();
});