working feed exists call

Author: toddtreece

AdafruitIO_Feed.cpp

@@ -47,6 +47,12 @@ AdafruitIO_Feed::~AdafruitIO_Feed()
 
   if(_topic)
     free(_topic);
+
+  if(_feed_url)
+    free(_feed_url);
+
+  if(_create_url)
+    free(_create_url);
 }
 
 void AdafruitIO_Feed::onMessage(AdafruitIODataCallbackType cb)
@@ -108,6 +114,19 @@ bool AdafruitIO_Feed::save(double value, double lat, double lon, double ele, int
   return _pub->publish(data->toCSV());
 }
 
+bool AdafruitIO_Feed::exists()
+{
+  _io->_http->get(_feed_url);
+  _io->_http->sendHeader("X-AIO-Key", _io->_key);
+  int status = _io->_http->responseStatusCode();
+  return status == 200;
+}
+
+bool AdafruitIO_Feed::create()
+{
+
+}
+
 void AdafruitIO_Feed::setLocation(double lat, double lon, double ele)
 {
   data->setLocation(lat, lon, ele);
@@ -125,20 +144,33 @@ void AdafruitIO_Feed::subCallback(char *val, uint16_t len)
 void AdafruitIO_Feed::_init()
 {
 
-  // dynamically allocate memory for topic
+  // dynamically allocate memory for mqtt topic and REST URLs
   _topic = (char *) malloc(sizeof(char) * (strlen(_io->_username) + strlen(name) + 8)); // 8 extra chars for /f/, /csv & null termination
+  _feed_url = (char *) malloc(sizeof(char) * (strlen(_io->_username) + strlen(name) + 16)); // 16 extra for api path & null term
+  _create_url = (char *) malloc(sizeof(char) * (strlen(_io->_username) + 15)); // 15 extra for api path & null term
 
   // init feed data
   data = new AdafruitIO_Data(this);
 
-  if(_topic) {
+  if(_topic && _create_url && _feed_url) {
 
     // build topic string
     strcpy(_topic, _io->_username);
     strcat(_topic, "/f/");
     strcat(_topic, name);
     strcat(_topic, "/csv");
 
+    // build feed url string
+    strcpy(_feed_url, "/api/v2/");
+    strcat(_feed_url, _io->_username);
+    strcat(_feed_url, "/feeds/");
+    strcat(_feed_url, name);
+
+    // build create url string
+    strcpy(_create_url, "/api/v2/");
+    strcat(_create_url, _io->_username);
+    strcat(_create_url, "/feeds");
+
     // setup subscription
     _sub = new Adafruit_MQTT_Subscribe(_io->_mqtt, _topic);
     _pub = new Adafruit_MQTT_Publish(_io->_mqtt, _topic);
@@ -150,6 +182,8 @@ void AdafruitIO_Feed::_init()
 
     // malloc failed
     _topic = 0;
+    _create_url = 0;
+    _feed_url = 0;
     _sub = 0;
     _pub = 0;
     data = 0;

AdafruitIO_Feed.h

@@ -39,6 +39,9 @@ class AdafruitIO_Feed {
     bool save(float value, double lat=0, double lon=0, double ele=0, int precision=6);
     bool save(double value, double lat=0, double lon=0, double ele=0, int precision=6);
 
+    bool exists();
+    bool create();
+
     void setLocation(double lat, double lon, double ele=0);
 
     void subCallback(char *val, uint16_t len);
@@ -50,6 +53,8 @@ class AdafruitIO_Feed {
     void _init();
 
     char *_topic;
+    char *_create_url;
+    char *_feed_url;
 
     Adafruit_MQTT_Subscribe *_sub;
     Adafruit_MQTT_Publish *_pub;