pim/lightbar2mqtt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: reboot when MQTT connection fails too often

Browse Source
This commit is contained in:
Erik Borowski
2024-12-05 17:06:24 +01:00
parent 8901d409ca
commit 4507063ff4
1 changed files with 9 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
mqtt.cpp
View File

@ -101,22 +101,15 @@ void MQTT::setup()
this->client->setServer(this->mqttServer, this->mqttPort); this->client->setServer(this->mqttServer, this->mqttPort);
this->client->setCallback(std::bind(&MQTT::onMessage, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3)); this->client->setCallback(std::bind(&MQTT::onMessage, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));
uint retries = 0;
Serial.println("[MQTT] Connecting to MQTT broker...");
while (!this->client->connected()) while (!this->client->connected())
{ {
Serial.println("[MQTT] Connecting to MQTT broker..."); if (!this->client->connect(this->clientId.c_str(), this->mqttUser, this->mqttPassword, String(this->getCombinedRootTopic() + "/availability").c_str(), 1, true, "offline"))
uint retries = 0;
if (this->client->connect(this->clientId.c_str(), this->mqttUser, this->mqttPassword, String(this->getCombinedRootTopic() + "/availability").c_str(), 1, true, "offline"))
{
Serial.println("[MQTT] connected!");
this->client->publish(String(this->getCombinedRootTopic() + "/availability").c_str(), "online", true);
this->client->subscribe(String(this->getCombinedRootTopic() + "/+/command").c_str());
this->client->subscribe(String(this->getCombinedRootTopic() + "/+/pair").c_str());
}
else
{ {
Serial.print("[MQTT] Connection failed! rc="); Serial.print("[MQTT] Connection failed! rc=");
Serial.print(this->client->state()); Serial.print(this->client->state());
Serial.println(" try again in 1 second"); Serial.println(" trying again in 1 second.");
delay(1000); delay(1000);
retries++; retries++;
if (retries > 60) if (retries > 60)
@ -124,6 +117,11 @@ void MQTT::setup()
} }
} }
Serial.println("[MQTT] connected!");
this->client->publish(String(this->getCombinedRootTopic() + "/availability").c_str(), "online", true);
this->client->subscribe(String(this->getCombinedRootTopic() + "/+/command").c_str());
this->client->subscribe(String(this->getCombinedRootTopic() + "/+/pair").c_str());
this->sendAllHomeAssistantDiscoveryMessages(); this->sendAllHomeAssistantDiscoveryMessages();
} }