movieHandlers.js

const database = require("./database");

const getMovies = (req, res) => {
    const initialSql = "select * from movies";
    const where = [];
  
    if (req.query.color != null) {
      where.push({
        column: "color",
        value: req.query.color,
        operator: "=",
      });
    }
    if (req.query.max_duration != null) {
      where.push({
        column: "duration",
        value: req.query.max_duration,
        operator: "<=",
      });
    }
  
    database
      .query(
        where.reduce(
          (sql, { column, operator }, index) =>
            `${sql} ${index === 0 ? "where" : "and"} ${column} ${operator} ?`,
          initialSql
        ),
        where.map(({ value }) => value)
      )
      .then(([movies]) => {
        res.json(movies);
      })
      .catch((err) => {
        console.error(err);
        res.status(500).send("Error retrieving data from database");
      });
  };

const deleteMovie = (req, res) => {
  const id = parseInt(req.params.id);

  database
    .query("delete from movies where id = ?", [id])
    .then(([result]) => {
      if (result.affectedRows === 0) {
        res.status(404).send("Not Found");
      } else {
        res.sendStatus(204);
      }
    })
    .catch((err) => {
      console.error(err);
      res.status(500).send("Error deleting the movie");
    });
};

const updateMovie = (req, res) => {
  const id = parseInt(req.params.id);
  const { title, director, year, color, duration } = req.body;

  database
    .query(
      "update movies set title = ?, director = ?, year = ?, color = ?, duration = ? where id = ?",
      [title, director, year, color, duration, id]
    )
    .then(([result]) => {
      if (result.affectedRows === 0) {
        res.status(404).send("Not Found");
      } else {
        res.sendStatus(204);
      }
    })
    .catch((err) => {
      console.error(err);
      res.status(500).send("Error editing the movie");
    });
};

const postMovie = (req, res) => {
  const { title, director, year, color, duration } = req.body;

  database
    .query(
      "INSERT INTO movies(title, director, year, color, duration) VALUES (?, ?, ?, ?, ?)",
      [title, director, year, color, duration]
    )
    .then(([result]) => {
      res.location(`/api/movies/${result.insertId}`).sendStatus(201);
    })
    .catch((err) => {
      console.error(err);
      res.status(500).send("Error saving the movie");
    });
};
const getMovieById = (req, res) => {
    const id = parseInt(req.params.id);
  
    database
      .query("select * from movies where id = ?", [id])
      .then(([movies]) => {
        if (movies[0] != null) {
          res.json(movies[0]);
        } else {
          res.status(404).send("Not Found");
        }
      })
      .catch((err) => {
        console.error(err);
        res.status(500).send("Error retrieving data from database");
      });
  };
  


module.exports = {
  getMovies,
  getMovieById,
  postMovie, // don't forget to export your function ;)
  updateMovie, // don't forget to export your function ;)
  deleteMovie, // don't forget to export your function ;)
};