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) => {
    const subscriptionModel = new Subscription(req.body.subs);
    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;