feedc0de/boost_beast
1
0
Fork 0
forked from boostorg/beast
Code Pull Requests Activity

New constructors for message:

Browse Source 
The message class now behaves like a pair with respect to the construction
of the body and headers. Additional constructors allow construction of
just the body portion from a tuple, leaving the headers default
constructed.

Previous constructors are removed as they were a notational convenience
for assembling HTTP/1 requests and responses. They are not necessary
as this library aims at library writers and not end users.
This commit is contained in:
Vinnie Falco
2016-05-07 15:18:22 -04:00
parent 3484996048
commit c49cde844b
13 changed files with 334 additions and 144 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
README.md
View File

@@ -63,7 +63,10 @@ int main()
r.resolve(boost::asio::ip::tcp::resolver::query{host, "http"})); r.resolve(boost::asio::ip::tcp::resolver::query{host, "http"}));
// Send HTTP request using beast // Send HTTP request using beast
beast::http::request_v1<beast::http::empty_body> req({"GET", "/", 11}); beast::http::request_v1<beast::http::empty_body> req;
req.method = "GET";
req.url = "/";
req.version = 11;
req.headers.replace("Host", host + ":" + std::to_string(sock.remote_endpoint().port())); req.headers.replace("Host", host + ":" + std::to_string(sock.remote_endpoint().port()));
req.headers.replace("User-Agent", "Beast"); req.headers.replace("User-Agent", "Beast");
beast::http::prepare(req); beast::http::prepare(req);

5
doc/beast.qbk
View File

@@ -113,7 +113,10 @@ int main()
r.resolve(boost::asio::ip::tcp::resolver::query{host, "http"})); r.resolve(boost::asio::ip::tcp::resolver::query{host, "http"}));
// Send HTTP request using beast // Send HTTP request using beast
beast::http::request_v1<beast::http::empty_body> req({"GET", "/", 11}); beast::http::request_v1<beast::http::empty_body> req;
req.method = "GET";
req.url = "/";
req.version = 11;
req.headers.replace("Host", host + ":" + std::to_string(sock.remote_endpoint().port())); req.headers.replace("Host", host + ":" + std::to_string(sock.remote_endpoint().port()));
req.headers.replace("User-Agent", "Beast"); req.headers.replace("User-Agent", "Beast");
beast::http::prepare(req); beast::http::prepare(req);

12
examples/http_async_server.hpp
View File

@@ -127,8 +127,10 @@ private:
path = root_ + path; path = root_ + path;
if(! boost::filesystem::exists(path)) if(! boost::filesystem::exists(path))
{ {
response_v1<string_body> resp( response_v1<string_body> resp;
{404, "Not Found", req_.version}); resp.status = 404;
resp.reason = "Not Found";
resp.version = req_.version;
resp.headers.replace("Server", "http_async_server"); resp.headers.replace("Server", "http_async_server");
resp.body = "The file '" + path + "' was not found"; resp.body = "The file '" + path + "' was not found";
prepare(resp); prepare(resp);
@@ -137,8 +139,10 @@ private:
asio::placeholders::error)); asio::placeholders::error));
return; return;
} }
resp_type resp( resp_type resp;
{200, "OK", req_.version}); resp.status = 200;
resp.reason = "OK";
resp.version = req_.version;
resp.headers.replace("Server", "http_async_server"); resp.headers.replace("Server", "http_async_server");
resp.headers.replace("Content-Type", "text/html"); resp.headers.replace("Content-Type", "text/html");
resp.body = path; resp.body = path;

5
examples/http_crawl.cpp
View File

@@ -46,7 +46,10 @@ int main(int, char const*[])
stream<ip::tcp::socket> hs(ios); stream<ip::tcp::socket> hs(ios);
connect(hs.lowest_layer(), it); connect(hs.lowest_layer(), it);
auto ep = hs.lowest_layer().remote_endpoint(); auto ep = hs.lowest_layer().remote_endpoint();
request_v1<empty_body> req({"GET", "/", 11}); request_v1<empty_body> req;
req.method = "GET";
req.url = "/";
req.version = 11;
req.headers.insert("Host", host + req.headers.insert("Host", host +
std::string(":") + std::to_string(ep.port())); std::string(":") + std::to_string(ep.port()));
req.headers.insert("User-Agent", "beast/http"); req.headers.insert("User-Agent", "beast/http");

5
examples/http_example.cpp
View File

