SNode.C
Loading...
Searching...
No Matches
echoclient.cpp File Reference
#include "core/SNodeC.h"
#include "web/http/legacy/in/Client.h"
#include "web/http/tls/in/Client.h"
Include dependency graph for echoclient.cpp:

Go to the source code of this file.

Functions

int main (int argc, char *argv[])

Function Documentation

◆ main()

int main ( int argc,
char * argv[] )

Definition at line 52 of file echoclient.cpp.

52 {
53 core::SNodeC::init(argc, argv);
54
55 {
56 using LegacyClient = web::http::legacy::in::Client;
57 using MasterRequest = LegacyClient::MasterRequest;
58 using Request = LegacyClient::Request;
59 using Response = LegacyClient::Response;
60 using LegacySocketAddress = LegacyClient::SocketAddress;
61
62 const LegacyClient legacyClient(
63 "legacy",
64 [](const std::shared_ptr<MasterRequest>& req) {
65 const std::string connectionName = req->getSocketContext()->getSocketConnection()->getConnectionName();
66
67 VLOG(1) << connectionName << ": OnRequestBegin";
68
69 req->set("Sec-WebSocket-Protocol", "subprotocol, echo");
70
71 req->upgrade(
72 "/ws",
73 "websocket",
74 [connectionName](bool success) {
75 VLOG(1) << connectionName << ": HTTP Upgrade (http -> websocket) start " << (success ? "success" : "failed");
76 },
77 [connectionName]([[maybe_unused]] const std::shared_ptr<Request>& req,
78 const std::shared_ptr<Response>& res,
79 [[maybe_unused]] bool success) {
80 VLOG(1) << connectionName << ": Upgrade success:";
81
82 VLOG(1) << connectionName << ": Requested: " << req->header("upgrade");
83 VLOG(1) << connectionName << ": Selected: " << res->get("upgrade");
84 },
85 [connectionName](const std::shared_ptr<Request>&, const std::string& message) {
86 VLOG(1) << connectionName << ": Request parse error: " << message;
87 });
88 },
89 []([[maybe_unused]] const std::shared_ptr<MasterRequest>& req) {
90 const std::string connectionName = req->getSocketContext()->getSocketConnection()->getConnectionName();
91
92 VLOG(1) << connectionName << ": OnRequestEnd";
93 });
94
95 legacyClient
96 .setOnInitState([]([[maybe_unused]] core::eventreceiver::ConnectEventReceiver* connectEventReceiver) {
97 VLOG(0) << "------------------- Legacy Client Init: " << connectEventReceiver;
98 })
99 .connect([instanceName = legacyClient.getConfig().getInstanceName()](const LegacySocketAddress& socketAddress,
100 const core::socket::State& state) {
101 switch (state) {
102 case core::socket::State::OK:
103 VLOG(1) << instanceName << " connected to '" << socketAddress.toString() << "'";
104 break;
105 case core::socket::State::DISABLED:
106 VLOG(1) << instanceName << " disabled";
107 break;
108 case core::socket::State::ERROR:
109 VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
110 break;
111 case core::socket::State::FATAL:
112 VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
113 break;
114 }
115 }); // Connection:keep-alive\r\n\r\n"
116
117 using TlsClient = web::http::tls::in::Client;
118 using MasterRequest = TlsClient::MasterRequest;
119 using Request = TlsClient::Request;
120 using Response = TlsClient::Response;
121 using TLSSocketAddress = TlsClient::SocketAddress;
122
123 const TlsClient tlsClient(
124 "tls",
125 [](const std::shared_ptr<MasterRequest>& req) {
126 const std::string connectionName = req->getSocketContext()->getSocketConnection()->getConnectionName();
127
128 VLOG(1) << connectionName << ": OnRequestBegin";
129
130 req->set("Sec-WebSocket-Protocol", "subprotocol, echo");
131
132 req->upgrade(
133 "/ws",
134 "websocket",
135 [connectionName](bool success) {
136 VLOG(1) << connectionName << ": HTTP Upgrade (http -> websocket) start " << (success ? "success" : "failed");
137 },
138 [connectionName]([[maybe_unused]] const std::shared_ptr<Request>& req,
139 [[maybe_unused]] const std::shared_ptr<Response>& res,
140 [[maybe_unused]] bool success) {
141 },
142 [connectionName](const std::shared_ptr<Request>&, const std::string& message) {
143 VLOG(1) << connectionName << ": Request parse error: " << message;
144 });
145 },
146 []([[maybe_unused]] const std::shared_ptr<MasterRequest>& req) {
147 const std::string connectionName = req->getSocketContext()->getSocketConnection()->getConnectionName();
148
149 VLOG(1) << connectionName << ": OnRequestEnd";
150 });
151
152 tlsClient
153 .setOnInitState([]([[maybe_unused]] core::eventreceiver::ConnectEventReceiver* connectEventReceiver) {
154 VLOG(0) << "------------------- TLS Client Init: " << connectEventReceiver;
155 })
156 .connect([instanceName = tlsClient.getConfig().getInstanceName()](const TLSSocketAddress& socketAddress,
157 const core::socket::State& state) {
158 switch (state) {
159 case core::socket::State::OK:
160 VLOG(1) << instanceName << " connected to '" << socketAddress.toString() << "'";
161 break;
162 case core::socket::State::DISABLED:
163 VLOG(1) << instanceName << " disabled";
164 break;
165 case core::socket::State::ERROR:
166 VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
167 break;
168 case core::socket::State::FATAL:
169 VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
170 break;
171 }
172 }); // Connection:keep-alive\r\n\r\n"
173 }
174
175 return core::SNodeC::start();
176}
core::SNodeC::init
static void init(int argc, char *argv[])
Definition SNodeC.cpp:54
core::SNodeC::start
static int start(const utils::Timeval &timeOut={LONG_MAX, 0})
Definition SNodeC.cpp:60
apps::http::legacy::Response
Client::Response Response
Definition clients.h:93
apps::http::legacy::MasterRequest
Client::MasterRequest MasterRequest
Definition clients.h:91
apps::http::legacy::Request
Client::Request Request
Definition clients.h:92
core::system::connect
int connect(int sockfd, const sockaddr *addr, socklen_t addrlen)
Definition socket.cpp:76
web::http::legacy::in::Client
web::http::client::Client< net::in::stream::legacy::SocketClient > Client
Definition Client.h:54
web::http::tls::in::Client
web::http::client::Client< net::in::stream::tls::SocketClient > Client
Definition Client.h:54

References web::http::client::Client< SocketClientT >::Client(), core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::connect(), core::socket::State::DISABLED, core::socket::State::ERROR, core::socket::State::FATAL, web::http::client::Response::get(), core::socket::Socket< ConfigT >::getConfig(), core::socket::stream::SocketConnection::getConnectionName(), net::config::ConfigInstance::getInstanceName(), core::socket::stream::SocketContext::getSocketConnection(), web::http::client::Request::getSocketContext(), web::http::client::Request::header(), core::SNodeC::init(), core::socket::State::OK, web::http::client::Request::set(), core::socket::stream::SocketClient< SocketConnectorT, SocketContextFactoryT, Args >::setOnInitState(), core::SNodeC::start(), net::in::SocketAddress::toString(), web::http::client::MasterRequest::upgrade(), and core::socket::State::what().

Here is the call graph for this function: