docker/main.cc

//
//  main.cc
//
//  Copyright (c) 2026 Yuji Hirose. All rights reserved.
//  MIT License
//

#include <atomic>
#include <chrono>
#include <ctime>
#include <format>
#include <iomanip>
#include <iostream>
#include <signal.h>
#include <sstream>

#include <httplib.h>

using namespace httplib;

const auto SERVER_NAME =
    std::format("cpp-httplib-server/{}", CPPHTTPLIB_VERSION);

Server svr;

void signal_handler(int signal) {
  if (signal == SIGINT || signal == SIGTERM) {
    std::cout << "\nReceived signal, shutting down gracefully...\n";
    svr.stop();
  }
}

std::string get_time_format() {
  auto now = std::chrono::system_clock::now();
  auto time_t = std::chrono::system_clock::to_time_t(now);

  std::stringstream ss;
  ss << std::put_time(std::localtime(&time_t), "%d/%b/%Y:%H:%M:%S %z");
  return ss.str();
}

std::string get_error_time_format() {
  auto now = std::chrono::system_clock::now();
  auto time_t = std::chrono::system_clock::to_time_t(now);

  std::stringstream ss;
  ss << std::put_time(std::localtime(&time_t), "%Y/%m/%d %H:%M:%S");
  return ss.str();
}

// Escape a value for a log line the way NGINX does: '"', '\\', control
// bytes and non-ASCII bytes become \xHH. Request fields are attacker-controlled
// (e.g. a raw CR in the request target or a decoded %0D%0A in req.path), so
// writing them verbatim would let a client forge extra log lines.
std::string escape_log(const std::string &s) {
  std::string out;
  out.reserve(s.size());
  for (unsigned char c : s) {
    if (c == '"' || c == '\\' || c < 0x20 || c >= 0x7f) {
      out += std::format("\\x{:02X}", c);
    } else {
      out += static_cast<char>(c);
    }
  }
  return out;
}

// NGINX Combined log format:
// $remote_addr - $remote_user [$time_local] "$request" $status $body_bytes_sent
// "$http_referer" "$http_user_agent"
void nginx_access_logger(const Request &req, const Response &res) {
  std::string remote_user =
      "-"; // cpp-httplib doesn't have built-in auth user tracking
  auto time_local = get_time_format();
  // $request is the original request line, so log the raw target rather than
  // the percent-decoded req.path.
  auto request = std::format("{} {} {}", req.method, req.target, req.version);
  auto status = res.status;
  // A static file is sent by a content provider, which leaves res.body empty.
  auto body_bytes_sent =
      req.method == "HEAD" ? 0 : res.get_header_value_u64("Content-Length");
  auto http_referer = req.get_header_value("Referer");
  if (http_referer.empty()) http_referer = "-";
  auto http_user_agent = req.get_header_value("User-Agent");
  if (http_user_agent.empty()) http_user_agent = "-";

  std::cout << std::format("{} - {} [{}] \"{}\" {} {} \"{}\" \"{}\"",
                           req.remote_addr, remote_user, time_local,
                           escape_log(request), status, body_bytes_sent,
                           escape_log(http_referer), escape_log(http_user_agent))
            << std::endl;
}

// NGINX Error log format:
// YYYY/MM/DD HH:MM:SS [level] message, client: client_ip, request: "request",
// host: "host"
void nginx_error_logger(const Error &err, const Request *req) {
  auto time_local = get_error_time_format();
  std::string level = "error";

  if (req) {
    auto request =
        std::format("{} {} {}", req->method, req->target, req->version);
    auto host = req->get_header_value("Host");
    if (host.empty()) host = "-";

    std::cerr << std::format("{} [{}] {}, client: {}, request: "
                             "\"{}\", host: \"{}\"",
                             time_local, level, to_string(err),
                             req->remote_addr, escape_log(request),
                             escape_log(host))
              << std::endl;
  } else {
    // If no request context, just log the error
    std::cerr << std::format("{} [{}] {}", time_local, level, to_string(err))
              << std::endl;
  }
}

