#include <Request.h>

Inheritance diagram for web::http::client::Request:

Collaboration diagram for web::http::client::Request:

Public Member Functions
	Request (web::http::client::SocketContext *socketContext, const std::string &host)

	Request (Request &)=delete

	Request (Request &&) noexcept

Request &	operator= (Request &)=delete

Request &	operator= (Request &&) noexcept=delete

	~Request () override

void	setMasterRequest (const std::shared_ptr< Request > &masterRequest)

virtual void	init ()

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)

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=responseParseError)

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=responseParseError)

bool	upgrade (const std::string &url, const std::string &protocols, 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=responseParseError)

void	upgrade (const std::shared_ptr< Response > &response, const std::function< void(const std::string &)> &status)

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=responseParseError)

Request &	sendHeader ()

Request &	sendFragment (const char *chunk, std::size_t chunkLen)

Request &	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=responseParseError)

std::string	header (const std::string &field)

const CiStringMap< std::string > &	getQueries () const

const CiStringMap< std::string > &	getHeaders () const

const CiStringMap< std::string > &	getCookies () const

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

Public Member Functions inherited from core::pipe::Sink
	Sink (Sink &)=delete

Sink &	operator= (Sink &)=delete

Static Public Member Functions
static void	responseParseError (const std::shared_ptr< Request > &request, const std::string &message)

Public Attributes
std::string	hostFieldValue

std::string	method = "GET"

std::string	url = "/"

int	httpMajor = 1

int	httpMinor = 1

Protected Attributes
CiStringMap< std::string >	queries

CiStringMap< std::string >	headers

CiStringMap< std::string >	cookies

CiStringMap< std::string >	trailer

Private Member Functions
bool	initiate ()

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

bool	executeUpgrade (const std::string &url, const std::string &protocols)

bool	executeEnd ()

bool	executeSendHeader ()

bool	executeSendFragment (const char *chunk, std::size_t chunkLen)

void	requestPrepared ()

void	requestDelivered ()

void	deliverResponse (const std::shared_ptr< Request > &request, const std::shared_ptr< Response > &response)

void	deliverResponseParseError (const std::shared_ptr< Request > &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

TransferEncoding	transferEncoding = TransferEncoding::HTTP10

std::size_t	contentLength = 0

std::size_t	contentLengthSent = 0

ConnectionState	connectionState = ConnectionState::Default

std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)>	onResponseReceived

std::function< void(const std::shared_ptr< Request > &request, const std::string &message)>	onResponseParseError

std::weak_ptr< Request >	masterRequest

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

Friends
class	commands::SendFileCommand

class	commands::SendFragmentCommand

class	commands::SendHeaderCommand

class	commands::UpgradeCommand

class	commands::EndCommand

class	SocketContext

Additional Inherited Members
Protected Member Functions inherited from core::pipe::Sink
	Sink ()=default

	Sink (Sink &&) noexcept=default

Sink &	operator= (Sink &&) noexcept=default

virtual	~Sink ()

bool	isStreaming ()

void	stop ()

Detailed Description

Definition at line 76 of file Request.h.

Constructor & Destructor Documentation

◆ Request() [1/3]

web::http::client::Request::Request	(	web::http::client::SocketContext *	socketContext,
		const std::string &	host
	)

explicit

Definition at line 75 of file Request.cpp.

        : hostFieldValue(host)
        , socketContext(socketContext) {
        this->host(hostFieldValue);
    }

References host(), hostFieldValue, and socketContext.

Here is the call graph for this function:

◆ Request() [2/3]

web::http::client::Request::Request ( Request & )

explicitdelete

◆ Request() [3/3]

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

explicitnoexcept

