在消息节点中添加子项时发送通知
每当在消息节点中添加新子节点时，所有用户都应该收到类似"你有新消息"的消息。我对node了解不多.js所以我想要会发送通知的云函数。
您将在下面找到满足您需求的教程或代码示例的链接。(更新：我还复制了第一个示例的整个代码，这是一个官方的Firebase示例(。
https://firebase.google.com/docs/functions/use-cases#notify_users_when_something_interesting_happens
https://github.com/firebase/functions-samples/blob/master/developer-motivator/functions/index.js
https://android.jlelse.eu/serverless-notifications-with-cloud-functions-for-firebase-685d7c327cd4
更新：在评论之后，我将第一个示例(这是官方Firebase示例(的源代码粘贴到下面。
通知的发送方式是使用 Firebase 管理员 SDK 完成的。网络 客户端将单个设备令牌写入实时数据库 函数用于发送通知。
依赖项列在functions/package.json中。
示例数据库结构
用户登录到应用并被要求在 他们的浏览器。如果他们成功启用通知，则设备 令牌保存在数据存储中的/users/$uid/notificationTokens.：
/functions-project-12345
/users
/Uid-12345
displayName: "Bob Dole"
/notificationTokens
1234567890: true
photoURL: "https://lh3.googleusercontent.com/..."
如果用户开始关注我们将写入的另一个用户/关注者/$followedUid/$followerUid：
/functions-project-12345
/followers
/followedUid-12345
followerUid-67890: true
/users
/Uid-12345
displayName: "Bob Dole"
/notificationTokens
1234567890: true
photoURL: "https://lh3.googleusercontent.com/..."
触发规则
每次跟随标志的值在/关注者/$followedUid/$followerUid.
索引.js
/**
* Copyright 2016 Google Inc. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
'use strict';
const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();
/**
* Triggers when a user gets a new follower and sends a notification.
*
* Followers add a flag to `/followers/{followedUid}/{followerUid}`.
* Users save their device notification tokens to `/users/{followedUid}/notificationTokens/{notificationToken}`.
*/
exports.sendFollowerNotification = functions.database.ref('/followers/{followedUid}/{followerUid}')
.onWrite((change, context) => {
const followerUid = context.params.followerUid;
const followedUid = context.params.followedUid;
// If un-follow we exit the function.
if (!change.after.val()) {
return console.log('User ', followerUid, 'un-followed user', followedUid);
}
console.log('We have a new follower UID:', followerUid, 'for user:', followerUid);
// Get the list of device notification tokens.
const getDeviceTokensPromise = admin.database()
.ref(`/users/${followedUid}/notificationTokens`).once('value');
// Get the follower profile.
const getFollowerProfilePromise = admin.auth().getUser(followerUid);
// The snapshot to the user's tokens.
let tokensSnapshot;
// The array containing all the user's tokens.
let tokens;
return Promise.all([getDeviceTokensPromise, getFollowerProfilePromise]).then(results => {
tokensSnapshot = results[0];
const follower = results[1];
// Check if there are any device tokens.
if (!tokensSnapshot.hasChildren()) {
return console.log('There are no notification tokens to send to.');
}
console.log('There are', tokensSnapshot.numChildren(), 'tokens to send notifications to.');
console.log('Fetched follower profile', follower);
// Notification details.
const payload = {
notification: {
title: 'You have a new follower!',
body: `${follower.displayName} is now following you.`,
icon: follower.photoURL
}
};
// Listing all tokens as an array.
tokens = Object.keys(tokensSnapshot.val());
// Send notifications to all tokens.
return admin.messaging().sendToDevice(tokens, payload);
}).then((response) => {
// For each message check if there was an error.
const tokensToRemove = [];
response.results.forEach((result, index) => {
const error = result.error;
if (error) {
console.error('Failure sending notification to', tokens[index], error);
// Cleanup the tokens who are not registered anymore.
if (error.code === 'messaging/invalid-registration-token' ||
error.code === 'messaging/registration-token-not-registered') {
tokensToRemove.push(tokensSnapshot.ref.child(tokens[index]).remove());
}
}
});
return Promise.all(tokensToRemove);
});
});
包.json
{
"name": "fcm-notifications-functions",
"description": "Send FCM notifications Firebase Functions sample",
"dependencies": {
"firebase-admin": "~5.11.0",
"firebase-functions": "^1.0.0"
},
"devDependencies": {
"eslint": "^4.13.1",
"eslint-plugin-promise": "^3.6.0"
},
"scripts": {
"lint": "./node_modules/.bin/eslint --max-warnings=0 .",
"serve": "firebase serve --only functions",
"shell": "firebase experimental:functions:shell",
"start": "npm run shell",
"deploy": "firebase deploy --only functions",
"logs": "firebase functions:log"
},
"private": true
}