iot/spore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feature/cluster-message #9

Merged
master merged 3 commits from feature/cluster-message into main 2025-09-28 13:43:54 +02:00
Conversation 0 Commits 3 Files Changed 6 +25 -75
1 changed files with 25 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 8da9f77441 - Show all commits

100
examples/neopattern/NeoPatternService.cpp
View File

@@ -126,87 +126,43 @@ void NeoPatternService::handleControlRequest(AsyncWebServerRequest* request) {
bool updated = false; bool updated = false;
bool broadcast = false; bool broadcast = false;
if (request->hasParam("pattern", true)) {
String name = request->getParam("pattern", true)->value();
if (isValidPattern(name)) {
setPatternByName(name);
updated = true;
} else {
// Invalid pattern name - could add error handling here
LOG_WARN("NeoPattern", "Invalid pattern name: " + name);
}
}
if (request->hasParam("color", true)) {
String colorStr = request->getParam("color", true)->value();
uint32_t color = parseColor(colorStr);
setColor(color);
updated = true;
}
if (request->hasParam("color2", true)) {
String colorStr = request->getParam("color2", true)->value();
uint32_t color = parseColor(colorStr);
setColor2(color);
updated = true;
}
if (request->hasParam("brightness", true)) {
int b = request->getParam("brightness", true)->value().toInt();
if (b < 0) b = 0;
if (b > 255) b = 255;
setBrightness(static_cast<uint8_t>(b));
updated = true;
}
if (request->hasParam("total_steps", true)) {
int steps = request->getParam("total_steps", true)->value().toInt();
if (steps > 0) {
setTotalSteps(static_cast<uint16_t>(steps));
updated = true;
}
}
if (request->hasParam("direction", true)) {
String dirStr = request->getParam("direction", true)->value();
NeoDirection dir = (dirStr.equalsIgnoreCase("reverse")) ? NeoDirection::REVERSE : NeoDirection::FORWARD;
setDirection(dir);
updated = true;
}
if (request->hasParam("interval", true)) {
unsigned long interval = request->getParam("interval", true)->value().toInt();
if (interval > 0) {
setUpdateInterval(interval);
updated = true;
}
}
if (request->hasParam("broadcast", true)) { if (request->hasParam("broadcast", true)) {
String b = request->getParam("broadcast", true)->value(); String b = request->getParam("broadcast", true)->value();
broadcast = b.equalsIgnoreCase("true") || b == "1"; broadcast = b.equalsIgnoreCase("true") || b == "1";
} }
if (broadcast) { // Build JSON payload from provided params (single source of truth)
// Build JSON payload from provided params JsonDocument payload;
JsonDocument payload; bool any = false;
if (request->hasParam("pattern", true)) payload["pattern"] = request->getParam("pattern", true)->value(); if (request->hasParam("pattern", true)) { payload["pattern"] = request->getParam("pattern", true)->value(); any = true; }
if (request->hasParam("color", true)) payload["color"] = request->getParam("color", true)->value(); if (request->hasParam("color", true)) { payload["color"] = request->getParam("color", true)->value(); any = true; }
if (request->hasParam("color2", true)) payload["color2"] = request->getParam("color2", true)->value(); if (request->hasParam("color2", true)) { payload["color2"] = request->getParam("color2", true)->value(); any = true; }
if (request->hasParam("brightness", true)) payload["brightness"] = request->getParam("brightness", true)->value(); if (request->hasParam("brightness", true)) { payload["brightness"] = request->getParam("brightness", true)->value(); any = true; }
if (request->hasParam("total_steps", true)) payload["total_steps"] = request->getParam("total_steps", true)->value(); if (request->hasParam("total_steps", true)) { payload["total_steps"] = request->getParam("total_steps", true)->value(); any = true; }
if (request->hasParam("direction", true)) payload["direction"] = request->getParam("direction", true)->value(); if (request->hasParam("direction", true)) { payload["direction"] = request->getParam("direction", true)->value(); any = true; }
if (request->hasParam("interval", true)) payload["interval"] = request->getParam("interval", true)->value(); if (request->hasParam("interval", true)) { payload["interval"] = request->getParam("interval", true)->value(); any = true; }
String payloadStr; String payloadStr;
serializeJson(payload, payloadStr); serializeJson(payload, payloadStr);
// Always apply locally via event so we have a single codepath for updates
if (any) {
std::string ev = "api/neopattern";
String localData = payloadStr;
LOG_INFO("NeoPattern", String("Applying local api/neopattern via event payloadLen=") + String(payloadStr.length()));
ctx.fire(ev, &localData);
updated = true;
}
// Broadcast to peers if requested
if (broadcast && any) {
JsonDocument eventDoc; JsonDocument eventDoc;
eventDoc["event"] = "api/neopattern"; eventDoc["event"] = "api/neopattern";
eventDoc["data"] = payloadStr; // data is arbitrary JSON string eventDoc["data"] = payloadStr; // data is JSON string
String eventJson; String eventJson;
serializeJson(eventDoc, eventJson); serializeJson(eventDoc, eventJson);
// Compute subnet-directed broadcast to improve delivery on some networks // Compute subnet-directed broadcast to improve delivery on some networks
IPAddress ip = WiFi.localIP(); IPAddress ip = WiFi.localIP();
IPAddress mask = WiFi.subnetMask(); IPAddress mask = WiFi.subnetMask();
@@ -216,12 +172,6 @@ void NeoPatternService::handleControlRequest(AsyncWebServerRequest* request) {
String msg = String(ClusterProtocol::CLUSTER_EVENT_MSG) + ":" + eventJson; String msg = String(ClusterProtocol::CLUSTER_EVENT_MSG) + ":" + eventJson;
ctx.udp->write(msg.c_str()); ctx.udp->write(msg.c_str());
ctx.udp->endPacket(); ctx.udp->endPacket();
// Fire locally as well so the sender applies the change
std::string ev = "api/neopattern";
String localData = payloadStr;
LOG_INFO("NeoPattern", "Firing local api/neopattern event after broadcast");
ctx.fire(ev, &localData);
} }
// Return current state // Return current state