headup_api/routes/api/jumps.js

var router = require('express').Router(),
    mongoose = require('mongoose'),
    Jump = mongoose.model('Jump'),
    User = mongoose.model('User');
const auth = require('../auth');

// Preload jump objects on routes with ':jump'
router.param('jump', function (req, res, next, slug) {
    Jump.findOne({ slug: slug })
        .populate('author')
        .then(function (jump) {
            if (!jump) {
                return res.sendStatus(404);
            }
            req.jump = jump;
            return next();
        }).catch(next);
});

/**
 * return all jumps
 */
router.get('/', auth.required, function (req, res, next) {
    var query = {};
    var limit = 25;
    var offset = 0;
    if (typeof req.query.limit !== 'undefined') {
        limit = req.query.limit;
    }
    if (typeof req.query.offset !== 'undefined') {
        offset = req.query.offset;
    }
    if (typeof req.query.title !== 'undefined') {
        const rgx = new RegExp(`.*${req.query.title}.*`);
        query = {
            $or: [
                { title: { $regex: rgx, $options: "i" } },
                { slug: { $regex: rgx, $options: "i" } },
            ],
        }
    }

    Promise.all([
        req.query.author ? User.findOne({ username: req.query.author }) : null,
        req.query.favorited ? User.findOne({ username: req.query.favorited }) : null
    ]).then(function (users) {
        var author = users[0];

        if (author) {
            query.author = author._id;
        }

        return Promise.all([
            Jump.find(query)
                .limit(Number(limit))
                .skip(Number(offset))
                .sort({ numero: 'desc' })
                .populate('author')
                .exec(),
            Jump.count(query).exec(),
            req.payload ? User.findById(req.payload.id) : null
        ]).then(function (results) {
            var jumps = results[0];
            var jumpsCount = results[1];
            var user = results[2];

            return res.json({
                jumps: jumps.map(function (jump) {
                    return jump.toJSONFor(user);
                }),
                jumpsCount: jumpsCount
            });
        });
    }).catch(next);
});

router.get('/allByDate', auth.required, function (req, res, next) {
    User.findById(req.payload.id).then(function (user) {
        if (!user) {
            return res.sendStatus(401);
        }
        var limit = 120;
        var offset = 0;
        if (typeof req.query.limit !== 'undefined') {
            limit = req.query.limit;
        }
        if (typeof req.query.offset !== 'undefined') {
            offset = req.query.offset;
        }
        var query = [
            {
                '$match': {
                    '$expr': {
                        '$eq': [ '$author' , { '$toObjectId': user._id.toString() } ]
                    }
                }
            }, {
                '$project': {
                    '_id': 0,
                    'year': {
                        '$year': '$date'
                    },
                    'month': {
                        '$month': '$date'
                    }
                }
            }, {
                '$group': {
                    '_id': {
                        'year': '$year',
                        'month': '$month'
                    },
                    'count': {
                        '$sum': 1
                    }
                }
            }, {
                '$sort': {
                    '_id': 1
                }
            }
        ];

        Jump.aggregate(query)
        .limit(Number(limit))
        .skip(Number(offset))
        .exec()
        .then(function (result) {
            var jumps = result;
            //console.log(jumps);
            return res.json({
                jumps: jumps,
                jumpsCount: jumps.length
            });
        }).catch(next);
    }).catch(next);
});


router.get('/feed', auth.required, function (req, res, next) {
    var limit = 25;
    var offset = 0;
    if (typeof req.query.limit !== 'undefined') {
        limit = req.query.limit;
    }
    if (typeof req.query.offset !== 'undefined') {
        offset = req.query.offset;
    }

    User.findById(req.payload.id).then(function (user) {
        if (!user) {
            return res.sendStatus(401);
        }
        var query = { author: { $in: user.following } };
        Promise.all([
            Jump.find(query)
                .limit(Number(limit))
                .skip(Number(offset))
                .populate('author')
                .exec(),
            Jump.count(query)
        ]).then(function (results) {
            var jumps = results[0];
            var jumpsCount = results[1];
            return res.json({
                jumps: jumps.map(function (jump) {
                    return jump.toJSONFor(user);
                }),
                jumpsCount: jumpsCount
            });
        }).catch(next);
    });
});

/**
 * return last jump
 */
router.get('/last', auth.required, function (req, res, next) {

    User.findById(req.payload.id).then(function (user) {
        if (!user) {
            return res.sendStatus(401);
        }
        /*Jump.findOne({ slug: slug })
            .populate('author')
            .then(function (jump) {
                if (!jump) {
                    return res.sendStatus(404);
                }
                req.jump = jump;
                return next();
            }).catch(next);*/
        Jump.find({})
            .limit(1)
            .skip(0)
            .sort({ numero: 'desc' })
            .populate('author')
            .exec()
            .then(function (jumps) {
                if (!jumps) {
                    return res.sendStatus(404);
                }
                req.lastjump = jumps[0];
                if (req.lastjump.author._id.toString() !== req.payload.id.toString()) {
                    return res.sendStatus(403);
                }
                return res.json({ jump: req.lastjump.toJSONFor(user) });
            }).catch(next);
    }).catch(next);
});
/**
 * return a jump
 */
