Kagome
Polkadot Runtime Engine in C++17
session_impl.hpp
Go to the documentation of this file.
1 
6 #ifndef KAGOME_CORE_METRICS_IMPL_SESSION_IMPL_HPP
7 #define KAGOME_CORE_METRICS_IMPL_SESSION_IMPL_HPP
8 
9 #include <string_view>
10 
11 #include <boost/asio/strand.hpp>
12 #include <boost/beast.hpp>
13 #include "log/logger.hpp"
14 #include "metrics/session.hpp"
15 
16 namespace kagome::metrics {
17 
18  class SessionImpl : public Session,
19  public std::enable_shared_from_this<SessionImpl> {
20  using Body = boost::beast::http::string_body;
21  using Request = boost::beast::http::request<Body>;
22  using Response = boost::beast::http::response<Body>;
23  using Parser = boost::beast::http::request_parser<Body>;
24  using HttpField = boost::beast::http::field;
25  using HttpError = boost::beast::http::error;
26 
27  public:
33  SessionImpl(Context &context, Configuration config);
34  ~SessionImpl() override = default;
35 
36  Socket &socket() override {
37  return stream_.socket();
38  }
39 
43  void start() override;
44 
49  void respond(Response response) override;
50 
55  SessionId id() const override {
56  return 0ull;
57  }
58 
59  private:
63  void stop();
64 
70  void handleRequest(Request &&request);
71 
75  void asyncRead();
76 
82  void asyncWrite(Response message);
83 
87  void onRead(boost::system::error_code ec, std::size_t size);
88 
92  void onWrite(bool close, boost::system::error_code ec, std::size_t);
93 
99  void reportError(boost::system::error_code ec, std::string_view message);
100 
101  static constexpr boost::string_view kServerName = "Kagome";
102 
104  boost::asio::strand<boost::asio::io_context::executor_type> strand_;
105 
106  Configuration config_;
107  boost::beast::tcp_stream stream_;
108  boost::beast::flat_buffer buffer_;
109  std::shared_ptr<void> res_;
110 
115  std::unique_ptr<Parser> parser_;
116  log::Logger logger_;
117  };
118 
119 } // namespace kagome::metrics
120 
121 #endif // KAGOME_CORE_METRICS_IMPL_SESSION_IMPL_HPP
kagome::metrics::SessionImpl::SessionImpl
SessionImpl(Context &context, Configuration config)
constructor
Definition: session_impl.cpp:12
kagome::metrics::SessionImpl::HttpError
boost::beast::http::error HttpError
Definition: session_impl.hpp:25
kagome::metrics::SessionImpl::HttpField
boost::beast::http::field HttpField
Definition: session_impl.hpp:24
kagome::metrics::SessionImpl::buffer_
boost::beast::flat_buffer buffer_
read buffer
Definition: session_impl.hpp:108
kagome::metrics::SessionImpl::id
SessionId id() const override
method to get id of the session
Definition: session_impl.hpp:55
kagome::metrics::SessionImpl::reportError
void reportError(boost::system::error_code ec, std::string_view message)
reports error code and message
Definition: session_impl.cpp:92
kagome::metrics::SessionImpl::asyncRead
void asyncRead()
asynchronously read http message
Definition: session_impl.cpp:32
kagome::metrics::SessionImpl::Body
boost::beast::http::string_body Body
Definition: session_impl.hpp:20
kagome::metrics::SessionImpl::start
void start() override
starts session
Definition: session_impl.cpp:18
kagome::metrics::Session
session interface for OpenMetrics service
Definition: session.hpp:19
kagome::metrics::SessionImpl::Parser
boost::beast::http::request_parser< Body > Parser
Definition: session_impl.hpp:23
kagome::metrics::SessionImpl::strand_
boost::asio::strand< boost::asio::io_context::executor_type > strand_
Strand to ensure the connection&#39;s handlers are not called concurrently.
Definition: session_impl.hpp:104
kagome::metrics::SessionImpl::stream_
boost::beast::tcp_stream stream_
stream
Definition: session_impl.hpp:107
kagome::metrics::SessionImpl::kServerName
static constexpr boost::string_view kServerName
Definition: session_impl.hpp:101
kagome::metrics::Session::Context
boost::asio::io_context Context
Definition: session.hpp:24
kagome::metrics::SessionImpl::respond
void respond(Response response) override
sends response wrapped by http message
Definition: session_impl.cpp:58
kagome::metrics::SessionImpl::Response
boost::beast::http::response< Body > Response
Definition: session_impl.hpp:22
kagome::metrics::SessionImpl::asyncWrite
void asyncWrite(Response message)
sends http message
Definition: session_impl.cpp:45
kagome::metrics::SessionImpl::socket
Socket & socket() override
Definition: session_impl.hpp:36
kagome::log::Logger
std::shared_ptr< soralog::Logger > Logger
Definition: logger.hpp:23
kagome::metrics::SessionImpl::~SessionImpl
~SessionImpl() override=default
kagome::metrics::SessionImpl::parser_
std::unique_ptr< Parser > parser_
request parser type
Definition: session_impl.hpp:115
kagome::metrics::SessionImpl::stop
void stop()
stops session
Definition: session_impl.cpp:22
kagome::metrics::SessionImpl::res_
std::shared_ptr< void > res_
Definition: session_impl.hpp:109
kagome::metrics::SessionImpl::Request
boost::beast::http::request< Body > Request
Definition: session_impl.hpp:21
kagome::metrics::SessionImpl::onWrite
void onWrite(bool close, boost::system::error_code ec, std::size_t)
write completion callback
Definition: session_impl.cpp:74
kagome::metrics::SessionImpl::onRead
void onRead(boost::system::error_code ec, std::size_t size)
read completion callback
Definition: session_impl.cpp:62
kagome::metrics::Session::Socket
boost::asio::ip::tcp::socket Socket
Definition: session.hpp:25
kagome::metrics::SessionImpl::config_
Configuration config_
session configuration
Definition: session_impl.hpp:106
kagome::metrics::SessionImpl::handleRequest
void handleRequest(Request &&request)
process http request, compose and execute response
Definition: session_impl.cpp:28