var express = require("express");
var router = express.Router();

var bodyParser = require("body-parser");

var { OAuth2Client } = require("google-auth-library");

const CLIENT_ID = "발급받은 ClientID";
var client = new OAuth2Client(CLIENT_ID);
var mysql = require("mysql");
const session = require("express-session");
const FileStore = require("session-file-store")(session);

router.use(bodyParser.urlencoded({ extended: false })); //url인코딩 x
router.use(bodyParser.json()); //json방식으로 파싱
router.use(
  session({
    secret: "원하는 암호", // 암호화
    resave: false,
    saveUninitialized: true,
    store: new FileStore(),
  })
);

var connection = mysql.createConnection({
  host: "IP주소 입력 (localhost 또는 AWS 서버 주소)",
  user: "계정 입력",
  password: "암호 입력",
  database: "스키마이름 입력",
});
connection.connect();

/* GET home page. */
router.get("/", function (req, res, next) {
  res.render("index", {
    client_id: CLIENT_ID,
  });
});
router.get("/index", function (req, res, next) {
  res.render("index", {
    client_id: CLIENT_ID,
  });
});

router.post("/index", (req, res) => {
  let token = req.body.token;
  async function verify() {
    const ticket = await client.verifyIdToken({
      idToken: token,
      audience: CLIENT_ID, // Specify the CLIENT_ID of the app that accesses the backend
    });
    const payload = ticket.getPayload();
    const userid = payload["sub"];
  }
  verify()
    .then(() => {
      res.cookie("session-token", token);
      res.send("success");
    })
    .catch(console.error);
});

router.get("/login", checkAuthenticated, (req, res) => {
  req.session.user = req.user;
  req.session.user.email = req.user.email;
  req.session.user.name = req.user.name;
  req.session.user.picture = req.user.picture;
  var sql = "SELECT * FROM USER WHERE EMAIL=?";
  var parameter = [req.session.user.email];
  connection.query(sql, parameter, function (err, row) {
    if (err) {
      console.log(err);
    } else {
      if (row.length > 0) {
        console.log("이미 가입이 되어있는 아이디");
        req.session.user.nickname = row[0].NICKNAME;
        req.session.user.age = row[0].AGE;
        req.session.user.gender = row[0].GENDER;
        res.render("map", { user: req.session.user });
      } else {
        return res.render("login", { user: req.session.user, message: "none" });
      }
    }
  });
});

router.post("/login", (req, res) => {
  //입력을 다하였는지
  if (
    !req.body.nickname ||
    !req.body.age ||
    !req.body.gender ||
    !req.body.price ||
    !req.body.kindness ||
    !req.body.accessibility
  ) {
    console.log("입력받지 않은 데이터 존재");
    return res.render("login", {
      user: req.session.user,
      message: "need data",
    });
  }
  var set = new Set([
    req.body.price,
    req.body.accessibility,
    req.body.kindness,
    req.body.noise,
  ]);
  //db에 동일 닉네임있는지 검사(닉네임은 유일해야함)
  var sql = " SELECT * FROM USER WHERE NICKNAME=?";
  var parameter = [req.body.nickname];
  connection.query(sql, parameter, function (err, row) {
    if (err) {
      console.log(err);
    } else if (row.length > 0) {
      console.log("동일 닉네임있음");
      return res.render("login", {
        user: req.session.user,
        message: "same nickname",
      });
    }
    //중복순위제
    else if (set.size != 4) {
      console.log("중복된 순위 존재");
      return res.render("login", {
        user: req.session.user,
        message: "wrong preference",
      });
    } else {
      req.session.user.nickname = req.body.nickname;
      req.session.user.age = req.body.age;
      req.session.user.gender = req.body.gender;
      req.session.user.price = req.body.price;
      req.session.user.kindness = req.body.kindness;
      req.session.user.noise = req.body.noise;
      req.session.user.accessibility = req.body.accessibility;
      var sql = "INSERT INTO USER(EMAIL,NICKNAME, AGE, GENDER) VALUES(?,?,?,?)";
      var parameter = [
        req.session.user.email,
        req.session.user.nickname,
        req.session.user.age,
        req.session.user.gender,
      ];
      connection.query(sql, parameter, function (err) {
        if (err) {
          console.log(err);
          return res.render("/", {
            client_id: CLIENT_ID,
          });
        } else {
          console.log("새로운 user데이터 입력");
        }
      });
      var sql2 =
        "INSERT INTO PREFERENCE(NICKNAME, PRICE, KINDNESS, NOISE, ACCESSIBILITY) VALUES(?,?,?,?,?)";
      var parameter2 = [
        req.session.user.nickname,
        req.session.user.price,
        req.session.user.kindness,
        req.session.user.noise,
        req.session.user.accessibility,
      ];
      connection.query(sql2, parameter2, function (err) {
        if (err) {
          console.log(err);
          return res.render("/", {
            client_id: CLIENT_ID,
          });
        } else {
          console.log("새로운 PREFERENCE데이터 입력");
        }
      });

      res.render("map", { user: req.session.user });
    }
  });
});

function checkAuthenticated(req, res, next) {
  let token = req.cookies["session-token"];
  let user = {};
  async function verify() {
    const ticket = await client.verifyIdToken({
      idToken: token,
      audience: CLIENT_ID, // Specify the CLIENT_ID of the app that accesses the backend
    });
    const payload = ticket.getPayload();
    user.email = payload.email;
    user.picture = payload.picture;
  }
  verify()
    .then(() => {
      req.user = user;
      next();
    })
    .catch((err) => {
      res.redirect("/index");
    });
}

// 로그아웃
router.get("/logout", function (req, res) {
  req.session.destroy(); //세션비우기
  res.redirect("/");
});

// 로그인 후 지도 화면
router.get("/map", function (req, res, next) {
  // 로그인된 사용자 존재
  if (req.session.user) {
    console.log(req.session.user);

    var sql = "SELECT * FROM USER WHERE EMAIL=?";
    var parameter = [req.session.user.email];

    connection.query(sql, parameter, function (err, row) {
      if (err) {
        console.log(err);
      } else {
        req.session.user.nickname = row[0].nickname;
        req.session.user.age = row[0].age;
        req.session.user.gender = row[0].gender;
      }
    });

    res.render("map", { user: req.session.user });
  }
});

// 카페 후기 입력 창
router.get("/review/:cafeId", function (req, res) {
  const cafeId = req.params.cafeId;
  res.render("review", { cafeId: cafeId });
});

// 카페 후기 등록
router.post("/review", function (req, res) {
  var cafeId = req.body.cafeId;
  var price = req.body.price;
  var kindness = req.body.kindness;
  var noise = req.body.noise;
  var accessibility = req.body.accessibility;

  console.log(price);
  console.log(kindness);
  console.log(noise);
  console.log(accessibility);

  // 입력받지 않은 데이터가 하나라도 존재 (카페아이디는 후기작성시 자동으로 받아옴)
  if (!cafeId || !price || !kindness || !noise || !accessibility) {
    console.log("입력받지 않은 데이터 존재");
    res.redirect("/review/:cafeId"); // 후기작성으로 다시 이동
  }

  var sql =
    "INSERT INTO REVIEW(CAFE_ID, PRICE, KINDNESS, NOISE, ACCESSIBILITY) VALUES(?,?,?,?,?)";

  var parameter = [cafeId, price, kindness, noise, accessibility];

  connection.query(sql, parameter, function (err) {
    if (err) {
      console.log(err);
    } else {
      console.log("새로운 comment 데이터 입력");
    }
  });
  return res.send(
    '<script>alert("등록 완료"); location.href = "/login";</script>'
  );
});

// 추천 API
router.get("/recommend", function (req, res) {
  console.log(req.session.user);

  var sql =
    "SELECT PRICE, KINDNESS, NOISE, ACCESSIBILITY FROM PREFERENCE WHERE NICKNAME = ?";

  var parameter = req.session.user.nickname;

  connection.query(sql, parameter, function (err, row) {
    if (err) {
      console.log(err);
    } else if (row.length > 0) {
      console.log(row[0]);

      const price = 5 - row[0].PRICE;
      const kindness = 5 - row[0].KINDNESS;
      const noise = 5 - row[0].NOISE;
      const accessibility = 5 - row[0].ACCESSIBILITY;

      var sql =
        "SELECT CAFE_ID FROM REVIEW GROUP BY CAFE_ID HAVING AVG(PRICE) >= ? AND AVG(KINDNESS) >= ? AND AVG(NOISE) >= ? AND AVG(ACCESSIBILITY) >= ?";

      var parameter = [price, kindness, noise, accessibility];

      connection.query(sql, parameter, function (err, row) {
        if (err) {
          console.log(err);
        } else if (row.length > 0) {
          console.log(row);
          res.send({ row: row });
        }
      });
    }
  });
});

module.exports = router;