#include <Request.h>

Inheritance diagram for web::http::client::MasterRequest:

Collaboration diagram for web::http::client::MasterRequest:

Public Member Functions
	MasterRequest (SocketContext *socketContext, const std::string &hostFieldValue)
	MasterRequest (MasterRequest &)=delete
	MasterRequest (MasterRequest &&) noexcept
MasterRequest &	operator= (MasterRequest &)=delete
MasterRequest &	operator= (MasterRequest &&) noexcept=delete
	~MasterRequest () override
void	setMasterRequest (const std::shared_ptr< MasterRequest > &masterRequest)
std::shared_ptr< MasterRequest >	getMasterRequest () const
SocketContext *	getSocketContext () const
void	init ()
void	disconnect ()
bool	isConnected () const
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)
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	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	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)
MasterRequest &	sendHeader ()
MasterRequest &	sendFragment (const char *chunk, std::size_t chunkLen)
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)
Public Member Functions inherited from web::http::client::Request
	Request (const std::string &connectionName, const std::string &host)
	Request (Request &)=delete
Request &	operator= (Request &)=delete
Request &	operator= (Request &&) noexcept=delete
std::string	getConnectionName () const
Request &	host (const std::string &hostFieldValue)
Request &	append (const std::string &field, const std::string &value)
Request &	set (const std::string &field, const std::string &value, bool overwrite=true)
Request &	set (const std::map< std::string, std::string > &headers, bool overwrite=true)
Request &	type (const std::string &type)
Request &	cookie (const std::string &name, const std::string &value)
Request &	cookie (const std::map< std::string, std::string > &cookies)
Request &	query (const std::string &key, const std::string &value)
Request &	setTrailer (const std::string &field, const std::string &value, bool overwrite=true)
std::string	header (const std::string &field) const
const std::map< std::string, std::string > &	getQueries () const
const CiStringMap< std::string > &	getHeaders () const
const CiStringMap< std::string > &	getTrailer () const
const CiStringMap< std::string > &	getCookies () const
Public Member Functions inherited from core::pipe::Sink
	Sink (Sink &)=delete
Sink &	operator= (Sink &)=delete

Private Member Functions
bool	requestEventSource (const std::string &url, const std::function< std::size_t()> &onServerSentEvent, const std::function< void()> &onOpen, const std::function< void()> &onError)
bool	initiate (const std::shared_ptr< MasterRequest > &request)
bool	executeSendFile (const std::string &file, const std::function< void(int)> &onStatus)
bool	executeUpgrade (const std::string &url, const std::string &protocols, const std::function< void(bool)> &onStatus)
bool	executeSendHeader ()
bool	executeSendFragment (const char *chunk, std::size_t chunkLen)
bool	executeEnd ()
bool	executeSse ()
void	requestPrepared (const std::shared_ptr< MasterRequest > &request)
void	requestDelivered ()
void	deliverResponse (const std::shared_ptr< MasterRequest > &request, const std::shared_ptr< Response > &response)
void	deliverResponseParseError (const std::shared_ptr< MasterRequest > &request, const std::string &message)
void	onSourceConnect (core::pipe::Source *source) override
void	onSourceData (const char *chunk, std::size_t chunkLen) override
void	onSourceEof () override
void	onSourceError (int errnum) override

Private Attributes
std::list< RequestCommand * >	requestCommands
std::size_t	contentLengthSent = 0
std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)>	onResponseReceived
std::function< void(const std::shared_ptr< Request > &, const std::string &message)>	onResponseParseError
web::http::client::SocketContext *	socketContext
std::weak_ptr< MasterRequest >	masterRequest

Friends
class	commands::SendFileCommand
class	commands::SendFragmentCommand
class	commands::SendHeaderCommand
class	commands::UpgradeCommand
class	commands::EndCommand
class	commands::SseCommand
class	SocketContext
template<typename Client>
class	tools::EventSourceT

Additional Inherited Members
Public Attributes inherited from web::http::client::Request
std::string	hostFieldValue
std::string	method = "GET"
std::string	url = "/"
int	httpMajor = 1
int	httpMinor = 1
std::size_t	count {0}
Protected Member Functions inherited from web::http::client::Request
	Request (Request &&request) noexcept
Protected Member Functions inherited from core::pipe::Sink
	Sink ()=default
	Sink (Sink &&) noexcept=default
Sink &	operator= (Sink &&) noexcept=default
virtual	~Sink ()
bool	isStreaming () const
void	stop ()
Protected Attributes inherited from web::http::client::Request
std::map< std::string, std::string >	queries
CiStringMap< std::string >	headers
CiStringMap< std::string >	cookies
CiStringMap< std::string >	trailer
std::string	connectionName
std::size_t	contentLength = 0
TransferEncoding	transferEncoding = TransferEncoding::HTTP10
ConnectionState	connectionState = ConnectionState::Default

