var express = require('express');
var router = express.Router();
var bcrypt = require('bcrypt');
const {ObjectId} = require("mongodb");
var saltRounds = 10;

var ResponseType = {
  INVALID_USERNAME: 0,
  INVALID_PASSWORD: 1,
  SUCCESS: 2
}

/* GET users listing. */
router.get('/', function(req, res, next) {
  res.send('respond with a resource');
});


// 회원 가입
router.post('/signup', async function (req, res, next) {
  try {
    var username = req.body.username;
    var password = req.body.password;
    var nickname = req.body.nickname;
    var profileImageIndex = req.body.imageindex ?? 0;

    // 입력값 검증
    if( !username || !password || !nickname ){
      return res.status(400).send("모든 필드를 입력하세요.")
    }

    var database = req.app.get('database');
    var users = database.collection('users');
    const existingUser = await users.findOne({username: username})
    if(existingUser){
      return res.status(409).send("이미 존재하는 사용자입니다.")
    }

    // 비밀번호 암호화
    var salt = bcrypt.genSaltSync(saltRounds);
    var hash = bcrypt.hashSync(password, salt);

    // 신규 유저를 DB에 저장
    await users.insertOne({
      username: username,
      password: hash,
      nickname: nickname,
      profileImageIndex: profileImageIndex,
      rating: 18,
      score:0
    });

    res.status(201).send("사용자가 성공적으로 생성되었습니다.");

  } catch (err){
    console.log("사용자 추가중 오류 발생 : " + err);
    res.status(500).send("서버 오류가 발생했습니다.");
  }
})

// 로그인
router.post("/signin", async function (req, res, next) {
  try {
    var username = req.body.username;
    var password = req.body.password;
    var database = req.app.get('database');
    var users = database.collection('users');

    // 입력값 검증
    if (!username || !password) {
      return res.status(400).send("모든 필드를 입력해주세요.");
    }

    const existingUser = await users.findOne({username: username});
    if(existingUser){
      var compareResult = bcrypt.compareSync(password, existingUser.password);
      if(compareResult){
        req.session.isAuthenticated = true;
        req.session.userId = existingUser._id.toString();
        req.session.username = existingUser.username;
        req.session.nickname = existingUser.nickname;
        req.session.profileImageIndex = existingUser.profileImageIndex || 0;
        req.session.rating = existingUser.rating;
        req.session.score = existingUser.score;

        res.json({
          result: ResponseType.SUCCESS,
          imageindex: existingUser.imageindex,
          rating: existingUser.rating,
          score: existingUser.score,
        });
      } else {
        res.json({result : ResponseType.INVALID_PASSWORD});
      }
    } else {
      res.json({result : ResponseType.INVALID_USERNAME});
    }
  }catch (err){
    console.log("로그인 중 오류 발생 : ", err);
    res.status(500).send("서버 오류가 발생했습니다.");
  }
})

// 로그 아웃
router.post("/signout", async function (req, res, next) {
  req.session.destroy((err) => {
    if(err) {
      console.log("로그아웃 중 오류 발생");
      return res.status(500).send("서버 오류가 발생했습니다.");
    }
    res.status(200).send("로그아웃 되었습니다.")
  });
});

// 점수 추가
router.post("/addscore", async function (req, res, next) {
  try {
    if(!req.session.isAuthenticated) {
      return res.status(400).send("로그인이 필요합니다.");
    }

    var userId = req.session.userId;
    var score = req.body.score;

    // 점수 유효성 검사
    if(!score || isNaN(score)) {
      return res.status(400).send("유효한 점수를 입력해주세요.");
    }

    var database = req.app.get('database');
    var users = database.collection('users');

    const result = await users.updateOne(
        {_id: ObjectId.createFromHexString(userId) },
        {
          $set: {
            score: Number(score),
            updatedAt: new Date()
          }
        }
    );

    if(result.matchedCount === 0 ) {
      return res.status(400).send("사용자를 찾을 수 없습니다.");
    }

    res.status(200).json({message: "점수가 성공적으로 업데이트되었습니다."});

  } catch(err) {
    console.log("점수 추가 중 오류 발생 : ",err);
    res.status(500).send("서버 오류가 발생했습니다.");
  }

})

// 점수 조회
router.get("/score", async function (req, res, next) {
  try {
    if(!req.session.isAuthenticated) {
      return res.status(403).send("로그인이 필요합니다.");
    }

    var userId = req.session.userId;
    var database = req.app.get('database');
    var users = database.collection('users');

    const user = await users.findOne({_id: ObjectId.createFromHexString(userId) });

    if(!user){
      return res.status(404).send("사용자를 찾을 수 없습니다.");
    }

    res.json({
      id: user._id.toString(),
      username: user.username,
      nickname: user.nickname,
      score: Number(user.score) || 0,
    })

  } catch (err) {
    console.error("점수 조회 중 오류 발생 : ", err);
    res.status(500).send("서버 오류가 발생했습니다.")
  }
})

module.exports = router;