Definition at line 81 of file Request.cpp.

        : hostFieldValue(request.hostFieldValue) // NOLINT
        , method(std::move(request.method))
        , url(std::move(request.url))
        , httpMajor(request.httpMajor)
        , httpMinor(request.httpMinor)
        , queries(std::move(request.queries))
        , headers(std::move(request.headers))
        , cookies(std::move(request.cookies))
        , trailer(std::move(request.trailer))
        , requestCommands(std::move(request.requestCommands))
        , transferEncoding(request.transferEncoding)
        , contentLength(request.contentLength)
        , contentLengthSent(request.contentLengthSent)
        , connectionState(request.connectionState)
        , onResponseReceived(std::move(request.onResponseReceived))
        , onResponseParseError(std::move(request.onResponseParseError))
        , masterRequest(request.masterRequest) // NOLINT
        , socketContext(request.socketContext) {
        request.init();
    }

References connectionState, contentLength, contentLengthSent, cookies, headers, hostFieldValue, httpMajor, httpMinor, init(), masterRequest, method, onResponseParseError, onResponseReceived, queries, requestCommands, socketContext, trailer, transferEncoding, and url.

Here is the call graph for this function:

◆ ~Request()

web::http::client::Request::~Request ( )

override

Definition at line 103 of file Request.cpp.

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

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

Here is the call graph for this function:

Member Function Documentation

◆ append()

Request & web::http::client::Request::append	(	const std::string &	field,
		const std::string &	value
	)

Definition at line 147 of file Request.cpp.

                                                                           {
        const std::map<std::string, std::string>::iterator it = headers.find(field);
 
        if (it != headers.end()) {
            set(field, it->second.append(", ").append(value));
        } else {
            set(field, value);
        }
 
        return *this;
    }

References headers, and set().

Here is the call graph for this function:

◆ cookie() [1/2]

Request & web::http::client::Request::cookie ( const std::map< std::string, std::string > & cookies )

Definition at line 225 of file Request.cpp.

                                                                        {
        for (const auto& [name, value] : cookies) {
            cookie(name, value);
        }
 
        return *this;
    }

References cookie().

Here is the call graph for this function:

◆ cookie() [2/2]

Request & web::http::client::Request::cookie	(	const std::string &	name,
		const std::string &	value
	)

Definition at line 219 of file Request.cpp.

                                                                          {
        cookies.insert({name, value});
 
        return *this;
    }

References cookies.

Referenced by cookie().

Here is the caller graph for this function:

◆ deliverResponse()

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

private

Definition at line 580 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::Request::deliverResponseParseError	(	const std::shared_ptr< Request > &	request,
		const std::string &	message
	)

private

Definition at line 584 of file Request.cpp.

                                                                                                           {
        onResponseParseError(request, message);
    }

References onResponseParseError.

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

Here is the caller graph for this function:

◆ end()

bool web::http::client::Request::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 = `responseParseError`
	)

Definition at line 416 of file Request.cpp.

                                                                                                                      {
        bool queued = true;
 
        if (!masterRequest.expired()) {
            this->onResponseReceived = onResponseReceived;
            this->onResponseParseError = onResponseParseError;
 
            sendHeader();
 
            requestCommands.push_back(new commands::EndCommand());
 
            requestPrepared();
        } else {
            queued = false;
        }
 
        return queued;
    }

References web::http::client::commands::EndCommand::EndCommand(), masterRequest, onResponseParseError, onResponseReceived, requestCommands, requestPrepared(), and sendHeader().

Here is the call graph for this function:

◆ executeEnd()

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

private

Definition at line 523 of file Request.cpp.

                             { // NOLINT
        return true;
    }

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

Here is the caller graph for this function:

◆ executeSendFile()

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

private

