trying to fix mqtt stops to work after a few hours

grillbaer · Nov 15, 2020 · 733ca42 · 733ca42
1 parent 91c7b5e
commit 733ca42
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 1 deletion.
diff --git a/include/ingest.h b/include/ingest.h
@@ -4,6 +4,7 @@
 #include "GeigerData.h"
 
 void initIngest();
+void loopIngest();
 void deinitIngest();
 void ingestToThingspeak(GeigerData &geigerData, uint16_t intervalSamples);
 void ingestToMqtt(GeigerData &geigerData, uint16_t intervalSamples);

diff --git a/src/ingest.cpp b/src/ingest.cpp
@@ -50,6 +50,14 @@ void initIngest()
  connectWiFi();
 }
 
+void loopIngest()
+{
+ if (mqttClient.connected())
+ {
+ mqttClient.loop();
+ }
+}
+
 void deinitIngest()
 {
  if (WiFi.status() == WL_CONNECTED)
@@ -182,6 +190,9 @@ void ingestToMqtt(GeigerData &geigerData, uint16_t intervalSamples)
  sprintf(payload, "{\"pulses\":%lu, \"cpm\":%lu,\"uSph\":%.3f,\"secs\":%d}",
  pulses, cpm, uSph, (int)intervalSamples);
 
- mqttClient.publish(mqttTopic, payload);
+ if (!mqttClient.publish(mqttTopic, payload))
+ {
+ mqttClient.disconnect();
+ }
  }
 }
diff --git a/src/main.cpp b/src/main.cpp
@@ -93,6 +93,7 @@ void loop()
 
  if (wifiSwitchOn())
  {
+ loopIngest();
  ingestCountdown--;
  if (ingestCountdown <= 0)
  {