const {
  createApp,
  getJsResponseTimeout,
  getMaxBodyBytes,
  setJsResponseTimeout,
  setMaxBodyBytes,
} = require("brahma-firelight");

const app = createApp();

// save production from disasters by locking in Rust
// defaults to 30 seconds and 4mb limit.
// set 2 minutes timeout (120 seconds)
setJsResponseTimeout(120);

// set max body to 50 MiB
setMaxBodyBytes(50 * 1024 * 1024); // 52_428_800

console.log("timeout secs:", getJsResponseTimeout()); // prints 120
console.log("max body bytes:", getMaxBodyBytes()); // prints 52428800

// CORS config
app.use((req, res, next) => {
  const origin = req.headers.origin;

  if (origin) {
    res.setHeader("Access-Control-Allow-Origin", origin); // echo back client origin
    res.setHeader("Access-Control-Allow-Credentials", "true");
  } else {
    // fallback (same-origin or no Origin header)
    res.setHeader("Access-Control-Allow-Origin", "*");
  }

  res.setHeader("Access-Control-Allow-Methods", "GET,POST,PUT,DELETE,OPTIONS");
  res.setHeader("Access-Control-Allow-Headers", "Content-Type, Authorization");

  if (req.method === "OPTIONS") {
    res.send(204);
  } else {
    next();
  }
});

// Middlewares

function authMiddleware(req, res, next) {
  if (!req.headers["authorization"]) return res.text("Unauthorized", 401);
  next();
}

// utils.js
function sleep(ms) {
  return new Promise((resolve) => setTimeout(resolve, ms));
}

app.get("/hi", (req, res) => {
  res.json({ message: "Hello World from Brahma-JS!" });
});

// // Async handler returning an object
app.get("/time", async (req) => {
  await sleep(20000);
  return {
    status: 400,
    headers: { "Content-Type": "application/json" }, // Custom Returns
    body: JSON.stringify({ now: Date.now() }),
  };
});

// To send HTML response
app.get("/page", (req, res) => {
  res.html(`<h1>Hello HTML</h1><p>Served by Brahma-JS id: ${req.reqId}</p>`);
});

app.post("/submit", (req, res) => {
  let formData = JSON.parse(req.body);
  console.log("bodyData:", formData);
  res.json(formData, 201); // return the JSON response with http-status-code
});

// Set-Up cookies and User Sessions

app.get("/set-cookies", (req, res) => {
  console.log("Request:-->", req); // Request Parameters-> contains all info + additional meta data
  res.send(
    200, // http-status code
    { "Content-Type": "text/plain" }, // headers Content-Type
    ["a=1; Path=/; HttpOnly", "b=2; Path=/; Secure; Max-Age=3600"], // manual cookie setup
    "hello" // optional Return Body
  );
});

app.get("/redirect", (req, res) => {
  res.redirect("https://google.com");
});

app.post("/protected", authMiddleware, (req, res) =>
  res.json({ success: true })
);

app.listen("0.0.0.0", 2000, () => {
  console.log("Server listening on port 2000");
});

// Enable built in Graceful Shutdown (optional for production use)

// process.on('SIGINT', async () => {
//   console.log('SIGINT → shutting down...');
//   await app.close(5000); // wait up to 5s for requests
//   process.exit(0);
// });

// process.on('SIGTERM', async () => {
//   console.log('SIGTERM → shutting down...');
//   await app.close(5000);
//   process.exit(0);
// });

app.get("/hello", (req, res) => {
  res.send("Hi there!");
});

app.get("/data", async (req, res) => {
  const result = await fetch(
    "https://jsonplaceholder.typicode.com/todos/1"
  ).then((r) => r.json());
  res.json({ result });
});

app.use((req, res, next) => {
  req.startTime = Date.now();
  next();
});

app.get("/delay", async (req, res) => {
  await new Promise((r) => setTimeout(r, 200));
  res.json({ elapsed: Date.now() - req.startTime });
});