Definition at line 461 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)->pipe(this, [this, &atomar, &absolutFileName, &onStatus](int errnum) {
                    errno = errnum;
                    onStatus(errnum);
 
                    if (errnum == 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 {
                errno = EINVAL;
                onStatus(errno);
            }
        } else {
            errno = ENOENT;
            onStatus(errno);
        }
 
        return atomar;
    }

References contentLength, web::http::MimeTypes::contentType(), executeSendHeader(), httputils::file_mod_http_date(), httpMajor, httpMinor, core::file::FileReader::open(), core::pipe::Source::pipe(), and 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::Request::executeSendFragment	(	const char *	chunk,
		std::size_t	chunkLen
	)

private

Definition at line 559 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, contentLength, contentLengthSent, core::socket::stream::SocketContext::sendToPeer(), core::socket::SocketContext::sendToPeer(), socketContext, and 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::Request::executeSendHeader ( )

private

Definition at line 527 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 contentLength, cookies, headers, httpMajor, httpMinor, method, queries, core::socket::SocketContext::sendToPeer(), set(), socketContext, httputils::to_http_date(), 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:

◆ executeUpgrade()

bool web::http::client::Request::executeUpgrade	(	const std::string &	url,
		const std::string &	protocols
	)

private

Definition at line 503 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) {
            socketContextUpgradeFactory->checkRefCount();
 
            executeSendHeader();
        } else {
            socketContext->close();
        }
 
        return true;
    }

References web::http::client::SocketContextUpgradeFactory::checkRefCount(), core::socket::stream::SocketContext::close(), executeSendHeader(), web::http::client::SocketContextUpgradeFactorySelector::instance(), web::http::client::SocketContextUpgradeFactorySelector::select(), set(), socketContext, and url.

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getCookies()

const web::http::CiStringMap< std::string > & web::http::client::Request::getCookies ( ) const

Definition at line 650 of file Request.cpp.

                                                                   {
        return cookies;
    }

References cookies.

◆ getHeaders()

const web::http::CiStringMap< std::string > & web::http::client::Request::getHeaders ( ) const

Definition at line 646 of file Request.cpp.

                                                                   {
        return headers;
    }

References headers.

◆ getQueries()

const web::http::CiStringMap< std::string > & web::http::client::Request::getQueries ( ) const

Definition at line 642 of file Request.cpp.

                                                                   {
        return queries;
    }

References queries.

◆ getSocketContext()

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

Definition at line 654 of file Request.cpp.

                                                   {
        return socketContext;
    }

References socketContext.

Referenced by responseParseError().

Here is the caller graph for this function:

◆ header()

std::string web::http::client::Request::header ( const std::string & field )

Definition at line 638 of file Request.cpp.

                                                    {
        return headers.contains(field) ? headers[field] : "";
    }

References headers.

Referenced by web::websocket::client::SocketContextUpgradeFactory::create(), main(), web::http::client::SocketContext::requestPrepared(), and upgrade().

Here is the caller graph for this function:

◆ host()

Request & web::http::client::Request::host ( const std::string & hostFieldValue )

Definition at line 141 of file Request.cpp.

                                                          {
        set("Host", hostFieldValue);
 
        return *this;
    }

References set().

Referenced by init(), and Request().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ init()

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

virtual

Definition at line 117 of file Request.cpp.

                       {
        method = "GET";
        url = "/";
        httpMajor = 1;
        httpMinor = 1;
        queries.clear();
        headers.clear();
        cookies.clear();
        trailer.clear();
        for (const RequestCommand* requestCommand : requestCommands) {
            delete requestCommand;
        }
        requestCommands.clear();
        transferEncoding = TransferEncoding::HTTP10;
        contentLength = 0;
        contentLengthSent = 0;
        connectionState = ConnectionState::Default;
        onResponseReceived = nullptr;
        onResponseParseError = nullptr;
 
        this->host(hostFieldValue);
        set("X-Powered-By", "snode.c");
    }

References connectionState, contentLength, contentLengthSent, cookies, web::http::Default, headers, host(), hostFieldValue, web::http::HTTP10, httpMajor, httpMinor, method, onResponseParseError, onResponseReceived, queries, requestCommands, set(), trailer, transferEncoding, and url.

Referenced by Request(), and requestPrepared().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ initiate()

bool web::http::client::Request::initiate ( )

private

