#include <SocketContext.h>

Inheritance diagram for web::http::server::SocketContext:

Collaboration diagram for web::http::server::SocketContext:

Public Member Functions
	SocketContext (core::socket::stream::SocketConnection *socketConnection, const std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)> &onRequestReady)

Public Member Functions inherited from core::socket::stream::SocketContext
	SocketContext (core::socket::stream::SocketConnection *socketConnection)

void	sendToPeer (const char *chunk, std::size_t chunkLen) const final

bool	streamToPeer (core::pipe::Source *source) const

void	streamEof ()

std::size_t	readFromPeer (char *chunk, std::size_t chunklen) const final

void	setTimeout (const utils::Timeval &timeout) final

void	shutdownRead ()

void	shutdownWrite (bool forceClose=false)

void	close () override

SocketConnection *	getSocketConnection () const

virtual void	switchSocketContext (SocketContext *newSocketContext)

void	sendToPeer (const std::string &data) const

virtual void	sendToPeer (const char *chunk, std::size_t chunkLen) const=0

Public Member Functions inherited from core::socket::SocketContext
	SocketContext (const SocketContext &)=delete

	SocketContext (SocketContext &&)=delete

SocketContext &	operator= (const SocketContext &)=delete

SocketContext &	operator= (SocketContext &&)=delete

void	sendToPeer (const std::string &data) const

Private Types
using	Super = core::socket::stream::SocketContext

using	Request = web::http::server::Request

using	Response = web::http::server::Response

Private Member Functions
void	deliverRequest ()

void	responseStarted ()

void	responseCompleted (bool success)

void	requestCompleted ()

void	onConnected () override

std::size_t	onReceivedFromPeer () override

void	onDisconnected () override

bool	onSignal (int signum) override

void	onWriteError (int errnum) override

Private Attributes
std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)>	onRequestReady

std::list< std::shared_ptr< Request > >	pendingRequests

std::shared_ptr< Response >	masterResponse

RequestParser	parser

bool	httpClose = false

friend	Response

Additional Inherited Members
Protected Member Functions inherited from core::socket::stream::SocketContext
void	onReadError (int errnum) override

Protected Member Functions inherited from core::socket::SocketContext
	SocketContext ()=default

virtual	~SocketContext ()

Detailed Description

Definition at line 67 of file SocketContext.h.

Member Typedef Documentation

◆ Request

using web::http::server::SocketContext::Request = web::http::server::Request

private

Definition at line 71 of file SocketContext.h.

◆ Response

using web::http::server::SocketContext::Response = web::http::server::Response

private

Definition at line 72 of file SocketContext.h.

◆ Super

using web::http::server::SocketContext::Super = core::socket::stream::SocketContext

private

Definition at line 69 of file SocketContext.h.

Constructor & Destructor Documentation

◆ SocketContext()

web::http::server::SocketContext::SocketContext	(	core::socket::stream::SocketConnection *	socketConnection,
		const std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)> &	onRequestReady
	)

Definition at line 59 of file SocketContext.cpp.

        : Super(socketConnection)
        , onRequestReady(onRequestReady)
        , masterResponse(std::make_shared<Response>(this))
        , parser(
              this,
              [this]() {
                  LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Request started";
              },
              [this](web::http::server::Request&& request) {
                  LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Request parsed: " << request.method << " "
                            << request.url << " HTTP/" << request.httpMajor << "." << request.httpMinor;
 
                  pendingRequests.emplace_back(std::make_shared<Request>(std::move(request)));
 
                  if (pendingRequests.size() == 1) {
                      deliverRequest();
                  }
              },
              [this](int status, const std::string& reason) {
                  LOG(ERROR) << getSocketConnection()->getConnectionName() << " HTTP Request parse error: " << reason << " (" << status
                             << ") ";
 
                  shutdownWrite(true);
              }) {
    }

References core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), masterResponse, onRequestReady, parser, web::http::server::RequestParser::RequestParser(), and core::socket::stream::SocketContext::SocketContext().

Referenced by web::http::server::SocketContextFactory::create().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

◆ deliverRequest()

