class Termek {
    constructor(id, nev, kep, tipus, ar, mennyiseg, leiras) {
        this.id = id;
        this.nev = nev;
        this.kep = kep;
        this.tipus = tipus;
        this.ar = ar;
        this.mennyiseg = mennyiseg;
        this.leiras = leiras;
    }
}

const express = require('express');
const http = require('http');
const app = express();
const oracledb = require('oracledb');
const session = require('express-session')
const cors = require('cors')
const fs = require('fs')

const port = 3000;

var corsOptions = {
    'Access-Control-Allow-Origin': '*',
    origin: 'localhost:4200',
    optionsSuccessStatus: 200 // some legacy browsers (IE11, various SmartTVs) choke on 204
}

const bodyParser = require('body-parser')

let connection;

app.use(cors(corsOptions))
app.use(session({
    secret: 'asdfghjklqwertzuiopyxcvbnm0123456789',
    saveUninitialized: false,
    resave: false
}))
app.use(bodyParser.json())

app.head(`<meta http-equiv="Content-Security-Policy" content="default-src *; style-src 'self' 'unsafe-inline'; script-src 'self' 'unsafe-inline' 'unsafe-eval' http://www.google.com">`)

async function run() {
    try {
        connection = await oracledb.getConnection({
            user: "h770367",
            password: "h770367",
            connectString: "(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=localhost)(PORT=4000))(CONNECT_DATA=(SID=kabinet)))"
        });
    } catch (err) {
        console.error(err);
    }
}



server = http.createServer(app);

try {
    server.listen(port);
}
catch (err) {
    console.log(err);
}

console.log(`Server listening on port: ${port}`);
run();

app.route('/termek').get((req, res, next) => {
    let result;
    console.log(req.query.text);
    try {
        if (typeof req.query.id != 'undefined') {
            console.log("id: " + req.query.id)
            try {
                result = connection.execute(
                    `SELECT * FROM termek WHERE termek_id = '${req.query.id}'`,
                    []
                )
            }
            catch (err) {
                console.error(err);
                res.sendStatus(500)
            }

        }
        else if (typeof req.query.text == 'undefined') {
            result = connection.execute(
                'SELECT * FROM TERMEK',
                []);
        }
        else {
            result = connection.execute(`SELECT * FROM TERMEK WHERE nev LIKE '%${req.query.text}%' OR leiras LIKE '%${req.query.text}%'`, []);
        }

        result.then(function (value) {
            console.log("GET termek");
            //console.log(value.rows);
            console.log(typeof value.rows);
            res.send(value.rows);

        });
    }
    catch (err) {

        console.log("Something happened:")
        console.log(err);
        res.send(404, "The server currently unavailable");
    }
});

app.route('/auth').get(async (req, res, next) => {
    try {
        let sql = `SELECT * FROM Felhasznalo WHERE felhasznalonev='${req.query.username}' AND jelszo='${req.query.password}'`;
        console.log(sql);
        await connection.execute(sql).then((value) => {

            console.log("GET Felhasznalo");
            if (value.rows.length == 1) {
                req.session.user = value.rows;
                req.session.save();
                res.send(req.session.user);
                console.log(req.session)
            }
            else {
                res.sendStatus(403);
            }
        });
    }
    catch (err) {

        console.log("Something happened:")
        console.log(err);
        res.status(401).send("The server currently unavailable");
    }
});

app.route('/isloggedin').get((req, res) => {
    console.log('GET isloggedin')
    res.send(req.session.user)
})

app.route('/logout').delete((req, res) => {
    console.log('GET logout')
    req.session.destroy();
    res.send(null)
})

app.route('/register').get((req, res) => {
    let result;
    let user = JSON.parse(req.query.user);
    console.log(user);
    try {
        let sql = `INSERT INTO FELHASZNALO VALUES ('${user.username}','${user.password}','${user.name}','${user.email}','${user.kep}',${user.zipcode},'${user.street}',${user.houseNum},0,'${user.tel}',${user.balance})`
        console.log(sql);
        result = connection.execute(sql, []);
        result.then((value) => {
            console.log("GET /register");
            console.log(value);
            connection.execute('COMMIT');
            res.send(value);
        })
            .catch((err) => {
                console.log(err);
                res.sendStatus(406);
            });
    }
    catch (err) {
        console.log(err);
        res.send(504);
    }
});

app.route("/rendelesek").get((req, res, next) => {
    let result;
    try {
        result = connection.execute("SELECT * FROM VASAROL WHERE allapot NOT LIKE 'kiszállítva' ORDER BY mikor DESC", []);
        result.then(function (value) {
            console.log("GET /rendelesek");
            res.send(JSON.stringify(value.rows));
        });
    }
    catch (err) {
        console.log(err);
        res.send(null);
    }
});

app.route("/updateRendelesek").get((req, res, next) => {
    let result;
    try {
        result = connection.execute("SELECT * FROM VASAROL ORDER BY mikor DESC", []);
        result.then(function (value) {
            console.log("GET /rendelesek");
            res.send(JSON.stringify(value.rows));
        });
    }
    catch (err) {
        console.log(err);
        res.send(null);
    }
});

app.route("/fizetve").get((req, res, next) => {
    console.log(req)
    try {
        /*result = connection.execute(`update termek set allapot = ${req.query.}`, []);
        result.then(function (value) {
            console.log("GET /rendelesek");
            res.send(JSON.stringify(value.rows));
        });*/
    }
    catch (err) {
        console.log(err);
        res.send(null);
    }
});

app.route("/fileUpload").post((req, res, next) => {
    console.log(req.params)
    try {
    }
    catch (err) {
        console.log(err);
        res.send(null);
    }
});

app.route("/passwordChange").post((req, res, next) => {
    try {
        //let id = req.params.
    }
    catch (err) {
        console.error(err);
    }
})

app.route("/changeBalance").post((req, res, next) => {
    //console.log(req.body.params.updates)
    let id = req.body.params.updates[0].value;
    let value = req.body.params.updates[1].value;
    //console.log(id + " " + value)

    try {
        let result = connection.execute(`UPDATE felhasznalo SET egyenleg = egyenleg+${value} WHERE felhasznalonev = '${id}'`, []);
        result.then(data => {
            console.log(data);
            res.send("OK");
            result = connection.execute("COMMIT");
            result.then((data) => {
                console.log(data);
            })
        })
    }
    catch (err) {
        console.error(err);
    }
})