SNode.C
Loading...
Searching...
No Matches
testregex.cpp File Reference
#include "database/mariadb/MariaDBClient.h"
#include "express/legacy/in/WebApp.h"
#include "express/tls/in/WebApp.h"
Include dependency graph for testregex.cpp:

Go to the source code of this file.

Functions

Router router (database::mariadb::MariaDBClient &db)
int main (int argc, char *argv[])

Function Documentation

◆ main()

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

Definition at line 269 of file testregex.cpp.

269 {
270 WebApp::init(argc, argv);
271
272 const database::mariadb::MariaDBConnectionDetails details = {
273 .connectionName = "regex",
274 .hostname = "localhost",
275 .username = "snodec",
276 .password = "pentium5",
277 .database = "snodec",
278 .port = 3306,
279 .socket = "/run/mysqld/mysqld.sock",
280 .flags = 0,
281 };
282
283 // CREATE USER 'snodec'@localhost IDENTIFIED BY 'pentium5'
284 // GRANT ALL PRIVILEGES ON *.* TO 'snodec'@localhost
285 // GRANT ALL PRIVILEGES ON 'snodec'.'snodec' TO 'snodec'@localhost
286 // CREATE DATABASE 'snodec';
287 // CREATE TABLE 'snodec' ('username' text NOT NULL, 'password' text NOT NULL ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
288
289 database::mariadb::MariaDBClient db(details, [](const database::mariadb::MariaDBState& state) {
290 if (state.error != 0) {
291 VLOG(0) << "MySQL error: " << state.errorMessage << " [" << state.error << "]";
292 } else if (state.connected) {
293 VLOG(0) << "MySQL connected";
294 } else {
295 VLOG(0) << "MySQL disconnected";
296 }
297 });
298
299 {
300 legacy::in::WebApp legacyApp("legacy-testregex");
301
302 legacyApp.use(router(db));
303
304 legacyApp.listen(8080, [](const legacy::in::WebApp::SocketAddress& socketAddress, const core::socket::State& state) {
305 switch (state) {
306 case core::socket::State::OK:
307 VLOG(1) << "legacy-testregex: listening on '" << socketAddress.toString() << "'";
308 break;
309 case core::socket::State::DISABLED:
310 VLOG(1) << "legacy-testregex: disabled";
311 break;
312 case core::socket::State::ERROR:
313 VLOG(1) << "legacy-testregex: error occurred";
314 break;
315 case core::socket::State::FATAL:
316 VLOG(1) << "legacy-testregex: fatal error occurred";
317 break;
318 }
319 });
320
321 legacyApp.setOnConnect([](legacy::in::WebApp::SocketConnection* socketConnection) {
322 VLOG(1) << "OnConnect:";
323
324 VLOG(1) << "\tServer: " + socketConnection->getRemoteAddress().toString();
325 VLOG(1) << "\tClient: " + socketConnection->getLocalAddress().toString();
326 });
327
328 legacyApp.setOnDisconnect([](legacy::in::WebApp::SocketConnection* socketConnection) {
329 VLOG(1) << "OnDisconnect:";
330
331 VLOG(1) << "\tServer: " + socketConnection->getRemoteAddress().toString();
332 VLOG(1) << "\tClient: " + socketConnection->getLocalAddress().toString();
333 });
334
335 tls::in::WebApp tlsApp("tls-testregex");
336
337 tlsApp.use(legacyApp);
338
339 tlsApp.listen(8088, [](const tls::in::WebApp::SocketAddress& socketAddress, const core::socket::State& state) {
340 switch (state) {
341 case core::socket::State::OK:
342 VLOG(1) << "tls-testregex: listening on '" << socketAddress.toString() << "'";
343 break;
344 case core::socket::State::DISABLED:
345 VLOG(1) << "tls-testregex: disabled";
346 break;
347 case core::socket::State::ERROR:
348 VLOG(1) << "tls-testregex: error occurred";
349 break;
350 case core::socket::State::FATAL:
351 VLOG(1) << "tls-testregex: fatal error occurred";
352 break;
353 }
354 });
355
356 tlsApp.setOnConnect([](tls::in::WebApp::SocketConnection* socketConnection) {
357 VLOG(1) << "OnConnect:";
358
359 VLOG(1) << "\tServer: " + socketConnection->getRemoteAddress().toString();
360 VLOG(1) << "\tClient: " + socketConnection->getLocalAddress().toString();
361 });
362
363 tlsApp.setOnConnected([](tls::in::WebApp::SocketConnection* socketConnection) {
364 VLOG(1) << "OnConnected:";
365
366 X509* client_cert = SSL_get_peer_certificate(socketConnection->getSSL());
367
368 if (client_cert != nullptr) {
369 const long verifyErr = SSL_get_verify_result(socketConnection->getSSL());
370
371 VLOG(1) << "\tClient certificate: " + std::string(X509_verify_cert_error_string(verifyErr));
372
373 char* str = X509_NAME_oneline(X509_get_subject_name(client_cert), nullptr, 0);
374 VLOG(1) << "\t Subject: " + std::string(str);
375 OPENSSL_free(str);
376
377 str = X509_NAME_oneline(X509_get_issuer_name(client_cert), nullptr, 0);
378 VLOG(1) << "\t Issuer: " + std::string(str);
379 OPENSSL_free(str);
380
381 // We could do all sorts of certificate verification stuff here before deallocating the certificate.
382
383 GENERAL_NAMES* subjectAltNames =
384 static_cast<GENERAL_NAMES*>(X509_get_ext_d2i(client_cert, NID_subject_alt_name, nullptr, nullptr));
385
386 const int32_t altNameCount = sk_GENERAL_NAME_num(subjectAltNames);
387
388 VLOG(1) << "\t Subject alternative name count: " << altNameCount;
389 for (int32_t i = 0; i < altNameCount; ++i) {
390 GENERAL_NAME* generalName = sk_GENERAL_NAME_value(subjectAltNames, i);
391 if (generalName->type == GEN_URI) {
392 const std::string subjectAltName =
393 std::string(reinterpret_cast<const char*>(ASN1_STRING_get0_data(generalName->d.uniformResourceIdentifier)),
394 static_cast<std::size_t>(ASN1_STRING_length(generalName->d.uniformResourceIdentifier)));
395 VLOG(1) << "\t SAN (URI): '" + subjectAltName;
396 } else if (generalName->type == GEN_DNS) {
397 const std::string subjectAltName =
398 std::string(reinterpret_cast<const char*>(ASN1_STRING_get0_data(generalName->d.dNSName)),
399 static_cast<std::size_t>(ASN1_STRING_length(generalName->d.dNSName)));
400 VLOG(1) << "\t SAN (DNS): '" + subjectAltName;
401 } else {
402 VLOG(1) << "\t SAN (Type): '" + std::to_string(generalName->type);
403 }
404 }
405
406 sk_GENERAL_NAME_pop_free(subjectAltNames, GENERAL_NAME_free);
407
408 X509_free(client_cert);
409 } else {
410 VLOG(1) << "\tClient certificate: no certificate";
411 }
412 });
413
414 tlsApp.setOnDisconnect([](tls::in::WebApp::SocketConnection* socketConnection) {
415 VLOG(1) << "OnDisconnect:";
416
417 VLOG(1) << "\tServer: " + socketConnection->getRemoteAddress().toString();
418 VLOG(1) << "\tClient: " + socketConnection->getLocalAddress().toString();
419 });
420 }
421
422 return WebApp::start();
423}
core::socket::State::DISABLED
static constexpr int DISABLED
Definition State.h:56
core::socket::State::ERROR
static constexpr int ERROR
Definition State.h:57
core::socket::State::FATAL
static constexpr int FATAL
Definition State.h:58
core::socket::State::OK
static constexpr int OK
Definition State.h:55
express::WebAppT< web::http::legacy::in::Server >::SocketConnection
typename Server::SocketConnection SocketConnection
Definition WebAppT.h:69
express::WebAppT< web::http::legacy::in::Server >::SocketAddress
typename Server::SocketAddress SocketAddress
Definition WebAppT.h:70
express::WebApp::init
static void init(int argc, char *argv[])
Definition WebApp.cpp:56
express::WebApp::start
static int start(const utils::Timeval &timeOut={LONG_MAX, 0})
Definition WebApp.cpp:60
express::legacy::in::WebApp
WebAppT< web::http::legacy::in::Server > WebApp
Definition WebApp.h:56
express::tls::in::WebApp
WebAppT< web::http::tls::in::Server > WebApp
Definition WebApp.h:54
router
Router router(database::mariadb::MariaDBClient &db)
Definition testregex.cpp:68

