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
Response &&	getResponse ()
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 41 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 37 of file ResponseParser.cpp.

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

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 88 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::Parser::parserState, and parsingFinished().

Here is the call graph for this function:

begin()

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

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 55 of file ResponseParser.cpp.

                               {
        onResponseStart();
    }

getResponse()

Response && web::http::client::ResponseParser::getResponse

(

)

Definition at line 47 of file ResponseParser.cpp.

                                           {
        if (!decoderQueue.empty()) {
            response.body = decoderQueue.back()->getContent();
        }
 
        return std::move(response);
    }

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 159 of file ResponseParser.cpp.

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

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

Here is the call graph for this function:

parseStartLine()

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

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 59 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));
 
                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::Parser::HEADER, and web::http::Parser::parserState.

parsingFinished()

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

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 146 of file ResponseParser.cpp.

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

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

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 69 of file ResponseParser.h.

onResponseParseError

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

private

Definition at line 70 of file ResponseParser.h.

onResponseStart

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

private

Definition at line 68 of file ResponseParser.h.

response

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

private

Definition at line 65 of file ResponseParser.h.

---

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

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