uhppoted-db-web/index.js
2025-08-28 06:17:31 -06:00

86 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');
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");
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.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.');
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);
});
})