References database::mariadb::MariaDBState::connected, database::mariadb::MariaDBConnectionDetails::connectionName, database::mariadb::MariaDBConnectionDetails::database, database::mariadb::MariaDBState::error, database::mariadb::MariaDBState::errorMessage, database::mariadb::MariaDBConnectionDetails::flags, database::mariadb::MariaDBConnectionDetails::hostname, database::mariadb::MariaDBConnectionDetails::password, database::mariadb::MariaDBConnectionDetails::port, database::mariadb::MariaDBConnectionDetails::socket, and database::mariadb::MariaDBConnectionDetails::username.

◆ router()

Router router ( database::mariadb::MariaDBClient & db)

Definition at line 68 of file testregex.cpp.

68 {
69 const Router router;
70
71 router.get(R"(/r1/:id([^/]+))", [] APPLICATION(req, res) {
72 std::cout << "Hier 1a ************" << std::endl;
73 std::cout << "Params: " << req->params["id"] << std::endl;
74 res->send("Done\n");
75 });
76
77 router.get(R"(/r1/:id/:subcollection)", [] APPLICATION(req, res) {
78 std::cout << "Hier 1b ************" << std::endl;
79 std::cout << "Params: " << req->params["id"] << std::endl;
80 std::cout << "Params: " << req->params["subcollection"] << std::endl;
81 res->send("Done\n");
82 });
83
84 router.get(R"(/r2/:id)", [] APPLICATION(req, res) {
85 std::cout << "Hier 2a ************" << std::endl;
86 std::cout << "Params: " << req->params["id"] << std::endl;
87 res->send("Done\n");
88 });
89
90 router.get(R"(/r2/:id/:subcollection)", [] APPLICATION(req, res) {
91 std::cout << "Hier 2b ************" << std::endl;
92 std::cout << "Params: " << req->params["id"] << std::endl;
93 std::cout << "Params: " << req->params["subcollection"] << std::endl;
94 res->send("Done\n");
95 });
96
97 router.get("/test/:variable(\\d)/:uri", [] APPLICATION(req, res) { // http://localhost:8080/test/1/urlstring
98 std::cout << "Hier 3 ************" << std::endl;
99 std::cout << "Params: " << req->params["variable"] << std::endl;
100 std::cout << "Params: " << req->params["uri"] << std::endl;
101 res->send("Done\n");
102 });
103
104 router
105 .get(
106 "/query/:userId",
107 [] MIDDLEWARE(req, res, next) {
108 VLOG(1) << "Move on to the next route to query database";
109 next();
110 },
111 [&db] MIDDLEWARE(req, res, next) { // http://localhost:8080/query/123
112 VLOG(1) << "UserId: " << req->params["userId"];
113 std::string userId = req->params["userId"];
114
115 req->setAttribute<std::string, "html-table">(std::string());
116
117 req->getAttribute<std::string, "html-table">([&userId](std::string& table) {
118 table = "<html>\n"
119 " <head>\n"
120 " <title>"
121 "Response from snode.c for " +
122 userId +
123 "\n"
124 " </title>\n"
125 " </head>\n"
126 " <body>\n"
127 " <h1>Return for " +
128 userId +
129 "\n"
130 " </h1>\n"
131 " <body>\n"
132 " <table border = \"1\">\n";
133 });
134
135 int i = 0;
136 db.query(
137 "SELECT * FROM snodec where username = '" + userId + "'",
138 [next, req, i](const MYSQL_ROW row) mutable {
139 if (row != nullptr) {
140 i++;
141 req->getAttribute<std::string, "html-table">([row, &i](std::string& table) {
142 table.append(" <tr>\n"
143 " <td>\n" +
144 std::to_string(i) +
145 "\n"
146 " </td>\n"
147 " <td>\n" +
148 std::string(row[0]) +
149 "\n"
150 " </td>\n"
151 " <td>\n" +
152 row[1] +
153 "\n"
154 " </td>\n"
155 " </tr>\n");
156 });
157 } else {
158 req->getAttribute<std::string, "html-table">([](std::string& table) {
159 table.append(std::string(" </table>\n"
160 " </body>\n"
161 "</html>\n"));
162 });
163 VLOG(1) << "Move on to the next route to send result";
164 next();
165 }
166 },
167 [res, userId](const std::string& errorString, unsigned int errorNumber) {
168 VLOG(1) << "Error: " << errorString << " : " << errorNumber;
169 res->status(404).send(userId + ": " + errorString + " - " + std::to_string(errorNumber));
170 });
171 },
172 [] MIDDLEWARE(req, res, next) {
173 VLOG(1) << "And again 1: Move on to the next route to send result";
174 next();
175 },
176 [] MIDDLEWARE(req, res, next) {
177 VLOG(1) << "And again 2: Move on to the next route to send result";
178 next();
179 })
180 .get([] MIDDLEWARE(req, res, next) {
181 VLOG(1) << "And again 3: Move on to the next route to send result";
182 next();
183 })
184 .get([] APPLICATION(req, res) {
185 VLOG(1) << "SendResult";
186
187 req->getAttribute<std::string, "html-table">(
188 [res](std::string& table) {
189 res->send(table);
190 },
191 [res](const std::string&) {
192 res->end();
193 });
194 });
195 router.get("/account/:userId(\\d*)/:userName", [&db] APPLICATION(req, res) { // http://localhost:8080/account/123/perfectNDSgroup
196 VLOG(1) << "Show account of";
197 VLOG(1) << "UserId: " << req->params["userId"];
198 VLOG(1) << "UserName: " << req->params["userName"];
199
200 const std::string response = "<html>"
201 " <head>"
202 " <title>Response from snode.c</title>"
203 " </head>"
204 " <body>"
205 " <h1>Regex return</h1>"
206 " <ul>"
207 " <li>UserId: " +
208 req->params["userId"] +
209 " </li>"
210 " <li>UserName: " +
211 req->params["userName"] +
212 " </li>"
213 " </ul>"
214 " </body>"
215 "</html>";
216
217 const std::string userId = req->params["userId"];
218 const std::string userName = req->params["userName"];
219
220 db.exec(
221 "INSERT INTO `snodec`(`username`, `password`) VALUES ('" + userId + "','" + userName + "')",
222 [userId, userName]() {
223 VLOG(1) << "Inserted: -> " << userId << " - " << userName;
224 },
225 [](const std::string& errorString, unsigned int errorNumber) {
226 VLOG(1) << "Error: " << errorString << " : " << errorNumber;
227 });
228
229 res->send(response);
230 });
231 router.get("/asdf/:testRegex1(d\\d{3}e)/jklö/:testRegex2", [] APPLICATION(req, res) { // http://localhost:8080/asdf/d123e/jklö/hallo
232 VLOG(1) << "Testing Regex";
233 VLOG(1) << "Regex1: " << req->params["testRegex1"];
234 VLOG(1) << "Regex2: " << req->params["testRegex2"];
235
236 const std::string response = "<html>"
237 " <head>"
238 " <title>Response from snode.c</title>"
239 " </head>"
240 " <body>"
241 " <h1>Regex return</h1>"
242 " <ul>"
243 " <li>Regex 1: " +
244 req->params["testRegex1"] +
245 " </li>"
246 " <li>Regex 2: " +
247 req->params["testRegex2"] +
248 " </li>"
249 " </ul>"
250 " </body>"
251 "</html>";
252
253 res->send(response);
254 });
255 router.get("/search/:search", [] APPLICATION(req, res) { // http://localhost:8080/search/buxtehude123
256 VLOG(1) << "Show Search of";
257 VLOG(1) << "Search: " << req->params["search"];
258 VLOG(1) << "Queries: " << req->query("test");
259
260 res->send(req->params["search"]);
261 });
262 router.use([] APPLICATION(req, res) {
263 res->status(404).send("Not found: " + req->url);
264 });
265
266 return router;
267}
APPLICATION
#define APPLICATION(req, res)
Definition Router.h:68
MIDDLEWARE
#define MIDDLEWARE(req, res, next)
Definition Router.h:63
database::mariadb::MariaDBClientASyncAPI::exec
MariaDBCommandSequence & exec(const std::string &sql, const std::function< void(void)> &onExec, const std::function< void(const std::string &, unsigned int)> &onError)
Definition MariaDBClientASyncAPI.cpp:88
database::mariadb::MariaDBClientASyncAPI::query
MariaDBCommandSequence & query(const std::string &sql, const std::function< void(const MYSQL_ROW)> &onQuery, const std::function< void(const std::string &, unsigned int)> &onError)
Definition MariaDBClientASyncAPI.cpp:66

References database::mariadb::MariaDBClientASyncAPI::exec().

Here is the call graph for this function: