web::websocket::server::SocketContextUpgradeFactory Class Reference

#include <SocketContextUpgradeFactory.h>

Inheritance diagram for web::websocket::server::SocketContextUpgradeFactory:

Collaboration diagram for web::websocket::server::SocketContextUpgradeFactory:

Public Member Functions
	SocketContextUpgradeFactory ()=default
Public Member Functions inherited from web::http::server::SocketContextUpgradeFactory
void	checkRefCount () final
Public Member Functions inherited from core::socket::stream::SocketContextFactory
	SocketContextFactory (SocketContextFactory &)=delete
	SocketContextFactory (SocketContextFactory &&)=delete
SocketContextFactory &	operator= (SocketContextFactory &)=delete
SocketContextFactory &	operator= (SocketContextFactory &&)=delete

Static Public Member Functions
static void	link ()
Static Public Member Functions inherited from web::http::server::SocketContextUpgradeFactory
static void	link (const std::string &upgradeContextName, SocketContextUpgradeFactory *(*linkedPlugin)())

Private Member Functions
std::string	name () override
http::SocketContextUpgrade< web::http::server::Request, web::http::server::Response > *	create (core::socket::stream::SocketConnection *socketConnection, web::http::server::Request *request, web::http::server::Response *response) override

Additional Inherited Members
Public Types inherited from web::http::server::SocketContextUpgradeFactory
using	Resquest = web::http::server::Request
using	Reponse = web::http::server::Response
Public Types inherited from web::http::SocketContextUpgradeFactory< web::http::server::Request, web::http::server::Response >
using	Request
using	Response
Protected Member Functions inherited from web::http::server::SocketContextUpgradeFactory
	SocketContextUpgradeFactory ()
Protected Member Functions inherited from web::http::SocketContextUpgradeFactory< web::http::server::Request, web::http::server::Response >
	SocketContextUpgradeFactory ()=default
	~SocketContextUpgradeFactory () override=default
void	prepare (Request &request, Response &response)
Protected Member Functions inherited from core::socket::stream::SocketContextFactory
	SocketContextFactory ()=default
virtual	~SocketContextFactory ()
Protected Attributes inherited from web::http::SocketContextUpgradeFactory< web::http::server::Request, web::http::server::Response >
std::size_t	refCount

Detailed Description

Definition at line 33 of file SocketContextUpgradeFactory.h.

Constructor & Destructor Documentation

SocketContextUpgradeFactory()

web::websocket::server::SocketContextUpgradeFactory::SocketContextUpgradeFactory ( )

default

Member Function Documentation

create()

http::SocketContextUpgrade< web::http::server::Request, web::http::server::Response > * web::websocket::server::SocketContextUpgradeFactory::create ( core::socket::stream::SocketConnection * socketConnection, web::http::server::Request * request, web::http::server::Response * response )

overrideprivatevirtual

Implements web::http::SocketContextUpgradeFactory< web::http::server::Request, web::http::server::Response >.

Definition at line 43 of file SocketContextUpgradeFactory.cpp.

                                                                         {
        SocketContextUpgrade* socketContext = nullptr;
 
        if (request->get("Sec-WebSocket-Version") == "13") {
            std::string requestedSubProtocolNames = request->get("sec-websocket-protocol");
 
            std::list<std::string> subProtocolNamesList;
            do {
                std::string subProtocolName;
                std::tie(subProtocolName, requestedSubProtocolNames) = httputils::str_split(requestedSubProtocolNames, ',');
                httputils::str_trimm(subProtocolName);
                subProtocolNamesList.push_back(subProtocolName);
            } while (!requestedSubProtocolNames.empty());
 
            if (!subProtocolNamesList.empty()) {
                std::string selectedSubProtocolName;
 
                socketContext = new SocketContextUpgrade(socketConnection, this);
                selectedSubProtocolName = socketContext->loadSubProtocol(subProtocolNamesList);
 
                if (!selectedSubProtocolName.empty()) {
                    response->set("Upgrade", "websocket");
                    response->set("Connection", "Upgrade");
                    response->set("Sec-WebSocket-Protocol", selectedSubProtocolName);
                    response->set("Sec-WebSocket-Accept", base64::serverWebSocketKey(request->get("sec-websocket-key")));
 
                    response->status(101); // Switch Protocol
                } else {
                    delete socketContext;
                    socketContext = nullptr;
 
                    response->set("Connection", "close");
                    response->status(400);
                }
            } else {
                checkRefCount();
 
                response->set("Connection", "close");
                response->status(400);
            }
        } else {
            checkRefCount();
 
            response->set("Sec-WebSocket-Version", "13");
            response->set("Connection", "close");
            response->status(426);
        }
 
        return socketContext;
    }

link()

void web::websocket::server::SocketContextUpgradeFactory::link ( )

static

Definition at line 96 of file SocketContextUpgradeFactory.cpp.

                                           {
        static bool linked = false;
 
        if (!linked) {
            web::http::server::SocketContextUpgradeFactory::link("websocket", websocketServerSocketContextUpgradeFactory);
            linked = true;
        }
    }

name()

std::string web::websocket::server::SocketContextUpgradeFactory::name ( )

overrideprivatevirtual

Implements web::http::SocketContextUpgradeFactory< web::http::server::Request, web::http::server::Response >.

Definition at line 38 of file SocketContextUpgradeFactory.cpp.

                                                {
        return "websocket";
    }

---

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

• web/websocket/server/SocketContextUpgradeFactory.h
• web/websocket/server/SocketContextUpgradeFactory.cpp