Avnet / Mbed 2 deprecated WNCInterface_M2Xdemo

This example program uses the ARM mbed HTTP client library to send/receive data to/from AT&T's M2X service (https://m2x.att.com/) using the AT&T Cellular IoT Starter Kit from Avnet (http://cloudconnectkits.org/product/att-cellular-iot-starter-kit). This kit contains a FRDM-K64F from NXP (https://developer.mbed.org/platforms/FRDM-K64F/).

Dependencies:   M2XStreamClient-JMF WNCInterface jsonlite mbed-rtos mbed

See the README for details on this example program. NOTE: When started, the program can take up to 40 seconds before it will respond. This delay is the time required for the WNC Data Module to connect with the network.

main.cpp@1:1c840717deea, 2016-09-27 (annotated)

Committer:
JMF
Date:
Tue Sep 27 20:02:21 2016 +0000
Revision:
1:1c840717deea
Parent:
0:62feed0f1fd9
Child:
2:eb0768c06c1b
Adding code to initialize stdio/stderr output, moved out of WNCInterface.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
JMF 0:62feed0f1fd9 1 //
JMF 0:62feed0f1fd9 2 // This file contains an example implementation of M2X using the HTTP interface as the underlying
JMF 0:62feed0f1fd9 3 // transport.
JMF 0:62feed0f1fd9 4 //
JMF 0:62feed0f1fd9 5
JMF 0:62feed0f1fd9 6 #include "mbed.h"
JMF 0:62feed0f1fd9 7 #include "WNCInterface.h"
JMF 0:62feed0f1fd9 8
JMF 0:62feed0f1fd9 9 #define MBED_PLATFORM
JMF 0:62feed0f1fd9 10 #define M2X_ENABLE_READER
JMF 0:62feed0f1fd9 11
JMF 0:62feed0f1fd9 12 #include <jsonlite.h>
JMF 0:62feed0f1fd9 13 #include "M2XStreamClient.h"
JMF 0:62feed0f1fd9 14
JMF 0:62feed0f1fd9 15 #define CRLF "\n\r"
JMF 0:62feed0f1fd9 16
JMF 0:62feed0f1fd9 17 char deviceId[] = "e83cdd8645ab1a7c0c480156efbf78f6"; // Device you want to post to
JMF 0:62feed0f1fd9 18 char m2xKey[] = "4d7e1da7f05c3fa4d5426419891a254d"; // Your M2X API Key or Master API Key
JMF 0:62feed0f1fd9 19
JMF 0:62feed0f1fd9 20 const char *hstreamName = "humidity";
JMF 0:62feed0f1fd9 21 const char *tstreamName = "temperature";
JMF 0:62feed0f1fd9 22 const char *streamNames[] = { tstreamName, hstreamName };
JMF 0:62feed0f1fd9 23 char name[] = "Wake Forest"; // Name of current location of datasource
JMF 0:62feed0f1fd9 24
JMF 0:62feed0f1fd9 25 int counts[] = { 2, 1 };
JMF 0:62feed0f1fd9 26 const char *ats[] = { "2016-09-09T02:05:14.692Z",
JMF 0:62feed0f1fd9 27 "2016-09-09T02:05:14.700Z",
JMF 0:62feed0f1fd9 28 "2016-09-09T02:05:14.692Z" };
JMF 0:62feed0f1fd9 29 double values[] = { 10.9, 11.2, 6.1 };
JMF 0:62feed0f1fd9 30
JMF 0:62feed0f1fd9 31 char fromTime[]= "1969-12-31T19:00:01.000Z"; // yyyy-mm-ddTHH:MM:SS.SSSZ
JMF 0:62feed0f1fd9 32 char endTime[25];
JMF 0:62feed0f1fd9 33
JMF 0:62feed0f1fd9 34 double latitude = 33.007872; // You could read these values from a GPS but
JMF 0:62feed0f1fd9 35 double longitude = -96.751614; // for now, will just hardcode them
JMF 0:62feed0f1fd9 36 double elevation = 697.00;
JMF 0:62feed0f1fd9 37
JMF 0:62feed0f1fd9 38 WNCInterface eth;
JMF 0:62feed0f1fd9 39 Client client;
JMF 0:62feed0f1fd9 40 M2XStreamClient m2xClient(&client, m2xKey);
JMF 0:62feed0f1fd9 41 TimeService timeService(&m2xClient);
JMF 1:1c840717deea 42 MODSERIAL pc(USBTX,USBRX,256,256);
JMF 0:62feed0f1fd9 43
JMF 0:62feed0f1fd9 44 void on_data_point_found(const char* at, const char* value, int index, void* context, int type) {
JMF 0:62feed0f1fd9 45 printf(">>Found a data point, index: %d type: %d" CRLF, index, type);
JMF 0:62feed0f1fd9 46 printf(">>At: %s" CRLF " Value: %s" CRLF, at, value);
JMF 0:62feed0f1fd9 47 }
JMF 0:62feed0f1fd9 48
JMF 0:62feed0f1fd9 49
JMF 0:62feed0f1fd9 50 void on_command_found(const char* id, const char* name, int index, void *context) {
JMF 0:62feed0f1fd9 51 printf(">>Found a command, index: %d" CRLF, index);
JMF 0:62feed0f1fd9 52 printf(">>ID: %s\n Name: %s" CRLF, id, name);
JMF 0:62feed0f1fd9 53 }
JMF 0:62feed0f1fd9 54
JMF 0:62feed0f1fd9 55 void on_location_found(const char* name,
JMF 0:62feed0f1fd9 56 double latitude,
JMF 0:62feed0f1fd9 57 double longitude,
JMF 0:62feed0f1fd9 58 double elevation,
JMF 0:62feed0f1fd9 59 const char* timestamp,
JMF 0:62feed0f1fd9 60 int index,
JMF 0:62feed0f1fd9 61 void* context) {
JMF 0:62feed0f1fd9 62 printf(">>Found a location, index: %d" CRLF, index);
JMF 0:62feed0f1fd9 63 printf(">>Name: %s" CRLF ">>Latitude: %lf" CRLF ">>Longitude: %lf" CRLF, name, latitude, longitude);
JMF 0:62feed0f1fd9 64 printf(">>Elevation: %lf" CRLF ">>Timestamp: %s" CRLF, elevation, timestamp);
JMF 0:62feed0f1fd9 65 }
JMF 0:62feed0f1fd9 66
JMF 0:62feed0f1fd9 67 int main() {
JMF 0:62feed0f1fd9 68 char timestamp[25];
JMF 0:62feed0f1fd9 69 int length = 25;
JMF 0:62feed0f1fd9 70 char amb_temp[6];
JMF 0:62feed0f1fd9 71 char amb_humd[6];
JMF 0:62feed0f1fd9 72 int response, cnt=1;
JMF 0:62feed0f1fd9 73 double temp=0.00; //we will just increment these 0.01 each time through the loop
JMF 0:62feed0f1fd9 74 double humid=0.00; //we will just increment these 1 each time through the loop wrapping at 100
JMF 0:62feed0f1fd9 75
JMF 1:1c840717deea 76 pc.baud(115200);
JMF 0:62feed0f1fd9 77 printf("Start m2x-demo-all by initializng the network" CRLF);
JMF 0:62feed0f1fd9 78 response = eth.init();
JMF 0:62feed0f1fd9 79 printf("WNC Module %s initialized (%02X)." CRLF, response?"IS":"IS NOT", response);
JMF 0:62feed0f1fd9 80 if( !response ) {
JMF 0:62feed0f1fd9 81 printf(" - - - - - - - ALL DONE - - - - - - - " CRLF);
JMF 0:62feed0f1fd9 82 while(1);
JMF 0:62feed0f1fd9 83 }
JMF 0:62feed0f1fd9 84
JMF 0:62feed0f1fd9 85 response = eth.connect();
JMF 0:62feed0f1fd9 86 printf("IP Address: %s " CRLF CRLF, eth.getIPAddress());
JMF 0:62feed0f1fd9 87
JMF 0:62feed0f1fd9 88 printf("initialize the M2X time service" CRLF);
JMF 0:62feed0f1fd9 89 if (!m2x_status_is_success(timeService.init()))
JMF 0:62feed0f1fd9 90 printf("Cannot initialize time service!" CRLF);
JMF 0:62feed0f1fd9 91 else {
JMF 0:62feed0f1fd9 92 timeService.getTimestamp(timestamp, &length);
JMF 0:62feed0f1fd9 93 printf("Current timestamp: %s" CRLF, timestamp);
JMF 0:62feed0f1fd9 94 strcpy(endTime,timestamp);
JMF 0:62feed0f1fd9 95 }
JMF 0:62feed0f1fd9 96
JMF 0:62feed0f1fd9 97 printf("Now delete all existing values" CRLF);
JMF 0:62feed0f1fd9 98 // Delete values
JMF 0:62feed0f1fd9 99 printf("Delete humidity values..." CRLF);
JMF 0:62feed0f1fd9 100 response = m2xClient.deleteValues(deviceId,hstreamName, fromTime, endTime);
JMF 0:62feed0f1fd9 101 printf("Delete response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 102
JMF 0:62feed0f1fd9 103 printf("Delete temp values..." CRLF);
JMF 0:62feed0f1fd9 104 response = m2xClient.deleteValues(deviceId,tstreamName, fromTime, endTime);
JMF 0:62feed0f1fd9 105 printf("Delete response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 106
JMF 0:62feed0f1fd9 107 printf("Delete location values..." CRLF);
JMF 0:62feed0f1fd9 108 response = m2xClient.deleteLocations(deviceId, fromTime, endTime);
JMF 0:62feed0f1fd9 109 printf("Delete response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 110
JMF 0:62feed0f1fd9 111 printf("Query for possible commands using this device..." CRLF);
JMF 0:62feed0f1fd9 112 response = m2xClient.listCommands(deviceId, on_command_found, NULL);
JMF 0:62feed0f1fd9 113 printf("listCommands response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 114
JMF 0:62feed0f1fd9 115 while (true) {
JMF 0:62feed0f1fd9 116 // read temp -- for now, just use a fixed temp, but will need to read the HTS221
JMF 0:62feed0f1fd9 117 // and put it into a 6 byte string formatted as "%0.2f"
JMF 0:62feed0f1fd9 118 sprintf(amb_temp,"%0.2f",temp);
JMF 0:62feed0f1fd9 119 sprintf(amb_humd,"%0.2f",humid);
JMF 0:62feed0f1fd9 120 temp += .01;
JMF 0:62feed0f1fd9 121 humid += 1.0;
JMF 0:62feed0f1fd9 122 humid = fmod(humid,100.0);
JMF 0:62feed0f1fd9 123 printf("cnt=%d\r\n",cnt++);
JMF 0:62feed0f1fd9 124 // post the humidity value
JMF 0:62feed0f1fd9 125 printf("Post updateStreamValue (humidity)..." CRLF);
JMF 0:62feed0f1fd9 126 response = m2xClient.updateStreamValue(deviceId, "humidity", humid);
JMF 0:62feed0f1fd9 127 printf("Post response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 128
JMF 0:62feed0f1fd9 129 // post the temp value
JMF 0:62feed0f1fd9 130 printf("Post updateStreamValue (temp)..." CRLF);
JMF 0:62feed0f1fd9 131 response = m2xClient.updateStreamValue(deviceId, "temperature", temp);
JMF 0:62feed0f1fd9 132 printf("Post response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 133
JMF 0:62feed0f1fd9 134 // read temperature
JMF 0:62feed0f1fd9 135 printf("listStreamValues (temp)..." CRLF);
JMF 0:62feed0f1fd9 136 response = m2xClient.listStreamValues(deviceId, tstreamName, on_data_point_found, NULL);
JMF 0:62feed0f1fd9 137 printf("listStreamValues response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 138 if (response == -1) while (true) ;
JMF 0:62feed0f1fd9 139
JMF 0:62feed0f1fd9 140 // read temperature
JMF 0:62feed0f1fd9 141 printf("listStreamValues (humid)..." CRLF);
JMF 0:62feed0f1fd9 142 response = m2xClient.listStreamValues(deviceId, hstreamName, on_data_point_found, NULL);
JMF 0:62feed0f1fd9 143 printf("listStreamValues response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 144 if (response == -1) while (true) ;
JMF 0:62feed0f1fd9 145
JMF 0:62feed0f1fd9 146 // update location
JMF 0:62feed0f1fd9 147 printf("updateLocation..." CRLF);
JMF 0:62feed0f1fd9 148 response = m2xClient.updateLocation(deviceId, name, latitude, longitude, elevation);
JMF 0:62feed0f1fd9 149 printf("updateLocation response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 150 if (response == -1) while (true) ;
JMF 0:62feed0f1fd9 151
JMF 0:62feed0f1fd9 152 // read location
JMF 0:62feed0f1fd9 153 printf("readLocation..." CRLF);
JMF 0:62feed0f1fd9 154 int response = m2xClient.readLocation(deviceId, on_location_found, NULL);
JMF 0:62feed0f1fd9 155 printf("readLocation response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 156
JMF 0:62feed0f1fd9 157 printf("PostDeviceUpdates..." CRLF);
JMF 0:62feed0f1fd9 158 response = m2xClient.postDeviceUpdates(deviceId, 2, streamNames, counts, ats, values);
JMF 0:62feed0f1fd9 159 printf("Post response code: %d" CRLF, response);
JMF 0:62feed0f1fd9 160
JMF 0:62feed0f1fd9 161 timeService.getTimestamp(timestamp, &length);
JMF 0:62feed0f1fd9 162 printf("Thats all folks, got to wait 60 seconds... (%s)" CRLF CRLF CRLF, timestamp);
JMF 0:62feed0f1fd9 163
JMF 0:62feed0f1fd9 164 // wait 60 secs and then loop
JMF 0:62feed0f1fd9 165 delay(6000);
JMF 0:62feed0f1fd9 166
JMF 0:62feed0f1fd9 167
JMF 0:62feed0f1fd9 168 }
JMF 0:62feed0f1fd9 169 }
JMF 0:62feed0f1fd9 170