BeamMP/BeamMP-Server
1
0
Fork 0
mirror of https://github.com/BeamMP/BeamMP-Server.git synced 2025-07-02 07:45:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Http: cleanup

Browse Source
This commit is contained in:
Lion Kortlepel 2021-11-07 23:09:06 +01:00
parent 9f5fa8fb9b
commit 1e305c3c90
No known key found for this signature in database
GPG Key ID: 4322FF2B4C71259B
1 changed files with 2 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/Http.cpp
View File

@ -32,9 +32,6 @@ std::string GenericRequest(http::verb verb, const std::string& host, int port, c
results = resolver.resolve(protocol, host, std::to_string(port)); results = resolver.resolve(protocol, host, std::to_string(port));
if (!SSL_set_tlsext_host_name(stream.native_handle(), host.c_str())) { if (!SSL_set_tlsext_host_name(stream.native_handle(), host.c_str())) {
boost::system::error_code ec { static_cast<int>(::ERR_get_error()), boost::asio::error::get_ssl_category() }; boost::system::error_code ec { static_cast<int>(::ERR_get_error()), boost::asio::error::get_ssl_category() };
// FIXME: we could throw and crash, if we like
// throw boost::system::system_error { ec };
//debug("POST " + host + target + " failed.");
return false; return false;
} }
beast::get_lowest_layer(stream).connect(results); beast::get_lowest_layer(stream).connect(results);
@ -43,16 +40,12 @@ std::string GenericRequest(http::verb verb, const std::string& host, int port, c
} }
return true; return true;
}; };
//bool ok = try_connect_with_protocol(tcp::v6());
//if (!ok) {
//debug("IPv6 connect failed, trying IPv4");
bool ok = try_connect_with_protocol(tcp::v4()); bool ok = try_connect_with_protocol(tcp::v4());
if (!ok) { if (!ok) {
Application::Console().Write("[ERROR] failed to resolve or connect in POST " + host + target); Application::Console().Write("[ERROR] failed to resolve or connect in POST " + host + target);
Sentry.AddErrorBreadcrumb("failed to resolve or connect to " + host + target, __FILE__, std::to_string(__LINE__)); // FIXME: this is ugly. Sentry.AddErrorBreadcrumb("failed to resolve or connect to " + host + target, __FILE__, std::to_string(__LINE__)); // FIXME: this is ugly.
return "-1"; return "-1";
} }
//}
stream.handshake(ssl::stream_base::client); stream.handshake(ssl::stream_base::client);
http::request<http::string_body> req { verb, target, 11 /* http 1.1 */ }; http::request<http::string_body> req { verb, target, 11 /* http 1.1 */ };
@ -65,11 +58,8 @@ std::string GenericRequest(http::verb verb, const std::string& host, int port, c
req.set(http::field::content_length, std::to_string(body.size())); req.set(http::field::content_length, std::to_string(body.size()));
req.body() = body; req.body() = body;
// beammp_info("body is " + body + " (" + req.body() + ")");
// beammp_info("content size is " + std::to_string(body.size()) + " (" + boost::lexical_cast<std::string>(body.size()) + ")");
} }
for (const auto& pair : fields) { for (const auto& pair : fields) {
// beammp_info("setting " + pair.first + " to " + pair.second);
req.set(pair.first, pair.second); req.set(pair.first, pair.second);
} }
@ -81,7 +71,7 @@ std::string GenericRequest(http::verb verb, const std::string& host, int port, c
std::string ValueString(header.value()); std::string ValueString(header.value());
request_data[KeyString] = ValueString; request_data[KeyString] = ValueString;
} }
Sentry.SetContext("https-post-request-data", request_data); Sentry.SetContext("https-request-data", request_data);
std::stringstream oss; std::stringstream oss;
oss << req; oss << req;
@ -108,7 +98,7 @@ std::string GenericRequest(http::verb verb, const std::string& host, int port, c
std::string ValueString(header.value()); std::string ValueString(header.value());
response_data[KeyString] = ValueString; response_data[KeyString] = ValueString;
} }
Sentry.SetContext("https-post-response-data", response_data); Sentry.SetContext("https-response-data", response_data);
if (status) { if (status) {
*status = response.base().result_int(); *status = response.base().result_int();
@ -121,11 +111,9 @@ std::string GenericRequest(http::verb verb, const std::string& host, int port, c
stream.shutdown(ec); stream.shutdown(ec);
// IGNORING ec // IGNORING ec
// beammp_info(result.str());
std::string debug_response_str; std::string debug_response_str;
std::getline(result, debug_response_str); std::getline(result, debug_response_str);
//debug("POST " + host + target + ": " + debug_response_str);
return std::string(response.body()); return std::string(response.body());
} catch (const std::exception& e) { } catch (const std::exception& e) {