Definition at line 436 of file Request.cpp.

                           {
        bool error = false;
        bool atomar = true;
 
        for (RequestCommand* requestCommand : requestCommands) {
            if (!error) {
                const bool atomarCommand = requestCommand->execute(this);
                if (atomar) {
                    atomar = atomarCommand;
                }
 
                error = requestCommand->getError();
            }
 
            delete requestCommand;
        }
        requestCommands.clear();
 
        if (atomar && (!error || contentLengthSent != 0)) {
            requestDelivered();
        }
 
        return !error || contentLengthSent != 0;
    }

References contentLengthSent, web::http::client::RequestCommand::execute(), web::http::client::RequestCommand::getError(), 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:

◆ onSourceConnect()

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

overrideprivatevirtual

Implements core::pipe::Sink.

Definition at line 605 of file Request.cpp.

                                                        {
        if (!masterRequest.expired()) {
            if (socketContext->streamToPeer(source)) {
                source->start();
            }
        } else {
            source->stop();
        }
    }

References masterRequest, 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::Request::onSourceData	(	const char *	chunk,
		std::size_t	chunkLen
	)

overrideprivatevirtual

Implements core::pipe::Sink.

Definition at line 615 of file Request.cpp.

                                                                    {
        executeSendFragment(chunk, chunkLen);
    }

References executeSendFragment().

Here is the call graph for this function:

◆ onSourceEof()

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

overrideprivatevirtual

Implements core::pipe::Sink.

Definition at line 619 of file Request.cpp.

                              {
        if (!masterRequest.expired()) {
            socketContext->streamEof();
 
            requestDelivered();
        }
    }

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

Here is the call graph for this function:

◆ onSourceError()

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

overrideprivatevirtual

Implements core::pipe::Sink.

Definition at line 627 of file Request.cpp.

                                          {
        errno = errnum;
 
        if (!masterRequest.expired()) {
            socketContext->streamEof();
            socketContext->close();
 
            requestDelivered();
        }
    }

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

Here is the call graph for this function:

◆ operator=() [1/2]

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

deletenoexcept

◆ operator=() [2/2]

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

delete

◆ query()

Request & web::http::client::Request::query	(	const std::string &	key,
		const std::string &	value
	)

Definition at line 233 of file Request.cpp.

                                                                        {
        queries.insert({key, value});
 
        return *this;
    }

References queries.

◆ requestDelivered()

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

private

Definition at line 588 of file Request.cpp.

                                   {
        if (!masterRequest.expired()) {
            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(std::move(*this), contentLengthSent == contentLength);
        }
    }

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ requestPrepared()

void web::http::client::Request::requestPrepared ( )

private

Definition at line 575 of file Request.cpp.

                                  {
        socketContext->requestPrepared(std::move(*this));
        init();
    }

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ responseParseError()

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

static

Definition at line 258 of file Request.cpp.

                                                                                                    {
        LOG(WARNING) << request->getSocketContext()->getSocketConnection()->getConnectionName()
                     << " HTTP: Response parse error: " << request->method << " " << request->url << " "
                     << "HTTP/" << request->httpMajor << "." << request->httpMinor << ": " << message;
    }

References core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), getSocketContext(), httpMajor, httpMinor, method, and url.

Here is the call graph for this function:

◆ send() [1/2]

bool web::http::client::Request::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 = `responseParseError`
	)

Definition at line 264 of file Request.cpp.

                                                                                                                       {
        bool queued = true;
 
        if (!masterRequest.expired()) {
            this->onResponseReceived = onResponseReceived;
            this->onResponseParseError = onResponseParseError;
 
            if (chunkLen > 0) {
                set("Content-Type", "application/octet-stream", false);
            }
 
            sendHeader();
            sendFragment(chunk, chunkLen);
 
            requestCommands.push_back(new commands::EndCommand());
 
            requestPrepared();
        } else {
            queued = false;
        }
 
        return queued;
    }

References web::http::client::commands::EndCommand::EndCommand(), masterRequest, onResponseParseError, onResponseReceived, requestCommands, requestPrepared(), sendFragment(), sendHeader(), and 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::Request::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 = `responseParseError`
	)

Definition at line 291 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 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::Request::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 = `responseParseError`
	)

