web::http::server::RequestParser Class Reference

#include <RequestParser.h>

Inheritance diagram for web::http::server::RequestParser:

Collaboration diagram for web::http::server::RequestParser:

Public Member Functions
	RequestParser (core::socket::stream::SocketContext *socketContext, const std::function< void()> &onRequestStart, const std::function< void(Request &&)> &onRequestParsed, const std::function< void(int, const std::string &)> &onRequestParseError)
	RequestParser (const RequestParser &)=delete
RequestParser &	operator= (const RequestParser &)=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
virtual bool	methodSupported (const std::string &method) const
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
std::set< std::string >	supportedMethods {"GET", "PUT", "POST", "DELETE", "CONNECT", "OPTIONS", "TRACE", "PATCH", "HEAD"}
Request	request
std::function< void()>	onRequestStart
std::function< void(Request &&)>	onRequestParsed
std::function< void(int, const std::string &)>	onRequestParseError

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 40 of file RequestParser.h.

Constructor & Destructor Documentation

RequestParser() [1/2]

web::http::server::RequestParser::RequestParser	(	core::socket::stream::SocketContext *	socketContext,
		const std::function< void()> &	onRequestStart,
		const std::function< void(Request &&)> &	onRequestParsed,
		const std::function< void(int, const std::string &)> &	onRequestParseError )

Definition at line 34 of file RequestParser.cpp.

        : Parser(socketContext)
        , onRequestStart(onRequestStart)
        , onRequestParsed(onRequestParsed)
        , onRequestParseError(onRequestParseError) {
    }

References RequestParser().

Referenced by RequestParser().

Here is the call graph for this function:

Here is the caller graph for this function:

RequestParser() [2/2]

web::http::server::RequestParser::RequestParser ( const RequestParser & )

delete

Member Function Documentation

analyzeHeader()

void web::http::server::RequestParser::analyzeHeader ( )

overrideprivatevirtual

Reimplemented from web::http::Parser.

Definition at line 89 of file RequestParser.cpp.

                                      {
        Parser::analyzeHeader();
 
        if (headers.contains("Connection")) {
            const std::string& connection = headers["Connection"];
            if (web::http::ciContains(connection, "keep-alive")) {
                request.connectionState = ConnectionState::Keep;
            } else if (web::http::ciContains(connection, "close")) {
                request.connectionState = ConnectionState::Close;
            }
        }
 
        if (headers.contains("Cookie")) {
            std::string& cookiesLine = headers["Cookie"];
 
            while (!cookiesLine.empty()) {
                std::string cookieLine;
                std::tie(cookieLine, cookiesLine) = httputils::str_split(cookiesLine, ',');
 
                while (!cookieLine.empty()) {
                    std::string cookie;
                    std::tie(cookie, cookieLine) = 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);
 
                    request.cookies.emplace(cookieName, cookieValue);
                }
            }
 
            headers.erase("Cookie");
        }
 
        if (transferEncoding != TransferEncoding::Chunked && 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::server::RequestParser::begin ( )

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 48 of file RequestParser.cpp.

                              {
        onRequestStart();
    }

methodSupported()

bool web::http::server::RequestParser::methodSupported ( const std::string & method ) const

privatevirtual

Definition at line 44 of file RequestParser.cpp.

                                                                     {
        return supportedMethods.contains(method);
    }

operator=()

RequestParser & web::http::server::RequestParser::operator= ( const RequestParser & )

delete

parseError()

void web::http::server::RequestParser::parseError ( int code, const std::string & reason )

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 146 of file RequestParser.cpp.

                                                                    {
        onRequestParseError(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::server::RequestParser::parseStartLine ( const std::string & line )

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 52 of file RequestParser.cpp.

                                                            {
        parserState = Parser::ParserState::HEADER;
 
        if (!line.empty()) {
            std::string remaining;
 
            std::tie(request.method, remaining) = httputils::str_split(line, ' ');
            std::tie(request.url, request.httpVersion) = httputils::str_split(remaining, ' ');
 
            std::string queriesLine;
            std::tie(std::ignore, queriesLine) = httputils::str_split(request.url, '?');
 
            if (!methodSupported(request.method)) {
                parseError(400, "Bad request method: " + request.method);
            } else if (request.url.empty() || request.url.front() != '/') {
                parseError(400, "Malformed request");
            } else {
                std::smatch httpVersionMatch;
                if (!std::regex_match(request.httpVersion, httpVersionMatch, httpVersionRegex)) {
                    parseError(400, "Wrong protocol-version: " + request.httpVersion);
                } else {
                    httpMajor = std::stoi(httpVersionMatch.str(1));
                    httpMinor = std::stoi(httpVersionMatch.str(2));
 
                    while (!queriesLine.empty()) {
                        std::string query;
 
                        std::tie(query, queriesLine) = httputils::str_split(queriesLine, '&');
                        request.queries.insert(httputils::str_split(query, '='));
                    }
                }
            }
        } else {
            parseError(400, "Request-line empty");
        }
    }

References web::http::Parser::HEADER, and web::http::Parser::parserState.

parsingFinished()

void web::http::server::RequestParser::parsingFinished ( )

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 133 of file RequestParser.cpp.

                                        {
        request.httpMajor = httpMajor;
        request.httpMinor = httpMinor;
        request.headers = std::move(Parser::headers);
        request.body = std::move(content);
 
        onRequestParsed(std::move(request));
 
        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

onRequestParsed

std::function<void(Request&&)> web::http::server::RequestParser::onRequestParsed

private

Definition at line 72 of file RequestParser.h.

onRequestParseError

std::function<void(int, const std::string&)> web::http::server::RequestParser::onRequestParseError

private

Definition at line 73 of file RequestParser.h.

onRequestStart

std::function<void()> web::http::server::RequestParser::onRequestStart

private

Definition at line 71 of file RequestParser.h.

request

Request web::http::server::RequestParser::request

private

Definition at line 68 of file RequestParser.h.

supportedMethods

std::set<std::string> web::http::server::RequestParser::supportedMethods {"GET", "PUT", "POST", "DELETE", "CONNECT", "OPTIONS", "TRACE", "PATCH", "HEAD"}

private

Definition at line 52 of file RequestParser.h.

{"GET", "PUT", "POST", "DELETE", "CONNECT", "OPTIONS", "TRACE", "PATCH", "HEAD"};

---

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

• web/http/server/RequestParser.h
• web/http/server/RequestParser.cpp