jeans/openHASP
jeans/openHASP
1
0
Fork 0
mirror of https://github.com/HASwitchPlate/openHASP.git synced 2025-07-25 20:26:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Reflect MQTT state with online/offline scripts

Browse Source
This commit is contained in:
Kuba Szczodrzyński 2024-02-12 19:30:05 +01:00
parent 37e66cdf5b
commit d71473a4e7
No known key found for this signature in database
GPG Key ID: 43037AC62A600562
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/mqtt/hasp_mqtt_paho_async.cpp
View File

@ -94,6 +94,9 @@ int mqttPublish(const char* topic, const char* payload, size_t len, bool retain
static void onConnectFailure(void* context, MQTTAsync_failureData* response) static void onConnectFailure(void* context, MQTTAsync_failureData* response)
{ {
#if HASP_TARGET_PC
dispatch_run_script(NULL, "L:/offline.cmd", TAG_HASP);
#endif
mqttConnecting = false; mqttConnecting = false;
mqttConnected = false; mqttConnected = false;
LOG_ERROR(TAG_MQTT, "Connection failed, return code %d (%s)", response->code, response->message); LOG_ERROR(TAG_MQTT, "Connection failed, return code %d (%s)", response->code, response->message);
@ -101,6 +104,9 @@ static void onConnectFailure(void* context, MQTTAsync_failureData* response)
static void onDisconnect(void* context, MQTTAsync_successData* response) static void onDisconnect(void* context, MQTTAsync_successData* response)
{ {
#if HASP_TARGET_PC
dispatch_run_script(NULL, "L:/offline.cmd", TAG_HASP);
#endif
mqttConnecting = false; mqttConnecting = false;
mqttConnected = false; mqttConnected = false;
} }
@ -124,6 +130,9 @@ static void onSubscribeFailure(void* context, MQTTAsync_failureData* response)
static void connlost(void* context, char* cause) static void connlost(void* context, char* cause)
{ {
#if HASP_TARGET_PC
dispatch_run_script(NULL, "L:/offline.cmd", TAG_HASP);
#endif
LOG_WARNING(TAG_MQTT, F(D_MQTT_DISCONNECTED ": %s"), cause); LOG_WARNING(TAG_MQTT, F(D_MQTT_DISCONNECTED ": %s"), cause);
mqttConnecting = false; mqttConnecting = false;
mqttConnected = false; mqttConnected = false;
@ -341,6 +350,10 @@ static void onConnect(void* context, MQTTAsync_successData* response)
#endif #endif
mqttPublish(mqttLwtTopic.c_str(), "online", 6, true); mqttPublish(mqttLwtTopic.c_str(), "online", 6, true);
#if HASP_TARGET_PC
dispatch_run_script(NULL, "L:/online.cmd", TAG_HASP);
#endif
} }
void mqttStart() void mqttStart()