SNode.C
Loading...
Searching...
No Matches
echoserver.cpp
Go to the documentation of this file.
1/*
2 * SNode.C - A Slim Toolkit for Network Communication
3 * Copyright (C) Volker Christian <me@vchrist.at>
4 * 2020, 2021, 2022, 2023, 2024, 2025
5 *
6 * This program is free software: you can redistribute it and/or modify
7 * it under the terms of the GNU Lesser General Public License as published
8 * by the Free Software Foundation, either version 3 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU Lesser General Public License for more details.
15 *
16 * You should have received a copy of the GNU Lesser General Public License
17 * along with this program. If not, see <http://www.gnu.org/licenses/>.
18 */
19
20/*
21 * MIT License
22 *
23 * Permission is hereby granted, free of charge, to any person obtaining a copy
24 * of this software and associated documentation files (the "Software"), to deal
25 * in the Software without restriction, including without limitation the rights
26 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
27 * copies of the Software, and to permit persons to whom the Software is
28 * furnished to do so, subject to the following conditions:
29 *
30 * The above copyright notice and this permission notice shall be included in
31 * all copies or substantial portions of the Software.
32 *
33 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
34 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
35 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
36 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
37 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
38 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
39 * THE SOFTWARE.
40 */
41
42#include "express/legacy/in/WebApp.h"
43#include "express/middleware/VerboseRequest.h"
44#include "express/tls/in/WebApp.h"
45
46#ifndef DOXYGEN_SHOULD_SKIP_THIS
47
48#include "log/Logger.h"
49
50#include <algorithm>
51#include <cstring>
52#include <list>
53#include <string>
54
55#endif /* DOXYGEN_SHOULD_SKIP_THIS */
56
57using namespace express;
58
59int main(int argc, char* argv[]) {
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
69 legacyApp.use(express::middleware::VerboseRequest());
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) {
109 case core::socket::State::OK:
110 VLOG(1) << instanceName << " listening on '" << socketAddress.toString() << "'";
111 break;
112 case core::socket::State::DISABLED:
113 VLOG(1) << instanceName << " disabled";
114 break;
115 case core::socket::State::ERROR:
116 VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
117 break;
118 case core::socket::State::FATAL:
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
139 tlsApp.use(express::middleware::VerboseRequest());
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) {
175 case core::socket::State::OK:
176 VLOG(1) << instanceName << " listening on '" << socketAddress.toString() << "'";
177 break;
178 case core::socket::State::DISABLED:
179 VLOG(1) << instanceName << " disabled";
180 break;
181 case core::socket::State::ERROR:
182 VLOG(1) << instanceName << " " << socketAddress.toString() << ": " << state.what();
183 break;
184 case core::socket::State::FATAL:
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}
200
201/*
2022021-05-14 10:21:39 0000000002: accept-encoding: gzip, deflate, br
2032021-05-14 10:21:39 0000000002: accept-language: en-us,en;q=0.9,de-at;q=0.8,de-de;q=0.7,de;q=0.6
2042021-05-14 10:21:39 0000000002: cache-control: no-cache
2052021-05-14 10:21:39 0000000002: connection: upgrade, keep-alive
2062021-05-14 10:21:39 0000000002: host: localhost:8080
2072021-05-14 10:21:39 0000000002: origin: file://
2082021-05-14 10:21:39 0000000002: pragma: no-cache
2092021-05-14 10:21:39 0000000002: sec-websocket-extensions: permessage-deflate; client_max_window_bits
2102021-05-14 10:21:39 0000000002: sec-websocket-key: et6vtby1wwyooittpidflw==
2112021-05-14 10:21:39 0000000002: sec-websocket-version: 13
2122021-05-14 10:21:39 0000000002: upgrade: websocket
2132021-05-14 10:21:39 0000000002: user-agent: mozilla/5.0 (x11; linux x86_64) applewebkit/537.36 (khtml, like gecko)
214chrome/90.0.4430.212 safari/537.36
215*/
#define APPLICATION(req, res)
Definition Router.h:68
Config & getConfig() const
Definition Socket.hpp:60
static constexpr int DISABLED
Definition State.h:56
static constexpr int ERROR
Definition State.h:57
std::string what() const
Definition State.cpp:114
static constexpr int FATAL
Definition State.h:58
static constexpr int OK
Definition State.h:55
const std::string & getConnectionName() const
SocketConnection * getSocketConnection() const
void listen(const std::function< void(const SocketAddress &, core::socket::State)> &onStatus) const
std::string url
Definition Request.h:96
const std::string & get(const std::string &key, int i=0) const
Definition Request.cpp:93
void sendStatus(int state, const std::string &html={})
Definition Response.cpp:91
web::http::server::SocketContext * getSocketContext() const
Definition Response.cpp:64
void upgrade(const std::shared_ptr< Request > &request, const std::function< void(const std::string)> &status)
Definition Response.cpp:169
std::list< std::string > getRoutes() const
Definition Router.cpp:84
WebAppT(const std::string &name)
Definition WebAppT.h:76
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
const std::string & getInstanceName() const
std::string toString(bool expanded=true) const override
int main(int argc, char *argv[])