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
            {   console.log('Т1111111');
                if(main(data) != 0 ) {
                console.log('Такой маил есть');
            }else{
                let hPassword = passwordHash.generate(data.password);
                data.hPassword = hPassword;
                main_insert(data);
            }
            }
            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);
    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]);
    })
}