SNode.C
Loading...
Searching...
No Matches
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
 
SocketContextFactoryoperator= (SocketContextFactory &)=delete
 
SocketContextFactoryoperator= (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 = web::http::server::Request
 
using Response = web::http::server::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 55 of file SocketContextUpgradeFactory.h.

Constructor & Destructor Documentation

◆ SocketContextUpgradeFactory()

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

Referenced by web::websocket::server::websocketServerSocketContextUpgradeFactory().

Here is the caller graph for this function:

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 65 of file SocketContextUpgradeFactory.cpp.

67 {
68 SocketContextUpgrade* socketContext = nullptr;
69
70 if (request->get("Sec-WebSocket-Version") == "13") {
71 std::string requestedSubProtocolNames = request->get("sec-websocket-protocol");
72
73 std::list<std::string> subProtocolNamesList;
74 do {
75 std::string subProtocolName;
76 std::tie(subProtocolName, requestedSubProtocolNames) = httputils::str_split(requestedSubProtocolNames, ',');
77 httputils::str_trimm(subProtocolName);
78 subProtocolNamesList.push_back(subProtocolName);
79 } while (!requestedSubProtocolNames.empty());
80
81 if (!subProtocolNamesList.empty()) {
82 std::string selectedSubProtocolName;
83
84 socketContext = new SocketContextUpgrade(socketConnection, this);
85 selectedSubProtocolName = socketContext->loadSubProtocol(subProtocolNamesList);
86
87 if (!selectedSubProtocolName.empty()) {
88 response->set("Upgrade", "websocket");
89 response->set("Connection", "Upgrade");
90 response->set("Sec-WebSocket-Protocol", selectedSubProtocolName);
91 response->set("Sec-WebSocket-Accept", base64::serverWebSocketKey(request->get("sec-websocket-key")));
92
93 response->status(101); // Switch Protocol
94 } else {
95 delete socketContext;
96 socketContext = nullptr;
97
98 response->set("Connection", "close");
99 response->status(400);
100 }
101 } else {
103
104 response->set("Connection", "close");
105 response->status(400);
106 }
107 } else {
109
110 response->set("Sec-WebSocket-Version", "13");
111 response->set("Connection", "close");
112 response->status(426);
113 }
114
115 return socketContext;
116 }
const std::string & get(const std::string &key, int i=0) const
Definition Request.cpp:53
Response & status(int statusCode)
Definition Response.cpp:102
Response & set(const std::string &field, const std::string &value, bool overwrite=true)
Definition Response.cpp:128
std::string serverWebSocketKey(const std::string &clientWebSocketKey)
Definition base64.cpp:56
std::pair< std::string, std::string > str_split(const std::string &base, char c_middle)
std::string & str_trimm(std::string &text)

References web::http::server::SocketContextUpgradeFactory::checkRefCount(), web::http::server::Request::get(), web::websocket::server::SocketContextUpgrade::loadSubProtocol(), base64::serverWebSocketKey(), web::http::server::Response::set(), web::websocket::server::SocketContextUpgrade::SocketContextUpgrade(), web::http::server::Response::status(), httputils::str_split(), and httputils::str_trimm().

Here is the call graph for this function:

◆ link()

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

Definition at line 118 of file SocketContextUpgradeFactory.cpp.

118 {
119 static bool linked = false;
120
121 if (!linked) {
123 linked = true;
124 }
125 }
static void link(const std::string &upgradeContextName, SocketContextUpgradeFactory *(*linkedPlugin)())
web::http::server::SocketContextUpgradeFactory * websocketServerSocketContextUpgradeFactory()

References web::http::server::SocketContextUpgradeFactory::link(), and web::websocket::server::websocketServerSocketContextUpgradeFactory().

Here is the call graph for this function:

◆ name()

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

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