From 7d2f384898d558df59317c5543d6826d05ae1a5c Mon Sep 17 00:00:00 2001
From: Rune Harlyk <rune@harlyk.dk>
Date: Thu, 27 Nov 2025 17:30:00 +0100
Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20Fix=20system=20metric=20emit?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 esp32/include/communication/comm_base.hpp |  2 +-
 esp32/include/system_service.h            |  4 ++--
 esp32/src/main.cpp                        |  2 +-
 esp32/src/system_service.cpp              | 15 ++++++++-------
 4 files changed, 12 insertions(+), 11 deletions(-)

diff --git a/esp32/include/communication/comm_base.hpp b/esp32/include/communication/comm_base.hpp
index 1a55429..cafd346 100644
--- a/esp32/include/communication/comm_base.hpp
+++ b/esp32/include/communication/comm_base.hpp
@@ -47,7 +47,7 @@ class CommAdapterBase {
 #else
         String out;
         serializeJson(doc, out);
-        send(out.c_str(), cid);
+        send(out.c_str(), -1);
 #endif
     }
 
diff --git a/esp32/include/system_service.h b/esp32/include/system_service.h
index 1edd4f9..04b8efd 100644
--- a/esp32/include/system_service.h
+++ b/esp32/include/system_service.h
@@ -3,7 +3,7 @@
 #include <ESPmDNS.h>
 #include <PsychicHttp.h>
 #include <WiFi.h>
-// #include <communication/websocket_adapter.h>
+#include <communication/websocket_adapter.h>
 #include <filesystem.h>
 #include <global.h>
 #include "esp_timer.h"
@@ -25,7 +25,7 @@ void sleep();
 void status(JsonObject &root);
 void metrics(JsonObject &root);
 
-void emitMetrics();
+void emitMetrics(Websocket &socket);
 
 const char *resetReason(esp_reset_reason_t reason);
 } // namespace system_service
\ No newline at end of file
diff --git a/esp32/src/main.cpp b/esp32/src/main.cpp
index e998ebe..13afab8 100644
--- a/esp32/src/main.cpp
+++ b/esp32/src/main.cpp
@@ -157,7 +157,7 @@ void IRAM_ATTR serviceLoopEntry(void *) {
     for (;;) {
         wifiService.loop();
         apService.loop();
-        EXECUTE_EVERY_N_MS(2000, system_service::emitMetrics());
+        EXECUTE_EVERY_N_MS(2000, system_service::emitMetrics(socket));
 
         vTaskDelay(100 / portTICK_PERIOD_MS);
     }
diff --git a/esp32/src/system_service.cpp b/esp32/src/system_service.cpp
index 136b267..7fdbb34 100644
--- a/esp32/src/system_service.cpp
+++ b/esp32/src/system_service.cpp
@@ -121,13 +121,14 @@ void metrics(JsonObject &root) {
     root["core_temp"] = temperatureRead();
 }
 
-void emitMetrics() {
-    // if (!socket.hasSubscribers(EVENT_ANALYTICS)) return;
-    // analyticsDoc.clear();
-    // JsonObject root = analyticsDoc.to<JsonObject>();
-    // system_service::metrics(root);
-    // JsonVariant data = analyticsDoc.as<JsonVariant>();
-    // socket.emit(EVENT_ANALYTICS, data);
+void emitMetrics(Websocket &socket) {
+    if (!socket.hasSubscribers(EVENT_ANALYTICS)) return;
+
+    JsonDocument doc;
+    JsonObject root = doc.to<JsonObject>();
+    system_service::metrics(root);
+    JsonVariant data = doc.as<JsonVariant>();
+    socket.emit(EVENT_ANALYTICS, data);
 }
 
 const char *resetReason(esp_reset_reason_t reason) {