const express = require('express');
const app = express();
const session = require('express-session')
const port = 8080;
let sql = require("mssql/msnodesqlv8");
app.use(express.static("public"));

const bodyParser = require("body-parser");
app.use(bodyParser.urlencoded({
    extended: true
}));
app.use(bodyParser.json());

app.use(session({
    secret: '2C44-4D44-WppQ38S',
    resave: true,
    saveUninitialized: true
}));

let dbConfig = {
    driver: 'msnodesqlv8',
    connectionString: 'Driver={SQL Server Native Client 11.0};Server={db-mssql};Database={s15831};Trusted_Connection={yes};'
};
sql.connect(dbConfig, function (err) {
    if (err) {
        console.log("Error while connecting database :- " + err);
        res.send(err);
        sql.close();
    }
});

var auth = function (req, res, next) {
    if (req.session && req.session.user === "amy" && req.session.admin)
        return next();
    else
        return res.sendStatus(401);
};
//register
app.post("/registerForm", function (req, res) {
    let name = req.body.name;
    let secondName = req.body.secondName;
    let email = req.body.email;
    let password = req.body.password;
    let request = new sql.Request();
    console.log(req.body.name);
    console.log(req.body.secondName);
    console.log(req.body.email);
    console.log(req.body.password);
    var queryTmp = 'SELECT * FROM osoba WHERE email = \'' + email + '\'';
    console.log(queryTmp);
    request.query(queryTmp, function (err, result) {
        console.log(result.recordsets.length);
        if (err) {
            console.log('error')
            throw err;
        }
        else if (result.recordsets.length >= 2) {
            //istnieje
            console.log("Użytkownik istnieje")
        }
        else {
            request.multiple = true;
            console.log('INSERT INTO osoba (imie, nazwsisko, haslo, email) VALUES ('+name+'\',\''+secondName+'\',\''+password+'\',\''+email+'\')');
            request.query('INSERT INTO osoba (imie, nazwsisko, haslo, email) VALUES ('+'\''+name+'\',\''+secondName+'\',\''+password+'\',\''+email+'\')', function(err, recordset) {
                if (err) {
                   console.log(err);
                   return res.send('Error occured');
                }
                return res.send('Successfully inserted');
            });
            console.log("d");
        }
    });
});

// Login endpoint
app.post('/login', function (req, res) {
    let email = req.body.email;
    let password = req.body.password;
    console.log(req.body.email);
    console.log(req.body.password);
    var queryTmp = 'SELECT * FROM OSOBA WHERE EMAIL = ' + '\'email\'';
    request.query(queryTmp, function (err, result) {
        if (err) {
            //BRAK TAKIEJ OSOBY
            res.send('Brak takiej emaila w bazie');
            throw err;
        }
        console.log(result);
    });
    if (!email || !req.query.password) {
        res.send('login failed');
    } else if (req.query.username === "amy" || req.query.password === "amyspassword") {
        req.session.user = "amy";
        req.session.admin = true;
        res.send("login success!");
    }
});
//logout
app.get('/logout', function (req, res) {
    req.session.destroy();
    res.send("logout success!");
});

app.get('/d', function (req, res) {
    request.query('select * from marka', function (err, data) {
        if (err) {
            console.log("Error while connecting database :- " + err);
            res.send(err);
        }
        else {
            res.send(data.recordset);
        }
        sql.close();
    });
});

app.get('/hello', (req, res) => res.send('asd World!'));
app.get('/form', (req, res) => res.sendFile(__dirname + '/public/index.html'));
app.get('/formdata', (req, res) => {
    var fields = [[req.query['imie'], req.query['nazwisko'], req.query['wiek']]];
    res.render('people', { people: fields });
});

app.listen(port, () => console.log(`Listening on port ${port}!`));