Definition at line 374 of file Request.cpp.

                                                                                                                           {
        bool queued = true;
 
        if (!masterRequest.expired()) {
            this->onResponseReceived = onResponseReceived;
            this->onResponseParseError = onResponseParseError;
 
            requestCommands.push_back(new commands::SendFileCommand(file, onStatus));
 
            requestPrepared();
        } else {
            queued = false;
        }
 
        return queued;
    }

References masterRequest, onResponseParseError, onResponseReceived, requestCommands, requestPrepared(), and web::http::client::commands::SendFileCommand::SendFileCommand().

Here is the call graph for this function:

◆ sendFragment() [1/2]

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

Definition at line 402 of file Request.cpp.

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

References contentLength, masterRequest, 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]

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

Definition at line 412 of file Request.cpp.

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

References sendFragment().

Here is the call graph for this function:

◆ sendHeader()

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

Definition at line 394 of file Request.cpp.

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

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

Referenced by end(), and send().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ set() [1/2]

Request & web::http::client::Request::set	(	const std::map< std::string, std::string > &	headers,
		bool	overwrite = `true`
	)

Definition at line 205 of file Request.cpp.

                                                                                     {
        for (const auto& [field, value] : headers) {
            set(field, value, overwrite);
        }
 
        return *this;
    }

References set().

Here is the call graph for this function:

◆ set() [2/2]

Request & web::http::client::Request::set	(	const std::string &	field,
		const std::string &	value,
		bool	overwrite = `true`
	)

Definition at line 159 of file Request.cpp.

                                                                                        {
        if (!value.empty()) {
            if (overwrite) {
                headers.insert_or_assign(field, value);
            } else {
                headers.insert({field, value});
            }
 
            if (web::http::ciEquals(field, "Connection")) {
                if (web::http::ciContains(headers[field], "close")) {
                    connectionState = ConnectionState::Close;
                } else if (web::http::ciContains(headers[field], "keep-alive")) {
                    connectionState = ConnectionState::Keep;
                }
            } else if (web::http::ciEquals(field, "Content-Length")) {
                contentLength = std::stoul(value);
                transferEncoding = TransferEncoding::Identity;
                headers.erase("Transfer-Encoding");
            } else if (web::http::ciEquals(field, "Transfer-Encoding")) {
                if (web::http::ciContains(headers[field], "chunked")) {
                    transferEncoding = TransferEncoding::Chunked;
                    headers.erase("Content-Length");
                }
                if (web::http::ciContains(headers[field], "compressed")) {
                }
                if (web::http::ciContains(headers[field], "deflate")) {
                }
                if (web::http::ciContains(headers[field], "gzip")) {
                }
            } else if (web::http::ciEquals(field, "Content-Encoding")) {
                if (web::http::ciContains(headers[field], "compressed")) {
                }
                if (web::http::ciContains(headers[field], "deflate")) {
                }
                if (web::http::ciContains(headers[field], "gzip")) {
                }
                if (web::http::ciContains(headers[field], "br")) {
                }
            }
        } else {
            headers.erase(field);
        }
 
        return *this;
    }

References web::http::Chunked, web::http::ciContains(), web::http::ciEquals(), web::http::Close, connectionState, contentLength, headers, web::http::Identity, web::http::Keep, and transferEncoding.

Referenced by append(), executeSendFile(), executeSendHeader(), executeUpgrade(), host(), init(), main(), web::websocket::client::SocketContextUpgradeFactory::prepare(), send(), send(), set(), and setTrailer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ setMasterRequest()

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

Definition at line 113 of file Request.cpp.

                                                                              {
        this->masterRequest = masterRequest;
    }

References masterRequest.

◆ setTrailer()

Request & web::http::client::Request::setTrailer	(	const std::string &	field,
		const std::string &	value,
		bool	overwrite = `true`
	)