router.get('/:jump', auth.required, function (req, res, next) {
    Promise.all([
        req.payload ? User.findById(req.payload.id) : null
        /*req.jump.populate('author')*/
    ]).then(function (results) {
        var user = results[0];
        if (!user) {
            return res.sendStatus(401);
        }
        if (req.jump.author._id.toString() !== req.payload.id.toString()) {
            return res.sendStatus(403);
        }
        return res.json({ jump: req.jump.toJSONFor(user) });
    }).catch(next);
});

/**
 * save a jump
 */
router.post('/', auth.required, function (req, res, next) {
    Promise.all([
        req.payload ? User.findById(req.payload.id) : null
        /*Jump
            .find({}).select('numero')
            .sort({"numero" : -1}).limit(1)
            .exec()*/
    ]).then(function (results) {
        var user = results[0];
        //var numero = (results[1][0].numero + 1);
        if (!user) {
            return res.sendStatus(401);
        }
        var jump = new Jump(req.body.jump);
        jump.author = user;
        //jump.numero = numero;
        return jump.save().then(function () {
            return res.json({ jump: jump.toJSONFor(user) });
        });
    }).catch(next);
});

/**
 * update a jump
 */
router.put('/:jump', auth.required, function (req, res, next) {
    Promise.all([
        req.payload ? User.findById(req.payload.id) : null
    ]).then(function (results) {
        var user = results[0];
        if (!user) {
            return res.sendStatus(401);
        }
        if (req.jump.author._id.toString() !== req.payload.id.toString()) {
            return res.sendStatus(403);
        }
        if (typeof req.body.jump.date !== 'undefined') {
            req.jump.date = req.body.jump.date;
        }
        if (typeof req.body.jump.numero !== 'undefined') {
            req.jump.numero = req.body.jump.numero;
        }
        if (typeof req.body.jump.lieu !== 'undefined') {
            req.jump.lieu = req.body.jump.lieu;
        }
        if (typeof req.body.jump.oaci !== 'undefined') {
            req.jump.oaci = req.body.jump.oaci;
        }
        if (typeof req.body.jump.aeronef !== 'undefined') {
            req.jump.aeronef = req.body.jump.aeronef;
        }
        if (typeof req.body.jump.imat !== 'undefined') {
            req.jump.imat = req.body.jump.imat;
        }
        if (typeof req.body.jump.hauteur !== 'undefined') {
            req.jump.hauteur = req.body.jump.hauteur;
        }
        if (typeof req.body.jump.voile !== 'undefined') {
            req.jump.voile = req.body.jump.voile;
        }
        if (typeof req.body.jump.taille !== 'undefined') {
            req.jump.taille = req.body.jump.taille;
        }
        if (typeof req.body.jump.categorie !== 'undefined') {
            req.jump.categorie = req.body.jump.categorie;
        }
        if (typeof req.body.jump.module !== 'undefined') {
            req.jump.module = req.body.jump.module;
        }
        if (typeof req.body.jump.participants !== 'undefined') {
            req.jump.participants = req.body.jump.participants;
        }
        if (typeof req.body.jump.sautants !== 'undefined') {
            req.jump.sautants = req.body.jump.sautants;
        }
        if (typeof req.body.jump.programme !== 'undefined') {
            req.jump.programme = req.body.jump.programme;
        }
        if (typeof req.body.jump.accessoires !== 'undefined') {
            req.jump.accessoires = req.body.jump.accessoires;
        }
        if (typeof req.body.jump.zone !== 'undefined') {
            req.jump.zone = req.body.jump.zone;
        }
        if (typeof req.body.jump.dossier !== 'undefined') {
            req.jump.dossier = req.body.jump.dossier;
        }
        if (typeof req.body.jump.video !== 'undefined') {
            req.jump.video = req.body.jump.video;
        }

        return req.jump.save().then(function (jump) {
            return res.json({ jump: jump.toJSONFor(user) });
        });
    }).catch(next);
});

/**
 * delete a jump
 */
router.delete('/:jump', auth.required, function (req, res, next) {
    User.findById(req.payload.id).then(function (user) {
        if (!user) {
            return res.sendStatus(401);
        }
        if (req.jump.author._id.toString() === req.payload.id.toString()) {
            return req.jump.remove().then(function () {
                return res.sendStatus(204);
            });
        } else {
            return res.sendStatus(403);
        }
    }).catch(next);
});

module.exports = router;