first release

Author: EDBCREPO

.gitignore

@@ -0,0 +1,4 @@
+main.cpp
+main
+/www
+.env

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2023 NODEPP
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,58 @@
+# Node++
+
+**Node++** is an innovative open source project that aims to make it easier to create applications in **C++**. This project introduces a high-level abstraction layer that allows developers to write **C++** code in a way that is similar to how they would write code in **NodeJS**. With **Node++**, developers can leverage the advantages of the **C++** language while benefiting from the ease of use and flexibility that **NodeJS** offers. This unique combination of features makes **Node++** a powerful tool for creating high-performance and scalable applications. Additionally, since it is an open source project, anyone can contribute and improve **Node++** to fit their specific needs.
+
+- **uNode++:** compatible with embed devices [here](https://github.com/EDBCREPO/uNODEPP)
+- **Node++:** compatible with PC and esp32  [here](https://github.com/EDBCREPO/NODEPP)
+
+## Dependencies
+- Openssl `sudo apt install libssl-dev`
+- Zlib    `sudo apt install zlib1g-dev`
+
+## Key Features
+
+- Allows writing C++ code as if writing in NodeJS
+- Adds a high-level abstraction layer to simplify C++ application development
+- Includes an event loop that can handle multiple events and tasks on a single thread of execution
+- Supports coroutines, which allows running multiple tasks concurrently on a single thread
+- Includes support for TCP, TLS, UDP, HTTP, and HTTPS, making it easy to create networked applications
+- Includes a regular expression engine for processing and manipulating text strings
+- Compatible with several platforms, including Windows, macOS, Linux, ESP32, and ESP8266
+- Open source project, meaning anyone can contribute and improve it
+- Has extensive documentation and an active community of developers willing to help
+
+## Installation
+
+```bash
+  g++ -o main main.cpp -I ./include ; ./main
+```
+
+## Usage
+
+To use **Node++**, simply include the `node++.h` header file in your project and start writing **C++** code as if you were writing in **NodeJS**. Here's a simple example:
+
+```cpp
+  #include <node++/node++.h>
+
+  using namespace nodepp;
+
+  void _Ready() {
+    console::log("Hello World!");
+  }
+```
+
+Examples - [here](https://github.com/EDBCREPO/NODEPP/tree/main/examples)
+  
+## Contribution
+
+If you want to contribute to **Node++**, you are welcome to do so! You can contribute in several ways:
+
+- Improving the documentation
+- Reporting bugs and issues
+- Adding new features or improving existing ones
+- Writing tests and ensuring compatibility with different platforms
+- Before submitting a pull request, make sure to read the contribution guidelines.
+
+## License
+
+**Node++** is distributed under the MIT License. See the LICENSE file for more details.

examples/AdvanceObserver.cpp

@@ -0,0 +1,26 @@
+#include <node++/node++.h>
+#include <node++/observer.h>
+
+using namespace nodepp;
+
+observer_t obj ({
+    { "string", "hola mundo" },
+    { "int", 10 }
+});
+
+void _Ready() {
+
+    obj.on( "string", []( any_t A, any_t B ){
+        console::log( (string_t) A, "|", (string_t) B );
+    });
+
+    obj.on( "int", []( any_t A, any_t B ){
+        console::log( (int) A, "|", (int) B );
+    });
+
+    obj.set([]( observer_t state ){ return observer_t ({
+        { "string", (string_t) state["string"] + " de mierda" },
+        { "int", (int) state["int"] + 50 }
+    }); });
+
+}

examples/AdvancedHTTPSServer.cpp

@@ -0,0 +1,66 @@
+#include <node++/node++.h>
+#include <node++/https.h>
+#include <node++/timer.h>
+#include <node++/path.h>
+#include <node++/date.h>
+#include <node++/fs.h>
+
+using namespace nodepp;
+
+ssl_t ssl( "./ssl/key.pem", "./ssl/cert.pem" );
+
+void server( int process ){
+
+    auto server = https::server([=]( https_t cli ){ 
+
+        string_t dir = "www/index.html";
+        if( cli.path.size() > 1 )
+            dir = path::join( "www", cli.path );
+
+        console::log( cli.path, process );
+
+        if( !fs::exists_file(dir) ){
+            cli.write_headers( 404, {{ { "content-type", "text/plain" } }} );
+            cli.write( regex::format("404: Oops time: ${0}",date::fulltime()) ); 
+            cli.close(); return;
+        }
+
+        auto str = fs::readable( dir );
+
+        if( cli.headers["Range"].empty() ){
+
+            cli.write_headers( 200, {{
+                { "Content-Length", string::to_string(str.size()) },
+            //  { "Cache-Control", "public, max-age=3600" },
+                { "Content-Type",   path::mimetype(dir) }
+            }});
+
+            if(!regex::test(path::mimetype(dir),"audio|video","i") ) 
+                stream::pipe( str, cli );
+
+        } else if( !cli.headers["Range"].empty() ) {
+
+            array_t<string_t> range = regex::match_all(cli.headers["Range"],"\\d+","i");
+            ulong rang[2]; rang[0] = string::to_ulong( range[0] );
+                  rang[1] = min( rang[0]+CHUNK_MB(10), str.size()-1 );
+
+            cli.write_headers( 206, {{
+                { "Content-Range", regex::format("bytes ${0}-${1}/${2}",rang[0],rang[1],str.size()) },
+                { "Content-Type",  path::mimetype(dir) }, 
+                { "Accept-Range", "bytes" }
+            }});
+            
+            str.set_range( rang[0], rang[1] );
+            stream::pipe( str, cli );
+
+        }
+
+    }, &ssl );
+
+    server.listen( "localhost", 8000, [=]( ssocket_t server ){
+        console::log("server started at https://localhost:8000");
+    });
+
+}
+
+void _Ready() { server( os::pid() ); }

examples/AdvancedHTTPServer.cpp

@@ -0,0 +1,64 @@
+#include <node++/node++.h>
+#include <node++/timer.h>
+#include <node++/http.h>
+#include <node++/path.h>
+#include <node++/date.h>
+#include <node++/fs.h>
+
+using namespace nodepp;
+
+void server( int process ){
+
+    auto server = http::server([=]( http_t cli ){ 
+
+        string_t dir = "www/index.html";
+        if( cli.path.size() > 1 )
+            dir = path::join( "www", cli.path );
+
+        console::log( cli.path, process );
+
+        if( !fs::exists_file(dir) ){
+            cli.write_headers( 404, {{ { "content-type", "text/plain" } }} );
+            cli.write( regex::format("404: Oops time: ${0}",date::fulltime()) ); 
+            cli.close(); return;
+        }
+
+        auto str = fs::readable( dir );
+
+        if( cli.headers["Range"].empty() ){
+
+            cli.write_headers( 200, {{
+                { "Content-Length", string::to_string(str.size()) },
+            //  { "Cache-Control", "public, max-age=3600" },
+                { "Content-Type",   path::mimetype(dir) }
+            }});
+
+            if(!regex::test(path::mimetype(dir),"audio|video","i") ) 
+                stream::pipe( str, cli );
+
+        } else if( !cli.headers["Range"].empty() ) {
+
+            array_t<string_t> range = regex::match_all(cli.headers["Range"],"\\d+","i");
+            ulong rang[2]; rang[0] = string::to_ulong( range[0] );
+                  rang[1] = min( rang[0]+CHUNK_MB(10), str.size()-1 );
+
+            cli.write_headers( 206, {{
+                { "Content-Range", regex::format("bytes ${0}-${1}/${2}",rang[0],rang[1],str.size()) },
+                { "Content-Type",  path::mimetype(dir) }, 
+                { "Accept-Range", "bytes" }
+            }});
+
+            str.set_range( rang[0], rang[1] );
+            stream::pipe( str, cli );
+
+        }
+
+    });
+
+    server.listen( "localhost", 8000, [=]( socket_t server ){
+        console::log("server started at http://localhost:8000");
+    });
+
+}
+
+void _Ready() { server( os::pid() ); }

examples/AdvancedPromises.cpp

@@ -0,0 +1,33 @@
+#include <node++/node++.h>
+#include <node++/promise.h>
+#include <node++/timer.h>
+
+using namespace nodepp;
+
+void _Ready() { 
+
+    auto t = timer::add([](){
+        static int i=0; i++;
+        console::log("new interval",i);
+        return ( i >= 20 ) ? -1 : 1 ;
+    }, 1000 );
+
+    promise::resolve<int>([=]( function_t<void,int> res ){
+        timer::timeout([=](){ res(10); },1000);
+    },[=]( int res ){
+        console::log("first promise resolved:",res);
+    });
+
+    promise::resolve<int>([=]( function_t<void,int> res ){
+        timer::timeout([=](){ res(20); },5000);
+    },[]( int res ){
+        console::log("second promise resolved:",res);
+    });
+
+    promise::resolve<int>([=]( function_t<void,int> res ){
+        timer::timeout([=](){ res(30); },10000);
+    },[]( int res ){
+        console::log("third promise resolved:",res);
+    });
+
+}

examples/AdvancedStreams.cpp

@@ -0,0 +1,20 @@
+#include <node++/node++.h>
+#include <node++/path.h>
+#include <node++/fs.h>
+
+using namespace nodepp;
+
+void _Ready() { 
+    auto _rdb = fs::readable( path::join( process::cwd(), "www", "kloud.mp4" ) );
+    auto _wrt = fs::writable( path::join( process::cwd(), "www", "mojon.mp4" ) );
+
+    _rdb.onData.on([]( string_t chunk ){
+        console::log( chunk.size() );
+    });
+
+    _rdb.onClose.on([](){
+        console::log( "done" );
+    });
+
+    stream::pipe( _rdb, _wrt );
+}

examples/BufferFree.cpp

@@ -0,0 +1,18 @@
+#include <node++/node++.h>
+#include <node++/timer.h>
+
+using namespace nodepp;
+
+void _Ready() {
+
+    ptr_t<int> var = new int(10);
+
+    if( !var.null() ) console::log( *var, &var );
+    else              console::log( "undefined" );
+
+    console::log("free"); var.free();
+
+    if( !var.null() ) console::log( *var, &var );
+    else              console::log( "undefined" );
+
+}

examples/Coroutine.cpp

@@ -0,0 +1,23 @@
+#include <node++/node++.h>
+
+using namespace nodepp;
+
+void _Ready() {
+
+    process::loop::add([=](){ static int itr = 10;
+    _Start
+        while( itr --> 0 ){
+            console::done(" Coroutine 1:",itr); _Yield(1);
+        }
+    _Stop
+    });
+
+    process::loop::add([=](){ static int itr = 10;
+    _Start
+        while( itr --> 0 ){
+            console::error("Coroutine 2:",itr); _Yield(1);
+        }
+    _Stop
+    });
+
+}