void web::http::server::SocketContext::deliverRequest ( )

private

Definition at line 88 of file SocketContext.cpp.

                                       {
        if (!pendingRequests.empty()) {
            const std::shared_ptr<Request>& pendingRequest = pendingRequests.front();
 
            LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Request ready: " << pendingRequest->method << " "
                      << pendingRequest->url << " HTTP/" << pendingRequest->httpMajor << "." << pendingRequest->httpMinor;
 
            masterResponse->init();
            masterResponse->httpMajor = pendingRequest->httpMajor;
            masterResponse->httpMinor = pendingRequest->httpMinor;
 
            const std::string connection = pendingRequest->get("Connection");
            if (!connection.empty()) {
                masterResponse->set("Connection", connection);
            }
 
            onRequestReady(pendingRequest, masterResponse);
        } else {
            LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Request: No more pending";
        }
    }

Referenced by requestCompleted().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ onConnected()

void web::http::server::SocketContext::onConnected ( )

overrideprivatevirtual

Implements core::socket::stream::SocketContext.

Definition at line 159 of file SocketContext.cpp.

                                    {
        LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP: Connected";
 
        masterResponse->init();
    }

References core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), web::http::server::Response::init(), and masterResponse.

Here is the call graph for this function:

◆ onDisconnected()

void web::http::server::SocketContext::onDisconnected ( )

overrideprivatevirtual

Implements core::socket::stream::SocketContext.

Definition at line 175 of file SocketContext.cpp.

                                       {
        if (masterResponse != nullptr) {
            masterResponse->stopResponse();
        }
 
        LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP: Disconnected";
    }

References core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), masterResponse, and web::http::server::Response::stopResponse().

Here is the call graph for this function:

◆ onReceivedFromPeer()

std::size_t web::http::server::SocketContext::onReceivedFromPeer ( )

overrideprivatevirtual

Implements core::socket::SocketContext.

Definition at line 165 of file SocketContext.cpp.

                                                {
        std::size_t consumed = 0;
 
        if (!httpClose) {
            consumed = parser.parse();
        }
 
        return consumed;
    }

References httpClose, web::http::Parser::parse(), and parser.

Here is the call graph for this function:

◆ onSignal()

bool web::http::server::SocketContext::onSignal ( int signum )

overrideprivatevirtual

Implements core::socket::SocketContext.

Definition at line 183 of file SocketContext.cpp.

                                           {
        LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP: Received signal " << signum;
 
        return true;
    }

References core::socket::stream::SocketConnection::getConnectionName(), and core::socket::stream::SocketContext::getSocketConnection().

Here is the call graph for this function:

◆ onWriteError()

void web::http::server::SocketContext::onWriteError ( int errnum )

overrideprivatevirtual

Reimplemented from core::socket::stream::SocketContext.

Definition at line 189 of file SocketContext.cpp.

                                                                {
        // Do nothing in case of an write error
    }

◆ requestCompleted()

void web::http::server::SocketContext::requestCompleted ( )

private

Definition at line 137 of file SocketContext.cpp.

                                         {
        const std::shared_ptr<Request>& pendingRequest = pendingRequests.front();
 
        LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Request completed: " << pendingRequest->method << " "
                  << pendingRequest->url << " HTTP/" << pendingRequest->httpMajor << "." << pendingRequest->httpMinor;
 
        if (httpClose) {
            LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP: Connection = Close";
 
            shutdownWrite();
        } else {
            LOG(DEBUG) << getSocketConnection()->getConnectionName() << " HTTP: Connection = Keep-Alive";
 
            core::EventReceiver::atNextTick([this, response = static_cast<std::weak_ptr<Response>>(this->masterResponse)]() {
                if (!response.expired()) {
                    pendingRequests.pop_front();
                    deliverRequest();
                }
            });
        }
    }

References core::EventReceiver::atNextTick(), deliverRequest(), core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), httpClose, web::http::server::Request::httpMajor, web::http::server::Request::httpMinor, masterResponse, web::http::server::Request::method, pendingRequests, core::socket::stream::SocketContext::shutdownWrite(), and web::http::server::Request::url.

