Diff: main.cpp

Revision:

0:62feed0f1fd9

Child:

1:1c840717deea

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/main.cpp	Wed Sep 21 16:22:43 2016 +0000
@@ -0,0 +1,168 @@
+//
+// This file contains an example implementation of M2X using the HTTP interface as the underlying 
+// transport.
+//
+
+#include "mbed.h"
+#include "WNCInterface.h"
+
+#define MBED_PLATFORM
+#define M2X_ENABLE_READER
+
+#include <jsonlite.h>
+#include "M2XStreamClient.h"
+
+#define CRLF "\n\r"
+
+char deviceId[] = "e83cdd8645ab1a7c0c480156efbf78f6"; // Device you want to post to
+char m2xKey[]   = "4d7e1da7f05c3fa4d5426419891a254d"; // Your M2X API Key or Master API Key
+
+const char *hstreamName = "humidity";
+const char *tstreamName = "temperature";
+const char *streamNames[] = { tstreamName, hstreamName };
+char name[] = "Wake Forest"; // Name of current location of datasource
+
+int counts[] = { 2, 1 };
+const char *ats[] = { "2016-09-09T02:05:14.692Z", 
+                      "2016-09-09T02:05:14.700Z", 
+                      "2016-09-09T02:05:14.692Z" };
+double values[] = { 10.9, 11.2, 6.1 };
+
+char fromTime[]= "1969-12-31T19:00:01.000Z"; // yyyy-mm-ddTHH:MM:SS.SSSZ
+char endTime[25];
+
+double latitude = 33.007872;   // You could read these values from a GPS but
+double longitude = -96.751614; // for now, will just hardcode them
+double elevation = 697.00;
+
+WNCInterface eth;
+Client client;
+M2XStreamClient m2xClient(&client, m2xKey);
+TimeService timeService(&m2xClient);
+
+void on_data_point_found(const char* at, const char* value, int index, void* context, int type) {
+  printf(">>Found a data point, index: %d type: %d" CRLF, index, type);
+  printf(">>At: %s" CRLF " Value: %s" CRLF, at, value);
+}
+
+
+void on_command_found(const char* id, const char* name, int index, void *context) {
+  printf(">>Found a command, index: %d" CRLF, index);
+  printf(">>ID: %s\n Name: %s" CRLF, id, name);
+}
+
+void on_location_found(const char* name,
+                       double latitude,
+                       double longitude,
+                       double elevation,
+                       const char* timestamp,
+                       int index,
+                       void* context) {
+  printf(">>Found a location, index: %d" CRLF, index);
+  printf(">>Name: %s" CRLF ">>Latitude: %lf" CRLF ">>Longitude: %lf" CRLF, name, latitude, longitude);
+  printf(">>Elevation: %lf" CRLF ">>Timestamp: %s" CRLF, elevation, timestamp);
+}
+
+int main() {
+  char timestamp[25];
+  int length = 25;
+  char amb_temp[6];
+  char amb_humd[6];
+  int response, cnt=1;
+  double temp=0.00;  //we will just increment these 0.01 each time through the loop
+  double humid=0.00; //we will just increment these 1 each time through the loop wrapping at 100
+
+  printf("Start m2x-demo-all by initializng the network" CRLF);
+  response = eth.init();                     
+  printf("WNC Module %s initialized (%02X)." CRLF, response?"IS":"IS NOT", response);
+  if( !response ) {
+      printf(" - - - - - - - ALL DONE - - - - - - - " CRLF);
+      while(1);
+  }
+        
+    response = eth.connect();                 
+    printf("IP Address: %s " CRLF CRLF, eth.getIPAddress());
+
+  printf("initialize the M2X time service" CRLF);
+  if (!m2x_status_is_success(timeService.init())) 
+    printf("Cannot initialize time service!" CRLF);
+  else {
+    timeService.getTimestamp(timestamp, &length);
+    printf("Current timestamp: %s" CRLF, timestamp);
+    strcpy(endTime,timestamp);
+  }
+  
+  printf("Now delete all existing values" CRLF);
+  // Delete values
+  printf("Delete humidity values..." CRLF);
+  response = m2xClient.deleteValues(deviceId,hstreamName, fromTime, endTime);
+  printf("Delete response code: %d" CRLF, response); 
+
+  printf("Delete temp values..." CRLF);
+  response = m2xClient.deleteValues(deviceId,tstreamName, fromTime, endTime);
+  printf("Delete response code: %d" CRLF, response);  
+
+  printf("Delete location values..." CRLF);
+  response = m2xClient.deleteLocations(deviceId, fromTime, endTime);
+  printf("Delete response code: %d" CRLF, response);  
+  
+  printf("Query for possible commands using this device..." CRLF);
+  response = m2xClient.listCommands(deviceId, on_command_found, NULL);
+  printf("listCommands response code: %d" CRLF, response);  
+
+  while (true) {
+    // read temp -- for now, just use a fixed temp, but will need to read the HTS221
+    // and put it into a 6 byte string formatted as "%0.2f"
+    sprintf(amb_temp,"%0.2f",temp);
+    sprintf(amb_humd,"%0.2f",humid);
+    temp  += .01;
+    humid += 1.0;
+    humid = fmod(humid,100.0);
+    printf("cnt=%d\r\n",cnt++);
+    // post the humidity value
+    printf("Post updateStreamValue (humidity)..." CRLF);
+    response = m2xClient.updateStreamValue(deviceId, "humidity", humid);
+    printf("Post response code: %d" CRLF, response);
+
+    // post the temp value
+    printf("Post updateStreamValue (temp)..." CRLF);
+    response = m2xClient.updateStreamValue(deviceId, "temperature", temp);
+    printf("Post response code: %d" CRLF, response);
+
+    // read temperature
+    printf("listStreamValues (temp)..." CRLF);
+    response = m2xClient.listStreamValues(deviceId, tstreamName, on_data_point_found, NULL);
+    printf("listStreamValues response code: %d" CRLF, response);
+    if (response == -1) while (true) ;
+
+    // read temperature
+    printf("listStreamValues (humid)..." CRLF);
+    response = m2xClient.listStreamValues(deviceId, hstreamName, on_data_point_found, NULL);
+    printf("listStreamValues response code: %d" CRLF, response);
+    if (response == -1) while (true) ;
+
+    // update location
+    printf("updateLocation..." CRLF);
+    response = m2xClient.updateLocation(deviceId, name, latitude, longitude, elevation);
+    printf("updateLocation response code: %d" CRLF, response);
+    if (response == -1) while (true) ;
+    
+    // read location
+    printf("readLocation..." CRLF);
+    int response = m2xClient.readLocation(deviceId, on_location_found, NULL);
+    printf("readLocation response code: %d" CRLF, response);
+
+    printf("PostDeviceUpdates..." CRLF);
+    response = m2xClient.postDeviceUpdates(deviceId, 2, streamNames, counts, ats, values);
+    printf("Post response code: %d" CRLF, response);
+       
+    timeService.getTimestamp(timestamp, &length);
+    printf("Thats all folks, got to wait 60 seconds... (%s)" CRLF CRLF CRLF, timestamp);
+
+    // wait 60 secs and then loop
+    delay(6000);
+
+    
+  }
+}
+