require("dotenv").config({quiet:true});
const express = require("express");
const session = require("express-session");
const SQLiteStore = require('connect-sqlite3')(session);
const cors = require("cors");
const bcrypt = require('bcrypt');

var dbReady = false;

const DSN = `mysql://${process.env.DB_USER || "root"}:${process.env.DB_PASSWORD || ""}@tcp(${process.env.DB_HOST || "127.0.0.1"}:${process.env.DB_PORT || "3306"})/${process.env.DB_NAME}`;
const mariadb = require("mariadb");
const fs = require('fs');
const path = require('path');

const db = mariadb.createPool({
	host: process.env.DB_HOST || "127.0.0.1",
	port: process.env.DB_PORT || 3306,
	user: process.env.DB_USER || "root",
	password: process.env.DB_PASSWORD || null,
	database: process.env.DB_NAME || "uhppoted",
});
global.db = db;
global.DSN = DSN;
global.log = require("./logger.js")

const app = express();
const port = process.env.APP_PORT || 8080;


app.use(session({
	secret: process.env.SESSION_SECRET || "uhppoted-secret-change-me",
	cookie: { maxAge: 60000 },
	resave: false,
	saveUninitialized: false,
	store: new SQLiteStore({ db: 'sessions.db', dir: './' })
}));

global.hashPassword = async function(password) {
	const saltRounds = 12;
	return await bcrypt.hash(password, saltRounds);
};

global.comparePassword = async function(password, hash) {
	return await bcrypt.compare(password, hash);
};

app.use(cors());
app.use(express.json());
app.use(express.urlencoded({ extended: true }));
app.use(express.static("public"));
app.set("view engine", "ejs");
app.set("views", "./views");

app.use((req, res, next) => {
	if (!dbReady) {
		return res.render('error', { error: 'Database is not ready. Please try again later.' });
	}
});

const routersDir = path.join(__dirname, 'routes');
fs.readdirSync(routersDir).forEach(file => {
	const router = require(path.join(routersDir, file));
	if (file.endsWith('.js')) {
		const route = '/' + file.replace('.js', '');
		app.use(route, router);
	}
});

app.get('/', (req, res) => {
	res.redirect('/login');
})

app.listen(port, (err) => {
	if (err) {
		global.log.error(`Cannot start server: ${err}`);
		process.exit(1);
	}
	global.log.info(`Listening on port ${port}`);
	global.log.debug(`DSN: ${DSN}`);
	db.getConnection()
		.then(conn => {
			return conn.query('SELECT 1 FROM ACL LIMIT 1')
				.then(() => {
					global.log.info('Database connection validated with ACL table.');
					dbReady = true;
					conn.release();
				})
				.catch(err => {
					global.log.error(`Database ACL validation failed: ${err}`);
					conn.release();
					process.exit(1);
				});
		})
		.catch(err => {
			global.log.error(`Database connection failed: ${err}`);
			process.exit(1);
		});
})