web::http::client::ResponseParser Class Reference

#include <ResponseParser.h>

Inheritance diagram for web::http::client::ResponseParser:

Collaboration diagram for web::http::client::ResponseParser:

Public Member Functions
	ResponseParser (core::socket::stream::SocketContext *socketContext, const std::function< void()> &onResponseStart, const std::function< void(Response &)> &onResponseParsed, const std::function< void(int, const std::string &)> &onResponseParseError)
	ResponseParser (const ResponseParser &)=delete
ResponseParser &	operator= (const ResponseParser &)=delete
Public Member Functions inherited from web::http::Parser
	Parser (core::socket::stream::SocketContext *socketContext, const enum HTTPCompliance &compliance=HTTPCompliance::RFC2616|HTTPCompliance::RFC7230)
virtual	~Parser ()
std::size_t	parse ()
void	reset ()

Private Member Functions
void	begin () override
void	parseStartLine (const std::string &line) override
void	analyzeHeader () override
void	parsingFinished () override
void	parseError (int code, const std::string &reason) override

Private Attributes
Response	response
std::function< void()>	onResponseStart
std::function< void(Response &)>	onResponseParsed
std::function< void(int, const std::string &)>	onResponseParseError

Additional Inherited Members
Protected Types inherited from web::http::Parser
enum struct	HTTPCompliance : unsigned short {   RFC1945 = 0x01 << 0 , RFC2616 = 0x01 << 1 , RFC7230 = 0x01 << 2 , RFC7231 = 0x01 << 3 ,   RFC7232 = 0x01 << 4 , RFC7233 = 0x01 << 5 , RFC7234 = 0x01 << 6 , RFC7235 = 0x01 << 7 ,   RFC7540 = 0x01 << 8 , RFC7541 = 0x01 << 9 }
enum struct	ParserState {   BEGIN , FIRSTLINE , HEADER , BODY ,   TRAILER , ERROR }
Protected Attributes inherited from web::http::Parser
enum web::http::Parser::HTTPCompliance	hTTPCompliance
ParserState	parserState = ParserState::BEGIN
TransferEncoding	transferEncoding = TransferEncoding::HTTP10
CiStringMap< std::string >	headers
std::vector< char >	content
int	httpMajor = 0
int	httpMinor = 0
std::list< web::http::ContentDecoder * >	decoderQueue
core::socket::stream::SocketContext *	socketContext = nullptr
std::string	line
std::size_t	contentLength = 0
std::size_t	contentLengthRead = 0
Static Protected Attributes inherited from web::http::Parser
static const std::regex	httpVersionRegex

Detailed Description

Definition at line 63 of file ResponseParser.h.

Constructor & Destructor Documentation

ResponseParser() [1/2]

web::http::client::ResponseParser::ResponseParser	(	core::socket::stream::SocketContext *	socketContext,
		const std::function< void()> &	onResponseStart,
		const std::function< void(Response &)> &	onResponseParsed,
		const std::function< void(int, const std::string &)> &	onResponseParseError
	)

Definition at line 58 of file ResponseParser.cpp.

        : Parser(socketContext)
        , onResponseStart(onResponseStart)
        , onResponseParsed(onResponseParsed)
        , onResponseParseError(onResponseParseError) {
    }

References onResponseParsed, onResponseParseError, onResponseStart, and web::http::Parser::Parser().

Referenced by apps::http::getResponseParser(), and web::http::client::SocketContext::SocketContext().

Here is the call graph for this function:

Here is the caller graph for this function:

ResponseParser() [2/2]

web::http::client::ResponseParser::ResponseParser ( const ResponseParser &  )

delete

Member Function Documentation

analyzeHeader()

void web::http::client::ResponseParser::analyzeHeader ( )

overrideprivatevirtual

Reimplemented from web::http::Parser.

Definition at line 107 of file ResponseParser.cpp.

                                       {
        Parser::analyzeHeader();
 
        if (headers.contains("Connection")) {
            const std::string& connection = headers["Connection"];
            if (web::http::ciContains(connection, "keep-alive")) {
                response.connectionState = ConnectionState::Keep;
            } else if (web::http::ciContains(connection, "close")) {
                response.connectionState = ConnectionState::Close;
            }
        }
        if (headers.contains("Set-Cookie")) {
            std::string cookiesLine = headers["Set-Cookie"];
 
            while (!cookiesLine.empty()) {
                std::string cookieLine;
                std::tie(cookieLine, cookiesLine) = httputils::str_split(cookiesLine, ',');
 
                std::string cookieOptions;
                std::string cookie;
                std::tie(cookie, cookieOptions) = httputils::str_split(cookieLine, ';');
 
                std::string cookieName;
                std::string cookieValue;
                std::tie(cookieName, cookieValue) = httputils::str_split(cookie, '=');
 
                httputils::str_trimm(cookieName);
                httputils::str_trimm(cookieValue);
 
                std::map<std::string, CookieOptions>::iterator cookieElement;
                bool inserted = false;
                std::tie(cookieElement, inserted) = response.cookies.insert({cookieName, CookieOptions(cookieValue)});
 
                while (!cookieOptions.empty()) {
                    std::string option;
                    std::tie(option, cookieOptions) = httputils::str_split(cookieOptions, ';');
 
                    std::string optionName;
                    std::string optionValue;
                    std::tie(optionName, optionValue) = httputils::str_split(option, '=');
 
                    httputils::str_trimm(optionName);
                    httputils::str_trimm(optionValue);
 
                    cookieElement->second.setOption(optionName, optionValue);
                }
            }
 
            Parser::headers.erase("Set-Cookie");
        }
 
        if (transferEncoding == TransferEncoding::Identity && contentLength == 0) {
            parsingFinished();
        } else {
            parserState = Parser::ParserState::BODY;
        }
    }

