Implémentation SkydiverId API

routes/api/jumps.js

@@ -1,13 +1,20 @@
 var router = require('express').Router(),
     mongoose = require('mongoose'),
     Jump = mongoose.model('Jump'),
-    User = mongoose.model('User');
-const auth = require('../auth');
+    JumpFile = mongoose.model('JumpFile'),
+    User = mongoose.model('User'),
+    X2DataLog = mongoose.model('X2DataLog');
+const auth = require('../auth'),
+    chalk = require('chalk'),
+    queries = require('../queries'),
+    utils = require('../utils');
 
 // Preload jump objects on routes with ':jump'
 router.param('jump', function (req, res, next, slug) {
     Jump.findOne({ slug: slug })
         .populate('author')
+        .populate('files')
+        .populate('x2data')
         .then(function (jump) {
             if (!jump) {
                 return res.sendStatus(404);
@@ -21,9 +28,9 @@ router.param('jump', function (req, res, next, slug) {
  * return all jumps
  */
 router.get('/', auth.required, function (req, res, next) {
-    var query = {};
-    var limit = 25;
-    var offset = 0;
+    let query = {};
+    let limit = 25;
+    let offset = 0;
     if (typeof req.query.limit !== 'undefined') {
         limit = req.query.limit;
     }
@@ -39,31 +46,87 @@ router.get('/', auth.required, function (req, res, next) {
             ],
         }
     }
+    if (typeof req.query.numeroRangeStart !== 'undefined' && typeof req.query.numeroRangeEnd !== 'undefined') {
+        query.numero = {
+            $gte: req.query.numeroRangeStart,
+            $lte: req.query.numeroRangeEnd
+        };
+    }
+    if (typeof req.query.tailleRangeStart !== 'undefined' && typeof req.query.tailleRangeEnd !== 'undefined') {
+        query.taille = {
+            $gte: req.query.tailleRangeStart,
+            $lte: req.query.tailleRangeEnd
+        };
+    }
+    if (typeof req.query.participantsRangeStart !== 'undefined' && typeof req.query.participantsRangeEnd !== 'undefined') {
+        query.participants = {
+            $gte: req.query.participantsRangeStart,
+            $lte: req.query.participantsRangeEnd
+        };
+    }
+    if (typeof req.query.hauteurRangeStart !== 'undefined' && typeof req.query.hauteurRangeEnd !== 'undefined') {
+        query.hauteur = {
+            $gte: req.query.hauteurRangeStart,
+            $lte: req.query.hauteurRangeEnd
+        };
+    }
+    if (typeof req.query.yearRangeStart !== 'undefined' && typeof req.query.yearRangeEnd !== 'undefined') {
+        query.date = {
+            $gte: new Date(`${req.query.yearRangeStart}-01-01 00:00:00`),
+            $lte: new Date(`${req.query.yearRangeEnd}-12-31 23:59:59`)
+        };
+    }
+    if (typeof req.query.dateRangeStart !== 'undefined' && typeof req.query.dateRangeEnd !== 'undefined') {
+        query.date = {
+            $gte: new Date(`${req.query.dateRangeStart} 00:00:00`),
+            $lte: new Date(`${req.query.dateRangeEnd} 23:59:59`)
+        };
+    }
 
     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];
+        let author = users[0];
 
         if (author) {
             query.author = author._id;
         }
 
-        return Promise.all([
+        Promise.all([
             Jump.find(query)
-                .limit(Number(limit))
                 .skip(Number(offset))
+                .limit(Number(limit))
                 .sort({ numero: 'desc' })
                 .populate('author')
+                .populate('files')
+                .populate('x2data')
                 .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];
-
+            let jumps = results[0];
+            let jumpsCount = results[1];
+            let user = results[2];
+            /*
+            Promise.all(
+                jumps.map(jump => {
+                    if (jump.files[0] !== undefined && jump.files[0].type !== 'kml') {
+                        console.log( chalk.green(`Fichier ${jump.files[0].type}`))
+                        //console.log( chalk.green(`Suppression du fichier ${jump.files[2]._id}`))
+                        //return jump.removeFile(jump.files[2]._id);
+                    }
+                    return;
+                })
+            ).then(function () {
+                return res.json({
+                    jumps: jumps.map(function (jump) {
+                        return jump.toJSONFor(user);
+                    }),
+                    jumpsCount: jumpsCount
+                });
+            });
+            */
             return res.json({
                 jumps: jumps.map(function (jump) {
                     return jump.toJSONFor(user);
@@ -74,60 +137,29 @@ router.get('/', auth.required, function (req, res, next) {
     }).catch(next);
 });
 
-router.get('/allByDate', auth.required, function (req, res, next) {
+router.get('/allByCategorie', auth.required, function (req, res, next) {
     User.findById(req.payload.id).then(function (user) {
         if (!user) {
-            return res.sendStatus(401);
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
         }
-        var limit = 120;
-        var offset = 0;
+        let limit = 120;
+        let 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
-                }
-            }
-        ];
+        let query = queries.getJumpsByCategoryQuery(user._id.toString());
 
         Jump.aggregate(query)
-        .limit(Number(limit))
         .skip(Number(offset))
+        .limit(Number(limit))
         .exec()
         .then(function (result) {
-            var jumps = result;
-            //console.log(jumps);
+            let jumps = result.map(function (data) {
+                return { categorie: data._id.categorie, count: data.count };
+            });
             return res.json({
                 jumps: jumps,
                 jumpsCount: jumps.length
@@ -136,10 +168,133 @@ router.get('/allByDate', auth.required, function (req, res, next) {
     }).catch(next);
 });
 
+router.get('/allByDate', auth.required, function (req, res, next) {
+    User.findById(req.payload.id).then(function (user) {
+        if (!user) {
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
+        }
+        let limit = 120;
+        let offset = 0;
+        if (typeof req.query.limit !== 'undefined') {
+            limit = req.query.limit;
+        }
+        if (typeof req.query.offset !== 'undefined') {
+            offset = req.query.offset;
+        }
+        let query = queries.getJumpsByDateQuery(user._id.toString());
+
+        Jump.aggregate(query)
+        .skip(Number(offset))
+        .limit(Number(limit))
+        .exec()
+        .then(function (result) {
+            let jumps = result.map(function (data) {
+                return { year: data._id.year, month: data._id.month, count: data.count };
+            });
+            return res.json({
+                jumps: jumps,
+                jumpsCount: jumps.length
+            });
+        }).catch(next);
+    }).catch(next);
+});
+
+router.get('/allByDay', auth.required, function (req, res, next) {
+    User.findById(req.payload.id).then(function (user) {
+        if (!user) {
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
+        }
+        let query = {};
+        let limit = 50;
+        let 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.dateRangeStart !== 'undefined' && typeof req.query.dateRangeEnd !== 'undefined') {
+            query = queries.getJumpsByDayQuery(
+                user._id.toString(),
+                req.query.dateRangeStart,
+                req.query.dateRangeEnd
+            );
+        } else {
+            query = queries.getJumpsByDayQuery(user._id.toString());
+        }
+
+        Jump.aggregate(query)
+        .skip(Number(offset))
+        .limit(Number(limit))
+        .exec()
+        .then(function (result) {
+            let days = result.map(function (data) {
+                return { jumps: data.jumps, count: data.count };
+            });
+            return res.json({
+                days: days,
+                daysCount: days.length
+            });
+        }).catch(next);
+    }).catch(next);
+});
+
+router.get('/allByModule', auth.required, function (req, res, next) {
+    User.findById(req.payload.id).then(function (user) {
+        if (!user) {
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
+        }
+        let limit = 120;
+        let offset = 0;
+        if (typeof req.query.limit !== 'undefined') {
+            limit = req.query.limit;
+        }
+        if (typeof req.query.offset !== 'undefined') {
+            offset = req.query.offset;
+        }
+        let query = queries.getJumpsByModuleQuery(user._id.toString());
+
+        Jump.aggregate(query)
+        .skip(Number(offset))
+        .limit(Number(limit))
+        .exec()
+        .then(function (result) {
+            let jumps = result.map(function (data) {
+                return { categorie: data._id.categorie, module: data._id.module, count: data.count };
+            });
+            return res.json({
+                jumps: jumps,
+                jumpsCount: jumps.length
+            });
+        }).catch(next);
+    }).catch(next);
+});
+
+/**
+ * return a jump from SkydiverId API
+ */
+router.get('/allFromSkydiverIdApi', auth.required, function (req, res, next) {
+    User.findById(req.payload.id).then(function (user) {
+        if (!user) {
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
+        }
+        utils.fetchSkydiverIdApi('jumps', req.query).then(result => {
+            if (result.errors === undefined) {
+                console.log(`${utils.getDateTimeISOString()}`, chalk.green(`Réception des sauts SkydiverId`));
+            } else {
+                console.log(`${utils.getDateTimeISOString()}`, chalk.red(`Une erreur ${result.errors.code} '${result.errors.type}' est survenue lors de la réception des sauts SkydiverId : ${result.errors.name} ${result.errors.message}`));
+            }
+            return res.json({
+                jumps: result,
+                jumpsCount: result.items.length
+            });
+        }).catch(next);
+    }).catch(next);
+});
 
 router.get('/feed', auth.required, function (req, res, next) {
-    var limit = 25;
-    var offset = 0;
+    let limit = 25;
+    let offset = 0;
     if (typeof req.query.limit !== 'undefined') {
         limit = req.query.limit;
     }
@@ -149,19 +304,21 @@ router.get('/feed', auth.required, function (req, res, next) {
 
     User.findById(req.payload.id).then(function (user) {
         if (!user) {
-            return res.sendStatus(401);
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
         }
-        var query = { author: { $in: user.following } };
+        let query = { author: { $in: user.following } };
         Promise.all([
             Jump.find(query)
-                .limit(Number(limit))
                 .skip(Number(offset))
+                .limit(Number(limit))
                 .populate('author')
+                .populate('files')
+                .populate('x2data')
                 .exec(),
             Jump.count(query)
         ]).then(function (results) {
-            var jumps = results[0];
-            var jumpsCount = results[1];
+            let jumps = results[0];
+            let jumpsCount = results[1];
             return res.json({
                 jumps: jumps.map(function (jump) {
                     return jump.toJSONFor(user);
@@ -176,10 +333,9 @@ router.get('/feed', auth.required, function (req, res, 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);
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
         }
         /*Jump.findOne({ slug: slug })
             .populate('author')
@@ -192,9 +348,10 @@ router.get('/last', auth.required, function (req, res, next) {
             }).catch(next);*/
         Jump.find({})
             .limit(1)
-            .skip(0)
             .sort({ numero: 'desc' })
             .populate('author')
+            .populate('files')
+            .populate('x2data')
             .exec()
             .then(function (jumps) {
                 if (!jumps) {
@@ -202,28 +359,34 @@ router.get('/last', auth.required, function (req, res, next) {
                 }
                 req.lastjump = jumps[0];
                 if (req.lastjump.author._id.toString() !== req.payload.id.toString()) {
-                    return res.sendStatus(403);
+                    return res.status(403).json({ errors: { "Forbidden": "Vous ne disposez pas des autorisations suffisantes" } });
                 }
                 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];
+    User.findById(req.payload.id).then(function (user) {
         if (!user) {
-            return res.sendStatus(401);
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
         }
         if (req.jump.author._id.toString() !== req.payload.id.toString()) {
-            return res.sendStatus(403);
+            return res.status(403).json({ errors: { "Forbidden": "Vous ne disposez pas des autorisations suffisantes" } });
         }
-        return res.json({ jump: req.jump.toJSONFor(user) });
+        Promise.all([
+            Jump.findOne({numero: (req.jump.numero - 1)}).exec(),
+            Jump.findOne({numero: (req.jump.numero + 1)}).exec(),
+        ]).then(function (results) {
+            return res.json({
+                jump: req.jump.toJSONFor(user),
+                prevJump: results[0],
+                nextJump: results[1]
+            });
+        }).catch(next);
     }).catch(next);
 });
 
@@ -231,19 +394,12 @@ router.get('/:jump', auth.required, function (req, res, 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);
+    User.findById(req.payload.id).then(function (user) {
+        //let numero = (results[1][0].numero + 1);
         if (!user) {
-            return res.sendStatus(401);
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
         }
-        var jump = new Jump(req.body.jump);
+        let jump = new Jump(req.body.jump);
         jump.author = user;
         //jump.numero = numero;
         return jump.save().then(function () {
@@ -252,19 +408,136 @@ router.post('/', auth.required, function (req, res, next) {
     }).catch(next);
 });
 
+/**
+ * save a jump file
+ */
+router.post('/data/:jump', auth.required, function (req, res, next) {
+    User.findById(req.payload.id).then(function (user) {
+        if (!user) {
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
+        }
+        if (req.jump.author._id.toString() !== req.payload.id.toString()) {
+            return res.status(403).json({ errors: { "Forbidden": "Vous ne disposez pas des autorisations suffisantes" } });
+        }
+        /*
+        console.log(req.jump.files);
+        return res.json({ jump: req.jump.toJSONFor(user) });
+        */
+        Object.assign(req.body.file, {_id: new mongoose.Types.ObjectId()});
+        let file = new JumpFile(req.body.file);
+        let files = req.jump.files ? req.jump.files : [];
+        file.author = user;
+        files.push(file);
+        return file.save().then(function () {
+            Object.assign(req.body.data, {_id: new mongoose.Types.ObjectId()});
+            let x2data = new X2DataLog(req.body.data);
+            x2data.author = user;
+            return x2data.save().then(function () {
+                req.jump.files = files;
+                req.jump.x2data = x2data;
+                Jump.updateOne({_id: req.jump._id}, {files: files, x2data: x2data._id}).then(function () {
+                    return res.json({ jump: req.jump.toJSONFor(user) });
+                }).catch(next);
+            }).catch(next);
+        }).catch(next);
+    }).catch(next);
+});
+
+/**
+ * save a jump file
+ */
+router.post('/file/:jump', auth.required, function (req, res, next) {
+    User.findById(req.payload.id).then(function (user) {
+        if (!user) {
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
+        }
+        if (req.jump.author._id.toString() !== req.payload.id.toString()) {
+            return res.status(403).json({ errors: { "Forbidden": "Vous ne disposez pas des autorisations suffisantes" } });
+        }
+        Object.assign(req.body.file, {_id: new mongoose.Types.ObjectId()});
+        let file = new JumpFile(req.body.file);
+        let files = req.jump.files ? req.jump.files : [];
+        file.author = user;
+        files.push(file);
+        return file.save().then(function () {
+            Jump.updateOne({_id: req.jump._id}, {files: files}).then(function () {
+                return res.json({ file: file.toJSONForJump() });
+            }).catch(next);
+        }).catch(next);
+    }).catch(next);
+});
+
+/**
+ * save a jump file
+ */
+router.post('/kml/:jump', auth.required, function (req, res, next) {
+    User.findById(req.payload.id).then(function (user) {
+        if (!user) {
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
+        }
+        if (req.jump.author._id.toString() !== req.payload.id.toString()) {
+            return res.status(403).json({ errors: { "Forbidden": "Vous ne disposez pas des autorisations suffisantes" } });
+        }
+        Object.assign(req.body.file, {
+            _id: new mongoose.Types.ObjectId(),
+            name: `${req.jump.x2data.name}.kml`,
+            path: `/Volumes/Storage/Skydive/X2_Kmls/${req.jump.date.getFullYear()}/`,
+            type: 'kml'
+        });
+        let file = new JumpFile(req.body.file);
+        let files = req.jump.files ? req.jump.files : [];
+        file.author = user;
+        files.push(file);
+        //console.log(chalk.yellow(`jump/${req.jump.x2data.id}/kml`));
+        return res.json({ file: file.toJSONForJump() });
+        /*
+        utils.fetchSkydiverIdApi(`jump/${req.jump.x2data.id}/kml`, {}).then(result => {
+            if (result.errors === undefined) {
+                console.log(`${utils.getDateTimeISOString()}`, chalk.green(`Réception de l'url du fichier kml SkydiverId`));
+            } else {
+                console.log(`${utils.getDateTimeISOString()}`, chalk.red(`Une erreur ${result.errors.code} '${result.errors.type}' est survenue lors de la réception de l'url du fichier kml SkydiverId : ${result.errors.name} ${result.errors.message}`));
+            }
+            if (result.url !== undefined) {
+                console.log(chalk.green(result.url));
+            } else {
+                console.log(chalk.red('result.url is undefined'));
+            }
+            return res.json({ file: file.toJSONForJump() });
+        }).catch(next);
+
+
+
+        return file.save().then(function () {
+            Jump.updateOne({_id: req.jump._id}, {files: files}).then(function () {
+                utils.fetchSkydiverIdApi(`jump/${req.jump.x2data.id}/kml`, {}).then(result => {
+                    if (result.errors === undefined) {
+                        console.log(`${utils.getDateTimeISOString()}`, chalk.green(`Réception de l'url du fichier kml SkydiverId`));
+                    } else {
+                        console.log(`${utils.getDateTimeISOString()}`, chalk.red(`Une erreur ${result.errors.code} '${result.errors.type}' est survenue lors de la réception de l'url du fichier kml SkydiverId : ${result.errors.name} ${result.errors.message}`));
+                    }
+                    if (result.url !== undefined) {
+                        console.log(result.url);
+                    } else {
+                        console.log('result.url is undefined');
+                    }
+                    return res.json({ file: file.toJSONForJump() });
+                }).catch(next);
+            }).catch(next);
+        }).catch(next);
+        */
+    }).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];
+    User.findById(req.payload.id).then(function (user) {
         if (!user) {
-            return res.sendStatus(401);
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
         }
         if (req.jump.author._id.toString() !== req.payload.id.toString()) {
-            return res.sendStatus(403);
+            return res.status(403).json({ errors: { "Forbidden": "Vous ne disposez pas des autorisations suffisantes" } });
         }
         if (typeof req.body.jump.date !== 'undefined') {
             req.jump.date = req.body.jump.date;
@@ -333,16 +606,16 @@ router.put('/:jump', auth.required, function (req, res, next) {
 router.delete('/:jump', auth.required, function (req, res, next) {
     User.findById(req.payload.id).then(function (user) {
         if (!user) {
-            return res.sendStatus(401);
+            return res.status(401).json({ errors: { "Unauthorized": "autentification requise" } });
         }
         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);
+            return res.status(403).json({ errors: { "Forbidden": "Vous ne disposez pas des autorisations suffisantes" } });
         }
     }).catch(next);
 });
 
-module.exports = router;
+module.exports = router;