#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 62 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 56 of file RequestParser.cpp.

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

References onRequestParsed, onRequestParseError, onRequestStart, and web::http::Parser::Parser().

Referenced by web::http::server::SocketContext::SocketContext().

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 111 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::Chunked, web::http::ciContains(), web::http::Close, web::http::server::Request::connectionState, web::http::Parser::contentLength, web::http::server::Request::cookies, web::http::Parser::headers, web::http::Keep, web::http::Parser::parserState, parsingFinished(), request, httputils::str_split(), httputils::str_trimm(), and web::http::Parser::transferEncoding.

Here is the call graph for this function:

◆ begin()

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

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 70 of file RequestParser.cpp.

                              {
        onRequestStart();
    }

References onRequestStart.

◆ methodSupported()

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

privatevirtual

Definition at line 66 of file RequestParser.cpp.

                                                                     {
        return supportedMethods.contains(method);
    }

References supportedMethods.

Referenced by parseStartLine().

Here is the caller graph for this function:

◆ 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 168 of file RequestParser.cpp.

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

References web::http::Parser::ERROR, onRequestParseError, 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::server::RequestParser::parseStartLine ( const std::string & line )

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 74 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, web::http::Parser::httpMajor, web::http::Parser::httpMinor, web::http::server::Request::httpVersion, web::http::Parser::httpVersionRegex, web::http::server::Request::method, methodSupported(), parseError(), web::http::Parser::parserState, web::http::server::Request::queries, request, httputils::str_split(), and web::http::server::Request::url.

Here is the call graph for this function:

◆ parsingFinished()

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

overrideprivatevirtual

Implements web::http::Parser.

Definition at line 155 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::server::Request::body, web::http::Parser::content, web::http::Parser::headers, web::http::server::Request::headers, web::http::Parser::httpMajor, web::http::server::Request::httpMajor, web::http::Parser::httpMinor, web::http::server::Request::httpMinor, onRequestParsed, web::http::Parser::parserState, request, 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 94 of file RequestParser.h.

Referenced by parsingFinished(), and RequestParser().

◆ onRequestParseError

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

private

Definition at line 95 of file RequestParser.h.

Referenced by parseError(), and RequestParser().

◆ onRequestStart

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

private

Definition at line 93 of file RequestParser.h.

Referenced by begin(), and RequestParser().

◆ request

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

private

Definition at line 90 of file RequestParser.h.

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

◆ supportedMethods

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

private

Definition at line 74 of file RequestParser.h.

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

Referenced by methodSupported().

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

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

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ RequestParser() [1/2]

◆ RequestParser() [2/2]

Member Function Documentation

◆ analyzeHeader()

◆ begin()

◆ methodSupported()

◆ operator=()

◆ parseError()

◆ parseStartLine()

◆ parsingFinished()

Member Data Documentation

◆ onRequestParsed

◆ onRequestParseError

◆ onRequestStart

◆ request

◆ supportedMethods