43 lines
1.1 KiB
JavaScript
43 lines
1.1 KiB
JavaScript
const express = require('express');
|
|
const router = express.Router();
|
|
const mongoose = require('mongoose');
|
|
const Subscription = mongoose.model('subscribers');
|
|
const webpush = require('web-push');
|
|
|
|
router.post('/', (req, res) => {
|
|
console.log('req.body.others', req.body.others);
|
|
let subscriptionModel = new Subscription(req.body.subs);
|
|
subscriptionModel.userId = req.body.others.userId
|
|
|
|
subscriptionModel.save((err, subscription) => {
|
|
if (err) {
|
|
console.error(`Error occurred while saving subscription. Err: ${err}`);
|
|
res.status(500).json({
|
|
error: 'Technical error occurred'
|
|
});
|
|
} else {
|
|
// Send 201 - resource created
|
|
res.status(201).json({ data: 'Subscription saved.' });
|
|
|
|
sendBackNotif(subscription, req.body.options)
|
|
}
|
|
});
|
|
});
|
|
|
|
function sendBackNotif(subscription, payload) {
|
|
|
|
console.log('payload');
|
|
// Pass object into sendNotification
|
|
webpush.sendNotification(subscription, JSON.stringify(payload)).catch(err => console.error(err));
|
|
|
|
}
|
|
|
|
|
|
router.get('/', (req, res) => {
|
|
res.json({
|
|
data: 'Invalid Request Bad'
|
|
});
|
|
});
|
|
|
|
module.exports = router;
|