NodeJS通过Firebase将APN发送到应用程序

Question

您好，我希望将APN发送到我的应用程序。我成功地能够生成通知并将它们发送到我的应用程序。

我的问题是，服务器在一个块中相当频繁地发送通知。我猜测我的脚本算法有问题。

我想要做什么：

我想通知中每有一个在某条信息的评论时发送给设备。我想从Firebase数据库中显式获取用户名和评论。

我附上服务器脚本：

var firebase = require("firebase"); 
var once = require("once"); 
const apn = require('apn'); 

var config = { 
apiKey: "<key>", 
authDomain: "<domain>", 
databaseURL: "<url>", 
projectId: "<id>", 
storageBucket: "<bucket>", 
messagingSenderId: "<ID>" 
}; 
firebase.initializeApp(config); 

let options = { 
token: { 
    key: "<p8 file>", 

    keyId: "<key>", 
    teamId: "<team>" 
}, 
production: false 
}; 

    let apnProvider = new apn.Provider(options); 



    // Prepare the notifications 
    let notification = new apn.Notification(); 
    notification.expiry = Math.floor(Date.now()/1000) + 24 * 3600; // will  expire in 24 hours from now 
    notification.badge = 3; 
    notification.sound = "default"; 
    notification.topic = "<My bundle ID>"; 
    notification.payload = {'messageFrom': 'me'}; 


var author; 
var dtoken; 
var spotter; 
var comment; 
var database = firebase.database(); 



var postref = database.ref("posts").orderByChild("gen_notif").equalTo("yes").on("value", function (snapshot) { 
    var key; 
    var deviceToken; 
    console.log("-------------------Post Ids----------------------") 
    snapshot.forEach(function (childSnapshot) { 
     key = childSnapshot.key 
     author = childSnapshot.val()["author"]; 
     console.log(key) 
     var newref = database.ref("posts/" + childSnapshot.key + "/comment").on('child_added', function(snapy){ 
      console.log(snapy.val()) 
      console.log("-----------------comment Keys----------------------") 
      snapy.forEach(function(s){ 
       var spotuserkey = s.key 
       comment = s.val() 
       console.log(spotuserkey) 
       var spotuser = database.ref("users/"+ spotuserkey +"/credentials/name").on('value', function(spottersnap){ 
        console.log("-----------------User Key-----------------------") 
        spotuser = spottersnap.val() 
        console.log(spotuser) 

        var tokenref = database.ref("device/"+author+"/token").once('value', function(snap){ 
         console.log("-----------------device token---------------------") 
         deviceToken = snap.val() 
         console.log(deviceToken) 

          notification.alert = { 
          "title": "You Got Spotted", 
          "body": spotuser + " Spot you " + comment 
         }; 

         apnProvider.send(notification, deviceToken).then(result => { 
           console.log(result["failed"][0]["response"]); 
         }); 


        })//tokenref end 

       })//spotteref end 

      }); //snapy forEach end 

     })//newref end  

    }); //snapshot forEach end 

}); //postref end 

    apnProvider.shutdown(); 

Answer 1

要初始化您的应用程序，我认为这将更好地利用你可以通过火力地堡控制台下载serviceAccountKey文件，而不是直接写入你的代码中的密钥：

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

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

var serviceAccount = require("./serviceAccountKey.json"); 

admin.initializeApp({ 
    credential: admin.credential.cert(serviceAccount), 
    databaseURL: "YOUR_DATABASE_URL_GOES_HERE" 
}); 

当然，你需要在这里自己的数据库的URL进行替换，并确保您的serviceAccountKey.json文件是功能文件夹里面。

但是我认为你需要调整你的数据库一点点，使其更容易检索在服务器端你的ID，例如，它可能看起来像：

