Commit 40b0782b authored by Eric Duminil's avatar Eric Duminil
Browse files

Adding mqtt::connected? to web-server

parent df91cd6c
...@@ -22,6 +22,7 @@ PubSubClient mqttClient(espClient); ...@@ -22,6 +22,7 @@ PubSubClient mqttClient(espClient);
namespace mqtt { namespace mqtt {
unsigned long last_sent_at = 0; unsigned long last_sent_at = 0;
unsigned long last_failed_at = 0; unsigned long last_failed_at = 0;
bool connected = false;
String publish_topic; String publish_topic;
const char *json_sensor_format; const char *json_sensor_format;
...@@ -191,8 +192,9 @@ namespace mqtt { ...@@ -191,8 +192,9 @@ namespace mqtt {
mqttClient.connect(publish_topic.c_str(), config::mqtt_user, config::mqtt_password); mqttClient.connect(publish_topic.c_str(), config::mqtt_user, config::mqtt_password);
LedEffects::onBoardLEDOff(); LedEffects::onBoardLEDOff();
if (mqttClient.connected()) { connected = mqttClient.connected();
//TODO: Send local IP?
if (connected) {
if (config::allow_mqtt_commands) { if (config::allow_mqtt_commands) {
char control_topic[60]; // Should be enough for "CO2sensors/ESPd03cc5/control" char control_topic[60]; // Should be enough for "CO2sensors/ESPd03cc5/control"
snprintf(control_topic, sizeof(control_topic), "%s/control", publish_topic.c_str()); snprintf(control_topic, sizeof(control_topic), "%s/control", publish_topic.c_str());
......
...@@ -15,6 +15,7 @@ namespace config { ...@@ -15,6 +15,7 @@ namespace config {
} }
namespace mqtt { namespace mqtt {
extern String last_successful_publish; extern String last_successful_publish;
extern bool connected;
void initialize(String &topic); void initialize(String &topic);
void keepConnection(); void keepConnection();
void publishIfTimeHasCome(const String &timeStamp, const int16_t &co2, const float &temp, const float &hum); void publishIfTimeHasCome(const String &timeStamp, const int16_t &co2, const float &temp, const float &hum);
......
...@@ -95,7 +95,7 @@ namespace web_server { ...@@ -95,7 +95,7 @@ namespace web_server {
#endif #endif
#ifdef AMPEL_MQTT #ifdef AMPEL_MQTT
"<tr><th colspan='2'>MQTT</th></tr>\n" "<tr><th colspan='2'>MQTT</th></tr>\n"
//TODO: Add connected? "<tr><td>Connected?</td><td>%s</td></tr>\n"
"<tr><td>Last publish</td><td>%s</td></tr>\n" "<tr><td>Last publish</td><td>%s</td></tr>\n"
"<tr><td>Timestep</td><td>%5d s</td></tr>\n" "<tr><td>Timestep</td><td>%5d s</td></tr>\n"
#endif #endif
...@@ -225,7 +225,7 @@ namespace web_server { ...@@ -225,7 +225,7 @@ namespace web_server {
csv_writer::last_successful_write.c_str(), config::csv_interval, csv_writer::getAvailableSpace() / 1024, csv_writer::last_successful_write.c_str(), config::csv_interval, csv_writer::getAvailableSpace() / 1024,
#endif #endif
#ifdef AMPEL_MQTT #ifdef AMPEL_MQTT
mqtt::last_successful_publish.c_str(), config::sending_interval, mqtt::connected ? "Yes" : "No", mqtt::last_successful_publish.c_str(), config::sending_interval,
#endif #endif
#if defined(AMPEL_LORAWAN) && defined(ESP32) #if defined(AMPEL_LORAWAN) && defined(ESP32)
lorawan::connected ? "Yes" : "No", LMIC_FREQUENCY_PLAN, lorawan::last_transmission.c_str(), lorawan::connected ? "Yes" : "No", LMIC_FREQUENCY_PLAN, lorawan::last_transmission.c_str(),
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment