pohui_pohui/firmware
1
0
Fork 0
mirror of https://github.com/meshtastic/firmware.git synced 2025-08-01 19:35:42 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

Add client notification

Browse Source
This commit is contained in:
Ben Meadors 2025-07-24 06:03:17 -05:00
parent 857d86ef4d
commit 9646669d92
1 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/mqtt/MQTT.cpp
View File

@ -39,6 +39,7 @@
#include <machine/endian.h> #include <machine/endian.h>
#define ntohl __ntohl #define ntohl __ntohl
#endif #endif
#include <RTC.h>
MQTT *mqtt; MQTT *mqtt;
@ -624,14 +625,26 @@ bool MQTT::isValidConfig(const meshtastic_ModuleConfig_MQTTConfig &config, MQTTC
return connectPubSub(parsed, *pubSub, (client != nullptr) ? *client : *clientConnection); return connectPubSub(parsed, *pubSub, (client != nullptr) ? *client : *clientConnection);
} }
#else #else
LOG_ERROR("Invalid MQTT config: proxy_to_client_enabled must be enabled on nodes that do not have a network"); const char *warning = "Invalid MQTT config: proxy_to_client_enabled must be enabled on nodes that do not have a network";
LOG_ERROR(warning);
meshtastic_ClientNotification *cn = clientNotificationPool.allocZeroed();
cn->level = meshtastic_LogRecord_Level_WARNING;
cn->time = getValidTime(RTCQualityFromNet);
strcpy(cn->message, warning);
service->sendClientNotification(cn);
return false; return false;
#endif #endif
} }
const bool defaultServer = isDefaultServer(parsed.serverAddr); const bool defaultServer = isDefaultServer(parsed.serverAddr);
if (defaultServer && parsed.serverPort != PubSubConfig::defaultPort) { if (defaultServer && parsed.serverPort != PubSubConfig::defaultPort) {
LOG_ERROR("Invalid MQTT config: Unsupported port '%d' for the default MQTT server", parsed.serverPort); const char *warning = "Invalid MQTT config: default server address must not have a port specified";
LOG_ERROR(warning);
meshtastic_ClientNotification *cn = clientNotificationPool.allocZeroed();
cn->level = meshtastic_LogRecord_Level_WARNING;
cn->time = getValidTime(RTCQualityFromNet);
strcpy(cn->message, warning);
service->sendClientNotification(cn);
return false; return false;
} }
return true; return true;