@@ -21,7 +21,10 @@ int main()
r.resolve(boost::asio::ip::tcp::resolver::query{host, "http"})); r.resolve(boost::asio::ip::tcp::resolver::query{host, "http"}));
// Send HTTP request using beast // Send HTTP request using beast
beast::http::request_v1<beast::http::empty_body> req({"GET", "/", 11}); beast::http::request_v1<beast::http::empty_body> req;
req.method = "GET";
req.url = "/";
req.version = 11;
req.headers.replace("Host", host + ":" + std::to_string(sock.remote_endpoint().port())); req.headers.replace("Host", host + ":" + std::to_string(sock.remote_endpoint().port()));
req.headers.replace("User-Agent", "Beast"); req.headers.replace("User-Agent", "Beast");
beast::http::prepare(req); beast::http::prepare(req);

12
examples/http_sync_server.hpp
View File

@@ -155,8 +155,10 @@ public:
path = root_ + path; path = root_ + path;
if(! boost::filesystem::exists(path)) if(! boost::filesystem::exists(path))
{ {
response_v1<string_body> resp( response_v1<string_body> resp;
{404, "Not Found", req.version}); resp.status = 404;
resp.reason = "Not Found";
resp.version = req.version;
resp.headers.replace("Server", "http_sync_server"); resp.headers.replace("Server", "http_sync_server");
resp.body = "The file '" + path + "' was not found"; resp.body = "The file '" + path + "' was not found";
prepare(resp); prepare(resp);
@@ -164,8 +166,10 @@ public:
if(ec) if(ec)
break; break;
} }
resp_type resp( resp_type resp;
{200, "OK", req.version}); resp.status = 200;
resp.reason = "OK";
resp.version = req.version;
resp.headers.replace("Server", "http_sync_server"); resp.headers.replace("Server", "http_sync_server");
resp.headers.replace("Content-Type", "text/html"); resp.headers.replace("Content-Type", "text/html");
resp.body = path; resp.body = path;

22
include/beast/http/impl/message_v1.ipp
View File

