Create: Backend branch

controllers/user.controller.js

@@ -0,0 +1,546 @@
+const db = require("../models/mongodb.model");
+const {sendError, sendMessage} = require ("../config/response.config");
+const {checkLogin, setSessionCookie} = require("../config/sessionJWT.config");
+const ObjectId = require('mongoose').Types.ObjectId;
+const roles = require("../models/objects/role.model");
+const {youtube, dailymotion} = require("../config/host.config");
+const {asyncRequest} = require("../config/functions.config");
+const User = db.users;
+const Video = db.videos;
+const Ad = db.ads;
+
+// Authenticate a User
+exports.auth = (req, res) => {
+  // Validate request
+  if (!req.body.email || !req.body.hashPass) {
+    sendError(res, 400,-1,"Content can not be empty . (email and hashPass needed)");
+  } else{
+    // Check User in the database
+    User
+      .findOne({email: req.body.email, hashPass: req.body.hashPass, isActive: true, "role.isAccepted": true}, {role: true, profileImageUrl: true})
+      .then(data => {
+        if (data !== null){
+          User.findByIdAndUpdate(data._id.toString(), {lastConnexion: new Date()}, {useFindAndModify: false},
+            function (err) {
+              if (err){
+                return sendError(res, 400, 100,err.message || "Some error occurred while updating the User.");
+              }
+              else{
+                const dataRes = {id: data._id.toString(), email: req.body.email, profileImageUrl: data.profileImageUrl, role: data.role};
+                setSessionCookie(req, res, dataRes);
+                return sendMessage(res, 1, dataRes);
+              }
+            });
+        } else {
+          setSessionCookie(req, res, {id: -1, email: -1, profileImageUrl: -1, role: -1});
+          return sendError(res, 500, 101, "Invalid login or password.");
+        }
+      })
+      .catch(err => {
+        return sendError(res, 400, 100,err.message || "Some error occurred while authenticating the User.");
+      });
+  }
+};
+
+// Logout a User
+exports.logout = (req, res) => {
+  const token = checkLogin(req, res);
+  if(token){
+    setSessionCookie(req, res, {id: -1, email: -1, profileImageUrl: -1, role: -1});
+    return sendMessage(res, 2, {message: "User disconnected"});
+  }
+};
+
+// Request password reset with email
+exports.resetPass = (req, res) => {
+  return sendError(res, 501, -1, "User.resetPass not Implemented", null);
+};
+
+// Create and Save a new User
+exports.create = (req, res) => {
+  // Validate request
+  if (!req.body.email || !req.body.hashPass || !req.body.login) {
+    sendError(res, 400,-1,"Content can not be empty . (email, hashPass and login needed");
+  }
+  else{
+    User.exists({email: req.body.email}, function (err, docs){
+      if(err){
+        sendError(res, 500,100,err.message || "Some error occurred while checking if the User already exists.");
+      } else{
+        if(docs === null) {
+          let user;
+          let var_role;
+          if(typeof req.body.role !== 'undefined'){
+            switch(req.body.role){
+              case 'admin':
+                var_role = roles.Admin;
+                break;
+              case 'advertiser':
+                var_role = roles.Advertiser;
+                break;
+              default:
+                var_role = roles.User;
+            }
+          } else{
+            var_role = roles.User;
+          }
+
+          user = new User({
+            email: req.body.email,
+            hashPass: req.body.hashPass,
+            login: req.body.login,
+            role: var_role,
+            company: req.body.company ? req.body.company : null,
+            dateOfBirth: req.body.dateOfBirth ? req.body.dateOfBirth : null,
+            gender: req.body.gender ? req.body.gender : null,
+            interests: req.body.interests ? req.body.interests : null,
+          });
+
+          // Save User in the database
+          user
+            .save(user)
+            .then(data => {
+              data.hashPass = undefined; // Hiding hashPass on return
+              return sendMessage(res, 4, data)
+            })
+            .catch(err => {
+              return sendError(res, 500,100,err.message || "Some error occurred while creating the User.");
+            });
+        } else{
+          return sendError(res, 500, 104, err || `Email ${req.body.email} already exists.`);
+        }
+      }
+    });
+  }
+};
+
+// Retrieve all Users from the database if at least admin.
+exports.findAll = (req, res) => {
+  const token = checkLogin(req, res, roles.Admin);
+  if(token){
+    let query = {};
+    let condition;
+
+    const ids = req.query.userId;
+    condition = ids ? {$in: ids} : undefined;
+    query._id = condition;
+
+    const email = req.query.email;
+    condition = email ? { $regex: new RegExp(email), $options: "i" } : undefined;
+    query.email = condition;
+
+    const login = req.query.login;
+    condition = login ? { $regex: new RegExp(login), $options: "i" } : undefined;
+    query.login = condition;
+
+    const role = req.query.role;
+    condition = role ? role : undefined;
+    query["role.name"] = condition;
+
+    const company = req.query.company;
+    condition = company ? { $regex: new RegExp(company), $options: "i" } : undefined;
+    query.company = condition;
+
+    const dateOfBirth = req.query.dateOfBirth;
+    condition = dateOfBirth ? new Date(dateOfBirth) : undefined;
+    query.dateOfBirth = condition;
+
+    const gender = req.query.gender;
+    condition = gender ? gender : undefined;
+    query.gender = condition;
+
+    const isActive = req.query.isActive;
+    condition = isActive ? isActive : undefined;
+    query.isActive = condition;
+
+    const isAccepted = req.query.isAccepted;
+    if(isAccepted !== 'undefined'){
+      switch (isAccepted){
+        case 'true':
+          condition = true;
+          break;
+        case 'false':
+          condition = false;
+          break;
+      }
+    }
+    query["role.isAccepted"] = condition;
+
+    const sort = req.query.sort;
+    if(sort !== 'undefined'){
+      switch (sort){
+        case 'asc':
+          condition = {email: 1};
+          break;
+        case 'desc':
+          condition = {email: -1};
+          break;
+        case 'lastConnexionAsc':
+          condition = {lastConnexion: 1};
+          break;
+        case 'lastConnexionDesc':
+          condition = {lastConnexion: -1};
+          break;
+        case 'createdAtAsc':
+          condition = {createdAt: 1};
+          break;
+        case 'createdAtDesc':
+          condition = {createdAt: -1};
+          break;
+        case 'updatedAtAsc':
+          condition = {updatedAt: 1};
+          break;
+        case 'updatedAtDesc':
+          condition = {updatedAt: -1};
+          break;
+        default:
+          condition = {email: 1};
+      }
+    }
+    const query_sort = {sort: condition};
+
+    // Remove undefined key
+    Object.keys(query).forEach(key => query[key] === undefined ? delete query[key] : {});
+    console.log(query);
+
+    User.find(query, {hashPass: false}, query_sort)
+      .then(data => {
+        return sendMessage(res, 5, data, token);
+      })
+      .catch(err => {
+        return sendError(res,500,100,err.message || "Some error occurred while retrieving users.", token);
+      });
+  }
+};
+
+// Find a single User by session id
+exports.findOne = (req, res) => {
+  const token = checkLogin(req, res);
+  if(token && typeof req.params.id !== 'undefined') {
+    let id = null;
+    if(typeof token.id !== 'undefined' && token.id === req.params.id){
+      id = req.params.id;
+    } else {
+      if(typeof token.role !== 'undefined' &&
+        typeof token.role.permission !== 'undefined' &&
+        typeof token.role.isAccepted !== 'undefined' &&
+        token.role.isAccepted === true &&
+        token.role.permission >= roles.Admin.permission) {
+        id = req.params.id;
+      } else {
+        return sendError(res, 500, 106, `User do not have the permission.`, token);
+      }
+    }
+    if(id && ObjectId.isValid(id)){
+      User.findById(id, {hashPass: false})
+        .then(data => {
+          if(data){
+            return sendMessage(res, 6, data, token);
+          } else {
+            return sendError(res,404,105,`User not found with id=${id}`, token);
+          }
+        })
+        .catch(err => {
+          return sendError(res,500,100,err.message || `Some error occurred while finding the User with id=${id}`, token);
+        });
+    } else {
+      sendError(res, 500, -1, `Error id is not valid`, token);
+    }
+  } else {
+    return sendError(res, 500, -1, `No id given`, token);
+  }
+};
+
+// Update a User by the id in the request
+exports.update = (req, res) => {
+  const token = checkLogin(req, res);
+  if(token && typeof req.params.id !== 'undefined') {
+    let id = null;
+    if(typeof token.id !== 'undefined' && token.id === req.params.id){
+      id = req.params.id;
+    } else {
+      if(typeof token.role !== 'undefined' &&
+        typeof token.role.permission !== 'undefined' &&
+        typeof token.role.isAccepted !== 'undefined' &&
+        token.role.isAccepted === true &&
+        token.role.permission >= roles.Admin.permission) {
+        id = req.params.id;
+      } else {
+        return sendError(res, 500, 106, `User do not have the permission.`, token);
+      }
+    }
+    if(id && ObjectId.isValid(id)){
+      let update = null;
+      if(typeof req.body._id !== 'undefined' || typeof req.body.id !== 'undefined'){
+        return sendError(res, 500, -1, `User do not have the permission to modify id or _id`, token);
+      } else{
+        if(typeof req.body.role !== 'undefined' ||
+          typeof req.body.isActive !== 'undefined' ||
+          typeof req.body.lastConnexion !== 'undefined' ||
+          typeof req.body.createdAt !== 'undefined'||
+          typeof req.body.updatedAt !== 'undefined'){
+          if(typeof token.role !== 'undefined' &&
+            typeof token.role.permission !== 'undefined' &&
+            typeof token.role.isAccepted !== 'undefined' &&
+            token.role.isAccepted === true &&
+            token.role.permission >= roles.Admin.permission) {
+            update = true;
+          } else{
+            return sendError(res, 500, 106, `User do not have the permission to modify these keys.`, token);
+          }
+        } else{
+          update = true;
+        }
+      }
+      if(update === true){
+        User.findByIdAndUpdate(id, req.body, {useFindAndModify: false})
+          .then(data => {
+            if(data) {
+              data.hashPass = undefined;
+              Object.keys(req.body).forEach(key => data[key] = req.body[key]);
+              sendMessage(res, 7, data, token);
+            } else {
+              sendError(res, 404, -1, `User not found with id=${id}`, token);
+            }
+          })
+          .catch(err => {
+            sendError(res, 500, -1, err.message || `Some error occurred while updating the User with id=${id}`, token);
+          });
+      }
+    } else {
+      sendError(res, 500, -1, `Error id is not valid`, token);
+    }
+  } else {
+    return sendError(res, 500, -1, `No id given`, token);
+  }
+};
+
+
+
+// Delete a User with the specified id in the request
+exports.delete = (req, res) => {
+  const token = checkLogin(req, res);
+  if(token && typeof req.params.id !== 'undefined') {
+    let id = null;
+    if(typeof token.id !== 'undefined' && token.id === req.params.id){
+      id = req.params.id;
+    } else {
+      if(typeof token.role !== 'undefined' &&
+        typeof token.role.permission !== 'undefined' &&
+        typeof token.role.isAccepted !== 'undefined' &&
+        token.role.isAccepted === true &&
+        token.role.permission >= roles.Admin.permission) {
+        id = req.params.id;
+      } else {
+        return sendError(res, 500, 106, `User do not have the permission.`, token);
+      }
+    }
+    if(id && ObjectId.isValid(id)){
+      User.findByIdAndUpdate(id, {isActive: false}, {useFindAndModify: false})
+        .then(data => {
+          if(data) {
+            return sendMessage(res, 8, {message: `User ${id} was successfully deleted.`}, token);
+          } else {
+            return sendError(res, 404, 105, `User not found with id=${id}`, token);
+          }
+        })
+        .catch(err => {
+          return sendError(res, 500, 100, err.message || `Some error occurred while deleting the User with id=${id}`, token);
+        });
+    } else {
+      return sendError(res, 500, -1, `Error id is not valid`, token);
+    }
+  } else {
+    return sendError(res, 500, -1, `No id given`, token);
+  }
+};
+
+// Delete all Users from the database except superAdmin
+exports.deleteAll = (req, res) => {
+  const token = checkLogin(req, res, roles.SuperAdmin);
+  if(token) {
+    User.deleteMany({login: {$ne: "superAdmin"}})
+      .then(data => {
+        return sendMessage(res, 9, {
+          message: `${data.deletedCount} Users were deleted successfully.`
+        });
+      })
+      .catch(err => {
+        return sendError(res, 500, 100, err.message || "Some error occurred while removing all Users.");
+      });
+  }
+};
+
+// Get all Roles depending on the role of the User
+exports.roles = (req, res) => {
+  const token = checkLogin(req, res);
+  if(token){
+    return sendMessage(res, 10, roles, token);
+  }
+};
+
+// Get 1 or multiple ad adapted to the User session id
+exports.ad = (req, res) => {
+  const token = checkLogin(req, res);
+  if(token && typeof req.query.quantity !== 'undefined'){
+    const id = token.id;
+    const quantity = req.query.quantity;
+    // Interests from the user and from last 20 videos viewed if no ad matches -> find x ad from these interests + add date view to the ad
+    let interests = [];
+    const maxInterests = 20;
+    let limit = maxInterests;
+    User.findById(id, {_id: false, interests: true})
+      .then(data => {
+        if(typeof data.interests !== 'undefined' && data.interests !== null){
+          interests = interests.concat(data.interests);
+          limit = maxInterests-data.interests.length;
+        }
+        Video.aggregate([
+          {$match: {userId: id}},
+          {$project: {_id: false, interest: true}},
+          {$sort: {watchedDates: -1}},
+          {$limit: limit},
+          {$unwind: '$interest'},
+          {$group: {_id: null, interests: {$push: '$interest'}}}
+        ])
+          .then(data => {
+            if(typeof data[0] !== 'undefined' &&
+              typeof data[0].interests !== 'undefined' &&
+              data[0].interests !== [] &&
+              data[0].interests !== null){
+              interests = interests.concat(data[0].interests);
+            }
+            let match, pick;
+            if(interests.length > 0){
+              match = {$match: {isVisible: true, isActive: true, interests: {$elemMatch: {interest: {$in: interests}}}}};
+              pick = {$limit: parseInt(quantity, 10)}
+            } else {
+              match = {$match: {isVisible: true, isActive: true}};
+              pick = {$sample: {size: parseInt(quantity, 10)}};
+            }
+
+            Ad.aggregate([
+                match,
+                pick
+            ])
+              .then(data => {
+                if(data.length > 0){
+                  let ids = []
+                  for(const i in data){ids.push(data[i]._id);}
+                  Ad.updateMany({_id: {$in: ids}}, {$push: {views: [new Date()]}}, {timestamps: false})
+                    .then(dataUpdate => {
+                      if(dataUpdate && dataUpdate.modifiedCount > 0){
+                        return sendMessage(res, 11, data, token);
+                      } else {
+                        return sendError(res,500,101,`Some error occurred while updating ${quantity} ad(s) for the User.`, token);
+                      }
+                    })
+                    .catch(err => {
+                      return sendError(res,500,101,err.message || `Some error occurred while updating ${quantity} ad(s) for the User.`, token);
+                    });
+                } else {
+                  Ad.aggregate([{$match: {isVisible: true, isActive: true}}, {$sample: {size: parseInt(quantity, 10)}}])
+                    .then(data => {
+                      let ids = []
+                      for(const i in data){ids.push(data[i]._id);}
+                      Ad.updateMany({_id: {$in: ids}}, {$push: {views: [new Date()]}}, {timestamps: false})
+                        .then(dataUpdate => {
+                          if(dataUpdate && dataUpdate.modifiedCount > 0){
+                            return sendMessage(res, 11, data, token);
+                          } else {
+                            return sendError(res,500,101,`Some error occurred while updating ${quantity} ad(s) for the User.`, token);
+                          }
+                        })
+                        .catch(err => {
+                          return sendError(res,500,101,err.message || `Some error occurred while updating ${quantity} ad(s) for the User.`, token);
+                        });
+                    })
+                    .catch(err => {
+                      return sendError(res,500,101,err.message || `Some error occurred while getting ${quantity} ad(s) for the User.`, token);
+                    });
+                }
+              })
+              .catch(err => {
+                return sendError(res,500,101,err.message || `Some error occurred while getting ${quantity} ad(s) for the User.`, token);
+              });
+          })
+          .catch(err => {
+            return sendError(res,500,102,err.message || `Some error occurred while getting ${quantity} ad(s) for the User.`, token);
+          });
+      })
+      .catch(err => {
+        return sendError(res,500,100,err.message || `Some error occurred while getting ${quantity} ad(s) for the User.`, token);
+      });
+  }  else {
+    sendError(res, 500, -1, `No quantity given`, token);
+  }
+};
+
+// Get History
+exports.history = (req, res) => {
+  const token = checkLogin(req, res);
+  if(token){
+    const id = token.id;
+
+    Video.aggregate([
+        {$match: {userId: id, $expr: {$gt: [{$size: "$watchedDates"}, 0]}}},
+        {$limit: 300},
+        {$project: {
+          videoId: true,
+          source: true,
+          tags: true,
+          interest: true,
+          views: {$size: '$watchedDates'},
+          watchedDate: {$arrayElemAt: ["$watchedDates", -1]},
+          createdAt: true,
+          updatedAt: true
+        }},
+        {$sort: {watchedDate: -1}}])
+      .then(async data => {
+        let yt_results = [];
+        let dm_results = [];
+        let yt_videoIds = "";
+        let dm_videoIds = "";
+
+        for(const i in data) {
+          if(data[i].source === youtube.name) {
+            yt_videoIds = yt_videoIds + data[i].videoId + ",";
+          } else if (data[i].source === dailymotion.name) {
+            dm_videoIds = dm_videoIds + data[i].videoId + ",";
+          }
+        }
+        if(yt_videoIds !== ""){
+          const uri = youtube.baseAPIUrl + '/videos' + '?part=snippet&part=statistics&id=' + yt_videoIds.slice(0, -1) + '&key=' + youtube.YOUTUBE_API_KEY;
+          const dataVideos = await asyncRequest(uri, {});
+          if (dataVideos.response.statusCode === 200 && dataVideos.body.items.length > 0) {
+            yt_results = dataVideos.body.items;
+          }
+        }
+
+        if(dm_videoIds !== ""){
+          const uri = dailymotion.baseAPIUrl + '/videos?ids='+dm_videoIds.slice(0, -1)+'&fields=thumbnail_480_url%2Ctitle%2Cid';
+          const data = await asyncRequest(uri, {});
+          const response = data.response;
+          const jsonBody = data.body;
+          if(response.statusCode === 200){
+            dm_results = jsonBody.list;
+          }
+        }
+        for(const i in data) {
+          if(data[i].source === youtube.name) {
+            const obj = yt_results.filter(obj => obj.id === data[i].videoId);
+            data[i].imageUrl = obj[0].snippet.thumbnails.medium.url ? obj[0].snippet.thumbnails.medium.url : null;
+            data[i].title =  obj[0].snippet.title  ?  obj[0].snippet.title : null;
+          } else if (data[i].source === dailymotion.name) {
+            const obj = dm_results.filter(obj => obj.id === data[i].videoId);
+            data[i].imageUrl = obj[0].thumbnail_480_url ? obj[0].thumbnail_480_url : null;
+            data[i].title =  obj[0].title ? obj[0].title : null;
+          }
+        }
+        return sendMessage(res, 12, data, token)
+      })
+      .catch(err => {
+        return sendError(res,500,100,err.message || "Some error occurred while getting the User history.", token);
+      });
+  }
+};