const { Op, QueryTypes } = require("sequelize"); const pug = require("pug"); const striptags = require("striptags"); const config = require("../config/main.js"); const configQuestionnaires = require("../config/questionnaires.js"); const tool = require("../tools/main"); const toolError = require("../tools/error"); const toolFile = require("../tools/file"); const questionnaireCtrl = require("./questionnaire"); const userCtrl = require("./user"); const txtGeneral = require("../lang/"+config.adminLang+"/general"); const txtGroups = require("../lang/"+config.adminLang+"/group"); exports.create = async (req, res, next) => { try { const db = require("../models/index"); req.body.CreatorId=req.connectedUser.User.id; const group=await db["Group"].create({ ...req.body }, { fields: ["title", "slug", "introduction", "publishingAt", "language", "CreatorId"] }); creaGroupJson(group.id); res.status(201).json({ message: txtGeneral.addedOkMessage, id: group.id }); next(); } catch(e) { const returnAPI=toolError.returnSequelize(e); if(returnAPI.messages) { res.status(returnAPI.status).json({ errors : returnAPI.messages }); next(); } else next(e); } } exports.modify = async (req, res, next) => { try { const db = require("../models/index"); const group=await searchGroupById(req.params.id); if(!group) { const Err=new Error; error.status=404; error.message=txtGroups.notFound.replace("#SEARCH", req.params.id); throw Err; } else if(req.connectedUser.User.status==="creator" && req.connectedUser.User.id!==group.CreatorId) res.status(401).json({ errors: txtGeneral.notAllowed }); else await db["Group"].update({ ...req.body }, { where: { id : req.params.id } , fields: ["title", "slug", "introduction", "publishingAt", "language"], limit:1 }); await creaGroupJson(req.params.id); res.status(200).json({ message: txtGeneral.updateOkMessage }); next(); } catch(e) { const returnAPI=toolError.returnSequelize(e); if(returnAPI.messages) { res.status(returnAPI.status).json({ errors : returnAPI.messages }); next(); } else next(e); } } exports.delete = async (req, res, next) => { try { const db = require("../models/index"); const group=await searchGroupById(req.params.id); if(!group) { const Err=new Error; error.status=404; error.message=txtGroups.notFound.replace("#SEARCH", req.params.id); throw Err; } else if(req.connectedUser.User.status==="creator" && req.connectedUser.User.id!==group.CreatorId) res.status(401).json({ errors: txtGeneral.notAllowed }); else { // La suppression sera bloquée par SQL si des quizs dépendent de ce groupe // Donc il faut d'abord supprimer tous les quizs du groupe : for(let i in group.Questionnaires) await questionnaireCtrl.deleteQuestionnaireById(group.Questionnaires[i].id); const nb=await db["Group"].destroy( { where: { id : req.params.id }, limit:1 }); if(nb===1) { toolFile.deleteJSON(configQuestionnaires.dirCacheGroups, req.params.id); toolFile.deleteFile(configQuestionnaires.dirHTMLGroups, group.Group.slug+".html"); creaStatsGroupsJson(); res.status(200).json({ message: txtGeneral.deleteOkMessage }); } else { const Err=new Error; error.status=404; error.message=txtGroups.deleteFailMessage.replace("#ID", req.params.id); throw Err; } } next(); } catch(e) { next(e); } } // Recherche par mots-clés parmis tous les groupes (y compris ceux non publiés). // Le rank le + élevé des éléments déjà enregistrés dans le groupe permet de placer le nouveau. exports.searchGroups = async (req, res, next) => { try { let search=tool.trimIfNotNull(req.body.searchGroups); if(search === null || search === "" || search.length < configQuestionnaires.searchGroups.minlength) res.status(400).json(txtGroups.searchIsNotLongEnough.replace("#MIN", configQuestionnaires.searchGroups.minlength)); else { const db = require("../models/index"); const getGroups=await db.sequelize.query("SELECT `Groups`.`id`,`Groups`.`title`, MAX(`Questionnaires`.`rankInGroup`) as maxRank FROM `Groups` LEFT JOIN `Questionnaires` ON `Questionnaires`.`GroupId` = `Groups`.`id` WHERE `Groups`.`title` LIKE :search OR `Groups`.`introduction` LIKE :search GROUP BY `Groups`.`id` ORDER BY `Groups`.`title` ASC", { replacements: { search: "%"+search+"%" }, type: QueryTypes.SELECT }); res.status(200).json(getGroups); } next(); } catch(e) { next(e); } } exports.getOneById = async (req, res, next) => { try { const datas=await searchGroupById(req.params.id, true); if(datas) res.status(200).json(datas); else res.status(404).json({ message:txtGroups.notFound.replace("#SEARCH", req.params.id) }); next(); } catch(e) { next(e); } } exports.showOneGroupById = async (req, res, next) => { try { // Seuls certains utilisateurs peuvent avoir accès à cette page const connectedUser=await userCtrl.checkTokenUser(req.params.token); if(connectedUser===false) res.status(403).json({ errors:txtGeneral.failAuthToken }); else { if(["admin", "manager", "creator"].indexOf(connectedUser.User.status) === -1) res.status(403).json({ errors:txtGeneral.notAllowed }); else { const HTML=await creaGroupHTML(req.params.id, true); if(HTML) { res.setHeader("Content-Type", "text/html"); res.send(HTML); } else res.status(404).json({ errors:txtGeneral.notFound.replace("#SEARCH", req.params.id) }); } } next(); } catch(e) { next(e); } } // Retourne les statistiques concernant les groupes de questionnaires exports.getStats = async(req, res, next) => { try { const stats=await getStatsGroups(); res.status(200).json(stats); } catch(e) { next(e); } } // (Re)génère tous les fichiers HTML des groupes // La requête est ensuite passé aux tags qui font la même chose exports.HTMLRegenerate= async (req, res, next) => { try { const nb=await checkGroupsNeedToBePublished(true); res.messageToNext=txtGroups.haveBeenPublished.replace("#NB", nb); next(); } catch(e) { next(e); } } // CRONS // Supprime fichiers json de groupes n'existant plus. exports.cronDeleteJsonFiles = async (req, res, next) => { try { const db = require("../models/index"); const groups=await db["Group"].findAll({ attributes: ["id"] }); let saveFiles=["stats.json"];// dans le même répertoire et à garder. for(let i in groups) saveFiles.push(groups[i].id+".json"); const deleteFiles = await toolFile.deleteFilesInDirectory(configQuestionnaires.dirCacheGroups, saveFiles); res.status(200).json(deleteFiles); next(); } catch(e) { next(e); } } // Teste si des groupes doivent être publiés exports.cronCheckGroupsNeedToBePublished = async (req, res, next) => { try { console.log("Je teste si des groupes doivent être publiés"); const nb=await checkGroupsNeedToBePublished(); res.status(200).json(txtGroups.haveBeenPublished.replace("#NB", nb)); console.log(txtGroups.haveBeenPublished.replace("#NB", nb)); next(); } catch(e) { next(e); } } // FONCTIONS PARTAGÉES const creaGroupJson = async (id) => { const db = require("../models/index"); const Group=await db["Group"].findByPk(id); if(Group) { let datas={ Group }; const Questionnaires=await db["Questionnaire"].findAll({ where: { GroupId: Group.id, isPublished : true }, order: [["rankInGroup", "ASC"], ["createdAt", "ASC"]], attributes: ["id"] }); if(Questionnaires) datas.Questionnaires=Questionnaires; await toolFile.createJSON(configQuestionnaires.dirCacheGroups, id, datas); // Si le groupe est publiable on génère/actualise la page HTML : if(checkGroupIsPublishable(datas)) await creaGroupHTML(id);// !!! await important car sinon bug, plusieurs fonctions accédant au même fichier (à revoir car pas clair !) else // dans le cas contraire, on supprime l'éventuel fichier préexistant toolFile.deleteFile(configQuestionnaires.dirHTMLGroups, Group.slug+".html"); // Dans certains cas les fichiers HTML des quizs du groupe peuvent aussi être impactés (notamment le dernier) for(let i in Questionnaires) await questionnaireCtrl.creaQuestionnaireHTML(Questionnaires[i].id, false); // + mise à jour des statistiques : creaStatsGroupsJson(); return datas; } else return false; } exports.creaGroupJson = creaGroupJson; const checkGroupIsPublishable = (datas, checkDate=true) => { if(checkDate) { if(datas.Group.publishingAt === null) return false; else { const today=new Date(); today.setHours(0,0,0,0);// !! attention au décalage horaire du fait de l'enregistrement en UTC dans mysql const publishingAt=new Date(datas.Group.publishingAt); if (publishingAt.getTime() > today.getTime()) return false; } } if(datas.Questionnaires === undefined || datas.Questionnaires.length < config.nbQuestionnairesByGroupMin) return false; return true; } const creaGroupHTML = async (id, preview = false) => { const group=await searchGroupById(id, true); if(!group) return false; if(group.isPublishable === false && preview === false) return false; const txtIllustration = require("../lang/"+config.adminLang+"/illustration"); const txtQuestionnaire = require("../lang/"+config.adminLang+"/questionnaire"); const compiledFunction = pug.compileFile("./views/"+config.theme+"/quiz-group.pug"); const configTpl = require("../views/"+config.theme+"/config/"+config.availableLangs[0]+".js"); const pageDatas = { config: config, configQuestionnaires: configQuestionnaires, configTpl: configTpl, tool: tool, txtGeneral: txtGeneral, txtGroups: txtGroups, txtIllustration: txtIllustration, txtQuestionnaire: txtQuestionnaire, pageLang: group.Group.language, metaDescription: tool.shortenIfLongerThan(config.siteName+" : "+striptags(group.Group.introduction.replace("
", " ").replace("

", " ")), 200), author: group.Group.CreatorName, pageTitle: txtGroups.groupsName+" "+group.Group.title, contentTitle: group.Group.title+"("+txtGroups.groupsName+")", group: group, linkCanonical: config.siteUrl+"/"+configQuestionnaires.dirWebGroups+"/"+group.Group.slug+".html" } const html=await compiledFunction(pageDatas); if(preview === false) { await toolFile.createHTML(configQuestionnaires.dirHTMLGroups, group.Group.slug, html); return true; } else return html; } // Remonte toutes les données du groupe + les données des questionnaires y étant classés si reassemble=true const searchGroupById = async (id, reassemble=false) => { let group=await toolFile.readJSON(configQuestionnaires.dirCacheGroups, id); if(!group) group=await creaGroupJson(id); if(!group) return false; group.Group.isPublishable=checkGroupIsPublishable(group); if(reassemble) { let questionnaire; Questionnaires=[]; const author=await userCtrl.searchUserById(group.Group.CreatorId); if(author) group.Group.CreatorName=author.User.name; for(let i in group.Questionnaires) { questionnaire=await questionnaireCtrl.searchQuestionnaireById(group.Questionnaires[i].id, true); if(questionnaire) Questionnaires.push(questionnaire); } group.Questionnaires=Questionnaires; } return group; } exports.searchGroupById = searchGroupById; // Cherche si il y a des groupes de questionnaires dont la date de publication est passée, mais qui ne sont pas publiés // Vérifie si ils sont publiables et si oui génère le HTML // Si regenerate=true, tous les fichiers sont (ré)générés, même s'ils existent déjà (évolution template...) // Retourne le nombre de fichiers ayant été (ré)générés const checkGroupsNeedToBePublished = async (regenerate=false) => { const db = require("../models/index"); const groups = await db.sequelize.query("SELECT `id`,`slug` FROM `Groups` WHERE `publishingAt` < NOW()", { type: QueryTypes.SELECT }); let nb = 0; for(let i in groups) { if(regenerate === false) { if(await toolFile.checkIfFileExist(configQuestionnaires.dirHTMLGroups, groups[i].slug+".html") === false) { if(await creaGroupJson(groups[i].id))// permet aussi de mettre à jour les fichiers des quizs du groupe avec lien vers le groupe nb++; } } else { const publishedOk = await creaGroupHTML(groups[i].id);// creaGroupHTLM contrôle que le groupe est publiable. if(publishedOk) nb++; } } return nb; } exports.checkGroupsNeedToBePublished = checkGroupsNeedToBePublished; // Compte le nombre total de groupes et le stocke const creaStatsGroupsJson = async () => { const db = require("../models/index"); const Groups=await db["Group"].findAll({ attributes: ["id"] }); const GroupsPublished=await db.sequelize.query("SELECT `id` FROM `Groups` WHERE `publishingAt` < NOW()", { type: QueryTypes.SELECT }); const QuestionnairesInGroups=await db.sequelize.query("SELECT DISTINCT `id` FROM `Questionnaires` WHERE `GroupId` IS NOT NULL", { type: QueryTypes.SELECT }); if(Groups && GroupsPublished && QuestionnairesInGroups) { const stats = { nbTot : Groups.length, nbPublished : GroupsPublished.length, // ! en fait, peuvent être passé de date et non publié nbQuestionnaires : QuestionnairesInGroups.length } await toolFile.createJSON(configQuestionnaires.dirCacheGroups, "stats", stats); return stats; } else return false; } exports.creaStatsGroupsJson = creaStatsGroupsJson; // Retourne les données créées par la fonction précédente const getStatsGroups = async () => { let stats=await toolFile.readJSON(configQuestionnaires.dirCacheGroups, "stats"); if(!stats) stats=await creaStatsGroupsJson(); if(!stats) return false; else return stats; } exports.getStatsGroups = getStatsGroups;