I'm trying to integrate sending real-time information via sockets (using socket.io), and sending push notifications using the OneSignal platform.
It happens that if I put everything in the same module, I do not know why the method to send the notification is not executed after the information is sent, or before sending the information.
If I run the command npm start no error appears but the notification arrives as soon as the local or remote server is running, and this way I do not want it to happen.
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;
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);
});
};
var express = require('express');
var router = express.Router();
/* GET home page. */
router.get('/', function(req, res, next) {
res.render('index', { title: 'Express' });
});
module.exports = router;
var i = 0;
var ioapp;
exports.connection= function(io){
ioapp = io;
io.on('connect',function(s){
console.log("Conectado");
});
};
exports.io = ioapp;
In your notification.js File the sendToAll function will be executed when the file is required (which is probably at run time for you.)
api.sendToAll(message, null, function(err, res){
console.log(err);
console.log(res);
});
You're going to want to wrap this in a function and call it inside of your post route.
module.exports = function(message){
api.sendToAll(message, null, function(err, res){
console.log(err);
console.log(res);
});
}
Which can then be required at the top of your server
const sendMessageFunction = require('path/to/notification.js')
.
.
.
sendMessageFunction('helloWorld')
Replace Your notification.js with the below code
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);
};
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With