Version 2.9.0-beta11

Author: arjenhiemstra

compiled_firmware_files/firmware.json

@@ -9,17 +9,17 @@
         "2": {
             "latest_fw": "2.8.0",
             "link": "https://github.com/arjenhiemstra/ithowifi/raw/master/compiled_firmware_files/unified_hw2_noncve/nrgitho-v2.8.0.bin",
-            "latest_beta_fw": "2.9.0-beta10",
-            "link_beta": "https://github.com/arjenhiemstra/ithowifi/raw/master/compiled_firmware_files/unified_hw2_noncve/nrgitho-v2.9.0-beta10.bin",
-            "beta_release_notes": "https://github.com/arjenhiemstra/ithowifi/releases/tag/Version-2.9.0-beta10",
+            "latest_beta_fw": "2.9.0-beta11",
+            "link_beta": "https://github.com/arjenhiemstra/ithowifi/raw/master/compiled_firmware_files/unified_hw2_noncve/nrgitho-v2.9.0-beta11.bin",
+            "beta_release_notes": "https://github.com/arjenhiemstra/ithowifi/releases/tag/Version-2.9.0-beta11",
             "release_notes": "https://github.com/arjenhiemstra/ithowifi/releases/tag/Version-2.8.0"
         },
         "NON-CVE 1": {
             "latest_fw": "2.8.0",
             "link": "https://github.com/arjenhiemstra/ithowifi/raw/master/compiled_firmware_files/unified_hw2_noncve/nrgitho-v2.8.0.bin",
-            "latest_beta_fw": "2.9.0-beta10",
-            "link_beta": "https://github.com/arjenhiemstra/ithowifi/raw/master/compiled_firmware_files/unified_hw2_noncve/nrgitho-v2.9.0-beta10.bin",
-            "beta_release_notes": "https://github.com/arjenhiemstra/ithowifi/releases/tag/Version-2.9.0-beta10",
+            "latest_beta_fw": "2.9.0-beta11",
+            "link_beta": "https://github.com/arjenhiemstra/ithowifi/raw/master/compiled_firmware_files/unified_hw2_noncve/nrgitho-v2.9.0-beta11.bin",
+            "beta_release_notes": "https://github.com/arjenhiemstra/ithowifi/releases/tag/Version-2.9.0-beta11",
             "release_notes": "https://github.com/arjenhiemstra/ithowifi/releases/tag/Version-2.8.0"
         }
     }

compiled_firmware_files/unified_hw2_noncve/elf/nrgitho-v2.9.0-beta11.elf

@@ -4,6 +4,6 @@ dependencies:
     source:
       type: idf
     version: 4.4.7
-manifest_hash: e70ff19af7538c977dc9cd554f833f2d8783fe23418b97944d4714cd0f5d4039
+manifest_hash: 22fd7a5abc2cf92591f6ecc9e649f4d0f0f79afd775d7c4813993d231381ec1c
 target: esp32
 version: 1.0.0

compiled_firmware_files/unified_hw2_noncve/nrgitho-v2.9.0-beta11.bin

@@ -1,3 +1,3 @@
 #pragma once
 
-inline const char * fw_version = "2.9.0-beta10";
+inline const char * fw_version = "2.9.0-beta11";

software/NRG_itho_wifi/dependencies.lock

@@ -12,32 +12,37 @@ default_envs =
 [env]
 ; Global data for all [env:***]
 build_flags =
-  -D VERSION=2.9.0-beta10
+  -D VERSION=2.9.0-beta11
 ;upload_port = /dev/cu.usbserial-1410 #optional, only needed if PlatformIO autodetect is not working
 ;monitor_port = /dev/cu.usbserial-1410 #optional, only needed if PlatformIO autodetect is not working
