2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
42#ifndef WEB_HTTP_CLIENT_SOCKETCONTEXTFACTORY_H
43#define WEB_HTTP_CLIENT_SOCKETCONTEXTFACTORY_H
45#include "core/socket/stream//SocketContextFactory.h"
46#include "web/http/client/SocketContext.h"
52#ifndef DOXYGEN_SHOULD_SKIP_THIS
58namespace web::http::
client {
66 const std::function<
void(
const std::shared_ptr<
MasterRequest>&)>& onHttpDisconnected,
static void init(int argc, char *argv[])
static int start(const utils::Timeval &timeOut={LONG_MAX, 0})
Sink & operator=(Sink &)=delete
virtual void onSourceEof()=0
void pipe(Source *source)
Sink(Sink &&) noexcept=default
void streamError(int errnum)
void disconnect(const Source *source)
virtual void onSourceConnect(Source *source)=0
virtual void onSourceData(const char *chunk, std::size_t chunkLen)=0
Sink & operator=(Sink &&) noexcept=default
void streamData(const char *chunk, std::size_t chunkLen)
virtual void onSourceError(int errnum)=0
Config & getConfig() const
static constexpr int DISABLED
static constexpr int ERROR
static constexpr int FATAL
LogMessage(Level level, int verboseLevel=-1, bool withErrno=false)
const std::string & getInstanceName() const
std::string toString(bool expanded=true) const override
const Super & connect(const std::string &ipOrHostname, uint16_t port, const std::function< void(const SocketAddress &, core::socket::State)> &onStatus) const
const std::map< std::string, std::string > & getOptions() const
const std::string & getValue() const
Client(std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpConnected, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpDisconnected)
typename Super::SocketAddress SocketAddress
web::http::client::Request Request
web::http::client::MasterRequest MasterRequest
Client(const std::function< void(SocketConnection *)> &onConnect, const std::function< void(SocketConnection *)> &onConnected, const std::function< void(SocketConnection *)> &onDisconnect, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpConnected, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpDisconnected)
SocketClientT< web::http::client::SocketContextFactory, std::function< void(const std::shared_ptr< MasterRequest > &)>, std::function< void(const std::shared_ptr< MasterRequest > &)>, std::function< net::config::ConfigInstance &()> > Super
Client(const std::string &name, const std::function< void(SocketConnection *)> &onConnect, const std::function< void(SocketConnection *)> &onConnected, const std::function< void(SocketConnection *)> &onDisconnect, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpConnected, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpDisconnected)
Client(const std::string &name, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpConnected, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpDisconnected)
web::http::client::Response Response
typename Super::SocketConnection SocketConnection
ConfigHTTP & setPipelinedRequests(bool pipelinedRequests)
ConfigHTTP(utils::SubCommand *parent)
static constexpr std::string_view NAME
CLI::Option * pipelinedRequestsOpt
ConfigHTTP(ConfigHTTP &)=delete
CLI::Option * hostHeaderOpt
ConfigHTTP & setHostHeader(const std::string &hostHeader)
static constexpr std::string_view DESCRIPTION
ConfigHTTP(ConfigHTTP &&) noexcept=delete
ConfigHTTP & operator=(ConfigHTTP &)=delete
ConfigHTTP & operator=(ConfigHTTP &&)=delete
bool getPipelinedRequests() const
std::string getHostHeader() const
MasterRequest & operator=(MasterRequest &&) noexcept=delete
MasterRequest(MasterRequest &)=delete
bool send(const std::string &chunk, const std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)> &onResponseReceived, const std::function< void(const std::shared_ptr< Request > &, const std::string &)> &onResponseParseError)
bool executeUpgrade(const std::string &url, const std::string &protocols, const std::function< void(bool)> &onStatus)
bool send(const char *chunk, std::size_t chunkLen, const std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)> &onResponseReceived, const std::function< void(const std::shared_ptr< Request > &, const std::string &)> &onResponseParseError)
MasterRequest & sendHeader()
void onSourceData(const char *chunk, std::size_t chunkLen) override
void onSourceConnect(core::pipe::Source *source) override
bool requestEventSource(const std::string &url, const std::function< std::size_t()> &onServerSentEvent, const std::function< void()> &onOpen, const std::function< void()> &onError)
MasterRequest(MasterRequest &&) noexcept
std::function< void(const std::shared_ptr< Request > &, const std::string &message)> onResponseParseError
void requestPrepared(const std::shared_ptr< MasterRequest > &request)
void deliverResponseParseError(const std::shared_ptr< MasterRequest > &request, const std::string &message)
std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)> onResponseReceived
void deliverResponse(const std::shared_ptr< MasterRequest > &request, const std::shared_ptr< Response > &response)
void onSourceError(int errnum) override
bool upgrade(const std::string &url, const std::string &protocols, const std::function< void(bool)> &onUpgradeInitiate, const std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &, bool)> &onResponseReceived, const std::function< void(const std::shared_ptr< Request > &, const std::string &)> &onResponseParseError)
bool executeSendFragment(const char *chunk, std::size_t chunkLen)
bool sendFile(const std::string &file, const std::function< void(int errnum)> &onStatus, const std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)> &onResponseReceived, const std::function< void(const std::shared_ptr< Request > &, const std::string &)> &onResponseParseError)
std::size_t contentLengthSent
std::list< RequestCommand * > requestCommands
void onSourceEof() override
~MasterRequest() override
MasterRequest(SocketContext *socketContext, const std::string &hostFieldValue)
MasterRequest & operator=(MasterRequest &)=delete
MasterRequest & sendFragment(const std::string &data)
bool end(const std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)> &onResponseReceived, const std::function< void(const std::shared_ptr< Request > &, const std::string &)> &onResponseParseError)
MasterRequest & sendFragment(const char *chunk, std::size_t chunkLen)
bool executeSendFile(const std::string &file, const std::function< void(int)> &onStatus)
bool initiate(const std::shared_ptr< MasterRequest > &request)
CiStringMap< std::string > headers
Request & set(const std::string &field, const std::string &value, bool overwrite=true)
std::map< std::string, std::string > queries
TransferEncoding transferEncoding
void setMasterRequest(const std::shared_ptr< MasterRequest > &masterRequest)
const CiStringMap< std::string > & getCookies() const
Request(Request &&request) noexcept
ConnectionState connectionState
const std::map< std::string, std::string > & getQueries() const
CiStringMap< std::string > cookies
Request & cookie(const std::string &name, const std::string &value)
CiStringMap< std::string > trailer
Request(Request &)=delete
Request & operator=(Request &)=delete
Request & query(const std::string &key, const std::string &value)
Request(SocketContext *socketContext, const std::string &host)
std::weak_ptr< MasterRequest > masterRequest
Request & setTrailer(const std::string &field, const std::string &value, bool overwrite=true)
Request & cookie(const std::map< std::string, std::string > &cookies)
SocketContext * getSocketContext() const
std::string header(const std::string &field) const
Request & operator=(Request &&) noexcept=delete
Request & set(const std::map< std::string, std::string > &headers, bool overwrite=true)
std::size_t contentLength
web::http::client::SocketContext * socketContext
std::string hostFieldValue
const CiStringMap< std::string > & getTrailer() const
Request & append(const std::string &field, const std::string &value)
Request & host(const std::string &hostFieldValue)
std::shared_ptr< MasterRequest > getMasterRequest() const
Request & type(const std::string &type)
const CiStringMap< std::string > & getHeaders() const
void upgrade(const std::shared_ptr< Response > &response, const std::function< void(const std::string &)> &status)
CiStringMap< std::string > headers
CiStringMap< CookieOptions > cookies
std::function< void(const std::shared_ptr< MasterRequest > &)> onHttpConnected
std::function< void(const std::shared_ptr< MasterRequest > &)> onHttpDisconnected
net::config::ConfigInstance & configInstance
web::http::client::Response Response
web::http::client::MasterRequest MasterRequest
core::socket::stream::SocketContext * create(core::socket::stream::SocketConnection *socketConnection) override
SocketContextFactory(const std::function< void(const std::shared_ptr< MasterRequest > &)> &onHttpConnected, const std::function< void(const std::shared_ptr< MasterRequest > &)> &onHttpDisconnected, const std::function< net::config::ConfigInstance &()> &getConfigInstance)
int main(int argc, char *argv[])
net::in::stream::SocketClient< core::socket::stream::legacy::SocketConnector, net::in::stream::legacy::config::ConfigSocketClient, SocketContextFactoryT, Args... > SocketClient
web::http::client::Client< net::in::stream::legacy::SocketClient > Client