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("/insights", insightRouter);

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