nodepp-esp32/main.ino at main · NodeppOfficial/nodepp-esp32 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
#include <nodepp.h>
#include <nodepp/wifi.h>
#include <nodepp/http.h>
#include <nodepp/ws.h>

using namespace nodepp;

void server() {

    auto client = queue_t<ws_t>();
    auto server = http::server([=]( http_t cli ){

        cli.write_header( 200, header_t({
            { "content-type", "text/html" }
        }) );

        cli.write( _STRING_(

            <h1> WebSocket Server on ESP32 </h1>
            <div>
                <input type="text" placeholder="message">
                <button submit> send </button>
            </div>
            <div></div>

            <script> window.addEventListener( "load", ()=>{
                var cli = new WebSocket( window.origin.replace( "http", "ws" ) );

                document.querySelector( "[submit]" ).addEventListener("click",()=>{
                    cli.send( document.querySelector("input").value );
                    document.querySelector("input").value = "";
                });

                cli.onmessage = ({data})=>{
                    var el = document.createElement("p");
                        el.innerHTML = data;
                    document.querySelector("div").appendChild( el );
                }

            } ) </script>

        ) );

    }); ws::server( server );

    server.onConnect([=]( ws_t cli ){

        client.push( cli ); auto ID = client.last();
        cli.onData([=]( string_t data ){
            client.map([&]( ws_t cli ){
                cli.write( data );
            }); console::log( "->", data );
        });

        cli.onDrain([=](){
            client.erase( ID );
            console::log( "closed" );
        }); console::log( "connected" );

    });

    process::add( coroutine::add( COROUTINE(){
    coBegin

        while( true ){
            coWait( Serial.available() );
        do {
            auto data = string_t( Serial.readString().c_str() );
        if ( data.empty() ){ break; }
            client.map([&]( ws_t cli ){ cli.write( data ); });
            console::log( "->", data );
        } while(0); coNext; }

    coFinish
    }));

    server.listen( "0.0.0.0", 8000, [=]( socket_t /*unused*/ ){
        console::log( ">> server started" );
    });

}

void onMain() {

    console::enable( 115200 );

    wifi::get_wifi_hal().onAPConnected([=]( ptr_t<uchar> mac ){
        console::log( ">> connected new device" );
    });

    wifi::get_wifi_hal().onAPDisconnected([=]( ptr_t<uchar> mac ){
        console::log( ">> disconencted device" );
    });

    wifi::turn_on();

    wifi::create_wifi_AP( "WIFI_AP", "0123456789", 0 )

    .then([=]( wifi_t device ) { server(); })

    .fail([=](except_t err) {
        console::log( err.what() );
    });

}