Method handle_request

src/server/server.cpp:251–299

///@brief handle request

void HttpSession::handle_request(bool cors) {
    // --- BEGIN: Preflight (OPTIONS) request handling ---
    if (req_.method() == http::verb::options && cors) {
        header_print("✈️ ", "Handling Preflight (OPTIONS) request");

        // reponse empty body for OPTIONS
        auto options_res = std::make_shared<http::response<http::empty_body>>();
        options_res->version(req_.version());
        options_res->result(http::status::ok); 
        options_res->keep_alive(req_.keep_alive());

        options_res->set("Access-Control-Allow-Origin", "*");
        options_res->set("Access-Control-Allow-Methods", "GET, POST, OPTIONS");
        options_res->set("Access-Control-Allow-Headers", "Content-Type, Authorization, X-Requested-With");

        options_res->prepare_payload();
        auto self = shared_from_this();
        http::async_write(socket_, *options_res,
            [self, cors, options_res](beast::error_code ec, std::size_t) {
                if (ec) {
                    return;
                }
                // waiting the true response
                self->read_request(cors);
            });
        return;
    }
    // --- END: Preflight (OPTIONS) request handling ---


    // IF not OPTIONS
    // Reset response
    res_ = {};
    res_.version(req_.version());
    res_.keep_alive(req_.keep_alive());

    // Handle the request through the server
    bool deferred = server_.handle_request(req_, res_, socket_, shared_from_this());

    // Clear the buffer after processing to prevent data accumulation
    buffer_.consume(buffer_.size());

    if (!is_streaming_ && !deferred) {
        write_response();
    } else {
        // For streaming responses, we need to handle connection cleanup differently
        // The connection will be closed when streaming ends
    }
}

///@brief write response
void HttpSession::write_response() {