diff --git a/tooling/pipeline/src/web_client/http_web_client.cc b/tooling/pipeline/src/web_client/http_web_client.cc index b0910fff..c9f0891e 100644 --- a/tooling/pipeline/src/web_client/http_web_client.cc +++ b/tooling/pipeline/src/web_client/http_web_client.cc @@ -26,47 +26,47 @@ const std::regex kUrlRegex( R"(^(https?://[^/?#]+)(/[^?#]*(?:\?[^#]*)?(?:#.*)?)?)"); std::pair SplitUrl(const std::string& url) { - std::smatch match; - if (!std::regex_match(url, match, kUrlRegex)) { - throw std::invalid_argument("[HttpWebClient] Malformed URL: " + url); - } + std::smatch match; + if (!std::regex_match(url, match, kUrlRegex)) { + throw std::invalid_argument("[HttpWebClient] Malformed URL: " + url); + } - return {match[1].str(), match[2].matched ? match[2].str() : "/"}; + return {match[1].str(), match[2].matched ? match[2].str() : "/"}; } } // namespace std::string HttpWebClient::Get(const std::string& url) { - const auto [origin, path] = SplitUrl(url); + const auto [origin, path] = SplitUrl(url); - httplib::Client client(origin); - client.set_follow_location(true); - client.set_connection_timeout(kConnectionTimeoutSeconds); - client.set_read_timeout(kReadTimeoutSeconds); - client.set_default_headers({{"Accept", "application/json"}, - {"User-Agent", "biergarten-pipeline/1.0"}}); + httplib::Client client(origin); + client.set_follow_location(true); + client.set_connection_timeout(kConnectionTimeoutSeconds); + client.set_read_timeout(kReadTimeoutSeconds); + client.set_default_headers({{"Accept", "application/json"}, + {"User-Agent", "biergarten-pipeline/1.0"}}); - const httplib::Result result = client.Get(path); + const httplib::Result result = client.Get(path); - if (!result) { - throw std::runtime_error( - std::format("[HttpWebClient] Request failed for URL: {} — {}", url, - httplib::to_string(result.error()))); - } + if (!result) { + throw std::runtime_error( + std::format("[HttpWebClient] Request failed for URL: {} — {}", url, + httplib::to_string(result.error()))); + } - if (result->status < kSuccessMin || result->status >= kSuccessMax) { - if (logger_) { - logger_->Log({.level = LogLevel::Error, - .phase = PipelinePhase::Enrichment, - .message = std::format( - "[HttpWebClient] Request failed for URL: {}", url)}); - } - throw std::runtime_error(std::format("[HttpWebClient] HTTP {} for URL: {}", - result->status, url)); - } + if (result->status < kSuccessMin || result->status >= kSuccessMax) { + if (logger_) { + logger_->Log({.level = LogLevel::Error, + .phase = PipelinePhase::Enrichment, + .message = std::format( + "[HttpWebClient] Request failed for URL: {}", url)}); + } + throw std::runtime_error(std::format( + "[HttpWebClient] HTTP {} for URL: {}", result->status, url)); + } - return result->body; + return result->body; } std::string HttpWebClient::EncodeURL(const std::string& value) { - return httplib::encode_uri_component(value); + return httplib::encode_uri_component(value); }