void print_usage(const char *program_name) {
  std::cout << "Usage: " << program_name << " [OPTIONS]" << std::endl;
  std::cout << std::endl;
  std::cout << "Options:" << std::endl;
  std::cout << "  --host <hostname>        Server hostname (default: localhost)"
            << std::endl;
  std::cout << "  --port <port>            Server port (default: 8080)"
            << std::endl;
  std::cout << "  --mount <mount:path>     Mount point and document root"
            << std::endl;
  std::cout << "                           Format: mount_point:document_root"
            << std::endl;
  std::cout << "                           (default: /:./html)" << std::endl;
  std::cout << "  --trusted-proxy <ip>     Add trusted proxy IP address"
            << std::endl;
  std::cout << "                           (can be specified multiple times)"
            << std::endl;
  std::cout << "  --version                Show version information"
            << std::endl;
  std::cout << "  --help                   Show this help message" << std::endl;
  std::cout << std::endl;
  std::cout << "Examples:" << std::endl;
  std::cout << "  " << program_name
            << " --host localhost --port 8080 --mount /:./html" << std::endl;
  std::cout << "  " << program_name
            << " --host 0.0.0.0 --port 3000 --mount /api:./api" << std::endl;
  std::cout << "  " << program_name
            << " --trusted-proxy 192.168.1.100 --trusted-proxy 10.0.0.1"
            << std::endl;
}

struct ServerConfig {
  std::string hostname = "localhost";
  int port = 8080;
  std::string mount_point = "/";
  std::string document_root = "./html";
  std::vector<std::string> trusted_proxies;
};

enum class ParseResult { SUCCESS, HELP_REQUESTED, VERSION_REQUESTED, ERROR };

ParseResult parse_command_line(int argc, char *argv[], ServerConfig &config) {
  for (int i = 1; i < argc; i++) {
    if (strcmp(argv[i], "--help") == 0 || strcmp(argv[i], "-h") == 0) {
      print_usage(argv[0]);
      return ParseResult::HELP_REQUESTED;
    } else if (strcmp(argv[i], "--host") == 0) {
      if (i + 1 >= argc) {
        std::cerr << "Error: --host requires a hostname argument" << std::endl;
        print_usage(argv[0]);
        return ParseResult::ERROR;
      }
      config.hostname = argv[++i];
    } else if (strcmp(argv[i], "--port") == 0) {
      if (i + 1 >= argc) {
        std::cerr << "Error: --port requires a port number argument"
                  << std::endl;
        print_usage(argv[0]);
        return ParseResult::ERROR;
      }
      config.port = std::atoi(argv[++i]);
      if (config.port <= 0 || config.port > 65535) {
        std::cerr << "Error: Invalid port number. Must be between 1 and 65535"
                  << std::endl;
        return ParseResult::ERROR;
      }
    } else if (strcmp(argv[i], "--mount") == 0) {
      if (i + 1 >= argc) {
        std::cerr
            << "Error: --mount requires mount_point:document_root argument"
            << std::endl;
        print_usage(argv[0]);
        return ParseResult::ERROR;
      }
      std::string mount_arg = argv[++i];
      auto colon_pos = mount_arg.find(':');
      if (colon_pos == std::string::npos) {
        std::cerr << "Error: --mount argument must be in format "
                     "mount_point:document_root"
                  << std::endl;
        print_usage(argv[0]);
        return ParseResult::ERROR;
      }
      config.mount_point = mount_arg.substr(0, colon_pos);
      config.document_root = mount_arg.substr(colon_pos + 1);

      if (config.mount_point.empty() || config.document_root.empty()) {
        std::cerr
            << "Error: Both mount_point and document_root must be non-empty"
            << std::endl;
        return ParseResult::ERROR;
      }
    } else if (strcmp(argv[i], "--version") == 0) {
      std::cout << CPPHTTPLIB_VERSION << std::endl;
      return ParseResult::VERSION_REQUESTED;
    } else if (strcmp(argv[i], "--trusted-proxy") == 0) {
      if (i + 1 >= argc) {
        std::cerr << "Error: --trusted-proxy requires an IP address argument"
                  << std::endl;
        print_usage(argv[0]);
        return ParseResult::ERROR;
      }
      config.trusted_proxies.push_back(argv[++i]);
    } else {
      std::cerr << "Error: Unknown option '" << argv[i] << "'" << std::endl;
      print_usage(argv[0]);
      return ParseResult::ERROR;
    }
  }
  return ParseResult::SUCCESS;
}

