import {body, param, query} from "express-validator";
import {getClient} from "../utils/database.js";
import jwt from "jsonwebtoken";

export const User = {
    id: param("id").notEmpty().isNumeric().trim(),
    email: body("email").notEmpty().isEmail().trim(),
    username: body("username").notEmpty().isAlphanumeric("fr-FR", {ignore: " _-"}).trim(),
    password: body("password").notEmpty().trim(),
    picture: body("picture").notEmpty().isAlphanumeric().trim(),
}

export const UserRegister = {
    email: body("email").notEmpty().isEmail().trim(),
    username: body("username").notEmpty().isAlphanumeric("fr-FR", {ignore: " _-"}).trim(),
    password: body("password").notEmpty().isStrongPassword({
        minLength: 8,
        maxLength: 32,
        minLowercase: 1,
        minUppercase: 1,
        minSymbols: 1
    }).trim()
}

export const UserLogin = {
    username: body("username").notEmpty().isAlphanumeric("fr-FR", {ignore: " _-"}).trim(),
    password: body("password").notEmpty().isStrongPassword({
        minLength: 8,
        maxLength: 32,
        minLowercase: 1,
        minUppercase: 1,
        minSymbols: 1
    }).trim(),
}

export const UserRequest = {
    username: param("username").notEmpty().isAlphanumeric("fr-FR", {ignore: " _-"}).trim(),
}

export const UserSearch = {
    username: query("username").notEmpty().isAlphanumeric("fr-FR", {ignore: " _-"}).trim(),
}

export async function doEmailExists(req, res, next) {
    const client = await getClient();
    const logger = req.body.logger;
    const query = `SELECT * FROM users WHERE email = '${req.body.email}'`;
    const result = await client.query(query);

    if (result.rows.length > 0) {
        logger.write("failed because email already exists", 400)
        res.status(400).send({error: "Email already exists"})
    } else {
        next()
    }

}

export async function doUsernameExists(req, res, next) {
    const client = await getClient();
    const logger = req.body.logger;
    const query = `SELECT * FROM users WHERE username = '${req.body.username}'`;
    const result = await client.query(query);
    if (result.rows.length > 0) {
        logger.write("failed because username already exists", 400)
        res.status(400).send({error: "Username already exists"})
    } else {
        next()
    }

}

export async function doUserExists(req, res, next) {
    const client = await getClient();
    const logger = req.body.logger;
    const query = `SELECT id FROM users WHERE id = ${req.params.id}`;
    const result = await client.query(query);
    if (result.rows.length > 0) {
        next()
    }else{
        logger.write("failed because user doesn't exists", 404)
        res.status(404).json({error: "Not Found"})
    }
}

export async function doUserExistsBody(req, res, next) {
    const client = await getClient();
    const logger = req.body.logger;
    const query = `SELECT id FROM users WHERE id = ${req.body.owner}`;
    const result = await client.query(query);
    if (result.rows.length > 0) {
        next()
    }else{
        logger.write("failed because user doesn't exists", 404)
        res.status(404).json({error: "Not Found"})
    }
}

export async function isOwner(req, res, next) {
    const logger = req.body.logger;
    const token = req.headers.authorization.split(' ')[1];
    const claims = jwt.decode(token);
    if (req.params.id != claims.id) {
        logger.write("failed because he wasn't the owner of the user", 403)
        res.status(403).send({error: "Not Authorized"})
    } else {
        next()
    }
}

export async function isOwnerBody(req, res, next) {
    const logger = req.body.logger;
    const token = req.headers.authorization.split(' ')[1];
    const claims = jwt.decode(token);
    if (req.body.owner != claims.id) {
        logger.write("failed because he wasn't the owner of the user", 403)
        res.status(403).send({error: "Not Authorized"})
    } else {
        next()
    }
}