Detailed Description

Definition at line 144 of file Request.h.

Constructor & Destructor Documentation

◆ MasterRequest() [1/3]

web::http::client::MasterRequest::MasterRequest	(	SocketContext *	socketContext,
		const std::string &	hostFieldValue )

Definition at line 264 of file Request.cpp.

        : Request(socketContext->getSocketConnection()->getConnectionName(), host)
        , socketContext(socketContext) {
        this->init();
    }

References core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), init(), web::http::client::Request::Request(), and socketContext.

Here is the call graph for this function:

◆ MasterRequest() [2/3]

web::http::client::MasterRequest::MasterRequest ( MasterRequest & )

explicitdelete

◆ MasterRequest() [3/3]

web::http::client::MasterRequest::MasterRequest ( MasterRequest && request )

explicitnoexcept

Definition at line 270 of file Request.cpp.

        : Request(std::move(request))
        , requestCommands(std::move(request.requestCommands))
        , contentLengthSent(request.contentLengthSent)
        , onResponseReceived(std::move(request.onResponseReceived))
        , onResponseParseError(std::move(request.onResponseParseError))
        , socketContext(request.socketContext)
        , masterRequest(request.masterRequest) { // NOLINT
        request.init();
    }

References contentLengthSent, init(), masterRequest, onResponseParseError, onResponseReceived, web::http::client::Request::Request(), requestCommands, and socketContext.

Here is the call graph for this function:

◆ ~MasterRequest()

web::http::client::MasterRequest::~MasterRequest ( )

override

Definition at line 281 of file Request.cpp.

                                  {
        for (const RequestCommand* requestCommand : requestCommands) {
            delete requestCommand;
        }
 
        if (isConnected() && Sink::isStreaming()) {
            socketContext->streamEof();
        }
    }

References isConnected(), core::pipe::Sink::isStreaming(), requestCommands, socketContext, and core::socket::stream::SocketContext::streamEof().

Here is the call graph for this function:

Member Function Documentation

◆ deliverResponse()

void web::http::client::MasterRequest::deliverResponse	(	const std::shared_ptr< MasterRequest > &	request,
		const std::shared_ptr< Response > &	response )

private

Definition at line 716 of file Request.cpp.

                                                                                                                            {
        onResponseReceived(request, response);
    }

References onResponseReceived.

Referenced by web::http::client::SocketContext::deliverResponse().

Here is the caller graph for this function:

◆ deliverResponseParseError()

void web::http::client::MasterRequest::deliverResponseParseError	(	const std::shared_ptr< MasterRequest > &	request,
		const std::string &	message )

private

Definition at line 720 of file Request.cpp.

                                                                                                                       {
        onResponseParseError(request, message);
    }

References onResponseParseError.

Referenced by web::http::client::SocketContext::deliverResponseParseError().

Here is the caller graph for this function:

◆ disconnect()

void web::http::client::MasterRequest::disconnect ( )

Definition at line 307 of file Request.cpp.

                                   {
        stop();
        socketContext = nullptr;
    }

References socketContext, and core::pipe::Sink::stop().

Referenced by NextTester::dispatchNextRequest(), and web::http::client::SocketContext::onDisconnected().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ end()

bool web::http::client::MasterRequest::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 )

Definition at line 525 of file Request.cpp.

                                                                                                                       {
        bool queued = true;
 
        if (isConnected()) {
            const std::shared_ptr<MasterRequest> newRequest = std::make_shared<MasterRequest>(std::move(*this));
 
            newRequest->sendHeader();
 
            newRequest->requestCommands.push_back(new commands::EndCommand(onResponseReceived, onResponseParseError));
 
            requestPrepared(newRequest);
        } else {
            queued = false;
        }
 
        return queued;
    }

References web::http::client::commands::EndCommand::EndCommand(), isConnected(), requestCommands, requestPrepared(), and sendHeader().

Referenced by NextTester::dispatchNextRequest().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ executeEnd()

bool web::http::client::MasterRequest::executeEnd ( )

private

Definition at line 656 of file Request.cpp.

                                   {
        return true;
    }

Referenced by web::http::client::commands::EndCommand::execute(), and executeSendFile().

Here is the caller graph for this function:

◆ executeSendFile()

bool web::http::client::MasterRequest::executeSendFile	(	const std::string &	file,
		const std::function< void(int)> &	onStatus )

private

Definition at line 568 of file Request.cpp.

                                                                                                     {
        bool atomar = true;
 
        std::string absolutFileName = file;
 
        if (std::filesystem::exists(absolutFileName)) {
            std::error_code ec;
            absolutFileName = std::filesystem::canonical(absolutFileName);
 
            if (std::filesystem::is_regular_file(absolutFileName, ec) && !ec) {
                core::file::FileReader::open(absolutFileName, [this, &absolutFileName, &onStatus, &atomar](int fd) {
                    onStatus(errno);
 
                    if (fd >= 0) {
                        if (httpMajor == 1) {
                            atomar = false;
 
                            set("Content-Type", web::http::MimeTypes::contentType(absolutFileName), false);
                            set("Last-Modified", httputils::file_mod_http_date(absolutFileName), false);
                            if (httpMinor == 1 && contentLength == 0) {
                                set("Transfer-Encoding", "chunked");
                            } else {
                                set("Content-Length", std::to_string(std::filesystem::file_size(absolutFileName) + contentLength));
                            }
 
                            executeSendHeader();
                        }
                    } else {
                        executeEnd();
                    }
                })->pipe(this);
            } else {
                errno = EINVAL;
                onStatus(errno);
            }
        } else {
            errno = ENOENT;
            onStatus(errno);
        }
 
        return atomar;
    }

References web::http::client::Request::contentLength, web::http::MimeTypes::contentType(), executeEnd(), executeSendHeader(), httputils::file_mod_http_date(), web::http::client::Request::httpMajor, web::http::client::Request::httpMinor, core::file::FileReader::open(), core::pipe::Source::pipe(), and web::http::client::Request::set().

Referenced by web::http::client::commands::SendFileCommand::execute().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ executeSendFragment()

bool web::http::client::MasterRequest::executeSendFragment	(	const char *	chunk,
		std::size_t	chunkLen )

private

Definition at line 696 of file Request.cpp.

                                                                                 {
        if (transferEncoding == TransferEncoding::Chunked) {
            socketContext->sendToPeer(to_hex_str(chunkLen).append("\r\n"));
        }
 
        socketContext->sendToPeer(chunk, chunkLen);
        contentLengthSent += chunkLen;
 
        if (transferEncoding == TransferEncoding::Chunked) {
            socketContext->sendToPeer("\r\n");
            contentLength += chunkLen;
        }
 
        return true;
    }

References web::http::Chunked, web::http::client::Request::contentLength, contentLengthSent, core::socket::SocketContext::sendToPeer(), core::socket::stream::SocketContext::sendToPeer(), socketContext, and web::http::client::Request::transferEncoding.

Referenced by web::http::client::commands::SendFragmentCommand::execute(), onSourceData(), and requestDelivered().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ executeSendHeader()

bool web::http::client::MasterRequest::executeSendHeader ( )

private

Definition at line 664 of file Request.cpp.

                                          {
        const std::string httpVersion = "HTTP/" + std::to_string(httpMajor) + "." + std::to_string(httpMinor);
 
        std::string queryString;
        if (!queries.empty()) {
            queryString += "?";
            for (auto& [key, value] : queries) {
                queryString += httputils::url_encode(key) + "=" + httputils::url_encode(value) + "&";
            }
            queryString.pop_back();
        }
 
        socketContext->sendToPeer(method + " " + url + queryString + " " + httpVersion + "\r\n");
        socketContext->sendToPeer("Date: " + httputils::to_http_date() + "\r\n");
 
        if (!headers.contains("Transfer-Encoding") && contentLength > 0) {
            set("Content-Length", std::to_string(contentLength));
        }
 
        for (const auto& [field, value] : headers) {
            socketContext->sendToPeer(std::string(field).append(":").append(value).append("\r\n"));
        }
 
        for (const auto& [name, value] : cookies) {
            socketContext->sendToPeer(std::string("Cookie:").append(name).append("=").append(value).append("\r\n"));
        }
 
        socketContext->sendToPeer("\r\n");
 
        return true;
    }

References web::http::client::Request::contentLength, web::http::client::Request::cookies, web::http::client::Request::headers, web::http::client::Request::httpMajor, web::http::client::Request::httpMinor, web::http::client::Request::method, web::http::client::Request::queries, core::socket::SocketContext::sendToPeer(), web::http::client::Request::set(), socketContext, httputils::to_http_date(), web::http::client::Request::url, and httputils::url_encode().

Referenced by web::http::client::commands::SendHeaderCommand::execute(), executeSendFile(), and executeUpgrade().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ executeSse()

bool web::http::client::MasterRequest::executeSse ( )

private

Definition at line 660 of file Request.cpp.

                                   {
        return true;
    }

Referenced by web::http::client::commands::SseCommand::execute().

Here is the caller graph for this function:

◆ executeUpgrade()

bool web::http::client::MasterRequest::executeUpgrade	(	const std::string &	url,
		const std::string &	protocols,
		const std::function< void(bool)> &	onStatus )

private

Definition at line 611 of file Request.cpp.

                                                                                                                                {
        this->url = url;
 
        set("Connection", "Upgrade", true);
        set("Upgrade", protocols, true);
 
        web::http::client::SocketContextUpgradeFactory* socketContextUpgradeFactory =
            web::http::client::SocketContextUpgradeFactorySelector::instance()->select(protocols, *this);
 
        if (socketContextUpgradeFactory != nullptr) {
            LOG(DEBUG) << connectionName << " HTTP: "
                       << "SocketContextUpgradeFactory create success: " << socketContextUpgradeFactory->name();
            LOG(DEBUG) << connectionName << " HTTP: Initiating upgrade: " << method << " " << url
                       << " HTTP/" + std::to_string(httpMajor) + "." + std::to_string(httpMinor);
 
        } else {
            LOG(DEBUG) << connectionName << " HTTP: "
                       << "SocketContextUpgradeFactory create failed: " << protocols;
            LOG(DEBUG) << connectionName << " HTTP: Not initiating upgrade " << method << " " << url
                       << " HTTP/" + std::to_string(httpMajor) + "." + std::to_string(httpMinor);
        }
 
        LOG(DEBUG) << connectionName << " HTTP: Upgrade request:\n"
                   << httputils::toString(method,
                                          url,
                                          "HTTP/" + std::to_string(httpMajor) + "." + std::to_string(httpMinor),
                                          queries,
                                          headers,
                                          trailer,
                                          cookies,
                                          std::vector<char>());
 
        onStatus(socketContextUpgradeFactory != nullptr);
 
        if (socketContextUpgradeFactory != nullptr) {
            executeSendHeader();
 
            socketContextUpgradeFactory->checkRefCount();
        } else {
            socketContext->close();
        }
 
        return true;
    }

Referenced by web::http::client::commands::UpgradeCommand::execute().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getMasterRequest()

std::shared_ptr< MasterRequest > web::http::client::MasterRequest::getMasterRequest ( ) const

Definition at line 113 of file Request.cpp.

                                                                       {
        return masterRequest.lock();
    }

References masterRequest.

◆ getSocketContext()

SocketContext * web::http::client::MasterRequest::getSocketContext ( ) const

Definition at line 117 of file Request.cpp.

                                                         {
        return socketContext;
    }

References socketContext.

Referenced by web::http::client::SocketContext::initiateRequest(), main(), web::http::client::SocketContext::requestCompleted(), web::http::client::SocketContext::requestDelivered(), requestEventSource(), and upgrade().

Here is the caller graph for this function:

◆ init()

void web::http::client::MasterRequest::init ( )

Definition at line 291 of file Request.cpp.

                             {
        method = "GET";
        url = "/";
        httpMajor = 1;
        httpMinor = 1;
        queries.clear();
        headers.clear();
        cookies.clear();
        trailer.clear();
        requestCommands.clear();
        transferEncoding = TransferEncoding::HTTP10;
        contentLength = 0;
        contentLengthSent = 0;
        connectionState = ConnectionState::Default;
    }

Referenced by NextTester::dispatchNextRequest(), MasterRequest(), and MasterRequest().

Here is the caller graph for this function:

◆ initiate()

bool web::http::client::MasterRequest::initiate ( const std::shared_ptr< MasterRequest > & request )

private

Definition at line 544 of file Request.cpp.

                                                                            {
        bool error = false;
        bool atomar = true;
 
        for (RequestCommand* requestCommand : requestCommands) {
            if (!error) {
                this->onResponseParseError = requestCommand->onResponseParseError;
                this->onResponseReceived = requestCommand->onResponseReceived;
 
                atomar = requestCommand->execute(request);
                error = requestCommand->getError();
            }
 
            delete requestCommand;
        }
        requestCommands.clear();
 
        if (atomar && !error) {
            requestDelivered();
        }
 
        return !error;
    }

References web::http::client::RequestCommand::execute(), web::http::client::RequestCommand::getError(), onResponseParseError, web::http::client::RequestCommand::onResponseParseError, onResponseReceived, web::http::client::RequestCommand::onResponseReceived, requestCommands, and requestDelivered().

Referenced by web::http::client::SocketContext::initiateRequest().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isConnected()

bool web::http::client::MasterRequest::isConnected ( ) const

Definition at line 121 of file Request.cpp.

                                          {
        return socketContext != nullptr;
    }

References socketContext.

Referenced by NextTester::dispatchNextRequest(), end(), onSourceConnect(), onSourceData(), onSourceEof(), onSourceError(), requestDelivered(), requestEventSource(), send(), sendFile(), sendFragment(), sendHeader(), upgrade(), and ~MasterRequest().

Here is the caller graph for this function:

◆ onSourceConnect()

void web::http::client::MasterRequest::onSourceConnect ( core::pipe::Source * source )

overrideprivatevirtual

Implements core::pipe::Sink.

Definition at line 741 of file Request.cpp.

                                                              {
        if (isConnected()) {
            if (socketContext->streamToPeer(source)) {
                source->start();
            }
        } else {
            source->stop();
        }
    }

References isConnected(), socketContext, core::pipe::Source::start(), core::pipe::Source::stop(), and core::socket::stream::SocketContext::streamToPeer().

Here is the call graph for this function:

◆ onSourceData()

void web::http::client::MasterRequest::onSourceData	(	const char *	chunk,
		std::size_t	chunkLen )

overrideprivatevirtual

Implements core::pipe::Sink.

Definition at line 751 of file Request.cpp.

                                                                          {
        if (isConnected()) {
            executeSendFragment(chunk, chunkLen);
        }
    }

References executeSendFragment(), and isConnected().

Here is the call graph for this function:

◆ onSourceEof()

void web::http::client::MasterRequest::onSourceEof ( )

overrideprivatevirtual

Implements core::pipe::Sink.

Definition at line 757 of file Request.cpp.

                                    {
        if (isConnected()) {
            socketContext->streamEof();
 
            requestDelivered();
        }
    }

References isConnected(), requestDelivered(), socketContext, and core::socket::stream::SocketContext::streamEof().

Here is the call graph for this function:

◆ onSourceError()

void web::http::client::MasterRequest::onSourceError ( int errnum )

overrideprivatevirtual

Implements core::pipe::Sink.

Definition at line 765 of file Request.cpp.

                                                {
        errno = errnum;
 
        if (isConnected()) {
            socketContext->streamEof();
            socketContext->close();
 
            requestDelivered();
        }
    }

References core::socket::stream::SocketContext::close(), isConnected(), requestDelivered(), socketContext, and core::socket::stream::SocketContext::streamEof().

Here is the call graph for this function:

◆ operator=() [1/2]

MasterRequest & web::http::client::MasterRequest::operator= ( MasterRequest && )

deletenoexcept

◆ operator=() [2/2]

MasterRequest & web::http::client::MasterRequest::operator= ( MasterRequest & )

delete

◆ requestDelivered()

void web::http::client::MasterRequest::requestDelivered ( )

private

Definition at line 724 of file Request.cpp.

                                         {
        if (isConnected()) {
            if (transferEncoding == TransferEncoding::Chunked) {
                executeSendFragment("", 0); // For transfer encoding chunked. Terminate the chunk sequence.
 
                if (!trailer.empty()) {
                    for (auto& [field, value] : trailer) {
                        socketContext->sendToPeer(std::string(field).append(":").append(value).append("\r\n"));
                    }
                    socketContext->sendToPeer("\r\n");
                }
            }
 
            socketContext->requestDelivered(contentLengthSent == contentLength);
        }
    }

References web::http::Chunked, web::http::client::Request::contentLength, contentLengthSent, executeSendFragment(), isConnected(), web::http::client::SocketContext::requestDelivered(), core::socket::SocketContext::sendToPeer(), socketContext, web::http::client::Request::trailer, and web::http::client::Request::transferEncoding.

Referenced by initiate(), onSourceEof(), and onSourceError().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ requestEventSource()

bool web::http::client::MasterRequest::requestEventSource	(	const std::string &	url,
		const std::function< std::size_t()> &	onServerSentEvent,
		const std::function< void()> &	onOpen,
		const std::function< void()> &	onError )

private

Definition at line 434 of file Request.cpp.

                                                                               {
        if (isConnected()) {
            const std::shared_ptr<MasterRequest> newRequest = std::make_shared<MasterRequest>(std::move(*this));
 
            newRequest->url = url;
            newRequest->httpMajor = 1;
            newRequest->httpMinor = 1;
 
            newRequest->set("Connection", "keep-alive", true);
            newRequest->set("Accept", "text/event-stream", true);
            newRequest->set("Cache-Control", "no-cache", true);
 
            newRequest->sendHeader();
 
            newRequest->requestCommands.push_back(new commands::SseCommand(
                [masterRequest = this->masterRequest, onServerSentEvent, onOpen, onError](const std::shared_ptr<Request>& request,
                                                                                          const std::shared_ptr<Response>& response) {
                    if (!masterRequest.expired() && masterRequest.lock()->isConnected()) {
                        if (web::http::ciContains(response->headers["Content-Type"], "text/event-stream") &&
                            web::http::ciContains(request->header("Accept"), "text/event-stream")) {
                            masterRequest.lock()->getSocketContext()->setSseEventReceiver(onServerSentEvent);
 
                            onOpen();
                        } else {
                            masterRequest.lock()->getSocketContext()->close();
 
                            onError();
                        }
                    }
                },
                [masterRequest = this->masterRequest, connectionName = this->connectionName, onError](
                    [[maybe_unused]] const std::shared_ptr<Request>& request, const std::string& status) {
                    if (!masterRequest.expired() && masterRequest.lock()->isConnected()) {
                        LOG(DEBUG) << connectionName << " error in response: " << status;
                        masterRequest.lock()->getSocketContext()->close();
                        onError();
                    }
                }));
 
            requestPrepared(newRequest);
        }
 
        return isConnected();
    }

References web::http::ciContains(), core::socket::stream::SocketContext::close(), logger::DEBUG, getSocketContext(), web::http::client::Request::header(), web::http::client::Response::headers, web::http::client::Request::httpMajor, web::http::client::Request::httpMinor, isConnected(), logger::LogMessage::LogMessage(), requestCommands, requestPrepared(), sendHeader(), web::http::client::Request::set(), web::http::client::SocketContext::setSseEventReceiver(), web::http::client::commands::SseCommand::SseCommand(), and web::http::client::Request::url.

Here is the call graph for this function:

◆ requestPrepared()

void web::http::client::MasterRequest::requestPrepared ( const std::shared_ptr< MasterRequest > & request )

private

Definition at line 712 of file Request.cpp.

                                                                                   {
        socketContext->requestPrepared(request);
    }

References web::http::client::SocketContext::requestPrepared(), and socketContext.

Referenced by end(), requestEventSource(), send(), sendFile(), and upgrade().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send() [1/2]

bool web::http::client::MasterRequest::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 )

Definition at line 313 of file Request.cpp.

                                                                                                                        {
        bool queued = true;
 
        if (isConnected()) {
            const std::shared_ptr<MasterRequest> newRequest = std::make_shared<MasterRequest>(std::move(*this));
 
            if (chunkLen > 0) {
                newRequest->set("Content-Type", "application/octet-stream", false);
            }
 
            newRequest->sendHeader();
            newRequest->sendFragment(chunk, chunkLen);
 
            newRequest->requestCommands.push_back(new commands::EndCommand(onResponseReceived, onResponseParseError));
 
            newRequest->requestPrepared(newRequest);
 
        } else {
            queued = false;
        }
 
        return queued;
    }

References web::http::client::commands::EndCommand::EndCommand(), isConnected(), requestCommands, requestPrepared(), sendFragment(), sendHeader(), and web::http::client::Request::set().

Referenced by send().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send() [2/2]

bool web::http::client::MasterRequest::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 )

Definition at line 341 of file Request.cpp.

                                                                                                                        {
        if (!chunk.empty()) {
            set("Content-Type", "text/html; charset=utf-8", false);
        }
 
        return send(chunk.data(), chunk.size(), onResponseReceived, onResponseParseError);
    }

References send(), and web::http::client::Request::set().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sendFile()

bool web::http::client::MasterRequest::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 )

Definition at line 482 of file Request.cpp.

                                                                                                        {
        bool queued = false;
 
        if (isConnected()) {
            const std::shared_ptr<MasterRequest> newRequest = std::make_shared<MasterRequest>(std::move(*this));
 
            newRequest->requestCommands.push_back(new commands::SendFileCommand(file, onStatus, onResponseReceived, onResponseParseError));
 
            requestPrepared(newRequest);
 
            queued = true;
        }
 
        return queued;
    }

References isConnected(), requestCommands, requestPrepared(), and web::http::client::commands::SendFileCommand::SendFileCommand().

Here is the call graph for this function:

◆ sendFragment() [1/2]

MasterRequest & web::http::client::MasterRequest::sendFragment	(	const char *	chunk,
		std::size_t	chunkLen )

Definition at line 510 of file Request.cpp.

                                                                                    {
        if (isConnected()) {
            contentLength += chunkLen;
 
            requestCommands.push_back(new commands::SendFragmentCommand(chunk, chunkLen));
        }
 
        return *this;
    }

