我正在尝试通过套接字(使用socket.io)集成发送实时信息,并使用OneSignal平台发送推送通知.
碰巧的是,如果我把所有东西放在同一个模块中,我不知道为什么在发送信息之后或发送信息之前不会执行发送通知的方法.
如果我运行命令npm start没有出现错误,但是一旦本地或远程服务器运行,通知就会到达,这样我就不希望它发生了.
user.js的
var express = require('express');
var router = express.Router();
var misocket = require('../routes/misocket');
var notificacion = require('../routes/notificacion');
/*
run module when start server run,i don't want it
notificacion();
*/
/* GET users listing. sendnote*/
router.post('/sendasig',function(req,res,next) {
console.log(misocket);//registrednote
misocket.emit("registrar",req.body);
//run here,after the send data across post request
notificacion();
console.log(req.body);
res.status(200).json({
message : "send message"
});
});
module.exports = router;
notificacion.js
module.exports = function(){
var OnesignalNotificationApi = require('onesignal-notification');
var api = new OnesignalNotificationApi('N2FkY2ZkZWQtMGQ2MS00ZTUwLTlkM2QtODA2NmE0YjBiMzQ3','c4b92cce-4d59-4550-a4be-20939370e39c');
var message = {
it: 'Some message',en: 'Some message',es: 'Nueva Calificacion'
};
api.sendToAll(message,null,function(err,res){
console.log(err);
console.log(res);
});
};
index.js
var express = require('express');
var router = express.Router();
/* GET home page. */
router.get('/',next) {
res.render('index',{ title: 'Express' });
});
module.exports = router;
misocket.js
var i = 0;
var ioapp;
exports.connection= function(io){
ioapp = io;
io.on('connect',function(s){
console.log("Conectado");
});
};
exports.io = ioapp;
最佳答案
用以下代码替换您的notification.js
原文链接：https://www.f2er.com/js/429174.html module.exports = function(){
var sendNotification = function (data) {
var headers = {
"Content-Type": "application/json; charset=utf-8","Authorization": "Basic N2FkY2ZkZWQtMGQ2MS00ZTUwLTlkM2QtODA2NmE0YjBiMzQ3"
};
var options = {
host: "onesignal.com",port: 443,path: "/api/v1/notifications",method: "POST",headers: headers
};
var https = require('https');
var req = https.request(options,function (res) {
res.on('data',function (data) {
console.log("Response:");
console.log(JSON.parse(data));
});
});
req.on('error',function (e) {
console.log("ERROR:");
console.log(e);
});
req.write(JSON.stringify(data));
req.end();
};
var message = {
app_id: "c4b92cce-4d59-4550-a4be-20939370e39c",contents: {"en": "sample message"},included_segments: ["All"]
};
sendNotification(message);
};
