Method read_request

src/server/server.cpp:208–247

@brief read request

///@brief read request
void HttpSession::read_request(bool cors) {
    auto self = shared_from_this();

    // Use a parser to control the maximum accepted body size
    auto parser = std::make_shared<http::request_parser<http::string_body>>();
    parser->body_limit(self->server_.get_max_body_size_bytes());

    http::async_read(self->socket_, self->buffer_, *parser,
        [self, parser, cors](beast::error_code ec, std::size_t bytes_transferred) {
            if (!ec) {
                header_print("TCP", "Read " + std::to_string(bytes_transferred) + " bytes from socket");
                // Move the parsed message into our request object
                self->req_ = parser->release();
                self->handle_request(cors);
                return;
            }

            // Handle body too large explicitly with 413
            if (ec == http::error::body_limit) {
                self->res_ = {};
                self->res_.version(11);
                self->res_.result(http::status::payload_too_large);
                self->res_.set(http::field::content_type, "application/json");
                self->res_.keep_alive(false);
                json err = {{"error", "Request payload too large"}, {"max_bytes", self->server_.get_max_body_size_bytes()}};
                self->res_.body() = err.dump();
                self->res_.prepare_payload();
                self->write_response();
                return;
            }

            // Connection closed or other error, decrement connection counter
            try {
                header_print("🔒 ", "TCP connection closed - Remote: " + self->socket_.remote_endpoint().address().to_string() + ":" + std::to_string(self->socket_.remote_endpoint().port()));
            } catch (...) {
                header_print("🔒 ", "TCP connection closed - Remote endpoint unavailable");
            }
            self->server_.active_connections_.fetch_sub(1);
        });
}

///@brief handle request