let express = require("express");
let app = express();
let bodyParser = require("body-parser");
let urlencodedParser = bodyParser.urlencoded({ extended: false });
let passwordHash = require('password-hash');

app.set('view engine', 'ejs');

app.get('/', (req,res) => {
    res.writeHead(302, {
        'Location': '/login'
    });
    res.end();
});

app.get('/login', (req,res) => {
    res.sendFile(__dirname + '/login.html');
});

app.post('/login', urlencodedParser, function (req, res) {
    let data = req.body;
    if (!data) return res.sendStatus(400);
    if (data.type == null || data.type == undefined) return res.sendStatus(400);
    switch (data.type) {
        case 'login':
            break;
        case 'register':
            if (data.email == null || data.password == null || data.name == null) {
                return res.sendStatus(400);
            }
            else {
                if (main(data)===undefined) {
                    console.log("Чего Нибудь");
                    let hPassword = passwordHash.generate(data.password);
                    data.hPassword = hPassword;
                    main_insert(data);

                }
                else {
                    console.log("Динахуйпес");
                }
            }
            break;

        default: return res.sendStatus(400);

    }



    res.send('welcome, ' + data.email);
    console.log(req.body);
});

app.listen(3000);
let mysql= require('mysql');
var connection = mysql.createConnection({
    host : "a0300059.xsph.ru",
    user : "a0300059_WTbot",
    password : "UxCH3vpu",
    database : "a0300059_WTbot",
});

async function main(data){
    let res = await dbQuery('SELECT email FROM `WTBotClients` WHERE `email`= ?',data.email)

    console.log(res);
    console.log(res.length);
    if(res.length===0){
        return undefined;
    }else{
        return res.length;
    }

}

async function main_insert(data){
    let res = await dbQuery('INSERT INTO `WTBotClients`(`name`, `menu`,`email`,`hPassword`) VALUES (?,?,?,?)', [data.name,data.password,data.email,data.hPassword]);
    console.log(res);
}



async function dbQuery(...args) {
    return new Promise((resolve, reject) => {
        connection.query(args[0], args[1], (err, res) => {
            if (err) return reject(new Error(err));
            return resolve(res)
        }, args[3]);
    })
}