-platform = platformio/espressif32 @ ~6.9.0
+platform = platformio/espressif32 @ ~6.10.0
 ;platform = https://github.com/pioarduino/platform-espressif32/releases/download/53.03.10/platform-espressif32.zip
 framework = arduino, espidf
 ; board_build.embed_txtfiles =
 ;     managed_components/espressif__esp_insights/server_certs/https_server.crt
 ;     managed_components/espressif__esp_rainmaker/server_certs/rmaker_mqtt_server.crt
 ;     managed_components/espressif__esp_rainmaker/server_certs/rmaker_claim_service_server.crt
 ;     managed_components/espressif__esp_rainmaker/server_certs/rmaker_ota_server.crt
+
 lib_ldf_mode = chain+
 monitor_speed = 115200
 lib_deps =
     https://github.com/bblanchon/ArduinoStreamUtils.git#v1.9.0
-    https://github.com/bblanchon/ArduinoJson.git#v7.2.1
+    https://github.com/bblanchon/ArduinoJson.git#v7.4.1
     https://github.com/thijse/Arduino-Log.git#1.1.1
-    https://github.com/mathieucarbou/AsyncTCP.git#v3.3.1
-    https://github.com/mathieucarbou/ESPAsyncWebServer.git#v3.4.5
+    https://github.com/ESP32Async/AsyncTCP.git#v3.3.8
+    https://github.com/ESP32Async/ESPAsyncWebServer.git#v3.7.6
+    https://github.com/mathieucarbou/MycilaWebSerial#v8.1.1
     https://github.com/jclds139/FS_FilePrint.git#a8b3bae397ce918c49be112c034a0fcbbc5c24fd
     https://github.com/arjenhiemstra/pubsubclient.git#3c7c4a89df6536cc52a3962cd0b76b0bfc8f5818
     https://github.com/arcao/Syslog#e9c2eea7a91fdda3a55f9df2ebc122f3152da02d
     https://github.com/arjenhiemstra/ArduinoNvs.git
-    https://github.com/joltwallet/esp_littlefs.git#v1.14.8
+    https://github.com/joltwallet/esp_littlefs.git#v1.16.1
     ;https://github.com/jgromes/RadioLib.git#6.4.2
 
+lib_ignore =
+    LittleFS
+    
 [project_base]
 board_build.filesystem = littlefs
 board_build.partitions = ithowifi_parttable_coredump.csv

software/NRG_itho_wifi/main/version.h

