server.js

const Joi = require("joi");
const mysql = require("mysql2");
const express = require("express");
const app = express();

app.use(express.json());

// Callback function do not work now because of the connection being a promise;
const pool = mysql
  .createConnection({
    host: "localhost",
    user: "root",
    password: "michael2001",
    database: "blogger",
  })
  .promise();

const schema = Joi.object({
  title: Joi.string().required(),
  content: Joi.string().required(),
  category: Joi.string().required(),
  tags: Joi.array(),
});

async function fetchById(id) {
  let row = await pool.query(`SELECT * FROM blog WHERE id=${id}`);
  if (row[0][0]) {
    row = row[0][0];
    row.tags = row.tags.split(",");
    return row;
  }
  return undefined;
}

async function fetchAll(string = "%") {
  let rows = await pool.query(
    `SELECT * FROM blog WHERE title LIKE '%${string}%' OR content LIKE '%${string}%' OR tags LIKE '%${string}%'`,
  );
  if (rows[0][0]) {
    rows = rows[0];
    for (let row of rows) {
      row.tags = row.tags.split(",");
    }
    return rows;
  }
  return undefined;
}

app.get("/blogs", async (req, res) => {
  let rows;
  let term = req.query.term;
  if (term) rows = await fetchAll(term);
  else rows = await fetchAll();
  if (rows) {
    res.status(200).send(rows);
  } else {
    res.status(204).send({ error: "No rows found" }); // You aren't able to return data with a status of 204
  }
});

app.get("/blogs/:id", async (req, res) => {
  const row = await fetchById(req.params.id);
  if (row) {
    res.status(200).send(row);
  } else {
    res.status(404).send({ error: "Blog not found" });
  }
  // console.log("Retrieved data: ", row);
});

app.post("/blogs", async (req, res) => {
  const valid = schema.validate(req.body);
  if (typeof valid.error != "undefined") {
    // TODO: Maybe change the data schema of the error message details to match the other API calls
    res.status(400).send(valid.error.details);
    return;
  } else {
    req.body.tags = req.body.tags.join();
    const result = await pool.query(`INSERT INTO blog SET ?`, req.body);
    const id = result[0].insertId;
    let row = await fetchById(id);
    res.status(200).send(row);
  }
});

app.put("/blogs/:id", async (req, res) => {
  const valid = schema.validate(req.body);
  if (typeof valid.error != "undefined") {
    res.status(400).send(valid.error.details);
    return;
  } else {
    req.body.tags = req.body.tags.join();
    try {
      await pool.query(`UPDATE blog SET ?`, req.body);
      let row = await fetchById(req.params.id);
      res.status(200).send(row);
    } catch (e) {
      res.status(404).send({ error: "Blog not found" });
    }
  }
});

app.delete("/blogs/:id", async (req, res) => {
  let row = await fetchById(req.params.id);
  if (row) {
    await pool.query(`DELETE FROM blog WHERE id=${req.params.id}`);
    res.status(200).send(row);
  } else {
    res.status(404).send({ error: "Blog not found" });
  }
});

const port = 3000;

app.listen(port, () => {
  console.log("Listening for calls on http://localhost:3000");
});

// NOTE:
// 200 for proper response,
// 204 for not found but proper input (nothing to return),
// 400 for improper data or client usage,
// 404 for requested data not being found due to user error (bad path)
//
// NOTE:
// Data is return as an array of objects for plurality and an object for singularity
// Incoming updates and creations should contain the title, content, category, and tag fields
//
// NOTE:
// On top of that, a 'term' query may be added to only view blogs that contain the provided keystring
// which will be compared against the blog's title, content, category, and tags.