Definition at line 239 of file Request.cpp.

                                                                                               {
        if (!value.empty()) {
            if (overwrite) {
                trailer.insert_or_assign(field, value);
            } else {
                trailer.insert({field, value});
            }
            if (!headers.contains("Trailer")) {
                set("Trailer", field);
            } else {
                headers["Trailer"].append("," + field);
            }
        } else {
            trailer.erase(field);
        }
 
        return *this;
    }

References headers, set(), and trailer.

Here is the call graph for this function:

◆ type()

Request & web::http::client::Request::type ( const std::string & type )

Definition at line 213 of file Request.cpp.

                                                {
        headers.insert({"Content-Type", type});
 
        return *this;
    }

References headers.

Referenced by main().

Here is the caller graph for this function:

◆ upgrade() [1/2]

void web::http::client::Request::upgrade	(	const std::shared_ptr< Response > &	response,
		const std::function< void(const std::string &)> &	status
	)

Definition at line 321 of file Request.cpp.

                                                                                                                    {
        std::string name;
 
        if (!masterRequest.expired()) {
            if (response != nullptr) {
                if (web::http::ciContains(response->get("connection"), "Upgrade")) {
                    web::http::client::SocketContextUpgradeFactory* socketContextUpgradeFactory =
                        web::http::client::SocketContextUpgradeFactorySelector::instance()->select(*this, *response);
 
                    if (socketContextUpgradeFactory != nullptr) {
                        name = socketContextUpgradeFactory->name();
 
                        LOG(DEBUG) << socketContext->getSocketConnection()->getConnectionName()
                                   << " HTTP upgrade: SocketContextUpgradeFactory created successful: " << name;
 
                        core::socket::stream::SocketContext* socketContextUpgrade =
                            socketContextUpgradeFactory->create(socketContext->getSocketConnection());
 
                        if (socketContextUpgrade != nullptr) {
                            LOG(DEBUG) << socketContext->getSocketConnection()->getConnectionName()
                                       << " HTTP upgrade: SocketContextUpgrade created successful: " << name;
 
                            socketContext->switchSocketContext(socketContextUpgrade);
                        } else {
                            LOG(DEBUG) << socketContext->getSocketConnection()->getConnectionName()
                                       << " HTTP upgrade: Create SocketContextUpgrade failed: " << name;
 
                            socketContext->close();
                        }
                    } else {
                        LOG(DEBUG) << socketContext->getSocketConnection()->getConnectionName()
                                   << " HTTP upgrade: SocketContextUpgradeFactory not supported by server: " << header("upgrade");
 
                        socketContext->close();
                    }
                } else {
                    LOG(DEBUG) << socketContext->getSocketConnection()->getConnectionName()
                               << " HTTP upgrade: Not any protocol supported by server: " << header("upgrade");
 
                    socketContext->close();
                }
            } else {
                LOG(ERROR) << socketContext->getSocketConnection()->getConnectionName() << " HTTP upgrade: Response has gone away";
 
                socketContext->close();
            }
        } else {
            LOG(ERROR) << socketContext->getSocketConnection()->getConnectionName() << " HTTP upgrade: SocketContext has gone away";
        }
 
        status(name);
    }

References web::http::ciContains(), core::socket::stream::SocketContext::close(), web::http::SocketContextUpgradeFactory< RequestT, ResponseT >::create(), web::http::client::Response::get(), core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), header(), web::http::client::SocketContextUpgradeFactorySelector::instance(), masterRequest, web::http::SocketContextUpgradeFactory< RequestT, ResponseT >::name(), web::http::client::SocketContextUpgradeFactorySelector::select(), socketContext, and core::socket::stream::SocketContext::switchSocketContext().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ upgrade() [2/2]

bool web::http::client::Request::upgrade	(	const std::string &	url,
		const std::string &	protocols,
		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 = `responseParseError`
	)

Definition at line 301 of file Request.cpp.

                                                                                                                          {
        bool success = true;
 
        if (!masterRequest.expired()) {
            this->onResponseReceived = onResponseReceived;
            this->onResponseParseError = onResponseParseError;
 
            requestCommands.push_back(new commands::UpgradeCommand(url, protocols));
 
            requestPrepared();
        } else {
            success = false;
        }
 
        return success;
    }

