freeplanet_serverside/src/server/router/sendnotif_router.js

const express = require('express');
const router = express.Router();

const tools = require('../tools/general');
const server_constants = require('../tools/server_constants');

const {authenticate} = require('../middleware/authenticate');

const {SendNotif} = require('../models/sendnotif');

const _ = require('lodash');

router.post('/', authenticate, async (req, res) => {
  tools.mylog('INIZIO - SendNotif');
  // tools.mylog('req.body', req.body);
  const body = _.pick(req.body, tools.allfieldSendNotif());

  tools.mylog('crea SendNotif');
  let myrecnotif = new SendNotif(body);

  const recout = await SendNotif.saveAndSendNotif(myrecnotif, req, res);
  if (recout) {
    return res.send({code: server_constants.RIS_CODE_OK, notif: '', record: recout});
  } else {
    return res.send({code: server_constants.RIS_CODE_ERR, notif: ''});
  }

});

router.get('/setall/:username/:idapp', authenticate, async (req, res) => {

  const idapp = req.params.idapp;
  const username = req.params.username;
  const username_call = req.user.username;

  try {
    if (username === username_call) {
      const arrNotifs = await SendNotif.find({idapp, dest: username, read: false}).lean();
      if (arrNotifs) {
        for (const rec of arrNotifs) {
          await SendNotif.setNotifAsRead(idapp, username_call, rec._id);
        }
      }
      res.send(true);
    }
  } catch (e) {
    res.status(400).send(e);
  }

});

router.get('/del/:username/:id/:idapp', authenticate, async (req, res) => {

  const idapp = req.params.idapp;
  const username = req.params.username;
  const myid = req.params.id;
  const username_call = req.user.username;

  try {
    if (username === username_call) {
      await SendNotif.findOneAndRemove({idapp, _id: myid});
      return res.send(true);
    }
  } catch (e) {
    return res.status(400).send(e);
  }

  return res.send(false);

});

router.get('/delall/:username/:idapp', authenticate, async (req, res) => {

  const idapp = req.params.idapp;
  const username = req.params.username;
  const username_call = req.user.username;

  try {
    if (username === username_call) {
      const ris = await SendNotif.deleteMany({idapp, dest: username});
      if (ris)
        return res.send(true);
    }
  } catch (e) {
    return res.status(400).send(e);
  }

  return res.send(false);

});

router.get('/:username/:lastdataread/:idapp', authenticate, (req, res) => {
  tools.mylog('GET NotifS : ', req.params);
  const username = req.params.username;
  const lastdataread = req.params.lastdataread;
  const idapp = req.params.idapp;
  // var category = req.params.category;

  if (req.user.idapp !== idapp) {
    // I'm trying to get something not mine!
    return res.status(404).send({code: server_constants.RIS_CODE_NOT_MY_USERNAME});
  }

  return SendNotif.findAllNotifByUsernameIdAndIdApp(username, lastdataread, idapp).then((arrnotif) => {
    // const wait = new Promise((resolve, reject) => {
    // setTimeout(() => {
    return res.send({arrnotif});
    // }, 2000);
    // });

  }).catch((e) => {
    console.log(e.message);
    res.status(400).send(e);
  });

});

module.exports = router;