Upstream/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2024-09-03 00:30:58 +02:00
Code Issues Projects Releases Wiki Activity

fix to PR # 3887 MQTT connection not using discovery: false (#5275)

Browse Source
This commit is contained in:
luka6000 2023-09-01 03:20:21 +02:00 committed by Jesse Hills
parent 2cabe59c22
commit c146712b16
No known key found for this signature in database
GPG Key ID: BEAAE804EFD8E83A
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
esphome/components/mqtt/mqtt_client.cpp
View File

@ -66,25 +66,28 @@ void MQTTClientComponent::setup() {
}
#endif
this->subscribe(
"esphome/discover", [this](const std::string &topic, const std::string &payload) { this->send_device_info_(); },
2);
if (this->is_discovery_enabled()) {
this->subscribe(
"esphome/discover", [this](const std::string &topic, const std::string &payload) { this->send_device_info_(); },
2);
std::string topic = "esphome/ping/";
topic.append(App.get_name());
this->subscribe(
topic, [this](const std::string &topic, const std::string &payload) { this->send_device_info_(); }, 2);
std::string topic = "esphome/ping/";
topic.append(App.get_name());
this->subscribe(
topic, [this](const std::string &topic, const std::string &payload) { this->send_device_info_(); }, 2);
}
this->last_connected_ = millis();
this->start_dnslookup_();
}
void MQTTClientComponent::send_device_info_() {
if (!this->is_connected()) {
if (!this->is_connected() or !this->is_discovery_enabled()) {
return;
}
std::string topic = "esphome/discover/";
topic.append(App.get_name());
this->publish_json(
topic,
[](JsonObject root) {