root/ 
|  .... 
| 
| 
|___ posts/ 
|      |___ postID 
|              |___ authorId : ... 
|             |___ caption : ... 
|              |___ comments 
|                  |___ commentID 
|       |___ senderId: ... 
|               |___ text: ... 
|            ... 
| 
| 
|___ users/ 
|      |___ userID 
|              |___ name : ... 
|              |___ email : ... 
|              |___ notificationTokens 
|                       |___ token1 : true                       
|      |___ token2 : true 
|                       ... 

然后，你可以创建用该函数写一个通知节点内部通知对象每当有您的意见节点的新写事件：

exports.createPostCommentedNotification = functions.database.ref('/posts/{postID}/comments/{commentID}').onWrite(event => { 

    const data = event.data; 

    if(data == undefined || !data.val()) { return; } 

    const postID = event.params.postID; 
    const commentID = event.params.commentID; 

    const getCommentSender = admin.database().ref(`/posts/${postID}/comments/${commentID}`).once('value'); 

    const getPostAuthor = admin.database().ref(`/posts/${postID}`).once('value'); 

    return Promise.all([getCommentSender, getPostAuthor]).then(results => { 

     const commentSenderData = results[0]; 
     const postAuthorData = results[1]; 

     const commentSenderId = commentSenderData.val().senderId; 
     const postAuthorId = postAuthorData.val().authorId; 

     if(commentSenderId == postAuthorId) { 
      return; 
     }; 

     const notificationID = admin.database().ref().push().key; 
     const timestamp = Date.now() 

     const getSenderProfilePromise = admin.auth().getUser(commentSenderId); 

     return Promise.all([getSenderProfilePromise]).then(results => { 

      // Note that when you create a user account you would need to set the displayName of the user using the updateProfile() method, otherwise you would need to retrieve the senderName in a different way:) 

      const senderData = results[0] 
      const senderName = senderData.providerData[0].displayName 

      var notificationData = { 
      senderName: senderName, 
      notificationTimestamp: timestamp 
      }; 

      var updates = {}; 

      updates['/notifications/' + postAuthorId + '/' + notificationID] = notificationData; 

      admin.database().ref().update(updates); 

      }); 
     }); 
}); 

，那么你会创建另一个函数来实际发送推送通知，使用您的用户令牌，只要有是一个新的通知对象添加到通知节点，如下所示：

exports.sendPushNotifications = functions.database.ref('/notifications/{receiverId}/{notificationId}').onWrite(event => { 

    const data = event.data; 

    if(data == undefined || !data.val()) { return; } 

    const receiverId = event.params.receiverId; 
    const notificationId = event.params.notificationId; 

    const getDeviceTokensPromise = admin.database().ref(`/users/${receiverId}/notificationTokens`).once('value'); 

    const getMessageContentPromise = admin.database().ref(`/notifications/${receiverId}/${notificationId}/notificationType`).once('value'); 

    const getSenderPromise = admin.database().ref(`/notifications/${receiverId}/${notificationId}/senderName`).once('value'); 

    return Promise.all([getDeviceTokensPromise, getSenderPromise]).then(results => { 

    const tokensSnapshot = results[0]; 
    const senderSnapshot = results[1]; 

    const sender = senderSnapshot.val() 

    if (!tokensSnapshot.hasChildren()) { 
     return console.log('There are no notification tokens to send to.'); 
    } 

    const payload = { 
     notification: { 
     title: `${sender}`, 
     body: 'Someone commented on your post', 
     badge: '1' 
     } 
    }; 

    var options = { 
     priority: "high", 
     timeToLive: 60 * 60 * 24, 
     mutable_content : true, 
     content_available : true, 
     category : 'reminder' 
    }; 

    const tokens = Object.keys(tokensSnapshot.val()); 

    return admin.messaging().sendToDevice(tokens, payload, options).then(response => { 


     const tokensToRemove = []; 
     response.results.forEach((result, index) => { 
     const error = result.error; 
     if (error) { 
      console.error('Failure sending notification to', tokens[index], error); 

      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); 
    }); 
    }); 
}); 

那么让我知道如果您有任何问题！