512 lines
18 KiB
JavaScript
512 lines
18 KiB
JavaScript
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: {$in: interests}}};
|
|
pick = {$limit: parseInt(quantity, 10)}
|
|
} else {
|
|
match = {$match: {isVisible: true, isActive: true}};
|
|
pick = {$sample: {size: parseInt(quantity, 10)}};
|
|
}
|
|
console.log(match, pick, interests);
|
|
Ad.aggregate([
|
|
match,
|
|
pick
|
|
])
|
|
.then(data => {
|
|
return sendMessage(res, 11, data, 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);
|
|
});
|
|
}
|
|
};
|