Darkages/SpotMicroESP32-Leika
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

🪄 Formats EventEndpoint

Browse Source
This commit is contained in:
Rune Harlyk
2024-07-09 20:04:03 +02:00
committed by Rune Harlyk
parent 23a2ea566d
commit 3c8775de3d
1 changed files with 18 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
esp32/lib/ESP32-sveltekit/EventEndpoint.h
+18 -24
View File
@@ -21,43 +21,37 @@
#include <StatefulService.h>
template <class T>
class EventEndpoint
{
public:
EventEndpoint(JsonStateReader<T> stateReader,
JsonStateUpdater<T> stateUpdater,
StatefulService<T> *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<T> stateReader, JsonStateUpdater<T> stateUpdater, StatefulService<T> *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<T> _stateReader;
JsonStateUpdater<T> _stateUpdater;
StatefulService<T> *_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<JsonObject>();
String output;