server.js

// Server
//
var express = require("express");
var path = require("path");
var bodyParser = require("body-parser");
var mongodb = require("mongodb");
var ObjectID = mongodb.ObjectID;

var RKYAI_COLLECTION = "informations";

var app = express();
app.use(express.static(__dirname + "/public"));
app.use(bodyParser.json());

// Create a database variable outside of the database connection callback to reuse the connection pool in your app.
var db;

// Connect to the database before starting the application server.
mongodb.MongoClient.connect(process.env.MONGODB_URI, function (err, database) {
  if (err) {
    console.log(err);
    process.exit(1);
  }

  // Save database object from the callback for reuse.
  db = database;
  console.log("Database connexion OK");

  // Initialize the app.
  var server = app.listen(process.env.PORT || 8080, function () {
    var port = server.address().port;
    console.log("App en cours d'execution sur le port", port);
  });
});

// API ROUTES

// Error handler pour les endpoints.
function handleError(res, cause, message, code) {
  console.log("ERREUR: " + cause);
  res.status(code || 500).json({"erreur": message});
}

/*  "/api/v1"
 *    GET: finds all contacts
 *    POST: creates a new contact
 */
// GET tous les records
app.get("/api/v1/all", function(req, res) {
  db.collection(RKYAI_COLLECTION).find({}).toArray(function(err, docs) {
    if (err) {
      handleError(res, err.message, "Erreur pour recuperer les infos.");
    } else {
      res.status(200).json(docs);
    }
  });
});
// GET des records="map"
app.get("/api/v1/map", function(req, res) {
  db.collection(RKYAI_COLLECTION).find({ record:"map"}).toArray(function(err, docs) {
    if (err) {
      handleError(res, err.message, "Erreur pour recuperer les infos.");
    } else {
      res.status(200).json(docs);
    }
  });
});

// get tous les usedId de pseudo
app.get("/api/v1/liste/pseudo", function(req, res) {
  db.collection(RKYAI_COLLECTION).find( { "profil.user":"Python_Test"  } ).toArray(function(err, doc) {
      if (err) {
         handleError(res, err.message, "Failed to find liste de user");
     } else {
         res.status(200).json(doc);
      }
  });
});
// get tous les usedId de pseudo
app.get("/api/v1/liste/alerte", function(req, res) {
  db.collection(RKYAI_COLLECTION).find( { "etat": req.query.etat  } ).toArray(function(err, doc) {
      if (err) {
         handleError(res, err.message, "Failed to find liste de user");
     } else {
         res.status(200).json(doc);
      }
  });
});

//-------------------------------------
//Creation d'un nouvel utilisateur
app.post("/api/v1/map", function(req, res) {
  var newUser = req.body;
  var Crypto = require("crypto-js");
  var d = new Date();
//    newUser.profil.UTC = d.getTime();
    newUser.profil.date = d.toJSON();
  var words = Crypto.SHA256(req.body.user+d.toUTCString());
  var plaintext = words.toString(Crypto.enc.base64);
  newUser.userId = plaintext;
  newUser.profil.latitude = req.body.latitude;
  newUser.profil.longitude = req.body.longitude;
  newUser.etat = "safe";
  newUser.record = "map";
  newUser.type = "user";
  newUser.lastUser = newUser.profil.date;

  if (!(req.body.user || req.body.latitude)) {
    handleError(res, "Donnees Invalides", "Doit comporter la source et/ou localisation.", 400);
  }

  db.collection(RKYAI_COLLECTION).insertOne(newUser, function(err, doc) {
    if (err) {
      handleError(res, err.message, "Impossible de creer nouveau user");
    } else {
      res.status(201).json(doc.ops[0]);
    }
  });
});
//-------------------------------------
//Creation d'une nouvelle alerte
// userId+Longitude+latitude+etat
app.post("/api/v1/alerte", function(req, res) {
  var newAlert = req.body;
  var d = new Date();
  newAlert.record = "alerte";
  newAlert.type = "user";

  db.collection(RKYAI_COLLECTION).insertOne(newAlert, function(err, doc) {
    if (err) {
      handleError(res, err.message, "Impossible de creer nouvelle alerte");
    } else {
      res.status(201).json(doc.ops[0]);
    }
  });
});
/*  "/api/v1/contacts/:id"
 *    GET: find contact by id
 *    PUT: update contact by id
 *    DELETE: deletes contact by id
 */

