/* We simply call the root header file "App.h", giving you uWS::App and uWS::SSLApp */ #include "App.h" /* This is a simple WebSocket "async" upgrade example. * You may compile it with "WITH_OPENSSL=1 make" or with "make" */ int main() { /* ws->getUserData returns one of these */ struct PerSocketData { /* Define your user data */ int something; }; /* Keep in mind that uWS::SSLApp({options}) is the same as uWS::App() when compiled without SSL support. * You may swap to using uWS:App() if you don't need SSL */ uWS::SSLApp({ /* There are example certificates in uWebSockets.js repo */ .key_file_name = "misc/key.pem", .cert_file_name = "misc/cert.pem", .passphrase = "1234" }).ws("/*", { /* Settings */ .compression = uWS::SHARED_COMPRESSOR, .maxPayloadLength = 16 * 1024, .idleTimeout = 10, .maxBackpressure = 1 * 1024 * 1024, /* Handlers */ .upgrade = [](auto *res, auto *req, auto *context) { /* HttpRequest (req) is only valid in this very callback, so we must COPY the headers * we need later on while upgrading to WebSocket. You must not access req after first return. * Here we create a heap allocated struct holding everything we will need later on. */ struct UpgradeData { std::string secWebSocketKey; std::string secWebSocketProtocol; std::string secWebSocketExtensions; struct us_socket_context_t *context; decltype(res) httpRes; bool aborted = false; } *upgradeData = new UpgradeData { std::string(req->getHeader("sec-websocket-key")), std::string(req->getHeader("sec-websocket-protocol")), std::string(req->getHeader("sec-websocket-extensions")), context, res }; /* We have to attach an abort handler for us to be aware * of disconnections while we perform async tasks */ res->onAborted([=]() { /* We don't implement any kind of cancellation here, * so simply flag us as aborted */ upgradeData->aborted = true; std::cout << "HTTP socket was closed before we upgraded it!" << std::endl; }); /* Simulate checking auth for 5 seconds. This looks like crap, never write * code that utilize us_timer_t like this; they are high-cost and should * not be created and destroyed more than rarely! * * Also note that the code would be a lot simpler with capturing lambdas, maybe your * database client has such a nice interface? Either way, here we go!*/ struct us_loop_t *loop = (struct us_loop_t *) uWS::Loop::get(); struct us_timer_t *delayTimer = us_create_timer(loop, 0, sizeof(UpgradeData *)); memcpy(us_timer_ext(delayTimer), &upgradeData, sizeof(UpgradeData *)); us_timer_set(delayTimer, [](struct us_timer_t *t) { /* We wrote the upgradeData pointer to the timer's extension */ UpgradeData *upgradeData; memcpy(&upgradeData, us_timer_ext(t), sizeof(UpgradeData *)); /* Were'nt we aborted before our async task finished? Okay, upgrade then! */ if (!upgradeData->aborted) { std::cout << "Async task done, upgrading to WebSocket now!" << std::endl; /* If you don't want to upgrade you can instead respond with custom HTTP here, * such as res->writeStatus(...)->writeHeader(...)->end(...); or similar.*/ /* This call will immediately emit .open event */ upgradeData->httpRes->template upgrade({ /* We initialize PerSocketData struct here */ .something = 13 }, upgradeData->secWebSocketKey, upgradeData->secWebSocketProtocol, upgradeData->secWebSocketExtensions, upgradeData->context); } else { std::cout << "Async task done, but the HTTP socket was closed. Skipping upgrade to WebSocket!" << std::endl; } delete upgradeData; us_timer_close(t); }, 5000, 0); }, .open = [](auto *ws) { /* Open event here, you may access ws->getUserData() which points to a PerSocketData struct. * Here we simply validate that indeed, something == 13 as set in upgrade handler. */ std::cout << "Something is: " << static_cast(ws->getUserData())->something << std::endl; }, .message = [](auto *ws, std::string_view message, uWS::OpCode opCode) { /* We simply echo whatever data we get */ ws->send(message, opCode); }, .drain = [](auto */*ws*/) { /* Check ws->getBufferedAmount() here */ }, .ping = [](auto */*ws*/, std::string_view) { /* You don't need to handle this one, we automatically respond to pings as per standard */ }, .pong = [](auto */*ws*/, std::string_view) { /* You don't need to handle this one either */ }, .close = [](auto */*ws*/, int /*code*/, std::string_view /*message*/) { /* You may access ws->getUserData() here, but sending or * doing any kind of I/O with the socket is not valid. */ } }).listen(9001, [](auto *listen_socket) { if (listen_socket) { std::cout << "Listening on port " << 9001 << std::endl; } }).run(); } tion value='jarred/async_bio'>jarred/async_bio Unnamed repository; edit this file 'description' to name the repository.
aboutsummaryrefslogtreecommitdiff
path: root/integration/bunjs-only-snippets/bundled (unfollow)
AgeCommit message (Expand)AuthorFilesLines
2022-05-16Update README.mdGravatar Jarred Sumner 1-34/+34
2022-05-16Update README.mdGravatar Jarred Sumner 1-27/+90
2022-05-16Update README.mdGravatar Jarred Sumner 1-3/+3
2022-05-16Update README.mdGravatar Jarred Sumner 1-19/+17
2022-05-16Update README.mdGravatar Jarred Sumner 1-1/+1
2022-05-16`bun:sqlite` (#167)Gravatar Jarred Sumner 52-136/+258362
2022-05-16Add go and esbuild to build instructions (#169)Gravatar Divy Srivastava 2-1/+2
2022-05-12wrangler 2 released (#166)Gravatar Hugo Romano 1-1/+1
2022-05-11Update README.mdGravatar Jarred Sumner 1-1/+1
2022-05-11Update README.mdGravatar Jarred Sumner 1-2/+3
2022-05-11Add section about napiGravatar Jarred Sumner 1-0/+37
2022-05-11Update README.mdbun-v0.0.82Gravatar Jarred Sumner 1-2/+6
2022-05-11Update build-idGravatar Jarred Sumner 1-1/+1
2022-05-11Fix several bugs in napiGravatar Jarred Sumner 3-22/+54
2022-05-11Make the napi mjs file runnable in both bun & nodeGravatar Jarred Sumner 1-7/+6
2022-05-11Update build-idbun-v0.0.81Gravatar Jarred Sumner 1-1/+1
2022-05-11disable the new target allowed errorGravatar Jarred Sumner 1-4/+5
2022-05-11Update Makefilebun-v0.0.80Gravatar Jarred Sumner 1-0/+1
2022-05-11Update MakefileGravatar Jarred Sumner 1-1/+1
2022-05-11Fix export symbols on LinuxGravatar Jarred Sumner 4-25/+153
2022-05-11Add test for import.meta.requireGravatar Jarred Sumner 2-1/+11
2022-05-11[napi] Add a couple more symbolsGravatar Jarred Sumner 1-0/+2
2022-05-11[napi] Fix panic inside napi_fatal_errorGravatar Jarred Sumner 1-11/+18
2022-05-11[napi] Stub a couple moreGravatar Jarred Sumner 3-6/+52
2022-05-11[bun.js] eagerly convert to import.meta.requireGravatar Jarred Sumner 2-3/+24
2022-05-11[json] Fix bug with negative integers in json parserGravatar Jarred Sumner 1-3/+6
2022-05-11[bun.js] Implement a polyfill for the `detect-libc` npm packageGravatar Jarred Sumner 2-0/+53
2022-05-11[bun.js] Implement `import.meta.require`Gravatar Jarred Sumner 13-158/+539
2022-05-11[bun.js] Implement `import.meta.resolveSync`Gravatar Jarred Sumner 3-1/+78
2022-05-10Include napi in plus100Gravatar Jarred Sumner 1-4/+20
2022-05-10Add test for Buffer.byteLengthGravatar Jarred Sumner 1-0/+7
2022-05-10[napi] Error on import .nodeGravatar Jarred Sumner 1-29/+1
2022-05-10Update napi.cppGravatar Jarred Sumner 1-1/+0
2022-05-10[napi] Fix string bugGravatar Jarred Sumner 4-58/+125
2022-05-10[napi] transpile require(*.node) into process.dlopenGravatar Jarred Sumner 4-3/+30
2022-05-10[bun.js] Implement `Buffer.byteLength`Gravatar Jarred Sumner 7-47/+443
2022-05-09Fix extra quote in bundled require errorsGravatar Jarred Sumner 1-2/+2
2022-05-09few more napi functionsGravatar Jarred Sumner 2-1/+30
2022-05-09Update MakefileGravatar Jarred Sumner 1-3/+3
2022-05-09Update Dockerfile.baseGravatar Jarred Sumner 1-1/+1
2022-05-09[napi] getters & setters workGravatar Jarred Sumner 1-26/+39