SNode.C
Loading...
Searching...
No Matches
echoserver.cpp File Reference
Include dependency graph for echoserver.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 59 of file echoserver.cpp.

59 {
60 express::WebApp::init(argc, argv);
61
62 using LegacyWebApp = express::legacy::in::WebApp;
63 using Request = LegacyWebApp::Request;
64 using Response = LegacyWebApp::Response;
65 using SocketAddress = LegacyWebApp::SocketAddress;
66
67 const LegacyWebApp legacyApp("legacy");
68
70
71 legacyApp.get("/ws", [](const std::shared_ptr<Request>& req, const std::shared_ptr<Response>& res) {
72 const std::string connectionName = res->getSocketContext()->getSocketConnection()->getConnectionName();
73
74 res->upgrade(req, [req, res, connectionName](const std::string& name) {
75 if (!name.empty()) {
76 VLOG(1) << connectionName << ": Successful upgrade:";
77 VLOG(1) << connectionName << ": Requested: " << req->get("upgrade");
78 VLOG(1) << connectionName << ": Selected: " << name;
79
80 res->end();
81 } else {
82 VLOG(1) << connectionName << ": Can not upgrade to any of '" << req->get("upgrade") << "'";
83
84 res->sendStatus(404);
85 }
86 });
87 });
88
89 legacyApp.get("/", [] APPLICATION(req, res) {
90 VLOG(1) << "HTTP GET on "
91 << "/";
92 if (req->url == "/" || req->url == "/index.html") {
93 req->url = "/wstest.html";
94 }
95
96 VLOG(1) << CMAKE_CURRENT_SOURCE_DIR "/html" + req->url;
97 res->sendFile(CMAKE_CURRENT_SOURCE_DIR "/html" + req->url, [req](int errnum) {
98 if (errnum == 0) {
99 VLOG(1) << req->url;
100 } else {
101 VLOG(1) << "HTTP response send file failed: " << std::strerror(errnum);
102 }
103 });
104 });
105
106 legacyApp.listen(
107 [instanceName = legacyApp.getConfig().getInstanceName()](const SocketAddress& socketAddress, const core::socket::State& state) {
108 switch (state) {
110 VLOG(1) << instanceName << " listening on '" << socketAddress.toString() << "'";
111 break;
113 VLOG(1) << instanceName << " disabled";
114 break;
116 VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
117 break;
119 VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
120 break;
121 }
122 });
123
124 VLOG(1) << "Legacy Routes:";
125 for (std::string& route : legacyApp.getRoutes()) {
126 route.erase(std::remove(route.begin(), route.end(), '$'), route.end());
127
128 VLOG(1) << " " << route;
129 }
130
131 {
132 using TlsWebApp = express::tls::in::WebApp;
133 using Request = TlsWebApp::Request;
134 using Response = TlsWebApp::Response;
135 using SocketAddress = TlsWebApp::SocketAddress;
136
137 const TlsWebApp tlsApp("tls");
138
140
141 tlsApp.get("/ws", [](const std::shared_ptr<Request>& req, const std::shared_ptr<Response>& res) {
142 const std::string connectionName = res->getSocketContext()->getSocketConnection()->getConnectionName();
143
144 res->upgrade(req, [req, res, connectionName](const std::string& name) {
145 if (!name.empty()) {
146 VLOG(1) << connectionName << ": Upgrade success:";
147 VLOG(1) << connectionName << ": Requested: " << req->get("upgrade");
148 VLOG(1) << connectionName << ": Selected: " << name;
149
150 res->end();
151 } else {
152 VLOG(1) << connectionName << ": Can not upgrade to any of '" << req->get("upgrade") << "'";
153
154 res->sendStatus(404);
155 }
156 });
157 });
158
159 tlsApp.get("/", [] APPLICATION(req, res) {
160 if (req->url == "/" || req->url == "/index.html") {
161 req->url = "/wstest.html";
162 }
163
164 VLOG(1) << CMAKE_CURRENT_SOURCE_DIR "/html" + req->url;
165 res->sendFile(CMAKE_CURRENT_SOURCE_DIR "/html" + req->url, [req](int ret) {
166 if (ret != 0) {
167 PLOG(ERROR) << req->url;
168 }
169 });
170 });
171
172 tlsApp.listen(
173 [instanceName = tlsApp.getConfig().getInstanceName()](const SocketAddress& socketAddress, const core::socket::State& state) {
174 switch (state) {
176 VLOG(1) << instanceName << " listening on '" << socketAddress.toString() << "'";
177 break;
179 VLOG(1) << instanceName << " disabled";
180 break;
182 VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
183 break;
185 VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
186 break;
187 }
188 });
189
190 VLOG(1) << "Tls Routes:";
191 for (std::string& route : legacyApp.getRoutes()) {
192 route.erase(std::remove(route.begin(), route.end(), '$'), route.end());
193
194 VLOG(1) << " " << route;
195 }
196 }
197
198 return express::WebApp::start();
199}
#define APPLICATION(req, res)
Definition Router.h:68
static constexpr int DISABLED
Definition State.h:56
static constexpr int ERROR
Definition State.h:57
static constexpr int FATAL
Definition State.h:58
static constexpr int OK
Definition State.h:55
static void init(int argc, char *argv[])
Definition WebApp.cpp:56
static int start(const utils::Timeval &timeOut={LONG_MAX, 0})
Definition WebApp.cpp:60
WebAppT< web::http::legacy::in::Server > WebApp
Definition WebApp.h:56
WebAppT< web::http::tls::in::Server > WebApp
Definition WebApp.h:54
SocketClient::SocketAddress SocketAddress

References core::socket::State::DISABLED, express::Response::end(), core::socket::State::ERROR, core::socket::State::FATAL, express::Request::get(), core::socket::Socket< ConfigT >::getConfig(), core::socket::stream::SocketConnection::getConnectionName(), net::config::ConfigInstance::getInstanceName(), express::Router::getRoutes(), core::socket::stream::SocketContext::getSocketConnection(), express::Response::getSocketContext(), express::WebApp::init(), core::socket::stream::SocketServer< SocketAcceptorT, SocketContextFactoryT, Args >::listen(), core::socket::State::OK, express::Response::sendStatus(), express::WebApp::start(), net::in::SocketAddress::toString(), express::Response::upgrade(), express::Request::url, express::WebAppT< ServerT >::WebAppT(), and core::socket::State::what().

Here is the call graph for this function: