const validator = require('./google_validation.js').validator;

const crearUsuario = (con:any, data:object) => {
    return new Promise((resolve, reject) => {
        con.query (
            `INSERT INTO usuarios (nombre, email, img, carritoActual, GOOGLE_ID, ROL)\ 
            VALUES ('${(data as any)["nombreUsuario"]}', '${(data as any)["emailUsuario"]}',
            '${(data as any)["imagenUsuario"]}', '{}', '${(data as any)["googleID"]}', 'user')`,
            (err:any, res:string) => {
                if (err) {
                    reject("Error al ejecutar query SQL (revisarUsuarioG.ts fila 18))...\n" + err);
                }
                console.log("Resultado de añadir usuario a la BBDD (revisarUsuarioG.ts 22):\n" + res);
                resolve("Exito.");
            }
        );
    });
};

const revisarUsuarioG = (usuario:object, sesion:any) => {
    return new Promise((resolve, reject) => {
        const mysql = require('mysql');
        const SQL_CONNECT_DATA = require('./VARIABLES').sqlConnectData;

        const con = mysql.createConnection(SQL_CONNECT_DATA);

        con.connect( (err:any) => {
            if (err) {
                reject("Error al conectarse a la BBDD.");
            }

            const nombreUsuario:string = (usuario as any)["name"];
            const emailUsuario:string = (usuario as any)["email"];
            const imagenUsuario:string = (usuario as any)["picture"];
            const googleID:number = (usuario as any)["sub"];

            con.query (`SELECT nombre, email, img, carritoActual, USER_ID, ROL FROM usuarios WHERE GOOGLE_ID='${googleID}'`,
                (err:any, response:any) => {
                    if (err) {
                        reject("Error al ejecutar query SQL");
                    }
                    const respuestaBD:string = JSON.stringify(response);
                    if (respuestaBD === '[]') {
                        crearUsuario(con, {nombreUsuario, emailUsuario, imagenUsuario, googleID})
                            .then( () => {
                                resolve(`{ "nombre": "${nombreUsuario}", "email": "${emailUsuario}", "img": "${imagenUsuario}",
                                "carrito": {}, "rol": "user"}`);
                            })
                            .catch((msg:string) => {
                                reject("Error al crear el usuario...\n" + msg);
                            })
                    } else {
                        console.log(`Respuesta servidor:\n${respuestaBD}`);
                        resolve(JSON.stringify(response[0]));
                    }
                });
        });

    });
};

const revisarUsuario = (req:any, res:any) => {
    res.header('Access-Control-Allow-Origin', 'http://localhost:8081');
    res.header('Access-Control-Allow-Methods', 'GET,PUT,POST,DELETE');
    res.header('Access-Control-Allow-Headers', 'Content-Type');

    const token:string = req.body.idtoken;

    validator(token)
        .then( (usuario:object) => {
            revisarUsuarioG(usuario, req.session)
                .then(response => res.send(response.toString()))
                .catch(err => res.send(err))

        })
        .catch(console.error);

};

module.exports.revisarUsuarioG = revisarUsuario;