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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
#pragma once
#include "common.hpp"
#include "sessions.hpp"
#include <boost/asio/io_context.hpp>
#include <boost/asio/ip/address.hpp>
#include <boost/beast/http/message.hpp>
#include <boost/beast/http/string_body.hpp>
#include <boost/beast/websocket.hpp>
#include <boost/url/url_view.hpp>
#include <string>
#include <string_view>
#include <system_error>
namespace crow
{
struct Request
{
boost::beast::http::request<boost::beast::http::string_body> req;
boost::beast::http::fields& fields;
std::string_view url{};
boost::urls::url_view urlView{};
bool isSecure{false};
std::string& body;
boost::asio::io_context* ioService{};
boost::asio::ip::address ipAddress{};
std::shared_ptr<persistent_data::UserSession> session;
std::string userRole{};
Request(boost::beast::http::request<boost::beast::http::string_body> reqIn,
std::error_code& ec) :
req(std::move(reqIn)),
fields(req.base()), body(req.body())
{
if (!setUrlInfo())
{
ec = std::make_error_code(std::errc::invalid_argument);
}
}
Request(const Request& other) :
req(other.req), fields(req.base()), isSecure(other.isSecure),
body(req.body()), ioService(other.ioService),
ipAddress(other.ipAddress), session(other.session),
userRole(other.userRole)
{
setUrlInfo();
}
Request(Request&& other) noexcept :
req(std::move(other.req)), fields(req.base()), isSecure(other.isSecure),
body(req.body()), ioService(other.ioService),
ipAddress(std::move(other.ipAddress)),
session(std::move(other.session)), userRole(std::move(other.userRole))
{
setUrlInfo();
}
Request& operator=(const Request&) = delete;
Request& operator=(const Request&&) = delete;
~Request() = default;
boost::beast::http::verb method() const
{
return req.method();
}
std::string_view getHeaderValue(std::string_view key) const
{
return req[key];
}
std::string_view getHeaderValue(boost::beast::http::field key) const
{
return req[key];
}
std::string_view methodString() const
{
return req.method_string();
}
std::string_view target() const
{
return req.target();
}
bool target(std::string_view target)
{
req.target(target);
return setUrlInfo();
}
unsigned version() const
{
return req.version();
}
bool isUpgrade() const
{
return boost::beast::websocket::is_upgrade(req);
}
bool keepAlive() const
{
return req.keep_alive();
}
private:
bool setUrlInfo()
{
auto result = boost::urls::parse_relative_ref(target());
if (!result)
{
return false;
}
urlView = *result;
url = urlView.encoded_path();
return true;
}
};
} // namespace crow
|
