declare var require:any;

const express = require('express');
const app = express();
app.use(express.json());
app.use(express.urlencoded());
const port:number = 3000;

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

const crearUsuario = (con:any, data:object) => {
    return new Promise((resolve, reject) => {
        con.query (`INSERT INTO clientes (nombre, email, img, carritoActual, historial)\ 
                    VALUES ( '${(data as any)["nombreUsuario"]}', '${(data as any)["emailUsuario"]}',
                    '${(data as any)["imagenUsuario"]}', '{}', '{}')`,
            (err:any, res:string) => {
                if (err) {
                    reject("Error al ejecutar query SQL (start.ts fila 18))...\n" + err);
                }
                resolve("Exito.");
            }
        );
    });
};

const revisarUsuarioBD = (usuario:object) => {
    return new Promise((resolve, reject) => {
        const mysql = require('mysql');

        const con = mysql.createConnection({
            host: '35.193.16.64',
            user: 'Araozu',
            password: 'xsakah4b',
            database: 'Usuarios_DB'
        });

        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"];

            con.query (`SELECT nombre, email, img, carritoActual, historial FROM clientes WHERE nombre='${nombreUsuario}'`,
                (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})
                            .then( () => {
                                resolve(`{ "nombre": "${nombreUsuario}", "email": "${emailUsuario}", "img": "${imagenUsuario}",
                                "carrito": {}, "historial": {}}`);
                            })
                            .catch((msg:string) => {
                                reject("Error al crear el usuario...\n" + msg);
                            })
                    } else {
                        resolve(respuestaBD);
                    }
                });
        });

    });
};

app.post('/log-in',(req:any, res:any) => {
    res.header('Access-Control-Allow-Origin', 'http://localhost:8080');
    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) =>
            revisarUsuarioBD(usuario)
                .then(response => res.send(response.toString()))
                .catch(err => res.send(err))
        )
        .catch(console.error);

});

app.listen(port, () => {
    console.log(`Estoy escuchando el puerto ${port} we v:`);
});