const path = require('path'); const fs = require('fs'); const { validationResult } = require('express-validator'); const errorHandling = require('../assets/utils/errorHandling'); const { serverError } = require('../assets/config/errors'); const Functions = require('../models/functions'); const Categories = require('../models/categories'); const Quotes = require('../models/quotes'); const Users = require('../models/users'); const helperQueryNumber = require('../assets/utils/helperQueryNumber'); const Sequelize = require('sequelize'); const deleteFilesNameStartWith = require('../assets/utils/deleteFilesNameStartWith'); const { EMAIL_INFO, FRONT_END_HOST } = require('../assets/config/config'); const transporter = require('../assets/config/transporter'); const { emailQuoteTemplate } = require('../assets/config/emails'); const handleEditFunction = async (res, resultFunction, { title, slug, description, type, categorieId, isOnline }, imageName = false) => { resultFunction.title = title; resultFunction.slug = slug; resultFunction.description = description; resultFunction.type = type; resultFunction.categorieId = categorieId; resultFunction.isOnline = isOnline; if (imageName) { resultFunction.image = `/images/functions/${imageName}`; } const result = await resultFunction.save(); res.status(200).json({ message: "La fonction a bien été modifié!", result }); } exports.getFunctions = (req, res, next) => { const page = helperQueryNumber(req.query.page, 1); const limit = helperQueryNumber(req.query.limit, 10); const categoryId = helperQueryNumber(req.query.categoryId, 0); let search = req.query.search; try { search = search.toLowerCase(); } catch {} const offset = (page - 1) * limit; Functions.findAndCountAll({ limit, offset, where: { // Trie par catégorie ... (categoryId !== 0) && { categorieId: categoryId }, // Recherche ... (search != undefined) && { [Sequelize.Op.or]: [ { title: Sequelize.where(Sequelize.fn('LOWER', Sequelize.col('title')), 'LIKE', `%${search}%`) }, { slug: Sequelize.where(Sequelize.fn('LOWER', Sequelize.col('slug')), 'LIKE', `%${search}%`) }, { description: Sequelize.where(Sequelize.fn('LOWER', Sequelize.col('description')), 'LIKE', `%${search}%`) } ] } }, include: [ { model: Categories, attributes: ["name", "color"] } ], attributes: { exclude: ["updatedAt", "utilizationForm", "article", "isOnline"] }, order: [['createdAt', 'DESC']] }) .then((result) => { const { count, rows } = result; const hasMore = (page * limit) < count; return res.status(200).json({ totalItems: count, hasMore, rows }); }) .catch((error) => { console.log(error); return errorHandling(next, serverError); }); } exports.getFunctionBySlug = (req, res, next) => { const { slug } = req.params; Functions.findOne({ where: { slug }, include: [ { model: Categories, attributes: ["name", "color"] } ] }) .then((result) => { if (!result) { return errorHandling(next, { message: "La fonction n'existe pas.", statusCode: 404 }); } return res.status(200).json(result); }) .catch((error) => { console.log(error); return errorHandling(next, serverError); }); } exports.postFunction = (req, res, next) => { const { title, slug, description, type, categorieId } = req.body; const image = req.files.image; const errors = validationResult(req); if (!errors.isEmpty()) { return errorHandling(next, { message: errors.array()[0].msg, statusCode: 400 }); } if (!image || image.truncated && ( image.mimetype !== 'image/png' || image.mimetype !== 'image/jpg' || image.mimetype !== 'image/jpeg' )) { return errorHandling(next, { message:"La fonction doit avoir une image valide.", statusCode: 400 }); } const splitedImageName = image.name.split('.'); if (splitedImageName.length !== 2) return errorHandling(next, serverError); const imageName = slug + '.' + splitedImageName[1]; image.mv(path.join(__dirname, '..', 'assets', 'images', 'functions') + '/' + imageName, async (error) => { if (error) return errorHandling(next, serverError); try { const result = await Functions.create({ title, slug, description, type, categorieId, image: `/images/functions/${imageName}` }); return res.status(201).json({ message: "La fonction a été correctement ajouté!", result }); } catch (error) { console.log(error); return errorHandling(next, serverError); } }); } exports.putFunction = async (req, res, next) => { const { id } = req.params; const { title, slug, description, type, categorieId, isOnline } = req.body; const image = req.files.image; const errors = validationResult(req); if (!errors.isEmpty()) { return errorHandling(next, { message: errors.array()[0].msg, statusCode: 400 }); } try { // Vérifie si la fonction existe const resultFunction = await Functions.findOne({ where: { id } }); if (!resultFunction) { return errorHandling(next, { message: "La fonction n'existe pas.", statusCode: 404 }); } // Vérifie si le slug existe déjà const FunctionSlug = await Functions.findOne({ where: { slug } }); if (!FunctionSlug && FunctionSlug.id != resultFunction.id) { return errorHandling(next, { message: "Le slug existe déjà...", statusCode: 404 }); } // Sauvegarde de la fonction if (image != undefined) { if (image.truncated && ( image.mimetype !== 'image/png' || image.mimetype !== 'image/jpg' || image.mimetype !== 'image/jpeg' )) { return errorHandling(next, { message:"La fonction doit avoir une image valide.", statusCode: 400 }); } const splitedImageName = image.name.split('.'); if (splitedImageName.length !== 2) return errorHandling(next, serverError); const imageName = slug + '.' + splitedImageName[1]; // Supprime les anciennes images const functionPath = path.join(__dirname, '..', 'assets', 'images', 'functions'); deleteFilesNameStartWith(slug, functionPath, () => { image.mv(path.join(functionPath, imageName), async (error) => { if (error) return errorHandling(next, serverError); return await handleEditFunction(res, resultFunction, { title, slug, description, type, categorieId, isOnline }, imageName); }); }); } else { return await handleEditFunction(res, resultFunction, { title, slug, description, type, categorieId, isOnline }); } } catch (error) { console.log(error); return errorHandling(next, serverError); } } exports.putFunctionArticle = async (req, res, next) => { const { id } = req.params; const { article } = req.body; try { // Vérifie si la fonction existe const resultFunction = await Functions.findOne({ where: { id } }); if (!resultFunction) { return errorHandling(next, { message: "La fonction n'existe pas.", statusCode: 404 }); } resultFunction.article = article; const result = await resultFunction.save(); return res.status(200).json(result); } catch (error) { console.log(error); return errorHandling(next, serverError); } } exports.putFunctionForm = async (req, res, next) => { const { id } = req.params; const { form } = req.body; try { // Vérifie si la fonction existe const resultFunction = await Functions.findOne({ where: { id } }); if (!resultFunction) { return errorHandling(next, { message: "La fonction n'existe pas.", statusCode: 404 }); } resultFunction.utilizationForm = form; const result = await resultFunction.save(); return res.status(200).json(result); } catch (error) { console.log(error); return errorHandling(next, serverError); } } exports.deleteFunction = async (req, res, next) => { const { id } = req.params; try { const result = await Functions.findOne({ where: { id } }); if (!result) { return errorHandling(next, { message: "La fonction n'existe pas.", statusCode: 404 }); } if (result.image !== "/images/functions/default.png") { const filePath = path.join(__dirname, '..', 'assets', result.image); fs.unlinkSync(filePath); // supprime le fichier } await result.destroy(); res.status(200).json({ message: "La fonction a été correctement supprimé!"}); } catch (error) { console.log(error); return errorHandling(next, serverError); } } exports.postCategory = async (req, res, next) => { const { name, color } = req.body; if (!(name && color)) { return errorHandling(next, { message: "La catégorie doit avoir un nom et une couleur." }); } try { const result = await Categories.create({ name, color }); return res.status(201).json({ message: "La catégorie a bien été crée!", result }); } catch (error) { console.log(error); return errorHandling(next, serverError); } } exports.putCategory = async (req, res, next) => { const { name, color } = req.body; const { id } = req.params; if (!(name && color && id)) { return errorHandling(next, { message: "La catégorie doit avoir un nom, une couleur et un id." }); } try { const category = await Categories.findOne({ where: { id } }); if (!category) { return errorHandling(next, { message: "La catégorie n'existe pas." }); } category.name = name; category.color = color; const result = await category.save(); return res.status(200).json({ message: "La catégorie a bien été modifiée!", result }); } catch (error) { console.log(error); return errorHandling(next, serverError); } } exports.deleteCategory = async (req, res, next) => { const { id } = req.params; try { const category = await Categories.findOne({ where: { id } }); if (!category) { return errorHandling(next, { message: "La catégorie n'existe pas." }); } await category.destroy(); return res.status(200).json({ message: "La catégorie a bien été supprimée!" }); } catch (error) { console.log(error); return errorHandling(next, serverError); } } exports.getQuotes = (req, res, next) => { const page = helperQueryNumber(req.query.page, 1); const limit = helperQueryNumber(req.query.limit, 10); const offset = (page - 1) * limit; Quotes.findAndCountAll({ limit, offset, where: { isValidated: 0, }, include: [ { model: Users, attributes: ["name", "logo"] } ], order: [['createdAt', 'DESC']] }) .then((result) => { const { count, rows } = result; const hasMore = (page * limit) < count; return res.status(200).json({ totalItems: count, hasMore, rows }); }) .catch((error) => { console.log(error); return errorHandling(next, serverError); }); } exports.putQuote = async (req, res, next) => { const { id } = req.params; const { isValid } = req.body; try { if (typeof isValid !== 'boolean') { return errorHandling(next, { message: "isValid doit être un booléen.", statusCode: 400 }); } const quote = await Quotes.findOne({ where: { id, isValidated: 0 }, include: [ { model: Users, attributes: ["name", "email"] } ] }); if (!quote) { return errorHandling(next, { message: "La citation n'existe pas (ou est déjà validé).", statusCode: 404 }); } await transporter.sendMail({ from: `"FunctionProject" <${EMAIL_INFO.auth.user}>`, to: quote.user.email, subject: "FunctionProject - Citation proposée", html: emailQuoteTemplate(isValid, quote, FRONT_END_HOST) }); if (isValid) { quote.isValidated = true; await quote.save(); return res.status(200).json({ message: "La citation a bien été validée!" }); } else { await quote.destroy(); return res.status(200).json({ imessage: "La citation a bien été supprimée!" }); } } catch (error) { console.log(error); return errorHandling(next, serverError); } }