import express from "express";

import cors from "cors";

import bodyParser from "body-parser";

import morgan from "morgan";

import mainRouter from "@app/routes/main";

import userRouter from "@app/routes/users";

import authRouter from "@app/routes/auth";

import moodRouter from "@app/routes/moods";

import triggerRouter from "@app/routes/triggers";

import sleepRecordRouter from "@app/routes/sleepRecords";

import insightRouter from "@app/routes/insights";

import { errorHandler } from "@app/middleware/errorHandler";

import { PrismaClient } from "@prisma/client";

import {

  bootWorkers,

  closeAllWorkers,

  closeAllQueues,

  scheduleInsights,

} from "@app/lib/queue";

import pino from "pino";

import pinoHttp from "pino-http";

import path from "path";

export function createApp() {

  const app = express();

  bootWorkers();

  scheduleInsights();

  // Configure CORS

  app.use(cors({

    origin: process.env.FRONTEND_URL || '*',

    credentials: true

  }));

  app.use(bodyParser.json());

  const isDev = process.env.NODE_ENV !== 'production';

  const logger = pino({

    level: process.env.LOG_LEVEL || 'info',

    ...(isDev && {

      transport: {

        target: 'pino-pretty',

        options: {

          colorize: true,

          singleLine: false,

          messageFormat: '{if levelLabel}{levelLabel} - {end}{msg}',

        },

      },

    }),

  });

  // Use pino-http for HTTP logging (better than Morgan for structured logs)

  app.use(pinoHttp({ logger }));

  app.use("/users", userRouter);

  app.use("/auth", authRouter);

  app.use("/moods", moodRouter);

  app.use("/sleep_records", sleepRecordRouter);

  app.use("/triggers", triggerRouter);

  app.use(errorHandler); // always last

  // TODO: flesh the actual page here

  app.use(express.static(path.join(__dirname, './static')));

  app.get(/.*/, (req, res) => {

    res.sendFile(path.join(__dirname, './static/index.html')); });

  process.on('SIGTERM', shutdown);

  process.on('SIGINT', shutdown);

  return app;

}

const shutdown = async () => {

  await Promise.all([closeAllWorkers(), closeAllQueues()]);

  process.exit(0);

};