import express from "express";
import cors from "cors";
import bodyParser from "body-parser";
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 careActionsRouter from "@app/routes/careActions";
import medicineRegimensRouter from "@app/routes/medicineRegimens";
import exportsRouter from "@app/routes/exports";
import notificationRouter from "@app/routes/notifications";
import reportRouter from "@app/reports/report.router";
import { errorHandler } from "@app/middleware/errorHandler";
import { logger } from "@app/lib/logger";
import { PrismaClient } from "@prisma/client";
import {
  bootWorkers,
  closeAllWorkers,
  closeAllQueues,
  scheduleInsights,
} from "@app/lib/queue";

import pinoHttp from "pino-http";
import { randomUUID } from "crypto";
import path from "path";

export function createApp() {
  const app = express();
  bootWorkers();
  scheduleInsights();

  // Use pino-http for HTTP logging (better than Morgan for structured logs)
  // Registered before the rest so every request has a logger attached,
  // including errors raised by the CORS and body-parsing middleware below
  app.use(
    pinoHttp({
      logger,
      genReqId: (req, res) => {
        const header = req.headers["x-request-id"];
        const requestId =
          (Array.isArray(header) ? header[0] : header) || randomUUID();

        res.setHeader("X-Request-Id", requestId);

        return requestId;
      },
    }),
  );

  // Configure CORS
  app.use(
    cors({
      origin: process.env.FRONTEND_URL || "*",
      credentials: true,
    }),
  );

  app.use(bodyParser.json());

  app.use("/users", userRouter);
  app.use("/auth", authRouter);
  app.use("/moods", moodRouter);
  app.use("/sleep_records", sleepRecordRouter);
  app.use("/triggers", triggerRouter);
  app.use("/insights", insightRouter);
  app.use("/care-actions", careActionsRouter);
  app.use("/medicine-regimens", medicineRegimensRouter);
  app.use("/exports", exportsRouter);
  app.use("/notifications", notificationRouter);
  app.use("/reports", reportRouter);

  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);
};