@@ -16,28 +16,6 @@
namespace beast { namespace beast {
namespace http { namespace http {
template<bool isRequest, class Body, class Headers>
message_v1<isRequest, Body, Headers>::
message_v1(request_params params)
{
static_assert(isRequest, "message is not a request");
this->method = params.method;
this->url = std::move(params.url);
version = params.version;
}
template<bool isRequest, class Body, class Headers>
message_v1<isRequest, Body, Headers>::
message_v1(response_params params)
{
static_assert(! isRequest, "message is not a response");
this->status = params.status;
this->reason = std::move(params.reason);
version = params.version;
}
//------------------------------------------------------------------------------
template<bool isRequest, class Body, class Headers> template<bool isRequest, class Body, class Headers>
bool bool
is_keep_alive(message_v1<isRequest, Body, Headers> const& msg) is_keep_alive(message_v1<isRequest, Body, Headers> const& msg)

76
include/beast/http/message.hpp
View File

@@ -9,8 +9,11 @@
#define BEAST_HTTP_MESSAGE_HPP #define BEAST_HTTP_MESSAGE_HPP
#include <beast/http/basic_headers.hpp> #include <beast/http/basic_headers.hpp>
#include <beast/core/detail/integer_sequence.hpp>
#include <memory> #include <memory>
#include <string> #include <string>
#include <tuple>
#include <utility>
namespace beast { namespace beast {
namespace http { namespace http {
@@ -69,6 +72,79 @@ struct message
/// A container representing the body. /// A container representing the body.
typename Body::value_type body; typename Body::value_type body;
/// Default constructor
message() = default;
/** Construct a message.
@param u An argument forwarded to the body constructor.
*/
template<class U>
explicit
message(U&& u)
: body(std::forward<U>(u))
{
}
/** Construct a message.
@param u An argument forwarded to the body constructor.
@param v An argument forwarded to the headers constructor.
*/
template<class U, class V>
explicit
message(U&& u, V&& v)
: headers(std::forward<V>(v))
, body(std::forward<U>(u))
{
}
/** Construct a message.
@param un A tuple forwarded as a parameter pack to the body constructor.
*/
template<class... Un>
message(std::piecewise_construct_t, std::tuple<Un...> un)
: message(std::piecewise_construct, un,
beast::detail::make_index_sequence<sizeof...(Un)>{})
{
}
/** Construct a message.
@param un A tuple forwarded as a parameter pack to the body constructor.
@param vn A tuple forwarded as a parameter pack to the headers constructor.
*/
template<class... Un, class... Vn>
explicit
message(std::piecewise_construct_t,
std::tuple<Un...>&& un, std::tuple<Vn...>&& vn)
: message(std::piecewise_construct, un, vn,
beast::detail::make_index_sequence<sizeof...(Un)>{},
beast::detail::make_index_sequence<sizeof...(Vn)>{})
{
}
private:
template<class... Un, size_t... IUn>
message(std::piecewise_construct_t,
std::tuple<Un...>& tu, beast::detail::index_sequence<IUn...>)
: body(std::forward<Un>(std::get<IUn>(tu))...)
{
}
template<class... Un, class... Vn,
std::size_t... IUn, std::size_t... IVn>
message(std::piecewise_construct_t,
std::tuple<Un...>& tu, std::tuple<Vn...>& tv,
beast::detail::index_sequence<IUn...>,
beast::detail::index_sequence<IVn...>)
: headers(std::forward<Vn>(std::get<IVn>(tv))...)
, body(std::forward<Un>(std::get<IUn>(tu))...)
{
}
}; };
#if ! GENERATING_DOCS #if ! GENERATING_DOCS

33
include/beast/http/message_v1.hpp
View File

@@ -15,24 +15,6 @@
namespace beast { namespace beast {
namespace http { namespace http {
#if ! GENERATING_DOCS
struct request_params
{
std::string method;
std::string url;
int version;
};
struct response_params
{
int status;
std::string reason;
int version;
};
#endif
/** A HTTP/1 message. /** A HTTP/1 message.
A message can be a request or response, depending on the `isRequest` A message can be a request or response, depending on the `isRequest`
@@ -54,15 +36,18 @@ struct message_v1 : message<isRequest, Body, Headers>
/// HTTP/1 version (10 or 11) /// HTTP/1 version (10 or 11)
int version; int version;
/// Default constructor
message_v1() = default; message_v1() = default;
/// Construct a HTTP/1 request. /// Constructor
template<class Arg1, class... Argn>
explicit explicit
message_v1(request_params params); message_v1(Arg1& arg1, Argn&&... argn)
: message<isRequest, Body, Headers>(
/// Construct a HTTP/1 response. std::forward<Arg1>(arg1),
explicit std::forward<Argn>(argn)...)
message_v1(response_params params); {
}
}; };
#if ! GENERATING_DOCS #if ! GENERATING_DOCS

54
include/beast/websocket/impl/stream.ipp
View File

@@ -291,9 +291,9 @@ accept(http::request_v1<Body, Headers> const& req,
{ {
static_assert(is_SyncStream<next_layer_type>::value, static_assert(is_SyncStream<next_layer_type>::value,
"SyncStream requirements not met"); "SyncStream requirements not met");
auto const resp = build_response(req); auto const res = build_response(req);
http::write(stream_, resp, ec); http::write(stream_, res, ec);
if(resp.status != 101) if(res.status != 101)
{ {
ec = error::handshake_failed; ec = error::handshake_failed;
// VFALCO TODO Respect keep alive setting, perform // VFALCO TODO Respect keep alive setting, perform
@@ -349,11 +349,11 @@ handshake(boost::string_ref const& host,
build_request(host, resource, key), ec); build_request(host, resource, key), ec);
if(ec) if(ec)
return; return;
http::response_v1<http::string_body> resp; http::response_v1<http::string_body> res;
http::read(next_layer(), stream_.buffer(), resp, ec); http::read(next_layer(), stream_.buffer(), res, ec);
if(ec) if(ec)
return; return;
do_response(resp, key, ec); do_response(res, key, ec);
} }
template<class NextLayer> template<class NextLayer>
@@ -855,11 +855,13 @@ build_response(http::request_v1<Body, Headers> const& req)
auto err = auto err =
[&](std::string const& text) [&](std::string const& text)
{ {
http::response_v1<http::string_body> resp( http::response_v1<http::string_body> res;
{400, http::reason_string(400), req.version}); res.status = 400;
resp.body = text; res.reason = http::reason_string(res.status);
res.version = req.version;
res.body = text;
// VFALCO TODO respect keep-alive here // VFALCO TODO respect keep-alive here
return resp; return res;
}; };
if(req.version < 11) if(req.version < 11)
return err("HTTP version 1.1 required"); return err("HTTP version 1.1 required");
@@ -882,41 +884,43 @@ build_response(http::request_v1<Body, Headers> const& req)
if(! rfc2616::token_in_list( if(! rfc2616::token_in_list(
req.headers["Upgrade"], "websocket")) req.headers["Upgrade"], "websocket"))
return err("Missing websocket Upgrade token"); return err("Missing websocket Upgrade token");
http::response_v1<http::string_body> resp( http::response_v1<http::string_body> res;
{101, http::reason_string(101), req.version}); res.status = 101;
resp.headers.insert("Upgrade", "websocket"); res.reason = http::reason_string(res.status);
res.version = req.version;
res.headers.insert("Upgrade", "websocket");
{ {
auto const key = auto const key =
req.headers["Sec-WebSocket-Key"]; req.headers["Sec-WebSocket-Key"];
resp.headers.insert("Sec-WebSocket-Key", key); res.headers.insert("Sec-WebSocket-Key", key);
resp.headers.insert("Sec-WebSocket-Accept", res.headers.insert("Sec-WebSocket-Accept",
detail::make_sec_ws_accept(key)); detail::make_sec_ws_accept(key));
} }
resp.headers.replace("Server", "Beast.WSProto"); res.headers.replace("Server", "Beast.WSProto");
(*d_)(resp); (*d_)(res);
http::prepare(resp, http::connection::upgrade); http::prepare(res, http::connection::upgrade);
return resp; return res;
} }
template<class NextLayer> template<class NextLayer>
template<class Body, class Headers> template<class Body, class Headers>
void void
stream<NextLayer>:: stream<NextLayer>::
do_response(http::response_v1<Body, Headers> const& resp, do_response(http::response_v1<Body, Headers> const& res,
boost::string_ref const& key, error_code& ec) boost::string_ref const& key, error_code& ec)
{ {
// VFALCO Review these error codes // VFALCO Review these error codes
auto fail = [&]{ ec = error::response_failed; }; auto fail = [&]{ ec = error::response_failed; };
if(resp.status != 101) if(res.status != 101)
return fail(); return fail();
if(! is_upgrade(resp)) if(! is_upgrade(res))
return fail(); return fail();
if(! rfc2616::ci_equal( if(! rfc2616::ci_equal(
resp.headers["Upgrade"], "websocket")) res.headers["Upgrade"], "websocket"))
return fail(); return fail();
if(! resp.headers.exists("Sec-WebSocket-Accept")) if(! res.headers.exists("Sec-WebSocket-Accept"))
return fail(); return fail();
if(resp.headers["Sec-WebSocket-Accept"] != if(res.headers["Sec-WebSocket-Accept"] !=
detail::make_sec_ws_accept(key)) detail::make_sec_ws_accept(key))
return fail(); return fail();
role_ = role_type::client; role_ = role_type::client;

154
test/http/message.cpp
View File

@@ -1,21 +1,139 @@
//------------------------------------------------------------------------------ //
/* // Copyright (c) 2013-2016 Vinnie Falco (vinnie dot falco at gmail dot com)
This file is part of Beast: https://github.com/vinniefalco/Beast //
Copyright 2013, Vinnie Falco <vinnie.falco@gmail.com> // Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
Permission to use, copy, modify, and/or distribute this software for any //
purpose with or without fee is hereby granted, provided that the above
copyright notice and this permission notice appear in all copies.
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
ANY SPECIAL , DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/
//==============================================================================
// Test that header file is self-contained. // Test that header file is self-contained.
#include <beast/http/message.hpp> #include <beast/http/message.hpp>
#include <beast/http/headers.hpp>
#include <beast/unit_test/suite.hpp>
#include <type_traits>
namespace beast {
namespace http {
class message_test : public beast::unit_test::suite
{
public:
struct Arg1
{
bool moved = false;
Arg1() = default;
Arg1(Arg1&& other)
{
other.moved = true;
}
};
struct Arg2 { };
struct Arg3 { };
// default constructible Body
struct default_body
{
using value_type = std::string;
};
// 1-arg constructible Body
struct one_arg_body
{
struct value_type
{
explicit
value_type(Arg1 const&)
{
}
explicit
value_type(Arg1&& arg)
{
Arg1 arg_(std::move(arg));
}
};
};
// 2-arg constructible Body
struct two_arg_body
{
struct value_type
{
value_type(Arg1 const&, Arg2 const&)
{
}
};
};
void testConstruction()
{
static_assert(std::is_constructible<
message<true, default_body, headers>>::value, "");
static_assert(std::is_constructible<
message<true, one_arg_body, headers>, Arg1>::value, "");
static_assert(std::is_constructible<
message<true, one_arg_body, headers>, Arg1 const>::value, "");
static_assert(std::is_constructible<
message<true, one_arg_body, headers>, Arg1 const&>::value, "");
static_assert(std::is_constructible<
message<true, one_arg_body, headers>, Arg1&&>::value, "");
static_assert(! std::is_constructible<
message<true, one_arg_body, headers>>::value, "");
static_assert(std::is_constructible<
message<true, one_arg_body, headers>,
Arg1, headers::allocator_type>::value, "");
static_assert(std::is_constructible<
message<true, one_arg_body, headers>, std::piecewise_construct_t,
std::tuple<Arg1>>::value, "");
static_assert(std::is_constructible<
message<true, two_arg_body, headers>, std::piecewise_construct_t,
std::tuple<Arg1, Arg2>>::value, "");
static_assert(std::is_constructible<
message<true, two_arg_body, headers>, std::piecewise_construct_t,
std::tuple<Arg1, Arg2>, std::tuple<headers::allocator_type>>::value, "");
{
Arg1 arg1;
message<true, one_arg_body, headers>{std::move(arg1)};
expect(arg1.moved);
}
{
headers h;
h.insert("User-Agent", "test");
message<true, one_arg_body, headers> m{Arg1{}, h};
expect(h["User-Agent"] == "test");
expect(m.headers["User-Agent"] == "test");
}
{
headers h;
h.insert("User-Agent", "test");
message<true, one_arg_body, headers> m{Arg1{}, std::move(h)};
expect(! h.exists("User-Agent"));
expect(m.headers["User-Agent"] == "test");
}
}
void run() override
{
testConstruction();
}
};
BEAST_DEFINE_TESTSUITE(message,http,beast);
} // http
} // beast

41
test/http/message_v1.cpp
View File

@@ -1,21 +1,9 @@
//------------------------------------------------------------------------------ //
/* // Copyright (c) 2013-2016 Vinnie Falco (vinnie dot falco at gmail dot com)
This file is part of Beast: https://github.com/vinniefalco/Beast //
Copyright 2013, Vinnie Falco <vinnie.falco@gmail.com> // Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
Permission to use, copy, modify, and/or distribute this software for any //
purpose with or without fee is hereby granted, provided that the above
copyright notice and this permission notice appear in all copies.
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
ANY SPECIAL , DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/
//==============================================================================
// Test that header file is self-contained. // Test that header file is self-contained.
#include <beast/http/message_v1.hpp> #include <beast/http/message_v1.hpp>
@@ -29,7 +17,6 @@
namespace beast { namespace beast {
namespace http { namespace http {
namespace test {
class sync_echo_http_server class sync_echo_http_server
{ {
@@ -122,8 +109,10 @@ private:
read(sock, rb, req, ec); read(sock, rb, req, ec);
if(ec) if(ec)
break; break;
response_v1<string_body> resp( response_v1<string_body> resp;
{100, "OK", req.version}); resp.status = 100;
resp.reason = "OK";
resp.version = req.version;
resp.body = "Completed successfully."; resp.body = "Completed successfully.";
write(sock, resp, ec); write(sock, resp, ec);
if(ec) if(ec)
@@ -132,7 +121,7 @@ private:
} }
}; };
class message_test : public beast::unit_test::suite class message_v1_test : public beast::unit_test::suite
{ {
public: public:
using endpoint_type = boost::asio::ip::tcp::endpoint; using endpoint_type = boost::asio::ip::tcp::endpoint;
@@ -184,7 +173,10 @@ public:
streambuf rb; streambuf rb;
{ {
request_v1<string_body> req({"GET", "/", 11}); request_v1<string_body> req;
req.method = "GET";
req.url = "/";
req.version = 11;
req.body = "Beast.HTTP"; req.body = "Beast.HTTP";
req.headers.replace("Host", req.headers.replace("Host",
ep.address().to_string() + ":" + ep.address().to_string() + ":" +
@@ -214,8 +206,7 @@ public:
} }
}; };
BEAST_DEFINE_TESTSUITE(message,http,beast); BEAST_DEFINE_TESTSUITE(message_v1,http,beast);
} // test
} // http } // http
} // beast } // beast

54
test/http/write.cpp
View File

@@ -135,8 +135,10 @@ public:
{ {
// auto content-length HTTP/1.0 // auto content-length HTTP/1.0
{ {
message_v1<true, string_body, headers> m{{ message_v1<true, string_body, headers> m;
"GET", "/", 10}}; m.method = "GET";
m.url = "/";
m.version = 10;
m.headers.insert("User-Agent", "test"); m.headers.insert("User-Agent", "test");
m.body = "*"; m.body = "*";
prepare(m); prepare(m);
@@ -150,8 +152,10 @@ public:
} }
// keep-alive HTTP/1.0 // keep-alive HTTP/1.0
{ {
message_v1<true, string_body, headers> m{{ message_v1<true, string_body, headers> m;
"GET", "/", 10}}; m.method = "GET";
m.url = "/";
m.version = 10;
m.headers.insert("User-Agent", "test"); m.headers.insert("User-Agent", "test");
m.body = "*"; m.body = "*";
prepare(m, connection::keep_alive); prepare(m, connection::keep_alive);
@@ -166,8 +170,10 @@ public:
} }
// upgrade HTTP/1.0 // upgrade HTTP/1.0
{ {
message_v1<true, string_body, headers> m{{ message_v1<true, string_body, headers> m;
"GET", "/", 10}}; m.method = "GET";
m.url = "/";
m.version = 10;
m.headers.insert("User-Agent", "test"); m.headers.insert("User-Agent", "test");
m.body = "*"; m.body = "*";
try try
@@ -182,8 +188,10 @@ public:
} }
// no content-length HTTP/1.0 // no content-length HTTP/1.0
{ {
message_v1<true, test_body, headers> m{{ message_v1<true, test_body, headers> m;
"GET", "/", 10}}; m.method = "GET";
m.url = "/";
m.version = 10;
m.headers.insert("User-Agent", "test"); m.headers.insert("User-Agent", "test");
m.body = "*"; m.body = "*";
prepare(m); prepare(m);
@@ -200,8 +208,10 @@ public:
} }
// auto content-length HTTP/1.1 // auto content-length HTTP/1.1
{ {
message_v1<true, string_body, headers> m{{ message_v1<true, string_body, headers> m;
"GET", "/", 11}}; m.method = "GET";
m.url = "/";
m.version = 11;
m.headers.insert("User-Agent", "test"); m.headers.insert("User-Agent", "test");
m.body = "*"; m.body = "*";
prepare(m); prepare(m);
@@ -215,8 +225,10 @@ public:
} }
// close HTTP/1.1 // close HTTP/1.1
{ {
message_v1<true, string_body, headers> m{{ message_v1<true, string_body, headers> m;
"GET", "/", 11}}; m.method = "GET";
m.url = "/";
m.version = 11;
m.headers.insert("User-Agent", "test"); m.headers.insert("User-Agent", "test");
m.body = "*"; m.body = "*";
prepare(m, connection::close); prepare(m, connection::close);
@@ -235,8 +247,10 @@ public:
} }
// upgrade HTTP/1.1 // upgrade HTTP/1.1
{ {
message_v1<true, empty_body, headers> m{{ message_v1<true, empty_body, headers> m;
"GET", "/", 11}}; m.method = "GET";
m.url = "/";
m.version = 11;
m.headers.insert("User-Agent", "test"); m.headers.insert("User-Agent", "test");
prepare(m, connection::upgrade); prepare(m, connection::upgrade);
expect(str(m) == expect(str(m) ==
@@ -248,8 +262,10 @@ public:
} }
// no content-length HTTP/1.1 // no content-length HTTP/1.1
{ {
message_v1<true, test_body, headers> m{{ message_v1<true, test_body, headers> m;
"GET", "/", 11}}; m.method = "GET";
m.url = "/";
m.version = 11;
m.headers.insert("User-Agent", "test"); m.headers.insert("User-Agent", "test");
m.body = "*"; m.body = "*";
prepare(m); prepare(m);
@@ -270,8 +286,10 @@ public:
void testConvert() void testConvert()
{ {
message_v1<true, string_body, headers> m{{ message_v1<true, string_body, headers> m;
"GET", "/", 11}}; m.method = "GET";
m.url = "/";
m.version = 11;
m.headers.insert("User-Agent", "test"); m.headers.insert("User-Agent", "test");
m.body = "*"; m.body = "*";
prepare(m); prepare(m);