server.js

import express from "express";
import dotenv from "dotenv";
import cors from "cors";
import helmet from "helmet";
import pool from "./src/config/db.js";

// Routes Imports
import defaultRouter from "./src/defaultRoute.js";
import productRouter from "./src/modules/Products/productRoutes.js";
import productMediaRoutes from "./src/modules/ProductMedia/productMediaRoutes.js";
import authRoutes from "./src/modules/AuthSystem/authRoutes.js";
import authAdminRoutes from "./src/modules/AuthAdmin/authAdminRoutes.js";
import inventoryManagementRoutes from "./src/modules/InventoryManagement/inventoryRoutes.js";
import inventoryMovementsRoutes from "./src/modules/InventoryMovements/inventoryMovementRoutes.js";
import cartSystemRoutes from "./src/modules/cartSystem/cartRoutes.js";

//  Tables Imports
import { productTable } from "./src/db/productTable.sql.js";
import { userTable } from "./src/db/userTable.sql.js";
import { productMediaTable } from "./src/db/productMediaTable.sql.js";
import { inventoryTable } from "./src/db/inventoryTable.sql.js";
import { inventoryMovementTable } from "./src/db/inventoryMovementTable.sql.js";
import { cartTable } from "./src/db/cartTable.sql.js";
import { cartItemTable } from "./src/db/cartItemTable.sql.js";

// Swagger Imports
import swaggerUi from "swagger-ui-express";
import swaggerSpec from "./src/config/swagger.js";

// Redis Imports
import redisClient from "./src/config/redis.js";
import redisRouter from "./src/modules/RedisAdminStats/redisRoutes.js";

//  Redis Warm Cache Routes
import cacheWarmRoutes from "./src/modules/RedisAdminStats/cacheWarmRoutes.js";

//   Redis Stats Routes
import redisStatsRoutes from "./src/modules/RedisAdminStats/redisStatsRoutes.js";

// Dev Scripts
import { seedAminUser } from "./src/seed/admin.seed.js";

// Instances Creation
dotenv.config();
const app = express();
const PORT = process.env.BACKEND_PORT || 8000;

//  Default Middlewares
app.use(
  cors({
    origin: (origin, callback) => {
      // Allow requests with no origin (like Postman)
      if (!origin) return callback(null, true);

      // Allow localhost (dev)
      if (origin.includes("localhost")) {
        return callback(null, true);
      }

      // Allow ALL vercel deployments
      if (origin.includes("vercel.app")) {
        return callback(null, true);
      }

      // Block everything else
      return callback(new Error("Not allowed by CORS"));
    },
    methods: ["GET", "POST", "PUT", "DELETE"],
    credentials: true,
    allowedHeaders: ["Content-Type", "Authorization"],
  }),
);

app.use(express.json());

// Logger Middleware
app.use((req, res, next) => {
  res.on("finish", () => {
    const timeStamp = new Date().toISOString();
    console.log(`[${timeStamp}] ${req.method} ${req.url} ${res.statusCode}`);
  });
  next();
});

// Security Middleware
app.use(helmet());

// Router Usage
app.use("/api/v1/RedisImplementation/health", defaultRouter);
app.use("/api/v1/RedisImplementation/auth", authRoutes);
app.use("/api/v1/RedisImplementation/auth/admin", authAdminRoutes);
app.use("/api/v1/RedisImplementation/products", productRouter);
app.use("/api/v1/RedisImplementation/redis", redisRouter);
app.use("/api/v1/RedisImplementation/cache", cacheWarmRoutes);
app.use("/api/v1/RedisImplementation/redis", redisStatsRoutes);
app.use("/api/v1/RedisImplementation/product-media", productMediaRoutes);
app.use("/api/v1/RedisImplementation/inventory", inventoryManagementRoutes);
app.use("/api/v1/RedisImplementation/cart", cartSystemRoutes);


app.use(
  "/api/v1/RedisImplementation/inventory-movements",
  inventoryMovementsRoutes,
);

app.use(
  "/api-docs/RedisImplementation",
  swaggerUi.serve,
  swaggerUi.setup(swaggerSpec),
);

// 404 Handler
app.use((req, res) => {
  res.status(404).json({
    success: false,
    message: "Route Not Found",
  });
});

// Centralized Error Catching
app.use((err, req, res, next) => {
  console.log(err);
  res.status(err.statusCode || 500).json({
    success: false,
    message: err.message || "Internal Server Error",
  });
});

// Initialization of DB
async function initDB() {
  try {
    // PostgreSQL check
    const result = await pool.query("SELECT NOW()");
    console.log("Database Connected");
    console.log(result.rows[0]);

    await pool.query(`CREATE EXTENSION IF NOT EXISTS "pgcrypto";`);
    await productTable();
    await userTable();
    await productMediaTable();
    await inventoryTable();
    await inventoryMovementTable();
    await cartTable();
    await cartItemTable();

    console.log({
      ProductTable: "Ready",
      UserTable: "Ready",
      ProductMediaTable: "Ready",
      InventoryTable: "Ready",
      InventoryMovementTable: "Ready",
      CartTable: "Ready",
      cartItemTable: "Ready",
    });

    // Redis check
    await redisClient.connect();
    console.log("Redis Connected");

    // optional sanity test
    await redisClient.set("health-check", "ok");
    const test = await redisClient.get("health-check");
    console.log("Redis Test Value:", test);
  } catch (err) {
    console.error("Database Connection Failed");
    console.error(err);
    process.exit(1);
  }
}

// Server Listening
async function startServer() {
  await initDB();
  // Seed Script
  if (process.env.RUN_SEED_ADMIN === "true") {
    try {
      await seedAminUser();
      console.log("Admin user seeding completed");
    } catch (error) {
      console.error("Admin Seeding Failed", err.message);
    }
  }

  app.listen(PORT, () => {
    console.log(`Server is Running on http://localhost:${PORT}`);
  });
}

startServer();