References web::http::Parser::analyzeHeader(), web::http::Parser::BODY, web::http::ciContains(), web::http::Close, web::http::client::Response::connectionState, web::http::Parser::contentLength, web::http::CookieOptions::CookieOptions(), web::http::client::Response::cookies, web::http::Parser::headers, web::http::Identity, web::http::Keep, web::http::Parser::parserState, parsingFinished(), response, web::http::CookieOptions::setOption(), httputils::str_split(), httputils::str_trimm(), and web::http::Parser::transferEncoding.

Here is the call graph for this function:

begin()

void web::http::client::ResponseParser::begin ( )

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 68 of file ResponseParser.cpp.

                               {
        onResponseStart();
    }

References onResponseStart.

operator=()

ResponseParser & web::http::client::ResponseParser::operator= ( const ResponseParser &  )

delete

parseError()

void web::http::client::ResponseParser::parseError ( int  code, const std::string &  reason  )

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 178 of file ResponseParser.cpp.

                                                                     {
        onResponseParseError(code, reason);
 
        reset();
 
        parserState = ParserState::ERROR;
    }

References web::http::Parser::ERROR, onResponseParseError, web::http::Parser::parserState, and web::http::Parser::reset().

Referenced by parseStartLine().

Here is the call graph for this function:

Here is the caller graph for this function:

parseStartLine()

void web::http::client::ResponseParser::parseStartLine ( const std::string &  line )

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 72 of file ResponseParser.cpp.

                                                             {
        parserState = Parser::ParserState::HEADER;
 
        if (!line.empty()) {
            std::string remaining;
 
            std::tie(response.httpVersion, remaining) = httputils::str_split(line, ' ');
 
            std::smatch httpVersionMatch;
            if (!std::regex_match(response.httpVersion, httpVersionMatch, httpVersionRegex)) {
                parseError(400, "Wrong protocol version: " + response.httpVersion);
            } else {
                httpMajor = std::stoi(httpVersionMatch.str(1));
                httpMinor = std::stoi(httpVersionMatch.str(2));
 
                if (httpMinor == 0) {
                    transferEncoding = TransferEncoding::HTTP10;
                } else if (httpMinor == 1) {
                    transferEncoding = TransferEncoding::Identity;
                }
 
                std::tie(response.statusCode, response.reason) = httputils::str_split(remaining, ' ');
                if (StatusCode::contains(std::stoi(response.statusCode))) {
                    if (response.reason.empty()) {
                        parseError(400, "No reason phrase");
                    }
                } else {
                    parseError(400, "Unknown status code");
                }
            }
        } else {
            parseError(400, "Response line empty");
        }
    }

References web::http::StatusCode::contains(), web::http::Parser::HEADER, web::http::HTTP10, web::http::Parser::httpMajor, web::http::Parser::httpMinor, web::http::client::Response::httpVersion, web::http::Parser::httpVersionRegex, web::http::Identity, parseError(), web::http::Parser::parserState, web::http::client::Response::reason, response, web::http::client::Response::statusCode, httputils::str_split(), and web::http::Parser::transferEncoding.

Here is the call graph for this function:

parsingFinished()

void web::http::client::ResponseParser::parsingFinished ( )

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 165 of file ResponseParser.cpp.

                                         {
        response.httpMajor = httpMajor;
        response.httpMinor = httpMinor;
        response.headers = std::move(headers);
        response.body = std::move(content);
 
        onResponseParsed(response);
 
        reset();
 
        parserState = ParserState::BEGIN;
    }

References web::http::Parser::BEGIN, web::http::client::Response::body, web::http::Parser::content, web::http::client::Response::headers, web::http::Parser::headers, web::http::client::Response::httpMajor, web::http::Parser::httpMajor, web::http::client::Response::httpMinor, web::http::Parser::httpMinor, onResponseParsed, web::http::Parser::parserState, web::http::Parser::reset(), and response.

Referenced by analyzeHeader().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

onResponseParsed

std::function<void(Response&)> web::http::client::ResponseParser::onResponseParsed

private

Definition at line 89 of file ResponseParser.h.

Referenced by parsingFinished(), and ResponseParser().

onResponseParseError

std::function<void(int, const std::string&)> web::http::client::ResponseParser::onResponseParseError

private

Definition at line 90 of file ResponseParser.h.

Referenced by parseError(), and ResponseParser().

onResponseStart

std::function<void()> web::http::client::ResponseParser::onResponseStart

private

Definition at line 88 of file ResponseParser.h.

Referenced by begin(), and ResponseParser().

response

Response web::http::client::ResponseParser::response

private

Definition at line 85 of file ResponseParser.h.

Referenced by analyzeHeader(), parseStartLine(), and parsingFinished().

---

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

• web/http/client/ResponseParser.h
• web/http/client/ResponseParser.cpp