- What is snode.c
- Feature List (not complete)
- Copyright
- Requirements
- Components
- TODOs
- Example Applications
For compilation and installation move forward to Requirements
snode.c (Simple NODE in C++) is a lightweight, highly extendable, high-performance layer-based framework for network applications (servers and clients) in the spirit of node.js written entirely in C++. The development of the framework started during the summer semester 2020 in the context of the course Network and Distributed Systems of the masters program Interactive Media at the departement Informatics, Communications and Media at the University of Applied Sciences Upper Austria, Campus Hagenberg to give students an insight into the fundamental techniques of network and web frameworks. Main focus (but not only) of the framework is "Machine to Machine" (M2M) communication and here especially the field of "Internet of Things" (IoT). Keep in mind, that the framework is still in heavy development, APIs can break from commit to commit. But the highest level API (express) is considered stable.
- Non-blocking, event-driven (asynchronous), single-threaded, single-tasking, layer-based design that supports timer (single-shot, interval) and network communication (TCP/IPv4).
- Application protocol independent TCP server and TCP client functionality. Application protocols (HTTP, ...) can be easily and modularly connected.
- Application protocol independent bluetooth RFCOMM and L2CAP server and client functionality. Application protocols can be easily and modularly connected.
- TLS/SSL encryption for server and client (TCP, RFCOMM).
- Support of X.509 certificates. TLS/SSL connections can be protected and authenticated using certificates (TCP, RFCOMM).
- Fully implemented HTTP(S) application protocol layer (server and client) to which the application logic can be easily connected.
- High-Level Web API layer with JSON support similar to the API of node.js/express. (Speedup compared to node.js/express approx. 40)
GNU Lesser General Public License
- Volker Christian (me_AT_vchrist.at, volker.christian_AT_fh-hagenberg.at)
- Marlene Mayr
- Anna Moser
- Matteo Prock
- Eric Thalhammer
- Joelle Helgert
- Julia Gruber
- Patrick Brandstätter
- Fabian Mohr
- On Debian-Style-Systems run
sudo apt install doxygen iwyu clang-format cmake-format libmagic-dev libbackward-cpp-dev libdw-dev libdwarf-dev binutils-dev librange-v3-dev libssl-dev libeasyloggingpp-dev libbluetooth-dev nlohmann-json3-dev
to install all neccesarry dependencies. - cmake-format
- doxygen
- libeasyloggingpp-dev
- clang-format
- libbackward-cpp-dev
- binutils-dev libdw-dev libunwind-dev
- libbluetooth-dev
- libssl-dev
- nlohmann-json3-dev
- libmagic-dev
- iwyu
- cmake
- libnet (directory net) low level multiplexed network-layer (server/client) with event-loop supporting legacy- and tls-connections
- libhttp (directory http) low level http server and client
- libexpress (directory express) high level web-api similar to node.js's express module
- example applications (directory apps)
- Add better error processing in HTTPResponseParser
- Extend regex-match in Router (path-to-regex in JS)
- Add some more complex example apps (Game, Skill for Alexa, ...)
- Add WebSocket support for server and client, legacy and tls
- Add support for Template-Engines (similar to express)
- Add additional transport protocols (udp, bluetooth, local, ipv6, ...)
- Implement other protocols (contexts) than http (e.g. mqtt, ftp would be interresting, telnet, smtp)
- Finalize cmake-rules to support install
- Add cmake description files
- Add "logical" events
- Support "promisses"
- Add OAUTH2 server/client authentification
- Write unit tests
- Porting snode.c to MS-Windows
- Porting snode.c to macOS
- Add onSSLConnect callback
#include <easylogging++.h>
#include "legacy/WebApp.h"
#include "tls/WebApp.h"
#include "middleware/StaticMiddleware.h"
#define CERTF <PATH_TO_SERVER_CERTIFICATE_CHAIN_FILE>
#define KEYF <PATH_TO_SERVER_CERTIFICATE_KEY_FILE>
#define KEYFPASS <PASSWORD_OF_THE_SERVER_CERTIFICATE_KEY_FILE>
#define SERVERROOT <PATH_TO_ROOT_OF_WEBSITE>
int main(int argc, char* argv[]) {
express::WebApp::init(argc, argv);
express::legacy::WebApp legacyApp;
legacyApp.use(express::middleware::StaticMiddleware(SERVERROOT));
express::tls::WebApp tlsApp({{"certChain", CERTF},
{"keyPEM", KEYF},
{"password", KEYFPASS}});
tlsApp.use(express::middleware::StaticMiddleware(SERVERROOT));
legacyApp.listen(8080, [](int err) -> void {
if (err != 0) {
PLOG(FATAL) << "listen on port 8080";
} else {
VLOG(0) << "snode.c listening on port 8080 for legacy connections";
}
});
tlsApp.listen(8088, [](int err) -> void {
if (err != 0) {
PLOG(FATAL) << "listen on port 8088";
} else {
VLOG(0) << "snode.c listening on port 8088 for SSL/TLS connections";
}
});
return express::WebApp::start();
}
#include <easylogging++.h>
#include "legacy/WebApp.h"
#include "tls/WebApp.h"
#define CERTF <PATH_TO_SERVER_CERTIFICATE_CHAIN_FILE>
#define KEYF <PATH_TO_SERVER_CERTIFICATE_KEY_FILE>
#define KEYFPASS <PASSWORD_OF_THE_SERVER_CERTIFICATE_KEY_FILE>
int main(int argc, char* argv[]) {
express::WebApp::init(argc, argv);
express::legacy::WebApp legacyApp;
legacyApp.get("/", [] APPLICATION(req, res) {
res.send("<html>"
" <head>"
" <style>"
" main {"
" min-height: 30em;"
" padding: 3em;"
" background-image: repeating-radial-gradient( circle at 0 0, #fff, #ddd 50px);"
" }"
" input[type=\"file\"] {"
" display: block;"
" margin: 2em;"
" padding: 2em;"
" border: 1px dotted;"
" }"
" </style>"
" </head>"
" <body>"
" <h1>Datei-Upload mit input type=\"file\"</h1>"
" <main>"
" <h2>Schicken Sie uns was Schickes!</h2>"
" <form method=\"post\" enctype=\"multipart/form-data\">"
" <label> Wählen Sie eine Textdatei (*.txt, *.html usw.) von Ihrem Rechner aus."
" <input name=\"datei\" type=\"file\" size=\"50\" accept=\"text/*\">"
" </label>"
" <button>… und ab geht die Post!</button>"
" </form>"
" </main>"
" </body>"
"</html>");
});
legacyApp.post("/", [] APPLICATION(req, res) {
VLOG(0) << "Content-Type: " << req.header("Content-Type");
VLOG(0) << "Content-Length: " << req.header("Content-Length");
char* body = new char[std::stoul(req.header("Content-Length")) + 1];
memcpy(body, req.body, std::stoul(req.header("Content-Length")));
body[std::stoi(req.header("Content-Length"))] = 0;
VLOG(0) << "Body: ";
VLOG(0) << body;
delete[] body;
res.send("<html>"
" <body>"
" <h1>Thank you</h1>"
" </body>"
"</html>");
});
express::tls::WebApp tlsWebApp({{"certChain", CERTF},
{"keyPEM", KEYF},
{"password", KEYFPASS}});
tlsWebApp.use(legacyApp);
legacyApp.listen(8080, [](int err) {
if (err != 0) {
PLOG(FATAL) << "listen on port 8080";
} else {
VLOG(0) << "snode.c listening on port 8080 for legacy connections";
}
});
tlsWebApp.listen(8088, [](int err) {
if (err != 0) {
PLOG(FATAL) << "listen on port 8088";
} else {
VLOG(0) << "snode.c listening on port 8088 for SSL/TLS connections";
}
});
return express::WebApp::start();
}
#include <easylogging++.h>
#include <openssl/x509v3.h>
#include "legacy/WebApp.h"
#include "tls/WebApp.h"
#include "middleware/StaticMiddleware.h"
#define CERTF <PATH_TO_SERVER_CERTIFICATE_CHAIN_FILE>
#define KEYF <PATH_TO_SERVER_CERTIFICATE_KEY_FILE>
#define KEYFPASS <PASSWORD_OF_THE_SERVER_CERTIFICATE_KEY_FILE>
#define SERVERROOT <PATH_TO_ROOT_OF_WEBSITE>
using namespace express;
Router getRouter() {
Router router;
router.use(middleware::StaticMiddleware(SERVERROOT));
return router;
}
int main(int argc, char** argv) {
WebApp::init(argc, argv);
legacy::WebApp legacyApp(getRouter());
legacyApp.listen(8080, [](int err) {
if (err != 0) {
PLOG(FATAL) << "listen on port 8080";
} else {
VLOG(0) << "snode.c listening on port 8080 for legacy connections";
}
});
legacyApp.onConnect([](core::socket::legacy::SocketConnection* socketConnection) {
VLOG(0) << "OnConnect:";
VLOG(0) << "\tClient: " + socketConnection->getRemoteAddress().host()
+ "(" + socketConnection->getRemoteAddress().ip() + "):"
+ std::to_string(socketConnection->getRemoteAddress().port());
VLOG(0) << "\tServer: " + socketConnection->getLocalAddress().host()
+ "(" + socketConnection->getLocalAddress().ip() + "):"
+ std::to_string(socketConnection->getLocalAddress().port());
});
legacyApp.onDisconnect([](core::socket::legacy::SocketConnection* socketConnection) {
VLOG(0) << "OnDisconnect:";
VLOG(0) << "\tClient: " + socketConnection->getRemoteAddress().host()
+ "(" + socketConnection->getRemoteAddress().ip() + "):"
+ std::to_string(socketConnection->getRemoteAddress().port());
VLOG(0) << "\tServer: " + socketConnection->getLocalAddress().host()
+ "(" + socketConnection->getLocalAddress().ip() + "):"
+ std::to_string(socketConnection->getLocalAddress().port());
});
tls::WebApp tlsApp(getRouter(), {{"certChain", CERTF},
{"keyPEM", KEYF},
{"password", KEYFPASS}});
tlsApp.listen(8088, [](int err) {
if (err != 0) {
PLOG(FATAL) << "listen on port 8088";
} else {
VLOG(0) << "snode.c listening on port 8088 for SSL/TLS connections";
}
});
tlsApp.onConnect([](core::socket::tls::SocketConnection* socketConnection) {
VLOG(0) << "OnConnect:";
VLOG(0) << "\tServer: " + socketConnection->getLocalAddress().host()
+ "(" + socketConnection->getLocalAddress().ip() + "):"
+ std::to_string(socketConnection->getLocalAddress().port());
VLOG(0) << "\tClient: " + socketConnection->getRemoteAddress().host()
+ "(" + socketConnection->getRemoteAddress().ip() + "):"
+ std::to_string(socketConnection->getRemoteAddress().port());
X509* client_cert = SSL_get_peer_certificate(socketConnection->getSSL());
if (client_cert != NULL) {
int verifyErr = SSL_get_verify_result(socketConnection->getSSL());
VLOG(0) << "\tClient certificate: " + std::string(X509_verify_cert_error_string(verifyErr));
char* str = X509_NAME_oneline(X509_get_subject_name(client_cert), 0, 0);
VLOG(0) << "\t Subject: " + std::string(str);
OPENSSL_free(str);
str = X509_NAME_oneline(X509_get_issuer_name(client_cert), 0, 0);
VLOG(0) << "\t Issuer: " + std::string(str);
OPENSSL_free(str);
// We could do all sorts of certificate verification stuff here before deallocating the certificate.
GENERAL_NAMES* subjectAltNames = static_cast<GENERAL_NAMES*>(X509_get_ext_d2i(client_cert, NID_subject_alt_name, NULL, NULL));
int32_t altNameCount = sk_GENERAL_NAME_num(subjectAltNames);
VLOG(0) << "\t Subject alternative name count: " << altNameCount;
for (int32_t i = 0; i < altNameCount; ++i) {
GENERAL_NAME* generalName = sk_GENERAL_NAME_value(subjectAltNames, i);
if (generalName->type == GEN_URI) {
std::string subjectAltName = std::string(reinterpret_cast<const char*> (ASN1_STRING_get0_data(generalName->d.uniformResourceIdentifier)), ASN1_STRING_length(generalName->d.uniformResourceIdentifier));
VLOG(0) << "\t SAN (URI): '" + subjectAltName;
} else if (generalName->type == GEN_DNS) {
std::string subjectAltName = std::string(reinterpret_cast<const char*>(ASN1_STRING_get0_data(generalName->d.dNSName)), ASN1_STRING_length(generalName->d.dNSName));
VLOG(0) << "\t SAN (DNS): '" + subjectAltName;
} else {
VLOG(0) << "\t SAN (Type): '" + std::to_string(generalName->type);
}
}
sk_GENERAL_NAME_pop_free(subjectAltNames, GENERAL_NAME_free);
X509_free(client_cert);
} else {
VLOG(0) << "\tClient certificate: no certificate";
}
});
tlsApp.onDisconnect([](core::socket::tls::SocketConnection* socketConnection) {
VLOG(0) << "OnDisconnect:";
VLOG(0) << "\tServer: " + socketConnection->getLocalAddress().host()
+ "(" + socketConnection->getLocalAddress().ip() + "):"
+ std::to_string(socketConnection->getLocalAddress().port());
VLOG(0) << "\tClient: " + socketConnection->getRemoteAddress().host()
+ "(" + socketConnection->getRemoteAddress().ip() + "):"
+ std::to_string(socketConnection->getRemoteAddress().port());
});
return WebApp::start();
}
#include "legacy/WebApp.h"
#include "tls/WebApp.h"
#include <easylogging++.h>
using namespace express;
Router router() {
Router router;
// http://localhost:8080/account/123/username
router.get("/account/:userId(\\d*)/:username", [] APPLICATION(req, res) {
VLOG(0) << "Show account of";
VLOG(0) << "UserId: " << req.params["userId"];
VLOG(0) << "UserName: " << req.params["userName"];
std::string response = "<html>"
" <head>"
" <title>Response from snode.c</title>"
" </head>"
" <body>"
" <h1>Regex return</h1>"
" <ul>"
" <li>UserId: " + req.params["userId"] + </li>"
" <li>UserName: " + req.params["userName"] + </li>"
" </ul>"
" </body>"
"</html>";
res.send(response);
});
// http://localhost:8080/asdf/d123e/jklm/hallo
router.get("/asdf/:regex1(d\\d{3}e)/jklm/:regex2", [] APPLICATION(req, res) {
VLOG(0) << "Testing Regex";
VLOG(0) << "Regex1: " << req.params["regex1"];
VLOG(0) << "Regex2: " << req.params["regex2"];
std::string response = "<html>"
" <head>"
" <title>Response from snode.c</title>"
" </head>"
" <body>"
" <h1>Regex return</h1>"
" <ul>"
" <li>Regex 1: " + req.params["regex1"] + </li>"
" <li>Regex 2: " + req.params["regex2"] + </li>"
" </ul>"
" </body>"
"</html>";
res.send(response);
});
// http://localhost:8080/search/QueryString
router.get("/search/:search", [] APPLICATION(req, res) {
VLOG(0) << "Show Search of";
VLOG(0) << "Search: " + req.params["search"];
res.send(req.params["search"]);
});
router.use([] APPLICATION(req, res) {
res.status(404).send("Not found: " + req.url);
});
return router;
}