References web::http::client::Request::contentLength, isConnected(), requestCommands, and web::http::client::commands::SendFragmentCommand::SendFragmentCommand().

Referenced by send(), and sendFragment().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sendFragment() [2/2]

MasterRequest & web::http::client::MasterRequest::sendFragment ( const std::string & data )

Definition at line 520 of file Request.cpp.

                                                                    {
        return sendFragment(data.data(), data.size());
    }

References sendFragment().

Here is the call graph for this function:

◆ sendHeader()

MasterRequest & web::http::client::MasterRequest::sendHeader ( )

Definition at line 502 of file Request.cpp.

                                             {
        if (isConnected()) {
            requestCommands.push_back(new commands::SendHeaderCommand());
        }
 
        return *this;
    }

References isConnected(), requestCommands, and web::http::client::commands::SendHeaderCommand::SendHeaderCommand().

Referenced by end(), requestEventSource(), and send().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ setMasterRequest()

void web::http::client::MasterRequest::setMasterRequest ( const std::shared_ptr< MasterRequest > & masterRequest )

Definition at line 109 of file Request.cpp.

                                                                                          {
        this->masterRequest = masterRequest;
    }

References masterRequest.

◆ upgrade()

bool web::http::client::MasterRequest::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 )

Definition at line 351 of file Request.cpp.

                                                                                                        {
        if (isConnected()) {
            masterRequest.lock()->url = url;
 
            masterRequest.lock()->requestCommands.push_back(new commands::UpgradeCommand(
                url,
                protocols,
                onUpgradeInitiate,
                [masterRequest = this->masterRequest, connectionName = this->connectionName, onResponseReceived](
                    const std::shared_ptr<Request>& request, const std::shared_ptr<Response>& response) {
                    if (!masterRequest.expired() && masterRequest.lock()->isConnected()) {
                        LOG(DEBUG) << connectionName << " HTTP upgrade: Response to upgrade request: " << request->method << " "
                                   << request->url << " "
                                   << "HTTP/" << request->httpMajor << "." << request->httpMinor << "\n"
                                   << httputils::toString(response->httpVersion,
                                                          response->statusCode,
                                                          response->reason,
                                                          response->headers,
                                                          response->cookies,
                                                          response->body);
 
                        std::string socketContextUpgradeName;
 
                        if (web::http::ciContains(response->get("connection"), "Upgrade")) {
                            SocketContextUpgradeFactory* socketContextUpgradeFactory =
                                SocketContextUpgradeFactorySelector::instance()->select(*request, *response);
 
                            if (socketContextUpgradeFactory != nullptr) {
                                socketContextUpgradeName = socketContextUpgradeFactory->name();
 
                                LOG(DEBUG) << connectionName
                                           << " HTTP upgrade: SocketContextUpgradeFactory create success for: " << socketContextUpgradeName;
 
                                core::socket::stream::SocketContext* socketContextUpgrade =
                                    socketContextUpgradeFactory->create(masterRequest.lock()->getSocketContext()->getSocketConnection());
 
                                if (socketContextUpgrade != nullptr) {
                                    LOG(DEBUG) << connectionName
                                               << " HTTP upgrade: SocketContextUpgrade create success for: " << socketContextUpgradeName;
                                    masterRequest.lock()->getSocketContext()->getSocketConnection()->setSocketContext(socketContextUpgrade);
                                } else {
                                    LOG(DEBUG) << connectionName
                                               << " HTTP upgrade: SocketContextUpgrade create failed for: " << socketContextUpgradeName;
 
                                    masterRequest.lock()->getSocketContext()->close();
                                }
                            } else {
                                LOG(DEBUG) << connectionName << " HTTP upgrade: SocketContextUpgradeFactory not supported by server: "
                                           << request->header("upgrade");
 
                                masterRequest.lock()->getSocketContext()->close();
                            }
                        } else {
                            LOG(DEBUG) << connectionName << " HTTP upgrade: No upgrade requested";
 
                            masterRequest.lock()->getSocketContext()->close();
                        }
 
                        LOG(DEBUG) << connectionName << " HTTP upgrade: bootstrap "
                                   << (!socketContextUpgradeName.empty() ? "success" : "failed");
                        LOG(DEBUG) << "      Protocol selected: " << socketContextUpgradeName;
                        LOG(DEBUG) << "              requested: " << request->header("upgrade");
                        LOG(DEBUG) << "  Subprotocol  selected: " << response->get("Sec-WebSocket-Protocol");
                        LOG(DEBUG) << "              requested: " << request->header("Sec-WebSocket-Protocol");
 
                        onResponseReceived(request, response, !socketContextUpgradeName.empty());
                    }
                },
                onResponseParseError));
 
            const std::shared_ptr<MasterRequest> newRequest = std::make_shared<MasterRequest>(std::move(*this));
 
            requestPrepared(newRequest);
        }
 
        return isConnected();
    }

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ commands::EndCommand

