const cryptoJs = require("crypto-js");
const express = require("express");
const { pool } = require("../libs/MySQL");
const usersRouter = express.Router();

async function route() {
  // (loginID) => null | ID(str)
  usersRouter.get("/", async (req, res) => {
    console.log("/db/users");
    const connection = await pool.getConnection(async (con) => con);
    try {
      const queryString = `
          SELECT ID FROM users us
            WHERE us.loginID = '${req.query.loginID}'`;
      const [results] = await connection.query(queryString);
      res.send(results.length ? results[0].ID.toString() : null);
    } catch (e) {
      console.log(e);
      res.end();
    } finally {
      connection.release();
    }
  });

  // (loginID, loginPW) => null | "correct"
  usersRouter.get("/check", async (req, res) => {
    console.log("/db/users/check");
    const connection = await pool.getConnection(async (con) => con);
    try {
      const queryString = `
          SELECT loginPW FROM users us
            WHERE us.loginID = '${req.query.loginID}'`;
      const [results] = await connection.query(queryString);
      res.send(results[0].loginPW === req.query.loginPW ? "correct" : null);
    } catch (e) {
      console.log(e);
      res.end();
    } finally {
      connection.release();
    }
  });

  // (loginID, loginPW, name, ical) => ID
  usersRouter.post("/", async (req, res) => {
    console.log("post /db/users/");
    const connection = await pool.getConnection(async (con) => con);
    try {
      await connection.beginTransaction();
      const hashpw = cryptoJs.SHA256(req.body.loginPW).toString();
      let queryString = `
        INSERT INTO users
          (loginID, loginPW, name, ical)
        VALUES ('${req.body.loginID}', '${hashpw}', '${req.body.name}', '${req.body.ical}')`;
      await connection.query(queryString);

      queryString = `SELECT LAST_INSERT_ID() ID`;
      const [results] = await connection.query(queryString);
      await connection.commit();
      res.send(results[0]);
    } catch (e) {
      console.log(e);
      await connection.rollback();
      res.end();
    } finally {
      connection.release();
    }
  });

  // (ID) => ical
  usersRouter.get("/ical", async (req, res) => {
    console.log("/db/users/ical");
    const connection = await pool.getConnection(async (con) => con);
    try {
      const queryString = `
        SELECT ical FROM users us
          WHERE us.ID = '${req.query.ID}'`;
      const [results] = await connection.query(queryString);
      res.send(results[0]);
    } catch (e) {
      console.log(e);
      res.end();
    } finally {
      connection.release();
    }
  });
}
route();

module.exports = usersRouter;