WIP: Log all publish failures

Author: tyeth

src/Wippersnapper.cpp

@@ -2666,7 +2666,7 @@ bool Wippersnapper::publish(const char *topic, uint8_t *payload, uint16_t bLen,
   // method when caused with WS object in another file.
 #ifdef ARDUINO_ARCH_ESP32
 // print stack and heap usage
-  WS_DEBUG_PRINT("Free Heap: ");
+  WS_DEBUG_PRINT("\nFree Heap: ");
   WS_DEBUG_PRINTLN(ESP.getFreeHeap());
   WS_DEBUG_PRINT("Min Free Heap: ");
   WS_DEBUG_PRINTLN(ESP.getMinFreeHeap());
@@ -2894,9 +2894,15 @@ void Wippersnapper::publishPinConfigComplete() {
 
   // Publish message
   WS_DEBUG_PRINTLN("Publishing to pin config complete...");
-  WS.publish(WS._topic_device_pin_config_complete, _message_buffer,
-             _message_len, 1);
-  WS_DEBUG_PRINTLN("Published! (pin config complete)");
+  if (WS.publish(WS._topic_device_pin_config_complete, _message_buffer,
+                 _message_len, 1))
+  {
+    WS_DEBUG_PRINTLN("Published! (pin config complete)");
+  }
+  else
+  {
+    WS_DEBUG_PRINTLN("Failed to publish! (pin config complete)");
+  }
 }
 
 /**************************************************************************/

src/components/analogIO/Wippersnapper_AnalogIO.cpp

@@ -305,7 +305,10 @@ bool Wippersnapper_AnalogIO::encodePinEvent(
                       wippersnapper_signal_v1_CreateSignalRequest_fields,
                       &outgoingSignalMsg);
   WS_DEBUG_PRINT("Publishing pinEvent...");
-  WS.publish(WS._topic_signal_device, WS._buffer_outgoing, msgSz, 1);
+  if(!WS.publish(WS._topic_signal_device, WS._buffer_outgoing, msgSz, 1)) {
+    WS_DEBUG_PRINTLN("ERROR: Unable to publish analogIO pin event message");
+    return false;
+  }
   WS_DEBUG_PRINTLN("Published!");
 
   return true;

src/components/digitalIO/Wippersnapper_DigitalGPIO.cpp

@@ -276,8 +276,11 @@ void Wippersnapper_DigitalGPIO::processDigitalInputs() {
                             &_outgoingSignalMsg);
 
         WS_DEBUG_PRINT("Publishing pinEvent...");
-        WS.publish(WS._topic_signal_device, WS._buffer_outgoing, msgSz, 1);
-        WS_DEBUG_PRINTLN("Published!");
+        if (!WS.publish(WS._topic_signal_device, WS._buffer_outgoing, msgSz, 1)){
+          WS_DEBUG_PRINTLN("ERROR: Unable to publish DigitalIO pinEvent");
+        } else {
+          WS_DEBUG_PRINTLN("Published! (DigitalIO PinEvent)");
+        }
 
         // reset the digital pin
         _digital_input_pins[i].prvPeriod = curTime;
@@ -315,8 +318,14 @@ void Wippersnapper_DigitalGPIO::processDigitalInputs() {
               &msgSz, wippersnapper_signal_v1_CreateSignalRequest_fields,
               &_outgoingSignalMsg);
           WS_DEBUG_PRINT("Publishing pinEvent...");
-          WS.publish(WS._topic_signal_device, WS._buffer_outgoing, msgSz, 1);
-          WS_DEBUG_PRINTLN("Published!");
+          if (!WS.publish(WS._topic_signal_device, WS._buffer_outgoing, msgSz, 1))
+          {
+            WS_DEBUG_PRINTLN("ERROR: Unable to publish DigitalIO pinEvent");
+          }
+          else
+          {
+            WS_DEBUG_PRINTLN("Published! (DigitalIO PinEvent)");
+          }
 
           // set the pin value in the digital pin object for comparison on next
           // run

src/components/register/Wippersnapper_Register.cpp

@@ -56,8 +56,11 @@ bool Wippersnapper::encodePubRegistrationReq() {
     return _status;
 
   // pubish message
-  WS.publish(WS._topic_description, _message_buffer, _message_len, 1);
-  WS_DEBUG_PRINTLN("Published!");
+  if (!WS.publish(WS._topic_description, _message_buffer, _message_len, 1)){
+    WS_DEBUG_PRINTLN("ERROR: Unable to publish registration message");
+  } else {
+    WS_DEBUG_PRINTLN("Published! (Registration)");
+  }
   WS._boardStatus = WS_BOARD_DEF_SENT;
 
   return _status;
@@ -153,10 +156,15 @@ void Wippersnapper::decodeRegistrationResp(char *data, uint16_t len) {
     }
 
     // Publish message
-    WS.publish(_topic_description_status_complete, _message_buffer,
-               _message_len, 1);
-    WS_DEBUG_PRINTLN("Completed registration process, configuration next!");
-
+    if (WS.publish(_topic_description_status_complete, _message_buffer,
+                   _message_len, 1))
+    {
+      WS_DEBUG_PRINTLN("Completed registration process, configuration next!");
+    }
+    else
+    {
+      WS_DEBUG_PRINTLN("ERROR: Unable to publish registration complete message");
+    }
   } else {
     WS._boardStatus = WS_BOARD_DEF_INVALID;
   }