Projet : Simple Blog From Scratch Part5

const db = require("../models"); 
const { Op } = require("sequelize"); 
const auth = require("../middleware/auth")
const cxss = require("c-xss");
const messages = require('../messages');

// CREER UN POST
exports.createPost = async (req, res, next) => {
    try {
    // on vérifie l'identité de l'utilisateur connecté  
        const userId = auth.getUserID(req);
        const user = await db.User.findOne({ where: { id: userId } });
        // si le post ne comporte pas de titre ou de contenu on affiche un message d'erreur
        if(!req.body.title || !req.body.content){
            res.status(403).json({ message: messages.POST_ADDMISSINGTITLEORCONTENT });
        // sinon on créé le post en BDD
        } else {
            const myPost = await db.Post.create({
                // on utilise cxss pour éviter les attaques xss
                title: cxss(req.body.title),
                content: cxss(req.body.content),
                createdBy: user.username,
                UserId: userId,
            }); 
            // une fois le post enregistré en base on renvoi la réponse 
            res.status(200).json({ post: myPost, message: messages.POST_ADDOK });
        }
    } catch (error) {
        return res.status(500).json({ error: messages.SERVEUR_ERROR });
    }
};

// MODIFIER UN POST
exports.modifyPost = async (req, res, next) => {
    try {
        // on cherche le post à modifier grâce à son ID afin de pouvoir le modifier
        const thisPost = await db.Post.findOne({ where: { id: req.params.id } });
            if (req.body.title) {
                thisPost.title = cxss(req.body.title);
            }
            if (req.body.content) {
                thisPost.content = cxss(req.body.content);
            }
            // puis l'on renvoie en base 
            const newPost = await thisPost.save({
                fields: ["title", "content"],
            });
            res.status(200).json({ newPost: newPost, message: messages.POST_MODIFIED });
    } catch (error) {
        return res.status(500).json({ error: messages.SERVEUR_ERROR });
    }
};

// ARCHIVER UN POST -> Permet d'archiver un post en BDD afin de ne plus l'afficher sur le Front
exports.archivePost = async (req, res, next) => {
    try {
        // on recherche le post à archiver 
        const thisPost = await db.Post.findOne({ where: { id: req.params.id } });
            // et l'on passe l'archivage de false à true
            if(thisPost.isArchived === false) {
                thisPost.isArchived = true;
                const newPost = await thisPost.save({ 
                    fields: ["isArchived"],
                });
                res.status(200).json({ newPost: newPost, message: messages.POST_ARCHIVED });
            }
    } catch (error) {
        return res.status(500).json({ error: messages.SERVEUR_ERROR });
    }
};

// AFFICHER UN POST
exports.getOnePost = async (req, res, next) => {
    try {
        // on récupère le post afin d'afficher son titre et son contenu ainsi que son auteur et l'on vérifie aussi qu'il n'est pas archivé
        const post = await db.Post.findOne({ 
            attributes: ["id", "title", "content"], 
            where: { [Op.and]: [{id: req.params.id}, { is_archived: 0 }] },
            include: [
                {model: db.User, attributes: ["username"]},
            ],
        }); 
        if (post){
            res.status(200).json(post);
        } else {
            res.status(200).json({ message: messages.POST_NOPOST });
        }
    } catch (error) {
        return res.status(500).json({ error: messages.SERVEUR_ERROR });
    }
};

// AFFICHER TOUS LES POSTS
exports.getAllPosts = async (req, res, next) => {
    try {
        // on affiche uniquement les posts non archivés
        const allPosts = await db.Post.findAll({
            limit: 50, order: [["id", "DESC"]], 
            where: { is_archived: 0 },
            include: [
                {model: db.User, attributes: ["username"]},
            ],
        })
        res.status(200).json({ allPosts });
    } catch {
        return res.status(500).json({ error: messages.SERVEUR_ERROR });
    }
};

const express = require('express');
const router = express.Router();
const postCtrl = require("../controllers/post");
const auth = require('../middleware/auth');

// créer un post
router.post("/create", auth.signin, postCtrl.createPost);
// modifier un post
router.put("/modify/:id", auth.signin, postCtrl.modifyPost);
// archiver un post
router.put("/archive/:id", auth.signin, postCtrl.archivePost);
// afficher tous les posts
router.get("/all", postCtrl.getAllPosts);
// afficher un seul post
router.get("/:id", postCtrl.getOnePost);


module.exports = router;