Referenced by responseCompleted().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ responseCompleted()

void web::http::server::SocketContext::responseCompleted ( bool success )

private

Definition at line 117 of file SocketContext.cpp.

                                                      {
        if (success) {
            const std::shared_ptr<Request>& pendingRequest = pendingRequests.front();
 
            LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Response completed: " << pendingRequest->method << " "
                      << pendingRequest->url << " HTTP/" << pendingRequest->httpMajor << "." << pendingRequest->httpMinor;
 
            httpClose = masterResponse->connectionState == ConnectionState::Close ||
                        (masterResponse->connectionState == ConnectionState::Default &&
                         ((masterResponse->httpMajor == 0 && masterResponse->httpMinor == 9) ||
                          (masterResponse->httpMajor == 1 && masterResponse->httpMinor == 0)));
 
            requestCompleted();
        } else {
            LOG(WARNING) << getSocketConnection()->getConnectionName() << " HTTP Response wrong content length";
 
            shutdownWrite(true);
        }
    }

References web::http::Close, web::http::server::Response::connectionState, web::http::Default, core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), httpClose, web::http::server::Request::httpMajor, web::http::server::Response::httpMajor, web::http::server::Request::httpMinor, web::http::server::Response::httpMinor, masterResponse, web::http::server::Request::method, pendingRequests, requestCompleted(), core::socket::stream::SocketContext::shutdownWrite(), and web::http::server::Request::url.

Referenced by web::http::server::Response::sendCompleted().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ responseStarted()

void web::http::server::SocketContext::responseStarted ( )

private

Definition at line 110 of file SocketContext.cpp.

                                        {
        const std::shared_ptr<Request>& pendingRequest = pendingRequests.front();
 
        LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Response started: " << pendingRequest->method << " "
                  << pendingRequest->url << " HTTP/" << pendingRequest->httpMajor << "." << pendingRequest->httpMinor;
    }

References core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), web::http::server::Request::httpMajor, web::http::server::Request::httpMinor, web::http::server::Request::method, pendingRequests, and web::http::server::Request::url.

Referenced by web::http::server::Response::sendHeader().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

◆ httpClose

bool web::http::server::SocketContext::httpClose = false

private

Definition at line 97 of file SocketContext.h.

Referenced by onReceivedFromPeer(), requestCompleted(), and responseCompleted().

◆ masterResponse

std::shared_ptr<Response> web::http::server::SocketContext::masterResponse

private

Definition at line 93 of file SocketContext.h.

Referenced by deliverRequest(), onConnected(), onDisconnected(), requestCompleted(), responseCompleted(), and SocketContext().

◆ onRequestReady

std::function<void(const std::shared_ptr<Request>&, const std::shared_ptr<Response>&)> web::http::server::SocketContext::onRequestReady

private

Definition at line 84 of file SocketContext.h.

Referenced by deliverRequest(), and SocketContext().

◆ parser

RequestParser web::http::server::SocketContext::parser

private

Definition at line 95 of file SocketContext.h.

Referenced by onReceivedFromPeer(), and SocketContext().

◆ pendingRequests

std::list<std::shared_ptr<Request> > web::http::server::SocketContext::pendingRequests

private

Definition at line 92 of file SocketContext.h.

Referenced by deliverRequest(), requestCompleted(), responseCompleted(), and responseStarted().

◆ Response

friend web::http::server::SocketContext::Response

private

Definition at line 99 of file SocketContext.h.

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

web/http/server/SocketContext.h
web/http/server/SocketContext.cpp

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ Request

◆ Response

◆ Super

Constructor & Destructor Documentation

◆ SocketContext()

Member Function Documentation

◆ deliverRequest()

◆ onConnected()

◆ onDisconnected()

◆ onReceivedFromPeer()

◆ onSignal()

◆ onWriteError()

◆ requestCompleted()

◆ responseCompleted()

◆ responseStarted()

Member Data Documentation

◆ httpClose

◆ masterResponse

◆ onRequestReady

◆ parser

◆ pendingRequests

◆ Response