set up a default error printer

Author: toddtreece

AdafruitIO.cpp

@@ -59,6 +59,14 @@ AdafruitIO_Feed* AdafruitIO::feed(const __FlashStringHelper *name)
   return new AdafruitIO_Feed(this, name);
 }
 
+void errorCallback(char *err, uint16_t len)
+{
+  AIO_ERR_PRINTLN();
+  AIO_ERR_PRINT("ERROR: ");
+  AIO_ERR_PRINTLN(err);
+  AIO_ERR_PRINTLN();
+}
+
 void AdafruitIO::_init()
 {
   // we have never pinged, so set last ping to now
@@ -79,6 +87,7 @@ void AdafruitIO::_init()
     // setup error sub
     _err_sub = new Adafruit_MQTT_Subscribe(_mqtt, _err_topic);
     _mqtt->subscribe(_err_sub);
+    _err_sub->setCallback(errorCallback);
 
   } else {
 
@@ -99,6 +108,7 @@ void AdafruitIO::_init()
     // setup throttle sub
     _throttle_sub = new Adafruit_MQTT_Subscribe(_mqtt, _throttle_topic);
     _mqtt->subscribe(_throttle_sub);
+    _throttle_sub->setCallback(errorCallback);
 
   } else {
 
@@ -108,12 +118,6 @@ void AdafruitIO::_init()
   }
 }
 
-void AdafruitIO::setErrorHandler(SubscribeCallbackBufferType cb)
-{
-  _err_sub->setCallback(cb);
-  _throttle_sub->setCallback(cb);
-}
-
 const __FlashStringHelper* AdafruitIO::statusText()
 {
   switch(_status) {

AdafruitIO.h

@@ -32,11 +32,12 @@ class AdafruitIO {
 
     void connect(const char *user, const char *key);
     void connect(const __FlashStringHelper *user, const __FlashStringHelper *key);
+
     void run();
-    void setErrorHandler(SubscribeCallbackBufferType cb);
 
     AdafruitIO_Feed* feed(const char *name);
     AdafruitIO_Feed* feed(const __FlashStringHelper *name);
+
     const __FlashStringHelper* statusText();
 
     aio_status_t status();

AdafruitIO_Definitions.h

@@ -17,6 +17,22 @@ class AdafruitIO_Data;
 
 typedef void (*AdafruitIODataCallbackType)(AdafruitIO_Data *data);
 
+// uncomment/comment to turn on/off error output
+#define AIO_ERROR
+
+// where debug messages will be printed
+#define AIO_PRINTER Serial
+
+#ifdef AIO_ERROR
+  #define AIO_ERR_PRINT(...) { AIO_PRINTER.print(__VA_ARGS__); }
+  #define AIO_ERR_PRINTLN(...) { AIO_PRINTER.println(__VA_ARGS__); }
+  #define AIO_ERR_PRINTBUFFER(buffer, len) { printBuffer(buffer, len); }
+#else
+  #define AIO_ERR_PRINT(...) {}
+  #define AIO_ERR_PRINTLN(...) {}
+  #define AIO_ERR_PRINTBUFFER(buffer, len) {}
+#endif
+
 #define AIO_PING_INTERVAL 60000
 #define AIO_THROTTLE_RECONNECT_INTERVAL 60000