friend class commands::EndCommand

friend

Definition at line 201 of file Request.h.

◆ commands::SendFileCommand

friend class commands::SendFileCommand

friend

Definition at line 197 of file Request.h.

◆ commands::SendFragmentCommand

friend class commands::SendFragmentCommand

friend

Definition at line 198 of file Request.h.

◆ commands::SendHeaderCommand

friend class commands::SendHeaderCommand

friend

Definition at line 199 of file Request.h.

◆ commands::SseCommand

friend class commands::SseCommand

friend

Definition at line 202 of file Request.h.

◆ commands::UpgradeCommand

friend class commands::UpgradeCommand

friend

Definition at line 200 of file Request.h.

◆ SocketContext

friend class SocketContext

friend

Definition at line 233 of file Request.h.

◆ tools::EventSourceT

template<typename Client>

friend class tools::EventSourceT

friend

Definition at line 236 of file Request.h.

Member Data Documentation

◆ contentLengthSent

std::size_t web::http::client::MasterRequest::contentLengthSent = 0

private

Definition at line 224 of file Request.h.

Referenced by executeSendFragment(), init(), MasterRequest(), and requestDelivered().

◆ masterRequest

std::weak_ptr<MasterRequest> web::http::client::MasterRequest::masterRequest

private

Definition at line 231 of file Request.h.

Referenced by getMasterRequest(), MasterRequest(), setMasterRequest(), and upgrade().

◆ onResponseParseError

std::function<void(const std::shared_ptr<Request>&, const std::string& message)> web::http::client::MasterRequest::onResponseParseError

private

Definition at line 227 of file Request.h.

Referenced by deliverResponseParseError(), initiate(), and MasterRequest().

◆ onResponseReceived

std::function<void(const std::shared_ptr<Request>&, const std::shared_ptr<Response>&)> web::http::client::MasterRequest::onResponseReceived

private

Definition at line 226 of file Request.h.

Referenced by deliverResponse(), initiate(), and MasterRequest().

◆ requestCommands

std::list<RequestCommand*> web::http::client::MasterRequest::requestCommands

private

Definition at line 222 of file Request.h.

Referenced by end(), init(), initiate(), MasterRequest(), requestEventSource(), send(), sendFile(), sendFragment(), sendHeader(), upgrade(), and ~MasterRequest().

◆ socketContext

web::http::client::SocketContext* web::http::client::MasterRequest::socketContext

private

Definition at line 229 of file Request.h.

Referenced by disconnect(), executeSendFragment(), executeSendHeader(), executeUpgrade(), getSocketContext(), isConnected(), MasterRequest(), MasterRequest(), onSourceConnect(), onSourceEof(), onSourceError(), requestDelivered(), requestPrepared(), and ~MasterRequest().

The documentation for this class was generated from the following files:

web/http/client/Request.h
web/http/client/Request.cpp

SNode.C

Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ MasterRequest() [1/3]

◆ MasterRequest() [2/3]

◆ MasterRequest() [3/3]

◆ ~MasterRequest()

Member Function Documentation

◆ deliverResponse()

◆ deliverResponseParseError()

◆ disconnect()

◆ end()

◆ executeEnd()

◆ executeSendFile()

◆ executeSendFragment()

◆ executeSendHeader()

◆ executeSse()

◆ executeUpgrade()

◆ getMasterRequest()

◆ getSocketContext()

◆ init()

◆ initiate()

◆ isConnected()

◆ onSourceConnect()

◆ onSourceData()

◆ onSourceEof()

◆ onSourceError()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ requestDelivered()

◆ requestEventSource()

◆ requestPrepared()

◆ send() [1/2]

◆ send() [2/2]

◆ sendFile()

◆ sendFragment() [1/2]

◆ sendFragment() [2/2]

◆ sendHeader()

◆ setMasterRequest()

◆ upgrade()

Friends And Related Symbol Documentation

◆ commands::EndCommand

◆ commands::SendFileCommand

◆ commands::SendFragmentCommand

◆ commands::SendHeaderCommand

◆ commands::SseCommand

◆ commands::UpgradeCommand

◆ SocketContext

◆ tools::EventSourceT

Member Data Documentation

◆ contentLengthSent

◆ masterRequest

◆ onResponseParseError

◆ onResponseReceived

◆ requestCommands

◆ socketContext