📌 Nodepp | Bug Fixing | V1.3.1 📌

Author: EDBCREPO

README.md

@@ -1,4 +1,11 @@
 # Nodepp
+> **The DOOM of Async Frameworks: Write Once, Build Everywhere, Process Everything.**
+
+[![MIT License](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT)
+[![Platform](https://img.shields.io/badge/platform-Linux%20%7C%20Windows%20%7C%20Arduino%20%7C%20WASM-blue)](https://github.com/NodeppOfficial/nodepp)
+[![Build Status](https://github.com/NodeppOfficial/nodepp/actions/workflows/c-cpp.yml/badge.svg)](https://github.com/NodeppOfficial/nodepp/actions)
+
+Nodepp is a groundbreaking open-source project that simplifies C++ application development by bridging the gap between the language's raw power and the developer-friendly abstractions of Node.js.
 
 Nodepp is a groundbreaking open-source project that simplifies C++ application development by bridging the gap between the language's raw power and the developer-friendly abstractions of Node.js. By providing a high-level API, Nodepp empowers developers to write C++ code in a familiar, Node.js-inspired style.
 
@@ -40,17 +47,31 @@ target_link_libraries( #[...]
 - 📌: **Scalability:** Build applications that can handle large workloads and grow with your needs.
 - 📌: **Open-source:** Contribute to the project's development and customize it to your specific requirements.
 
-## Bateries Included
+## Projects made with NodePP
+
+- 🔗: [Computer Vision VR Controllers for phones Demo](https://github.com/PocketVR/Barely_VR_AR_Controller_Test)
+- 🔗: [Draw on your PC using your smartphone](https://github.com/ScreenDraw/PCDraw)
+- 🔗: [Simple multiplayer Game With Raylib](https://medium.com/@EDBCBlog/create-your-own-online-multiplayer-small-fast-and-fun-with-raylib-nodepp-and-websockets-190f5c174094)
+- 🔗: [Cursed Luna - A simple Raylib Game](https://github.com/EDBCREPO/Space-Shocker)
+- 🔗: [Smart Card Reader(Nodepp-Arduino)](https://github.com/EDBCREPO/emv-reader)
+- 🔗: [Serial Port arduino using Nodepp](https://github.com/EDBCREPO/Arduino_PC)
+- 🔗: [Simple Raylib Real-Time Chat](https://github.com/EDBCREPO/simple-raylib-websocket-chat)
+- 🔗: [Simple Bitget Trading Bot](https://github.com/EDBCREPO/simple-binance-bot-nodepp)
+
+Check out some articles on [Medium](https://medium.com/@EDBCBlog)
+
+## Batteries Included
 
 - 📌: Include a **build-in JSON** parser / stringify system.
 - 📌: Include a **build-in RegExp** engine for processing text strings.
-- 📌: Include Support for **UTF** manipulation | **UTF8 - UTF16 - UTF32**
+- 📌: Include support for **UTF** manipulation | **UTF8 - UTF16 - UTF32**
 - 📌: Include a **build-in System** that make every object **Async Task** safety.
 - 📌: Include a **Smart Pointer** base **Garbage Collector** to avoid **Memory Leaks**.
 - 📌: Include support for **Reactive Programming** based on **Events** and **Observers**.
 - 📌: Include an **Event Loop** that can handle multiple events and tasks on a single thread.
 - 📌: Include support for **TCP | TLS | UDP | HTTP | WS** making it easy to create networked applications.
-- 📌: Include Support for **Poll | Epoll | Kqueue | WSAPoll** making it easy to handle multiple file descriptors.
+- 📌: Include support for **Poll | Epoll | Kqueue | WSAPoll** making it easy to handle multiple file descriptors.
+- 📌: Include support for **Worker isolated event-loop** making it easy to create distributed self-contained event-loops.
 
 ## Build & Run
 ```bash
@@ -160,6 +181,47 @@ void onMain(){
 }
 ```
 
+### Worker Isolated Event-Loop
+```cpp
+#include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
+#include <nodepp/os.h>
+
+using namespace nodepp;
+
+atomic_t<int> shared_variable = 100;
+
+void local_main( int cpu_id ){
+
+    // this event-loop runs in it's own isolated worker-thread
+    
+    process::add( coroutine::add( COROUTINE(){
+        thread_local static int variable;
+    //  this will create a static variable per thread
+        static atomic_t<int> shared_variable;
+    //  this will create a shared global variable
+        int local_variable;
+    //  this is a normal variable only exists here
+    coBegin
+
+        while( shared_variable-->0 ){
+            console::log( cpu_id, "->", shared_variable.get() );
+        coDelay(1000); }
+
+    coFinish
+    }));
+
+}
+
+void onMain(){
+
+    for( auto x=os::cpus(); x-->0; ){ worker::add([=](){
+         local_main( x ); process::wait();
+    return -1; }); }
+
+}
+```
+
 ### More Examples [here](https://nodeppofficial.github.io/nodepp-doc/guide.html)
 
 ## Installing Nodepp
@@ -197,18 +259,6 @@ void onMain() {
 - 🔗: [NodePP for Arduino](https://github.com/NodeppOfficial/nodepp-arduino)
 - 🔗: [Nodepp for WASM](https://github.com/NodeppOfficial/nodepp-wasm)
 
-## Projects made with NodePP
-- 🔗: [Computer Vision VR Controllers for phones Demo](https://github.com/PocketVR/Barely_VR_AR_Controller_Test)
-- 🔗: [Draw on your PC using your smartphone](https://github.com/ScreenDraw/PCDraw)
-- 🔗: [Simple multiplayer Game With Raylib](https://medium.com/@EDBCBlog/create-your-own-online-multiplayer-small-fast-and-fun-with-raylib-nodepp-and-websockets-190f5c174094)
-- 🔗: [Cursed Luna - A simple Raylib Game](https://github.com/EDBCREPO/Space-Shocker)
-- 🔗: [Smart Card Reader(Nodepp-Arduino)](https://github.com/EDBCREPO/emv-reader)
-- 🔗: [Serial Port arduino using Nodepp](https://github.com/EDBCREPO/Arduino_PC)
-- 🔗: [Simple Raylib Real-Time Chat](https://github.com/EDBCREPO/simple-raylib-websocket-chat)
-- 🔗: [Simple Bitget Trading Bot](https://github.com/EDBCREPO/simple-binance-bot-nodepp)
-
-Check out some articles on [Medium](https://medium.com/@EDBCBlog)
-
 ## Official Libraries for Nodepp
 - 🔗: [ExpressPP](https://github.com/NodeppOfficial/nodepp-express)   -> Express equivalent for Nodepp
 - 🔗: [ApifyPP](https://github.com/NodeppOfficial/nodepp-apify)       -> Socket.io equivalent for Nodepp

examples/35-WS-Client.cpp

@@ -8,27 +8,19 @@ using namespace nodepp;
 void onMain() {
 
     auto client = ws::client( "ws://localhost:8000/" );
-    auto cin    = fs::std_input();
 
     client.onConnect([=]( ws_t cli ){ 
 
         console::log("connected", cli.get_peername() );
 
-        cli.onData([]( string_t chunk ){ 
-            console::log("client:>",chunk); 
+        cli.onData([]( string_t data ){ 
+            console::log( data ); 
         });
 
-        cin.onData([=]( string_t data ){
-            cli.write( data );
-        });
-
         cli.onDrain([=](){ 
             console::log("closed"); 
-            cin.close();
         });
 
-        stream::pipe( cin );
-
     });
 
     client.onError([=]( except_t err ){

examples/37-WSS-Client.cpp

@@ -10,27 +10,19 @@ void onMain() {
     ssl_t ssl; //ssl_t ssl( "./ssl/cert.key", "./ssl/cert.crt" );
 
     auto client = wss::client( "wss://localhost:8000/", &ssl );
-    auto cin    = fs::std_input();
 
     client.onConnect([=]( wss_t cli ){ 
 
         console::log("connected"); 
 
-        cli.onData([]( string_t chunk ){ 
-            console::log("client:>",chunk); 
+        cli.onData([]( string_t data ){ 
+            console::log( data ); 
         });
 
-        cin.onData([=]( string_t data ){
-            cli.write( data );
-        });
-
         cli.onDrain([=](){ 
             console::log("closed"); 
-            cin.close();
         });
 
-        stream::pipe( cin );
-
     });
 
     client.onError([=]( except_t err ){

examples/38-WS.cpp

@@ -21,24 +21,17 @@ void server(){
 
     server.onConnect([=]( ws_t cli ){
 
-        auto cin = fs::std_input();
         console::log("connected");
 
-        cin.onData([=]( string_t data ){
-            cli.write( data );
-        });
-
         cli.onData([=]( string_t data ){
-            console::log( "serv:", data );
+            cli.write( "<: received" );
+            console::log( data );
         });
 
         cli.onDrain([=](){ 
             console::log("closed"); 
-            cin.close();
         });
 
-        stream::pipe( cin );
-
     });
 
     server.listen( "localhost", 8000, [=]( socket_t server ){
@@ -56,8 +49,8 @@ void client() {
         auto cin = fs::std_input();
         console::log("connected");
 
-        cli.onData([]( string_t chunk ){ 
-            console::log("cli:", chunk); 
+        cli.onData([]( string_t data ){ 
+            console::log( data ); 
         });
 
         cin.onData([=]( string_t data ){

examples/38-WSS.cpp

@@ -23,24 +23,17 @@ void server(){
 
     server.onConnect([=]( wss_t cli ){
 
-        auto cin = fs::std_input();
         console::log("connected");
 
-        cin.onData([=]( string_t data ){
-            cli.write( data );
-        });
-
         cli.onData([=]( string_t data ){
-            console::log( "serv:", data );
+            cli.write( "<: received" );
+            console::log( data );
         });
 
         cli.onDrain([=](){ 
             console::log("closed"); 
-            cin.close();
         });
 
-        stream::pipe( cin );
-
     });
 
     server.listen( "localhost", 8000, [=]( ssocket_t server ){
@@ -60,8 +53,8 @@ void client() {
         auto cin = fs::std_input();
         console::log("connected"); 
 
-        cli.onData([]( string_t chunk ){ 
-            console::log("cli:", chunk); 
+        cli.onData([]( string_t data ){ 
+            console::log( data ); 
         });
 
         cin.onData([=]( string_t data ){

examples/45-TCPClient.cpp

@@ -11,23 +11,16 @@ void onMain(){
     client.onOpen([=]( socket_t cli ){
 
         console::log("connected", cli.get_peername() );
-        auto cin = fs::std_input();
 
         cli.onData([=]( string_t data ){
             console::log( data );
         });
 
-        cin.onData([=]( string_t data ){
-            cli.write( data );
-        });
-
         cli.onClose.once([=](){
             console::log("closed");
-            cin.close();
         });
 
         stream::pipe( cli );
-        stream::pipe( cin );
 
     });
 

examples/46-TCP.cpp

@@ -11,23 +11,17 @@ void server(){
     server.onConnect([=]( socket_t cli ){
 
         console::log("connected" );
-        auto cin = fs::std_input();
 
         cli.onData([=]( string_t data ){
+            cli.write( "<: received" );
             console::log( data );
         });
 
-        cin.onData([=]( string_t data ){
-            cli.write( data );
-        });
-
         cli.onDrain.once([=](){
             console::log("closed");
-            cin.close();
         });
 
         stream::pipe( cli );
-        stream::pipe( cin );
 
     });
 

examples/46-TCPServer.cpp

@@ -11,23 +11,16 @@ void onMain(){
     server.onConnect([=]( socket_t cli ){
 
         console::log("connected", cli.get_peername() );
-        auto cin = fs::std_input();
 
         cli.onData([=]( string_t data ){
             console::log( data );
         });
 
-        cin.onData([=]( string_t data ){
-            cli.write( data );
-        });
-
         cli.onDrain.once([=](){
             console::log("closed");
-            cin.close();
         });
 
         stream::pipe( cli );
-        stream::pipe( cin );
 
     });
 

examples/47-UDPClient.cpp

@@ -11,23 +11,16 @@ void onMain(){
     client.onConnect([=]( socket_t cli ){
 
         console::log("connected", cli.get_peername() );
-        auto cin = fs::std_input();
 
         cli.onData([=]( string_t data ){
             console::log( data );
         });
 
-        cin.onData([=]( string_t data ){
-            cli.write( data );
-        });
-
         cli.onDrain.once([=](){
             console::log("closed");
-            cin.close();
         });
 
         stream::pipe( cli );
-        stream::pipe( cin );
 
     });
 

examples/48-UDP.cpp

@@ -11,23 +11,17 @@ void server(){
     server.onConnect([=]( socket_t cli ){
 
         console::log("connected" );
-        auto cin = fs::std_input();
 
         cli.onData([=]( string_t data ){
+            cli.write( "<: received" );
             console::log( data );
         });
 
-        cin.onData([=]( string_t data ){
-            cli.write( data );
-        });
-
         cli.onDrain.once([=](){
             console::log("closed");
-            cin.close();
         });
 
         stream::pipe( cli );
-        stream::pipe( cin );
 
     });