uhppoted-db-web/index.js
2025-08-31 10:48:01 -06:00

90 lines
2.4 KiB
JavaScript

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();
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');
})
const port = process.env.APP_PORT || 8080
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.query("SELECT * FROM ACL LIMIT 1;")
.then(() => {
dbReady = true;
global.log.info("Database connection established");
})
.catch(err => {
global.log.error(`Database connection failed: ${err}`);
process.exit(1);
});
})