From 3c8775de3d30320c37dc484771040d512fc47bf6 Mon Sep 17 00:00:00 2001 From: Rune Harlyk Date: Tue, 9 Jul 2024 20:04:03 +0200 Subject: [PATCH] =?UTF-8?q?=F0=9F=AA=84=20Formats=20EventEndpoint?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- esp32/lib/ESP32-sveltekit/EventEndpoint.h | 42 ++++++++++------------- 1 file changed, 18 insertions(+), 24 deletions(-) diff --git a/esp32/lib/ESP32-sveltekit/EventEndpoint.h b/esp32/lib/ESP32-sveltekit/EventEndpoint.h index f3b3d6d..43ae56e 100644 --- a/esp32/lib/ESP32-sveltekit/EventEndpoint.h +++ b/esp32/lib/ESP32-sveltekit/EventEndpoint.h @@ -21,43 +21,37 @@ #include template -class EventEndpoint -{ -public: - EventEndpoint(JsonStateReader stateReader, - JsonStateUpdater stateUpdater, - StatefulService *statefulService, - EventSocket *socket, const char *event) : _stateReader(stateReader), - _stateUpdater(stateUpdater), - _statefulService(statefulService), - _socket(socket), - _event(event) - { - _statefulService->addUpdateHandler([&](const String &originId) - { syncState(originId); }, - false); +class EventEndpoint { + public: + EventEndpoint(JsonStateReader stateReader, JsonStateUpdater stateUpdater, StatefulService *statefulService, + EventSocket *socket, const char *event) + : _stateReader(stateReader), + _stateUpdater(stateUpdater), + _statefulService(statefulService), + _socket(socket), + _event(event) { + _statefulService->addUpdateHandler([&](const String &originId) { syncState(originId); }, false); } - void begin() - { - _socket->onEvent(_event, std::bind(&EventEndpoint::updateState, this, std::placeholders::_1, std::placeholders::_2)); - _socket->onSubscribe(_event, std::bind(&EventEndpoint::syncState, this, std::placeholders::_1, std::placeholders::_2)); + void begin() { + _socket->onEvent(_event, + std::bind(&EventEndpoint::updateState, this, std::placeholders::_1, std::placeholders::_2)); + _socket->onSubscribe(_event, + std::bind(&EventEndpoint::syncState, this, std::placeholders::_1, std::placeholders::_2)); } -private: + private: JsonStateReader _stateReader; JsonStateUpdater _stateUpdater; StatefulService *_statefulService; EventSocket *_socket; const char *_event; - void updateState(JsonObject &root, int originId) - { + void updateState(JsonObject &root, int originId) { _statefulService->update(root, _stateUpdater, String(originId)); } - void syncState(const String &originId, bool sync = false) - { + void syncState(const String &originId, bool sync = false) { JsonDocument jsonDocument; JsonObject root = jsonDocument.to(); String output;