bool setup_server(Server &svr, const ServerConfig &config) {
  svr.set_logger(nginx_access_logger);
  svr.set_error_logger(nginx_error_logger);

  // Set trusted proxies if specified
  if (!config.trusted_proxies.empty()) {
    svr.set_trusted_proxies(config.trusted_proxies);
  }

  auto ret = svr.set_mount_point(config.mount_point, config.document_root);
  if (!ret) {
    std::cerr
        << std::format(
               "Error: Cannot mount '{}' to '{}'. Directory may not exist.",
               config.mount_point, config.document_root)
        << std::endl;
    return false;
  }

  svr.set_file_extension_and_mimetype_mapping("html", "text/html");
  svr.set_file_extension_and_mimetype_mapping("htm", "text/html");
  svr.set_file_extension_and_mimetype_mapping("css", "text/css");
  svr.set_file_extension_and_mimetype_mapping("js", "text/javascript");
  svr.set_file_extension_and_mimetype_mapping("json", "application/json");
  svr.set_file_extension_and_mimetype_mapping("xml", "application/xml");
  svr.set_file_extension_and_mimetype_mapping("png", "image/png");
  svr.set_file_extension_and_mimetype_mapping("jpg", "image/jpeg");
  svr.set_file_extension_and_mimetype_mapping("jpeg", "image/jpeg");
  svr.set_file_extension_and_mimetype_mapping("gif", "image/gif");
  svr.set_file_extension_and_mimetype_mapping("svg", "image/svg+xml");
  svr.set_file_extension_and_mimetype_mapping("ico", "image/x-icon");
  svr.set_file_extension_and_mimetype_mapping("pdf", "application/pdf");
  svr.set_file_extension_and_mimetype_mapping("zip", "application/zip");
  svr.set_file_extension_and_mimetype_mapping("txt", "text/plain");

  svr.set_error_handler([](const Request & /*req*/, Response &res) {
    if (res.status == 404) {
      res.set_content(
          std::format(
              "<html><head><title>404 Not Found</title></head>"
              "<body><h1>404 Not Found</h1>"
              "<p>The requested resource was not found on this server.</p>"
              "<hr><p>{}</p></body></html>",
              SERVER_NAME),
          "text/html");
    }
  });

  svr.set_pre_routing_handler([](const Request & /*req*/, Response &res) {
    res.set_header("Server", SERVER_NAME);
    return Server::HandlerResponse::Unhandled;
  });

  signal(SIGINT, signal_handler);
  signal(SIGTERM, signal_handler);

  return true;
}

int main(int argc, char *argv[]) {
  ServerConfig config;

  auto result = parse_command_line(argc, argv, config);
  switch (result) {
  case ParseResult::HELP_REQUESTED:
  case ParseResult::VERSION_REQUESTED: return 0;
  case ParseResult::ERROR: return 1;
  case ParseResult::SUCCESS: break;
  }

  if (!setup_server(svr, config)) { return 1; }

  std::cout << "Serving HTTP on " << config.hostname << ":" << config.port
            << std::endl;
  std::cout << "Mount point: " << config.mount_point << " -> "
            << config.document_root << std::endl;

  if (!config.trusted_proxies.empty()) {
    std::cout << "Trusted proxies: ";
    for (size_t i = 0; i < config.trusted_proxies.size(); ++i) {
      if (i > 0) std::cout << ", ";
      std::cout << config.trusted_proxies[i];
    }
    std::cout << std::endl;
  }

  std::cout << "Press Ctrl+C to shutdown gracefully..." << std::endl;

  auto ret = svr.listen(config.hostname, config.port);

  std::cout << "Server has been shut down." << std::endl;

  return ret ? 0 : 1;
}