blob: 2047b0120a0021bbed9fb671c9cccbcd13361f21 (
about) (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
module;
#include <boost/asio/connect.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/ssl.hpp>
#include <boost/beast/core.hpp>
#include <boost/beast/http.hpp>
export module routemon:http.client;
export import :http.common;
namespace net = boost::asio;
namespace ssl = net::ssl;
using tcp = net::ip::tcp;
namespace routemon::http {
export class client
{
net::io_context& ioc_;
ssl::context sslc_{ssl::context::tlsv12_client};
tcp::resolver resolver_;
public:
explicit client(net::io_context& ioc);
template <class ReqBody>
auto do_request(bhttp::request<ReqBody>& req)
-> bhttp::response<bhttp::dynamic_body>
{
// TODO: call into non-template member ASAP.
// Consider using beast::message_generator.
auto stream = ssl::stream<beast::tcp_stream>{ioc_, sslc_};
auto host = std::string{req.at(bhttp::field::host)};
if (!SSL_set_tlsext_host_name(stream.native_handle(), host.c_str()))
{
throw beast::system_error(
static_cast<int>(::ERR_get_error()), net::error::get_ssl_category());
}
stream.set_verify_callback(ssl::host_name_verification(host));
auto const results = resolver_.resolve(host, "443");
beast::get_lowest_layer(stream).connect(results);
stream.handshake(ssl::stream_base::client);
req.set(bhttp::field::user_agent, "routemon/1.0");
bhttp::write(stream, req);
auto buffer = beast::flat_buffer{};
auto res = bhttp::response<bhttp::dynamic_body>{};
bhttp::read(stream, buffer, res);
auto ec = beast::error_code{};
stream.shutdown(ec);
if (ec != net::ssl::error::stream_truncated)
throw beast::system_error{ec};
return res;
}
};
} // namespace routemon::http
|