app.get("/api/v1/id/:id", function(req, res) {
  db.collection(RKYAI_COLLECTION).findOne({ _id: new ObjectID(req.params.id) }, function(err, doc) {
    if (err) {
      handleError(res, err.message, "Failed: impossible de recuperer le user");
    } else {
      res.status(200).json(doc);
    }
  });
});
app.get("/api/v1/user/:id", function(req, res) {
  db.collection(RKYAI_COLLECTION).findOne({ "userId": req.params.id, "record":"map" }, function(err, doc) {
    if (err) {
      handleError(res, err.message, "Failed: impossible de recuperer le user");
    } else {
      res.status(200).json(doc);
    }
  });
});
app.get("/api/v1/liste/user", function(req, res) {
        db.collection(RKYAI_COLLECTION).distinct( "userId" , function(err, doc) {
            if (err) {
                handleError(res, err.message, "Failed to find liste");
            } else {
                res.status(200).json(doc);
            }
    });
});
app.get("/api/v1/liste/id", function(req, res) {
        db.collection(RKYAI_COLLECTION).distinct( _id , function(err, doc) {
            if (err) {
                handleError(res, err.message, "Failed to find liste");
            } else {
                res.status(200).json(doc);
            }
    });
});
app.get("/api/v1/liste/type", function(req, res) {
        db.collection(RKYAI_COLLECTION).distinct( "type" , function(err, doc) {
            if (err) {
                handleError(res, err.message, "Failed to find liste");
            } else {
                res.status(200).json(doc);
            }
    });
});
app.get("/api/v1/liste/etat", function(req, res) {
        db.collection(RKYAI_COLLECTION).distinct( "etat" , function(err, doc) {
            if (err) {
                handleError(res, err.message, "Failed to find liste");
            } else {
                res.status(200).json(doc);
            }
    });
});
app.get("/api/v1/liste/record", function(req, res) {
        db.collection(RKYAI_COLLECTION).distinct( "record" , function(err, doc) {
            if (err) {
                handleError(res, err.message, "Failed to find liste");
            } else {
                res.status(200).json(doc);
            }
    });
});
app.get("/api/v1/search", function(req, res) {
    if (req.query.user == "*" || ( typeof req.query.user == 'undefined')) { user = { $regex: /\w|/, $options:"i"} } else { user = req.query.user }
    if (req.query.record == "*" || (typeof req.query.record == 'undefined')) { record = { $regex: /\w|/, $options:"i"} } else { record = req.query.record }
    if (req.query.etat == "*" || (typeof req.query.etat == 'undefined')) { etat = { $regex: /\w|/, $options:"i"} } else { etat = req.query.etat }
    if (req.query.type == "*" || (typeof req.query.type == 'undefined')) { type = { $regex: /\w|/, $options:"i"} } else { type = req.query.type }
//    if (typeof req.query.before == 'undefined') { before = ObjectID(Math.floor((new Date('2100/12/31'))/1000).toString(16) + "0000000000000000") } else { before = ObjectID(Math.floor((new Date(req.query.before))/1000 - 7200).toString(16) + "0000000000000000") }
//    if (typeof req.query.after == 'undefined') { after = ObjectID(Math.floor((new Date('2016/01/01'))/1000).toString(16) + "0000000000000000") } else { after = ObjectID(Math.floor((new Date(req.query.after))/1000 - 7200).toString(16) + "0000000000000000") }
//    if (typeof req.query.filtre == 'undefined') { filtre = {} } else { if (req.query.filtre == "name") { filtre = {name: 1, value:  1, _id: 0} } else {filtre = { value: 1 , _id: 0 } } }
    
  selection = { userId: user, record: record, etat: etat, type: type }; //, _id: {$lt: before, $gt: after}} ;
  filtre = { latitude:1,longitude:1,etat:1,_id:0};

//  console.log("before = "+before+"  after : "+after);
  
    db.collection(RKYAI_COLLECTION).find( selection , filtre ).toArray( function(err, doc) {
        if (err) {
            handleError(res, err.message, "Failed to find contact");
        } else {
            res.status(200).json(doc);
        }
    });
});
//-------------------------------------
//MAJ d'un utilisateur
// :id -> userId
app.put("/api/v1/map/:id", function(req, res) {
  var updateDoc = req.body;
  var SHA3 = require("crypto-js/sha3");
  delete updateDoc._id;
  delete updateDoc.userId;
  var d = new Date();
//    updateDoc.date = d.toUTCString();
//    updateDoc.UTC = d.getTime();
  if (req.body.type=="user") {
    updateDoc.lastUser = d.toJSON();
  }
//  db.collection(RKYAI_COLLECTION).updateOne({_id: new ObjectID(req.params.id)}, { $set: {"latitude":req.body.latitude , "longitude":req.body.longitude, "niveau":req.body.niveau, "date": updateDoc.date, "UTC": updateDoc.UTC, "json": updateDoc.json }, $currentDate: { lastModified: true } }, function(err, doc) {
  db.collection(RKYAI_COLLECTION).updateOne({"userId": req.params.id}, { $set: updateDoc, $currentDate: { lastModified: true } }, function(err, doc) {
    if (err) {
      handleError(res, err.message, "Failed: impossible de mettre à jour le user");
    } else {
      res.status(204).json(doc); //end();
    }
  });
});

app.delete("/api/v1/user/:id", function(req, res) {
  db.collection(RKYAI_COLLECTION).deleteOne({"userId": req.params.id, "record": "map" }, function(err, result) {
    if (err) {
      handleError(res, err.message, "Failed: impossible d'effacer le user");
    } else {
      res.status(204).end();
    }
  });
});