hostbbq-monitoring/server/src/index.ts

import { Pool } from 'mysql';

import { Logger, LogLevel } from '../../common/util/logger.class';

import { ControllerPool } from './ctrl/controller-pool.interface';
import { HttpCheckController } from './ctrl/http-check-controller.class';
import { MariaDBDatabase } from './ctrl/mariadb-database.class';
import { MariaDBPoolFactory } from './ctrl/mariadb-poolfactory.class';
import { ServerConnector } from './ctrl/server-connector.class';
import { Webserver } from './webserver.class';
import { Timer } from './timer.class';

const LOG_LEVEL: LogLevel = (process.env.LOG_LEVEL as LogLevel) || 'INFO';
Logger.logLevel = LOG_LEVEL;

process.on('SIGABRT', exitGracefully);
process.on('SIGQUIT', exitGracefully);
process.on('SIGTERM', exitGracefully);

let pool: ControllerPool;
let db: MariaDBDatabase;
let connectionPool: Pool;
(async () => {
  connectionPool = await MariaDBPoolFactory.createConnectionPool();

  db = new MariaDBDatabase(connectionPool);
  await db.open();

  pool = {
    connectionPool,
    serverConnector: new ServerConnector(connectionPool),
    httpChecks: new HttpCheckController(connectionPool)
  };

  Timer.instance.start();
  Timer.instance.subscribe(7 * 24 * 60 * 60, db.cleanupData.bind(db));
  db.cleanupData();

  new Webserver(Number(process.env.WEB_PORT ?? '80'), pool);
})();

async function exitGracefully(...args: any[]) {
  Logger.info(`[EXITING] Graceful exit, received ${JSON.stringify(args)}`);
  try {
    Logger.info(`[EXITING] Tear down Main Database Controller ...`);
    if (db) await db.close();

    Logger.info(`[EXITING] Tear down MariaDB Connection Pool ...`);
    if (connectionPool) await MariaDBPoolFactory.end(connectionPool);
  } catch (err) {
    Logger.error(`[ERROR] Tear down sequence failed:`, err);
    process.exit(2);
  }

  Logger.info(`[EXITING] Tear down sequence succeeded. exiting.`);
  process.exit(0);
}