References masterRequest, onResponseParseError, onResponseReceived, requestCommands, requestPrepared(), and web::http::client::commands::UpgradeCommand::UpgradeCommand().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Symbol Documentation

◆ commands::EndCommand

friend class commands::EndCommand

friend

Definition at line 136 of file Request.h.

◆ commands::SendFileCommand

friend class commands::SendFileCommand

friend

Definition at line 132 of file Request.h.

◆ commands::SendFragmentCommand

friend class commands::SendFragmentCommand

friend

Definition at line 133 of file Request.h.

◆ commands::SendHeaderCommand

friend class commands::SendHeaderCommand

friend

Definition at line 134 of file Request.h.

◆ commands::UpgradeCommand

friend class commands::UpgradeCommand

friend

Definition at line 135 of file Request.h.

◆ SocketContext

friend class SocketContext

friend

Definition at line 193 of file Request.h.

Member Data Documentation

◆ connectionState

ConnectionState web::http::client::Request::connectionState = ConnectionState::Default

private

Definition at line 184 of file Request.h.

Referenced by init(), Request(), and set().

◆ contentLength

std::size_t web::http::client::Request::contentLength = 0

private

Definition at line 181 of file Request.h.

Referenced by executeSendFile(), executeSendFragment(), executeSendHeader(), init(), Request(), requestDelivered(), sendFragment(), and set().

◆ contentLengthSent

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

private

Definition at line 182 of file Request.h.

Referenced by executeSendFragment(), init(), initiate(), Request(), and requestDelivered().

◆ cookies

CiStringMap<std::string> web::http::client::Request::cookies

protected

Definition at line 173 of file Request.h.

Referenced by cookie(), executeSendHeader(), getCookies(), init(), and Request().

◆ headers

CiStringMap<std::string> web::http::client::Request::headers

protected

Definition at line 172 of file Request.h.

Referenced by append(), executeSendHeader(), getHeaders(), header(), init(), Request(), set(), setTrailer(), and type().

◆ hostFieldValue

std::string web::http::client::Request::hostFieldValue

Definition at line 164 of file Request.h.

Referenced by init(), Request(), and Request().

◆ httpMajor

int web::http::client::Request::httpMajor = 1

Definition at line 167 of file Request.h.

Referenced by web::http::client::SocketContext::deliverResponse(), web::http::client::SocketContext::deliverResponseParseError(), executeSendFile(), executeSendHeader(), init(), web::http::client::SocketContext::initiateRequest(), web::http::client::SocketContext::onDisconnected(), Request(), web::http::client::SocketContext::requestDelivered(), web::http::client::SocketContext::requestPrepared(), web::http::client::SocketContext::responseDelivered(), responseParseError(), web::http::client::SocketContext::responseStarted(), and web::http::client::SocketContext::~SocketContext().

◆ httpMinor

int web::http::client::Request::httpMinor = 1

Definition at line 168 of file Request.h.

Referenced by web::http::client::SocketContext::deliverResponse(), web::http::client::SocketContext::deliverResponseParseError(), executeSendFile(), executeSendHeader(), init(), web::http::client::SocketContext::initiateRequest(), web::http::client::SocketContext::onDisconnected(), Request(), web::http::client::SocketContext::requestDelivered(), web::http::client::SocketContext::requestPrepared(), web::http::client::SocketContext::responseDelivered(), responseParseError(), web::http::client::SocketContext::responseStarted(), and web::http::client::SocketContext::~SocketContext().

◆ masterRequest

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

private

Definition at line 189 of file Request.h.

Referenced by end(), onSourceConnect(), onSourceEof(), onSourceError(), Request(), requestDelivered(), send(), sendFile(), sendFragment(), sendHeader(), setMasterRequest(), upgrade(), upgrade(), and ~Request().

◆ method

std::string web::http::client::Request::method = "GET"