@@ -0,0 +1,168 @@
+// SPDX-License-Identifier: LGPL-3.0-or-later
+// Copyright 2016-2025 Hristo Gochkov, Mathieu Carbou, Emil Muratov
+
+/*
+  This example demonstrates how to send data to a remote server asynchronously.
+  Run on the remote computer: nc -l -p 1234
+
+  You should see in the logs:
+
+Connected!
+Will send 5760 bytes...
+Acked 1436 bytes in 19 ms
+Will send 1436 bytes...
+Acked 1436 bytes in 2 ms
+Will send 996 bytes...
+Waiting for acks...
+Acked 1436 bytes in 1 ms
+Acked 1436 bytes in 5 ms
+Acked 1452 bytes in 17 ms
+Acked 996 bytes in 28 ms
+Buffer received - next send in 2 sec
+Will send 5760 bytes...
+Acked 1436 bytes in 14 ms
+Will send 1436 bytes...
+Acked 1436 bytes in 2 ms
+Acked 1436 bytes in 0 ms
+Acked 1452 bytes in 1 ms
+Will send 996 bytes...
+Waiting for acks...
+Acked 1436 bytes in 3 ms
+Acked 996 bytes in 18 ms
+Buffer received - next send in 2 sec
+
+  And in the remote terminal 3072 characters sent [.........  ...........] and so on.
+*/
+
+#include <Arduino.h>
+#include <AsyncTCP.h>
+#include <StreamString.h>
+#include <WiFi.h>
+
+#include <functional>
+#include <string>
+
+#define WIFI_SSID     "IoT"
+#define WIFI_PASSWORD ""
+
+#define REMOTE_IP   "192.168.125.116"
+#define REMOTE_PORT 1234
+
+#define BUFFER_SIZE 8 * 1024
+
+static char buffer[BUFFER_SIZE] = {0};
+static size_t bufferPos = 0;
+
+// 0 == disconnected
+// 1 == connecting
+// 2 == connected
+static uint8_t state = 0;
+
+// number of bytes waiting for a ack
+static size_t waitingAck = 0;
+
+static AsyncClient client;
+
+void setup() {
+  Serial.begin(115200);
+  while (!Serial) {
+    continue;
+  }
+
+  // connect to WiFi
+  WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
+  while (WiFi.status() != WL_CONNECTED) {
+    delay(500);
+  }
+  Serial.println("Connected to WiFi!");
+  Serial.println(WiFi.localIP());
+
+  // fill buffer
+  buffer[0] = '[';
+  for (size_t i = 1; i < BUFFER_SIZE - 1; i++) {
+    buffer[i] = '.';
+  }
+  buffer[BUFFER_SIZE - 1] = ']';
+
+  // register a callback when the client disconnects
+  client.onDisconnect([](void *arg, AsyncClient *client) {
+    Serial.printf("Disconnected.\n");
+    state = 0;
+  });
+
+  // register a callback when an error occurs
+  client.onError([](void *arg, AsyncClient *client, int8_t error) {
+    Serial.printf("Error: %s\n", client->errorToString(error));
+  });
+
+  // register a callback when data arrives, to accumulate it
+  client.onData([](void *arg, AsyncClient *client, void *data, size_t len) {
+    Serial.printf("Received %u bytes...\n", len);
+    Serial.write((uint8_t *)data, len);
+  });
+
+  // register a callback when we are connected
+  client.onConnect([](void *arg, AsyncClient *client) {
+    Serial.printf("Connected!\n");
+    state = 2;
+  });
+
+  client.onAck([](void *arg, AsyncClient *client, size_t len, uint32_t time) {
+    Serial.printf("Acked %u bytes in %" PRIu32 " ms\n", len, time);
+    assert(waitingAck >= len);
+    waitingAck -= len;
+  });
+
+  client.setRxTimeout(20000);
+  client.setNoDelay(true);
+}
+
+void loop() {
+  switch (state) {
+    case 0:
+    {
+      Serial.printf("Connecting...\n");
+      if (!client.connect(REMOTE_IP, REMOTE_PORT)) {
+        Serial.printf("Failed to connect!\n");
+        delay(1000);  // to not flood logs
+      } else {
+        state = 1;
+      }
+      break;
+    }
+
+    case 1:
+    {
+      Serial.printf("Still connecting...\n");
+      delay(500);  // to not flood logs
+      break;
+    }
+
+    case 2:
+    {
+      // fill PCB space until we can
+      size_t willSend;
+      while (bufferPos < BUFFER_SIZE && (willSend = client.write(buffer + bufferPos, BUFFER_SIZE - bufferPos))) {
+        Serial.printf("Will send %u bytes...\n", willSend);
+        bufferPos += willSend;
+        waitingAck += willSend;
+      }
+
+      // we have sent the whole buffer ?
+      if (bufferPos >= BUFFER_SIZE) {
+        // wait for acks, or send again after 2 sec
+        if (waitingAck) {
+          Serial.printf("Waiting for acks...\n");
+          delay(100);
+        } else {
+          Serial.printf("Buffer received - next send in 2 sec\n");
+          delay(2000);
+          bufferPos = 0;
+        }
+      }
+      break;
+    }
+
+    default: break;
+  }
+}

software/NRG_itho_wifi/platformio.ini

