FunctionProject/api/controllers/admin.js

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 getPagesHelper = require('../assets/utils/getPagesHelper')
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 = async (req, res, next) => {
  const categoryId = helperQueryNumber(req.query.categoryId, 0)
  let search = req.query.search
  try {
    search = search.toLowerCase()
  } catch {}
  const options = {
    where: {
      // Trie par catégorie
      ...(categoryId !== 0 && { categorieId: categoryId }),
      // Recherche
      ...(search != null && {
        [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']]
  }
  return await getPagesHelper({ req, res, next }, Functions, options)
}

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
        })
      }
      try {
        result.utilizationForm = JSON.parse(result.utilizationForm)
      } catch {}
      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 != null) {
      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 = JSON.stringify(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 = async (req, res, next) => {
  const options = {
    where: {
      isValidated: 0
    },
    include: [{ model: Users, attributes: ['name', 'logo'] }],
    order: [['createdAt', 'DESC']]
  }
  return await getPagesHelper({ req, res, next }, Quotes, options)
}

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)
  }
}