Definition at line 165 of file Request.h.

◆ onResponseParseError

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

private

Definition at line 187 of file Request.h.

Referenced by deliverResponseParseError(), end(), init(), Request(), send(), sendFile(), and upgrade().

◆ onResponseReceived

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

private

Definition at line 186 of file Request.h.

Referenced by deliverResponse(), end(), init(), Request(), send(), sendFile(), and upgrade().

◆ queries

CiStringMap<std::string> web::http::client::Request::queries

protected

Definition at line 171 of file Request.h.

Referenced by executeSendHeader(), getQueries(), init(), query(), and Request().

◆ requestCommands

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

private

Definition at line 177 of file Request.h.

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

◆ socketContext

web::http::client::SocketContext* web::http::client::Request::socketContext

private

Definition at line 191 of file Request.h.

Referenced by executeSendFragment(), executeSendHeader(), executeUpgrade(), getSocketContext(), onSourceConnect(), onSourceEof(), onSourceError(), Request(), Request(), requestDelivered(), requestPrepared(), upgrade(), and ~Request().

◆ trailer

CiStringMap<std::string> web::http::client::Request::trailer

protected

Definition at line 174 of file Request.h.

Referenced by init(), Request(), requestDelivered(), and setTrailer().

◆ transferEncoding

TransferEncoding web::http::client::Request::transferEncoding = TransferEncoding::HTTP10

private

Definition at line 179 of file Request.h.

Referenced by executeSendFragment(), init(), Request(), requestDelivered(), and set().

◆ url

std::string web::http::client::Request::url = "/"

Definition at line 166 of file Request.h.

Referenced by web::http::client::SocketContext::deliverResponse(), web::http::client::SocketContext::deliverResponseParseError(), executeSendHeader(), executeUpgrade(), init(), web::http::client::SocketContext::initiateRequest(), main(), Request(), web::http::client::SocketContext::requestDelivered(), web::http::client::SocketContext::requestPrepared(), web::http::client::SocketContext::responseDelivered(), responseParseError(), web::http::client::SocketContext::responseStarted(), and web::http::client::SocketContext::~SocketContext().

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

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

Public Member Functions

Static Public Member Functions

Public Attributes

Protected Attributes

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ Request() [1/3]

◆ Request() [2/3]

◆ Request() [3/3]

◆ ~Request()

Member Function Documentation

◆ append()

◆ cookie() [1/2]

◆ cookie() [2/2]

◆ deliverResponse()

◆ deliverResponseParseError()

◆ end()

◆ executeEnd()

◆ executeSendFile()

◆ executeSendFragment()

◆ executeSendHeader()

◆ executeUpgrade()

◆ getCookies()

◆ getHeaders()

◆ getQueries()

◆ getSocketContext()

◆ header()

◆ host()

◆ init()

◆ initiate()

◆ onSourceConnect()

◆ onSourceData()

◆ onSourceEof()

◆ onSourceError()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ query()

◆ requestDelivered()

◆ requestPrepared()

◆ responseParseError()

◆ send() [1/2]

◆ send() [2/2]

◆ sendFile()

◆ sendFragment() [1/2]

◆ sendFragment() [2/2]

◆ sendHeader()

◆ set() [1/2]

◆ set() [2/2]

◆ setMasterRequest()

◆ setTrailer()

◆ type()

◆ upgrade() [1/2]

◆ upgrade() [2/2]

Friends And Related Symbol Documentation

◆ commands::EndCommand

◆ commands::SendFileCommand

◆ commands::SendFragmentCommand

◆ commands::SendHeaderCommand

◆ commands::UpgradeCommand

◆ SocketContext

Member Data Documentation

◆ connectionState

◆ contentLength

◆ contentLengthSent

◆ cookies

◆ headers

◆ hostFieldValue

◆ httpMajor

◆ httpMinor

◆ masterRequest

◆ method

◆ onResponseParseError

◆ onResponseReceived

◆ queries

◆ requestCommands

◆ socketContext