@@ -0,0 +1,111 @@
+// SPDX-License-Identifier: LGPL-3.0-or-later
+// Copyright 2016-2025 Hristo Gochkov, Mathieu Carbou, Emil Muratov
+
+#include <Arduino.h>
+#include <AsyncTCP.h>
+#include <StreamString.h>
+#include <WiFi.h>
+
+#include <functional>
+#include <string>
+
+#define WIFI_SSID     "IoT"
+#define WIFI_PASSWORD ""
+
+void fetchAsync(const char *host, std::function<void(const StreamString *)> onDone) {
+  Serial.printf("[%s] Fetching: http://%s...\n", host, host);
+
+  // buffer where we will accumulate the received data
+  StreamString *content = new StreamString();
+
+  // reserve enough space to avoid reallocations
+  content->reserve(32 * 1024);
+
+  // create a new client
+  AsyncClient *client = new AsyncClient();
+
+  // register a callback when the client disconnects
+  client->onDisconnect([content, host, onDone](void *arg, AsyncClient *client) {
+    Serial.printf("[%s] Disconnected.\n", host);
+    onDone(content);
+    delete client;
+    delete content;
+  });
+
+  // register a callback when an error occurs
+  client->onError([host, onDone](void *arg, AsyncClient *client, int8_t error) {
+    Serial.printf("[%s] Error: %s\n", host, client->errorToString(error));
+  });
+
+  // register a callback when data arrives, to accumulate it
+  client->onData([host, content](void *arg, AsyncClient *client, void *data, size_t len) {
+    Serial.printf("[%s] Received %u bytes...\n", host, len);
+    content->write((const uint8_t *)data, len);
+  });
+
+  // register a callback when we are connected
+  client->onConnect([host](void *arg, AsyncClient *client) {
+    Serial.printf("[%s] Connected!\n", host);
+
+    // send request
+    client->write("GET / HTTP/1.1\r\n");
+    client->write("Host: ");
+    client->write(host);
+    client->write("\r\n");
+    client->write("User-Agent: ESP32\r\n");
+    client->write("Connection: close\r\n");
+    client->write("\r\n");
+  });
+
+  Serial.printf("[%s] Connecting...\n", host);
+
+  client->setRxTimeout(20000);
+  // client->setAckTimeout(10000);
+  client->setNoDelay(true);
+
+  if (!client->connect(host, 80)) {
+    Serial.printf("[%s] Failed to connect!\n", host);
+    delete client;
+    delete content;
+    onDone(nullptr);
+  }
+}
+
+void setup() {
+  Serial.begin(115200);
+  while (!Serial) {
+    continue;
+  }
+
+  // connect to WiFi
+  WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
+  while (WiFi.status() != WL_CONNECTED) {
+    delay(500);
+  }
+  Serial.println("Connected to WiFi!");
+  Serial.println(WiFi.localIP());
+
+  // fetch asynchronously 2 websites:
+
+  // equivalent to curl -v --raw http://www.google.com/
+  fetchAsync("www.google.com", [](const StreamString *content) {
+    if (content) {
+      Serial.printf("[www.google.com] Fetched website:\n%s\n", content->c_str());
+    } else {
+      Serial.println("[www.google.com] Failed to fetch website!");
+    }
+  });
+
+  // equivalent to curl -v --raw http://www.time.org/
+  fetchAsync("www.time.org", [](const StreamString *content) {
+    if (content) {
+      Serial.printf("[www.time.org] Fetched website:\n%s\n", content->c_str());
+    } else {
+      Serial.println("[www.time.org] Failed to fetch website!");
+    }
+  });
+}
+
+void loop() {
+  delay(500);
+}

software/lib/AsyncTCP/examples/AsyncSend/AsyncSend.ino

@@ -0,0 +1,15 @@
+set(COMPONENT_SRCDIRS
+    "src"
+)
+
+set(COMPONENT_ADD_INCLUDEDIRS
+    "src"
+)
+
+set(COMPONENT_REQUIRES
+    "arduino-esp32"
+)
+
+register_component()
+
+target_compile_options(${COMPONENT_TARGET} PRIVATE -fno-rtti)