jeans/openHASP
jeans/openHASP
1
0
Fork 0
mirror of https://github.com/HASwitchPlate/openHASP.git synced 2025-07-24 19:56:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add source tag to commands

Browse Source
This commit is contained in:
fvanroie 2021-07-19 22:23:08 +02:00
parent f03d231792
commit a3f1fd1dcc
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/mqtt/hasp_mqtt_paho_single.cpp
View File

@ -111,7 +111,7 @@ static void mqtt_message_cb(char* topic, char* payload, size_t length)
// Group topic // Group topic
topic += mqttGroupTopic.length(); // shorten topic topic += mqttGroupTopic.length(); // shorten topic
dispatch_topic_payload(topic, (const char*)payload, length > 0); dispatch_topic_payload(topic, (const char*)payload, length > 0, TAG_MQTT);
return; return;
#ifdef HASP_USE_BROADCAST #ifdef HASP_USE_BROADCAST
@ -120,14 +120,14 @@ static void mqtt_message_cb(char* topic, char* payload, size_t length)
// /" MQTT_TOPIC_BROADCAST "/ topic // /" MQTT_TOPIC_BROADCAST "/ topic
topic += strlen(MQTT_PREFIX "/" MQTT_TOPIC_BROADCAST "/"); // shorten topic topic += strlen(MQTT_PREFIX "/" MQTT_TOPIC_BROADCAST "/"); // shorten topic
dispatch_topic_payload(topic, (const char*)payload, length > 0); dispatch_topic_payload(topic, (const char*)payload, length > 0, TAG_MQTT);
return; return;
#endif #endif
#ifdef HASP_USE_HA #ifdef HASP_USE_HA
} else if(topic == strstr_P(topic, PSTR("homeassistant/status"))) { // HA discovery topic } else if(topic == strstr_P(topic, PSTR("homeassistant/status"))) { // HA discovery topic
if(mqttHAautodiscover && !strcasecmp_P((char*)payload, PSTR("online"))) { if(mqttHAautodiscover && !strcasecmp_P((char*)payload, PSTR("online"))) {
dispatch_current_state(); dispatch_current_state( TAG_MQTT);
mqtt_ha_register_auto_discovery(); mqtt_ha_register_auto_discovery();
} }
return; return;
@ -152,7 +152,7 @@ static void mqtt_message_cb(char* topic, char* payload, size_t length)
// LOG_TRACE(TAG_MQTT, F("ignoring LWT = online")); // LOG_TRACE(TAG_MQTT, F("ignoring LWT = online"));
} }
} else { } else {
dispatch_topic_payload(topic, (const char*)payload, length > 0); dispatch_topic_payload(topic, (const char*)payload, length > 0, TAG_MQTT);
} }
} }