MKR mqtt pooling fix

Author: Kacp3r3

src/Adafruit_MQTT.h

@@ -43,7 +43,7 @@
 // If using something like Zero or Due, change the above to SerialUSB
 
 // Define actual debug output functions when necessary.
-#define MQTT_DEBUG
+//#define MQTT_DEBUG
 #ifdef MQTT_DEBUG
 #define DEBUG_PRINT(...)                                                       \
   { DEBUG_PRINTER.print(__VA_ARGS__); }
@@ -59,7 +59,7 @@
 #define DEBUG_PRINTBUFFER(buffer, len)                                         \
   {}
 #endif
-
+#define MQTT_DEBUG
 #ifdef MQTT_ERROR
 #define ERROR_PRINT(...)                                                       \
   { DEBUG_PRINTER.print(__VA_ARGS__); }

src/LiveObjectsBase.cpp

@@ -2,7 +2,7 @@
 #include "LiveObjectsBase.h"
 LiveObjectsBase::LiveObjectsBase()
     :
-     lastKeepAliveNetwork(10000)
+     lastKeepAliveNetwork(5000)
     ,m_sPayload()
     ,m_sDecoder()
     ,m_Security(NONE)

src/LiveObjectsESP.cpp

@@ -108,9 +108,9 @@ void LiveObjectsESP::disconnectNetwork()
 
 void LiveObjectsESP::checkMQTT() 
 {
+  m_pMqttclient->loop();
   if(!m_pMqttclient->connected())
     connectMQTT();
-  m_pMqttclient->loop();
 }
 
 void LiveObjectsESP::connectMQTT() 

src/LiveObjectsFona.cpp

@@ -4,7 +4,7 @@ LiveObjectsFona::LiveObjectsFona()
   :
    m_Fona(FONA_RST)
    ,m_FonaSerial(FONA_TX,FONA_RX)
-   ,m_FonaMQTT(&m_Fona,MQTT_BROKER, 1883,"Fona", MQTT_USER, SECRET_LIVEOBJECTS_API_KEY)
+   ,m_FonaMQTT(&m_Fona,MQTT_BROKER, 1883,"Fona", MQTT_USER, SECRET_LIVEOBJECTS_API_KEY.c_str())
    ,m_sClientID()
    ,m_nPort(1883)
    ,m_Security(NONE)
@@ -78,7 +78,7 @@ void LiveObjectsFona::sendData()
     {
       //Serial.print("[INFO] Publishing message: ");
       //Serial.println(m_BufferPayload);
-      m_Fona.sendSMS(SECRET_SERVER_MSISDN,m_BufferPayload);
+      m_Fona.sendSMS(SECRET_SERVER_MSISDN.c_str(),m_BufferPayload);
     }
   }
   clearPayload();

src/LiveObjectsFona.h

@@ -5,7 +5,7 @@
 /******************************************************************************
    DEFAULT VALUES FOR LIVEOBJECTS
  ******************************************************************************/
-#define PAYLOAD_DATA_SIZE 256
+#define PAYLOAD_DATA_SIZE 200
 #define KEEP_ALIVE_NETWORK 1000
 #define SW_REVISION "1.8.0"
 #define MAX_COMMANDS 10
@@ -159,13 +159,13 @@ struct LiveObjects_command
   void addNetworkInfo();
 
   template<typename LOtA>
-  void addParameter(const String name, LOtA &variable){Serial.print("[ERROR] This board doesn't support this function");};
+  void addParameter(const String name, LOtA &variable){}//Serial.print("[ERROR] This board doesn't support this function");};
   template<typename LOtB>
-  void addParameter(const String name, LOtB &variable, LiveObjects_parameterType type){Serial.print("[ERROR] This board doesn't support this function");};
+  void addParameter(const String name, LOtB &variable, LiveObjects_parameterType type){}//Serial.print("[ERROR] This board doesn't support this function");};
   template<typename LOtC>
-  void addParameter(const String name, LOtC &variable, onParameterUpdateCallback callback){Serial.print("[ERROR] This board doesn't support this function");};
+  void addParameter(const String name, LOtC &variable, onParameterUpdateCallback callback){}//Serial.print("[ERROR] This board doesn't support this function");};
   template<typename LOtD>
-  void addParameter(const String name, LOtD &variable, onParameterUpdateCallback callback, LiveObjects_parameterType type){Serial.print("[ERROR] This board doesn't support this function");};
+  void addParameter(const String name, LOtD &variable, onParameterUpdateCallback callback, LiveObjects_parameterType type){}//Serial.print("[ERROR] This board doesn't support this function");};
 
 private:
   bool FONAconnect();
@@ -203,8 +203,8 @@ void LiveObjectsFona::addToStringPayload(T val, Args ... args)
   addToStringPayload(args...);
 }
 
-extern const char* SECRET_LIVEOBJECTS_API_KEY;
-extern const char* SECRET_SERVER_MSISDN;
+extern const String SECRET_LIVEOBJECTS_API_KEY;
+extern const String SECRET_SERVER_MSISDN;
 // extern const String SECRET_PINNUMBER;
 // extern const String SECRET_APN;
 // extern const String SECRET_APN_USER;

src/LiveObjectsMKR.cpp

@@ -34,6 +34,7 @@ void LiveObjectsMKR::sendMQTT(String& topic, String& doc)
 
 void LiveObjectsMKR::checkMQTT()
 {
+  m_pMqttclient->poll();
   if(!m_bSubCMD) if(commands.size()>0) m_pMqttclient->subscribe(MQTT_SUBCMD);
   if(!m_pMqttclient->connected())
     connectMQTT();