const db = require("../models");
const bcrypt = require("bcryptjs");
const jwt = require("jsonwebtoken");
const logger = require("../services/logger");
require("dotenv").config();

const User = db.user;

// Create User
exports.createUser = async (req, res) => {
  try {

    const { name, email, password } = req.body;
    const hashedPassword = await bcrypt.hash(password, 10);

    const user = await User.create({ name, email, password: hashedPassword });

    logger.info(`User created: ${email}`);

    res.status(201).send({'status':"success",'message':"created successfully",'data': user });

  } catch (err) {
    logger.error(err.message);
    res.status(500).send({'status':"failed",'message':err.message });
  }
};

// Get All Users
exports.getAllUsers = async (req, res) => {
  try {

    const users = await User.findAll();

    res.status(200).send({'status':"success",'message':"Fetched successfully",'data': users }); 

  } catch (err) {
    logger.error(err.message);
    res.status(500).send({'status':"failed",'message':err.message });
  }
};

// Get User by ID
exports.getUserById = async (req, res) => {
  try {

    const user = await User.findByPk(req.params.id);

    if (!user) res.status(404).send({'status':"failed",'message':"Record Not found",'data': "" }); 

    res.status(200).send({'status':"success",'message':"Fetched successfully",'data': user }); 

  } catch (err) {
    logger.error(err.message);
    res.status(500).send({'status':"failed",'message':err.message });
  }
};

// Update User
exports.updateUser = async (req, res) => {
  try {

    const { name, email } = req.body;
    const [updated] = await User.update({ name, email }, { where: { id: req.params.id } });

    if (updated) {
      const updatedUser = await User.findByPk(req.params.id);
      res.status(200).send({'status':"success",'message':"Updated successfully",'data': updatedUser });
    } else {
      res.status(404).send({'status':"failed",'message':"Record Not found",'data': "" }); 
    }

  } catch (err) {
    logger.error(err.message);
    res.status(500).send({'status':"failed",'message':err.message });
  }
};

// Delete User
exports.deleteUser = async (req, res) => {
  try {

    const deleted = await User.destroy({ where: { id: req.params.id } });

    if (deleted) {
      res.status(200).send({'status':"success",'message':"Deleted successfully",'data': "" });
    } else {
      res.status(404).send({'status':"failed",'message':"Record Not found",'data': "" }); 
    }
    
  } catch (err) {
    logger.error(err.message);
    res.status(500).send({'status':"failed",'message':err.message });
  }
};

// Change User Password
exports.changeAdminUserPassword = async (req, res) => {
  try {
    const { old_password, new_password, confirm_password } = req.body;
    const userId = req.params.id;

    // Validate inputs
    if (!old_password || !new_password || !confirm_password) {
      return res.status(400).send({ status: "failed", message: "All password fields are required" });
    }

    if (new_password !== confirm_password) {
      return res.status(400).send({ status: "failed", message: "New password and confirm password do not match" });
    }

    // Find user
    const user = await User.findByPk(userId);
    if (!user) {
      return res.status(404).send({ status: "failed", message: "User not found" });
    }

    // Verify old password
    const isMatch = await bcrypt.compare(old_password, user.password);
    if (!isMatch) {
      return res.status(400).send({ status: "failed", message: "Old password is incorrect" });
    }

    // Hash and update new password
    const hashedPassword = await bcrypt.hash(new_password, 10);
    await User.update(
      { password: hashedPassword },
      { where: { id: userId } }
    );

    return res.status(200).send({status: "success", message: "Password updated successfully",});
    
  } catch (err) {
    return res.status(500).send({ status: "failed", message: err.message });
  }
};