iot/sprocket-core
1
0
Fork 0
mirror of https://gitlab.com/wirelos/sprocket-lib.git synced 2025-12-16 13:25:03 +01:00
Code Issues Packages Projects Releases Wiki Activity

check message validity

Browse Source
This commit is contained in:
0x1d
2018-09-16 17:09:36 +02:00
parent ec6c41f4a1
commit db5a67229e
2 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/base/MeshSprocket.h
View File

@@ -35,13 +35,19 @@ class MeshSprocket : public Sprocket {
//Serial.printf("MeshSprocket onMessage: received from %u msg=%s\n", from, msg.c_str()); //Serial.printf("MeshSprocket onMessage: received from %u msg=%s\n", from, msg.c_str());
SprocketMessage sMsg; SprocketMessage sMsg;
sMsg.fromJsonString(msg); sMsg.fromJsonString(msg);
if(sMsg.valid){
sMsg.from = from; sMsg.from = from;
publish(sMsg.topic, sMsg.payload); publish(sMsg.topic, sMsg.payload);
}
}; };
void dispatch( uint32_t from, String &msg ) { void dispatch( uint32_t from, String &msg ) {
Sprocket::dispatch(from, msg); SprocketMessage sMsg;
onMessage(from, msg); sMsg.fromJsonString(msg);
if(sMsg.valid){
sMsg.from = from;
publish(sMsg.topic, sMsg.payload);
}
} }
void loop() { void loop() {

2
src/plugins/MeshManPlugin.cpp
View File

@@ -31,7 +31,7 @@ class MeshManPlugin : public Plugin {
subscribe("mesh/heartbeat", std::bind(&MeshManPlugin::gotHeartbeat, this, std::placeholders::_1)); subscribe("mesh/heartbeat", std::bind(&MeshManPlugin::gotHeartbeat, this, std::placeholders::_1));
} }
void gotHeartbeat(String msg){ void gotHeartbeat(String msg){
Serial.println(String("Got heartbeat: ") + msg); Serial.println(String("MeshManPlugin / Heartbeat: ") + msg);
} }
void getMeshConnections(AsyncWebServerRequest *request) { void getMeshConnections(AsyncWebServerRequest *request) {
request->send(200, "text/plain", net->mesh.subConnectionJson()); request->send(200, "text/plain", net->mesh.subConnectionJson());