const { winstonLogger } = require("./logging");

module.exports = (level) => (req, res, next) => {
  res.on("finish", () => {
    const { method, url, headers, query, body, ip, connection } = req;
    const { statusCode } = res;

    if (
      (level === "info" && statusCode < 400) ||
      (level === "warn" && statusCode >= 400 && statusCode < 500) ||
      (level === "error" && statusCode >= 500)
    ) {
      // Flatten nested objects into key-value pairs for metadata
      const flatten = (obj, prefix = "") => {
        if (!obj || typeof obj !== "object") return {};
        const res = {};
        for (const [k, v] of Object.entries(obj)) {
          const key = prefix ? `${prefix}.${k}` : k;
          if (v !== null && typeof v === "object") {
            Object.assign(res, flatten(v, key));
          } else {
            res[key] = String(v);
          }
        }
        return res;
      };

      const meta = {
        statusCode: String(statusCode),
        directIp: String(connection.remoteAddress),
        forwardedIp: String(ip),
        contentLength: String(res.getHeader("content-length") || "0"),
        ...flatten(headers, "headers"),
        ...flatten(query, "query"),
        ...flatten(body, "body"),
      };

      winstonLogger.log({
        level,
        message: `${method} ${url}`,
        ...meta,
      });
    }
  });

  next();
};