This program connects to a few sensors via I2C and sends the data collected to a WNC Cellular Module which is located on an Avnet WNC-Shield card.

Dependencies:   FXOS8700CQ MODSERIAL mbed

/media/uploads/kevinkeryk/avnet_logo_tagline_rgb.png

Avnet Cellular IoT Instructions

  • One problematic area is setting the MY_SERVER_URL. When you copy the URL from the flow, you must make sure the MY_SERVER_URL is also set to the appropriate server. It can be either "run-east.att.io" or "run-west.att.io".

Useful Links

Adding Additional Sensors

The FLOW_DEVICE_NAME field must contain the name of the instance of the Virtual Starter Kit in FLOW you will be communicating with. Usually this is "vstarterkit001", but if you have problems communicating you can verify this is correct. Note: This device will not be created until you click the “Initialize” input on the Virtual Device tab of the Starter Kit project in FLOW. At that point, it becomes available in M2X and you can see it as the DEVICE SERIAL field under Devices as in the image below. /media/uploads/JMF/vstarterkit.png

Sensors: When executing, the FRDM-K64F board uploads sensor measurements to AT&T’s Flow environment every 5 seconds, using the Cellular shield board. You can adjust how often you want to do this by editing the SENSOR_UPDATE_INTERVAL_MS value in the header file.

Temperature and humidity: By default, the board reports readings from the HTS221 temperature and humidity sensor. These two values are sent to the HTTP IN /climate port in FLOW with field names “temp” and “humidity”. Temperature is in degrees Fahrenheit and humidity is a %. This default assignment is: iSensorsToReport = TEMP_HUMIDITY_ONLY;

Accelerometer: If you want to expand and use the onboard motion sensor, you can also send 3-axis accelerometer information from the board as “accelX”, “accelY”, and “accelZ”. This is useful if you want to know the stationary position of the board with regards to gravity, or whether it is in motion. These readings are in g’s. To send these values, change the assignment to: iSensorsToReport = TEMP_HUMIDITY_ACCELEROMETER;

PMOD Sensors: If you have a Silicon Labs sensor module that can plug into the PMOD connector on the Cellular shield, you are able to measure proximity, UV light, ambient visible and infrared light from the Si1145 sensor. This PMOD also has a temperature and humidity sensor, but in this case it is redundant. When enabled, the fields “proximity”, “light_uv”, “light_vis” and “light_ir” are also sent. To enable all these sensors, change the assignment to: iSensorsToReport = TEMP_HUMIDITY_ACCELEROMETER_PMODSENSORS;

Connecting the PMOD sensors: Because the pinouts do not align, the SiLabs PMOD sensor board cannot be plugged into the J10 PMOD receptacle on the shield directly. The following wiring instructions must be followed:

SignalJ10ShieldPMOD Color in the image below
VCCPin 6Pin 6Red
GNDPin 5Pin 5Black
SDAPin4Pin 3Green
SCLPin3Pin 2Yellow

/media/uploads/JMF/xyz.jpg

AT&T M2X and FLOW Instructions

M2X & FLOW Instructions

Link to AT&T M2X

M2X

Link to AT&T Flow

FLOW

Avnet WNC-Shield Information

Getting Started with the Avnet WNC-Shield Software

  • This project uses Revision 119 of the MBED library because of I2C implementation differences with the tip (Revision 121).
  • This project uses Revision 4 of the FXOS8700CQ library for sensors.

Easily Modifiable Parameters

Inside the mbed Avnet_ATT_Cellular_IOT project, the parameters needed to customize your board are in the config_me.h file.

  • FLOW parameters: This project assumes you are using a fork of the Starter Kit Base project, which is a reference design created using AT&T’s FLOW (https://flow.att.com) that allows the creation of online virtualization and other IoT functionality. The default parameters in the config_me.h file are done for a specific instance of this project. When you fork the original project, you get your own instance and it will have its own base address. At the bottom of the FLOW environment, when you click on the Endpoints tab, URL information that is specific to your instance is displayed. Of note is the Base URL. In the example below (as in the default mbed project), the Base URL is: https://run-west.att.io/1e464b19cdcde/774c88d68202/86694923d5bf28a/in/flow You have to take note of two parts of this address. The run-west.att.io part is the server URL, and you have to make sure the
  • MY_SERVER_URL field in config_me.h matches this. The rest of the base URL, in green above, needs to be pasted into the FLOW_BASE_URL field.

There is also a FLOW_INPUT_NAME field. This should match the name of the HTTP IN port in the FLOW project that you want to send sensor data to. The default is "/climate", as in the FLOW image below.

/media/uploads/JMF/sf.png

Where is the Binary I compiled

When the COMPILE button is pressed, it compiles your project and links it. The result is placed in the DOWNLOAD folder you use when downloading files from the Internet. It will be called AvnetATT_shape_hackathon_K64F.bin.

Additional Information on Compiling/Configuring

Comprehensive instructions can be found at: Quick Start Instructions

Committer:
stefanrousseau
Date:
Wed Jul 13 06:10:58 2016 +0000
Revision:
16:17c5916f2d12
Parent:
14:0c353e212296
Child:
17:38a8cc0c6ba5
Merged LED and JSON changes with power-up changes

Who changed what in which revision?

UserRevisionLine numberNew contents of line
JMF 0:9d5134074d84 1 #include "mbed.h"
JMF 0:9d5134074d84 2 #include <cctype>
JMF 0:9d5134074d84 3 #include <string>
JMF 0:9d5134074d84 4 #include "SerialBuffered.h"
JMF 0:9d5134074d84 5 #include "HTS221.h"
JMF 2:0e2ef866af95 6 #include "config_me.h"
JMF 2:0e2ef866af95 7 #include "wnc_control.h"
stefanrousseau 4:f83bedd9cab4 8 #include "sensors.h"
JMF 0:9d5134074d84 9
stefanrousseau 11:e6602513730f 10 #include "hardware.h"
stefanrousseau 11:e6602513730f 11 I2C i2c(PTC11, PTC10); //SDA, SCL -- define the I2C pins being used
stefanrousseau 11:e6602513730f 12
JMF 0:9d5134074d84 13 // comment out the following line if color is not supported on the terminal
JMF 0:9d5134074d84 14 #define USE_COLOR
JMF 0:9d5134074d84 15 #ifdef USE_COLOR
JMF 0:9d5134074d84 16 #define BLK "\033[30m"
JMF 0:9d5134074d84 17 #define RED "\033[31m"
JMF 0:9d5134074d84 18 #define GRN "\033[32m"
JMF 0:9d5134074d84 19 #define YEL "\033[33m"
JMF 0:9d5134074d84 20 #define BLU "\033[34m"
JMF 0:9d5134074d84 21 #define MAG "\033[35m"
JMF 0:9d5134074d84 22 #define CYN "\033[36m"
JMF 0:9d5134074d84 23 #define WHT "\033[37m"
JMF 0:9d5134074d84 24 #define DEF "\033[39m"
JMF 0:9d5134074d84 25 #else
JMF 0:9d5134074d84 26 #define BLK
JMF 0:9d5134074d84 27 #define RED
JMF 0:9d5134074d84 28 #define GRN
JMF 0:9d5134074d84 29 #define YEL
JMF 0:9d5134074d84 30 #define BLU
JMF 0:9d5134074d84 31 #define MAG
JMF 0:9d5134074d84 32 #define CYN
JMF 0:9d5134074d84 33 #define WHT
JMF 0:9d5134074d84 34 #define DEF
JMF 0:9d5134074d84 35 #endif
JMF 0:9d5134074d84 36
JMF 0:9d5134074d84 37 #define MDM_DBG_OFF 0
JMF 0:9d5134074d84 38 #define MDM_DBG_AT_CMDS (1 << 0)
JMF 0:9d5134074d84 39 int mdm_dbgmask = MDM_DBG_OFF;
JMF 0:9d5134074d84 40
JMF 0:9d5134074d84 41 Serial pc(USBTX, USBRX);
JMF 0:9d5134074d84 42 SerialBuffered mdm(PTD3, PTD2, 128);
stefanrousseau 16:17c5916f2d12 43 DigitalOut led_green(LED_GREEN);
stefanrousseau 16:17c5916f2d12 44 DigitalOut led_red(LED_RED);
stefanrousseau 16:17c5916f2d12 45 DigitalOut led_blue(LED_BLUE);
JMF 0:9d5134074d84 46
JMF 0:9d5134074d84 47 DigitalOut mdm_uart2_rx_boot_mode_sel(PTC17); // on powerup, 0 = boot mode, 1 = normal boot
JMF 0:9d5134074d84 48 DigitalOut mdm_power_on(PTB9); // 0 = turn modem on, 1 = turn modem off (should be held high for >5 seconds to cycle modem)
JMF 0:9d5134074d84 49 DigitalOut mdm_wakeup_in(PTC2); // 0 = let modem sleep, 1 = keep modem awake -- Note: pulled high on shield
JMF 0:9d5134074d84 50
fkellermavnet 14:0c353e212296 51 DigitalOut mdm_reset(PTC12); // active high
fkellermavnet 14:0c353e212296 52
JMF 0:9d5134074d84 53 DigitalOut shield_3v3_1v8_sig_trans_ena(PTC4); // 0 = disabled (all signals high impedence, 1 = translation active
JMF 0:9d5134074d84 54 DigitalOut mdm_uart1_cts(PTD0);
JMF 0:9d5134074d84 55
JMF 0:9d5134074d84 56 #define TOUPPER(a) (a) //toupper(a)
JMF 0:9d5134074d84 57
JMF 0:9d5134074d84 58 const char ok_str[] = "OK";
JMF 0:9d5134074d84 59 const char error_str[] = "ERROR";
JMF 0:9d5134074d84 60
JMF 0:9d5134074d84 61 #define MDM_OK 0
JMF 0:9d5134074d84 62 #define MDM_ERR_TIMEOUT -1
JMF 0:9d5134074d84 63
JMF 0:9d5134074d84 64 #define MAX_AT_RSP_LEN 255
JMF 0:9d5134074d84 65
JMF 0:9d5134074d84 66 ssize_t mdm_getline(char *buff, size_t size, int timeout_ms) {
JMF 0:9d5134074d84 67 int cin = -1;
JMF 0:9d5134074d84 68 int cin_last;
JMF 0:9d5134074d84 69
JMF 0:9d5134074d84 70 if (NULL == buff || size == 0) {
JMF 0:9d5134074d84 71 return -1;
JMF 0:9d5134074d84 72 }
JMF 0:9d5134074d84 73
JMF 0:9d5134074d84 74 size_t len = 0;
JMF 0:9d5134074d84 75 Timer timer;
JMF 0:9d5134074d84 76 timer.start();
JMF 0:9d5134074d84 77 while ((len < (size-1)) && (timer.read_ms() < timeout_ms)) {
JMF 0:9d5134074d84 78 if (mdm.readable()) {
JMF 0:9d5134074d84 79 cin_last = cin;
JMF 0:9d5134074d84 80 cin = mdm.getc();
JMF 0:9d5134074d84 81 if (isprint(cin)) {
JMF 0:9d5134074d84 82 buff[len++] = (char)cin;
JMF 0:9d5134074d84 83 continue;
JMF 0:9d5134074d84 84 } else if (('\r' == cin_last) && ('\n' == cin)) {
JMF 0:9d5134074d84 85 break;
JMF 0:9d5134074d84 86 }
JMF 0:9d5134074d84 87 }
JMF 0:9d5134074d84 88 wait_ms(1);
JMF 0:9d5134074d84 89 }
JMF 2:0e2ef866af95 90 buff[len] = (char)NULL;
JMF 0:9d5134074d84 91
JMF 0:9d5134074d84 92 return len;
JMF 0:9d5134074d84 93 }
JMF 0:9d5134074d84 94
JMF 0:9d5134074d84 95 int mdm_sendAtCmd(const char *cmd, const char **rsp_list, int timeout_ms) {
JMF 0:9d5134074d84 96 if (cmd && strlen(cmd) > 0) {
JMF 0:9d5134074d84 97 if (mdm_dbgmask & MDM_DBG_AT_CMDS) {
JMF 0:9d5134074d84 98 printf(MAG "ATCMD: " DEF "--> " GRN "%s" DEF "\n", cmd);
JMF 0:9d5134074d84 99 }
JMF 0:9d5134074d84 100 mdm.printf("%s\r\n", cmd);
JMF 0:9d5134074d84 101 }
JMF 0:9d5134074d84 102
JMF 0:9d5134074d84 103 if (rsp_list) {
JMF 0:9d5134074d84 104 Timer timer;
JMF 0:9d5134074d84 105 char rsp[MAX_AT_RSP_LEN+1];
JMF 0:9d5134074d84 106 int len;
JMF 0:9d5134074d84 107
JMF 0:9d5134074d84 108 timer.start();
JMF 0:9d5134074d84 109 while (timer.read_ms() < timeout_ms) {
JMF 0:9d5134074d84 110 len = mdm_getline(rsp, sizeof(rsp), timeout_ms - timer.read_ms());
JMF 0:9d5134074d84 111
JMF 0:9d5134074d84 112 if (len < 0)
JMF 0:9d5134074d84 113 return MDM_ERR_TIMEOUT;
JMF 0:9d5134074d84 114
JMF 0:9d5134074d84 115 if (len == 0)
JMF 0:9d5134074d84 116 continue;
JMF 0:9d5134074d84 117
JMF 0:9d5134074d84 118 if (mdm_dbgmask & MDM_DBG_AT_CMDS) {
JMF 0:9d5134074d84 119 printf(MAG "ATRSP: " DEF "<-- " CYN "%s" DEF "\n", rsp);
JMF 0:9d5134074d84 120 }
JMF 0:9d5134074d84 121
JMF 0:9d5134074d84 122 if (rsp_list) {
JMF 0:9d5134074d84 123 int rsp_idx = 0;
JMF 0:9d5134074d84 124 while (rsp_list[rsp_idx]) {
JMF 0:9d5134074d84 125 if (strcasecmp(rsp, rsp_list[rsp_idx]) == 0) {
JMF 0:9d5134074d84 126 return rsp_idx;
JMF 0:9d5134074d84 127 }
JMF 0:9d5134074d84 128 rsp_idx++;
JMF 0:9d5134074d84 129 }
JMF 0:9d5134074d84 130 }
JMF 0:9d5134074d84 131 }
JMF 0:9d5134074d84 132 return MDM_ERR_TIMEOUT;
JMF 0:9d5134074d84 133 }
JMF 0:9d5134074d84 134 return MDM_OK;
JMF 0:9d5134074d84 135 }
JMF 0:9d5134074d84 136
JMF 0:9d5134074d84 137 int mdm_init(void) {
fkellermavnet 14:0c353e212296 138 // disable signal level translator (necessary
fkellermavnet 14:0c353e212296 139 // for the modem to boot properly)
JMF 0:9d5134074d84 140 shield_3v3_1v8_sig_trans_ena = 0;
JMF 0:9d5134074d84 141
fkellermavnet 14:0c353e212296 142 // Hard reset the modem (doesn't go through
fkellermavnet 14:0c353e212296 143 // the signal level translator)
fkellermavnet 14:0c353e212296 144 mdm_reset = 1;
fkellermavnet 14:0c353e212296 145
fkellermavnet 14:0c353e212296 146 // wait a moment for the modem to react
fkellermavnet 14:0c353e212296 147 wait_ms(10);
fkellermavnet 14:0c353e212296 148
fkellermavnet 14:0c353e212296 149 // Let modem boot
fkellermavnet 14:0c353e212296 150 mdm_reset = 0;
fkellermavnet 14:0c353e212296 151
fkellermavnet 14:0c353e212296 152 // wait a moment for the modem to react
fkellermavnet 14:0c353e212296 153 wait(1.0);
fkellermavnet 14:0c353e212296 154
JMF 0:9d5134074d84 155 // power modem on //off
JMF 0:9d5134074d84 156 mdm_power_on = 0; //1;
JMF 0:9d5134074d84 157
JMF 0:9d5134074d84 158 // insure modem boots into normal operating mode
JMF 0:9d5134074d84 159 // and does not go to sleep when powered on
JMF 0:9d5134074d84 160 mdm_uart2_rx_boot_mode_sel = 1;
JMF 0:9d5134074d84 161 mdm_wakeup_in = 1;
JMF 0:9d5134074d84 162
JMF 0:9d5134074d84 163 // initialze comm with the modem
JMF 0:9d5134074d84 164 mdm.baud(115200);
JMF 2:0e2ef866af95 165 // clear out potential garbage
JMF 2:0e2ef866af95 166 while (mdm.readable())
JMF 2:0e2ef866af95 167 mdm.getc();
JMF 2:0e2ef866af95 168
JMF 0:9d5134074d84 169 mdm_uart1_cts = 0;
JMF 0:9d5134074d84 170
fkellermavnet 14:0c353e212296 171 // wait a moment for the modem to react to signal
fkellermavnet 14:0c353e212296 172 // conditions while the level translator is disabled
fkellermavnet 14:0c353e212296 173 // (sorry, don't have enough information to know
fkellermavnet 14:0c353e212296 174 // what exactly the modem is doing with the current
fkellermavnet 14:0c353e212296 175 // pin settings)
fkellermavnet 14:0c353e212296 176 wait(1.0);
fkellermavnet 14:0c353e212296 177
JMF 0:9d5134074d84 178 // enable the signal level translator to start
JMF 0:9d5134074d84 179 // modem reset process (modem will be powered down)
JMF 0:9d5134074d84 180 shield_3v3_1v8_sig_trans_ena = 1;
JMF 0:9d5134074d84 181
JMF 0:9d5134074d84 182 // Give the modem 60 secons to start responding by
JMF 0:9d5134074d84 183 // sending simple 'AT' commands to modem once per second.
JMF 0:9d5134074d84 184 Timer timer;
JMF 0:9d5134074d84 185 timer.start();
JMF 0:9d5134074d84 186 while (timer.read() < 60) {
JMF 0:9d5134074d84 187 const char * rsp_lst[] = { ok_str, error_str, NULL };
JMF 0:9d5134074d84 188 int rc = mdm_sendAtCmd("AT", rsp_lst, 500);
JMF 0:9d5134074d84 189 if (rc == 0)
fkellermavnet 14:0c353e212296 190 return true; //timer.read();
JMF 0:9d5134074d84 191 wait_ms(1000 - (timer.read_ms() % 1000));
JMF 0:9d5134074d84 192 pc.printf("\r%d",timer.read_ms()/1000);
JMF 0:9d5134074d84 193 }
JMF 0:9d5134074d84 194 return false;
JMF 0:9d5134074d84 195 }
JMF 0:9d5134074d84 196
JMF 2:0e2ef866af95 197 int mdm_sendAtCmdRsp(const char *cmd, const char **rsp_list, int timeout_ms, string * rsp, int * len) {
JMF 2:0e2ef866af95 198 static char cmd_buf[3200]; // Need enough room for the WNC sockreads (over 3000 chars)
fkellermavnet 6:713b4cbf1a7d 199 size_t n = strlen(cmd);
fkellermavnet 6:713b4cbf1a7d 200 if (cmd && n > 0) {
JMF 2:0e2ef866af95 201 if (mdm_dbgmask & MDM_DBG_AT_CMDS) {
JMF 2:0e2ef866af95 202 printf(MAG "ATCMD: " DEF "--> " GRN "%s" DEF "\n", cmd);
JMF 2:0e2ef866af95 203 }
fkellermavnet 6:713b4cbf1a7d 204 while (n--) {
fkellermavnet 6:713b4cbf1a7d 205 mdm.putc(*cmd++);
fkellermavnet 6:713b4cbf1a7d 206 wait_ms(1);
fkellermavnet 6:713b4cbf1a7d 207 };
fkellermavnet 6:713b4cbf1a7d 208 mdm.putc('\r');
fkellermavnet 6:713b4cbf1a7d 209 wait_ms(1);
fkellermavnet 6:713b4cbf1a7d 210 mdm.putc('\n');
fkellermavnet 6:713b4cbf1a7d 211 wait_ms(1);
JMF 2:0e2ef866af95 212 }
JMF 2:0e2ef866af95 213
JMF 2:0e2ef866af95 214 if (rsp_list) {
JMF 2:0e2ef866af95 215 rsp->erase(); // Clean up from prior cmd response
JMF 2:0e2ef866af95 216 *len = 0;
JMF 2:0e2ef866af95 217 Timer timer;
JMF 2:0e2ef866af95 218 timer.start();
JMF 2:0e2ef866af95 219 while (timer.read_ms() < timeout_ms) {
JMF 2:0e2ef866af95 220 int lenCmd = mdm_getline(cmd_buf, sizeof(cmd_buf), timeout_ms - timer.read_ms());
JMF 2:0e2ef866af95 221
JMF 2:0e2ef866af95 222 if (lenCmd == 0)
JMF 2:0e2ef866af95 223 continue;
JMF 2:0e2ef866af95 224
JMF 2:0e2ef866af95 225 if (lenCmd < 0)
JMF 2:0e2ef866af95 226 return MDM_ERR_TIMEOUT;
JMF 2:0e2ef866af95 227 else {
JMF 2:0e2ef866af95 228 *len += lenCmd;
JMF 2:0e2ef866af95 229 *rsp += cmd_buf;
JMF 2:0e2ef866af95 230 }
JMF 2:0e2ef866af95 231
JMF 2:0e2ef866af95 232 if (mdm_dbgmask & MDM_DBG_AT_CMDS) {
JMF 2:0e2ef866af95 233 printf(MAG "ATRSP: " DEF "<-- " CYN "%s" DEF "\n", cmd_buf);
JMF 2:0e2ef866af95 234 }
JMF 2:0e2ef866af95 235
JMF 2:0e2ef866af95 236 int rsp_idx = 0;
JMF 2:0e2ef866af95 237 while (rsp_list[rsp_idx]) {
JMF 2:0e2ef866af95 238 if (strcasecmp(cmd_buf, rsp_list[rsp_idx]) == 0) {
JMF 2:0e2ef866af95 239 return rsp_idx;
JMF 2:0e2ef866af95 240 }
JMF 2:0e2ef866af95 241 rsp_idx++;
JMF 2:0e2ef866af95 242 }
JMF 2:0e2ef866af95 243 }
JMF 2:0e2ef866af95 244 return MDM_ERR_TIMEOUT;
JMF 2:0e2ef866af95 245 }
JMF 2:0e2ef866af95 246 pc.printf("D %s",rsp);
JMF 2:0e2ef866af95 247 return MDM_OK;
JMF 2:0e2ef866af95 248 }
JMF 2:0e2ef866af95 249
JMF 2:0e2ef866af95 250 void reinitialize_mdm(void)
JMF 2:0e2ef866af95 251 {
JMF 2:0e2ef866af95 252 // Initialize the modem
JMF 2:0e2ef866af95 253 printf(GRN "Modem RE-initializing..." DEF "\r\n");
JMF 2:0e2ef866af95 254 if (!mdm_init()) {
JMF 2:0e2ef866af95 255 printf(RED "\n\rModem RE-initialization failed!" DEF "\n");
JMF 2:0e2ef866af95 256 }
JMF 2:0e2ef866af95 257 printf("\r\n");
JMF 2:0e2ef866af95 258 }
JMF 2:0e2ef866af95 259 // These are built on the fly
JMF 2:0e2ef866af95 260 string MyServerIpAddress;
JMF 2:0e2ef866af95 261 string MySocketData;
JMF 2:0e2ef866af95 262
JMF 2:0e2ef866af95 263 // These are to be built on the fly
JMF 2:0e2ef866af95 264 string my_temp;
JMF 2:0e2ef866af95 265 string my_humidity;
JMF 2:0e2ef866af95 266
JMF 0:9d5134074d84 267 #define CTOF(x) ((x)*1.8+32)
JMF 0:9d5134074d84 268
stefanrousseau 3:26b3cc155f39 269 //********************************************************************************************************************************************
stefanrousseau 12:7c94ec5069dc 270 //* Create string with sensor readings that can be sent to flow as an HTTP get
stefanrousseau 3:26b3cc155f39 271 //********************************************************************************************************************************************
stefanrousseau 12:7c94ec5069dc 272 K64F_Sensors_t SENSOR_DATA =
stefanrousseau 3:26b3cc155f39 273 {
stefanrousseau 12:7c94ec5069dc 274 .Temperature = "0",
stefanrousseau 12:7c94ec5069dc 275 .Humidity = "0",
stefanrousseau 12:7c94ec5069dc 276 .AccelX = "0",
stefanrousseau 12:7c94ec5069dc 277 .AccelY = "0",
stefanrousseau 12:7c94ec5069dc 278 .AccelZ = "0",
stefanrousseau 12:7c94ec5069dc 279 .MagnetometerX = "0",
stefanrousseau 12:7c94ec5069dc 280 .MagnetometerY = "0",
stefanrousseau 12:7c94ec5069dc 281 .MagnetometerZ = "0",
stefanrousseau 12:7c94ec5069dc 282 .AmbientLightVis = "0",
stefanrousseau 12:7c94ec5069dc 283 .AmbientLightIr = "0",
stefanrousseau 12:7c94ec5069dc 284 .UVindex = "0",
stefanrousseau 12:7c94ec5069dc 285 .Proximity = "0",
stefanrousseau 12:7c94ec5069dc 286 .Temperature_Si7020 = "0",
stefanrousseau 12:7c94ec5069dc 287 .Humidity_Si7020 = "0"
stefanrousseau 3:26b3cc155f39 288 };
stefanrousseau 12:7c94ec5069dc 289
stefanrousseau 3:26b3cc155f39 290 void GenerateModemString(char * modem_string)
stefanrousseau 3:26b3cc155f39 291 {
stefanrousseau 12:7c94ec5069dc 292 switch(iSensorsToReport)
stefanrousseau 12:7c94ec5069dc 293 {
stefanrousseau 12:7c94ec5069dc 294 case TEMP_HUMIDITY_ONLY:
stefanrousseau 12:7c94ec5069dc 295 {
stefanrousseau 12:7c94ec5069dc 296 sprintf(modem_string, "GET %s%s?serial=%s&temp=%s&humidity=%s %s%s\r\n\r\n", FLOW_BASE_URL, FLOW_INPUT_NAME, FLOW_DEVICE_NAME, SENSOR_DATA.Temperature, SENSOR_DATA.Humidity, FLOW_URL_TYPE, MY_SERVER_URL);
stefanrousseau 12:7c94ec5069dc 297 break;
stefanrousseau 12:7c94ec5069dc 298 }
stefanrousseau 12:7c94ec5069dc 299 case TEMP_HUMIDITY_ACCELEROMETER:
stefanrousseau 12:7c94ec5069dc 300 {
stefanrousseau 12:7c94ec5069dc 301 sprintf(modem_string, "GET %s%s?serial=%s&temp=%s&humidity=%s&accelX=%s&accelY=%s&accelZ=%s %s%s\r\n\r\n", FLOW_BASE_URL, FLOW_INPUT_NAME, FLOW_DEVICE_NAME, SENSOR_DATA.Temperature, SENSOR_DATA.Humidity, SENSOR_DATA.AccelX,SENSOR_DATA.AccelY,SENSOR_DATA.AccelZ, FLOW_URL_TYPE, MY_SERVER_URL);
stefanrousseau 12:7c94ec5069dc 302 break;
stefanrousseau 12:7c94ec5069dc 303 }
stefanrousseau 12:7c94ec5069dc 304 case TEMP_HUMIDITY_ACCELEROMETER_PMODSENSORS:
stefanrousseau 12:7c94ec5069dc 305 {
stefanrousseau 12:7c94ec5069dc 306 sprintf(modem_string, "GET %s%s?serial=%s&temp=%s&humidity=%s&accelX=%s&accelY=%s&accelZ=%s&proximity=%s&light_uv=%s&light_vis=%s&light_ir=%s %s%s\r\n\r\n", FLOW_BASE_URL, FLOW_INPUT_NAME, FLOW_DEVICE_NAME, SENSOR_DATA.Temperature, SENSOR_DATA.Humidity, SENSOR_DATA.AccelX,SENSOR_DATA.AccelY,SENSOR_DATA.AccelZ, SENSOR_DATA.Proximity, SENSOR_DATA.UVindex, SENSOR_DATA.AmbientLightVis, SENSOR_DATA.AmbientLightIr, FLOW_URL_TYPE, MY_SERVER_URL);
stefanrousseau 12:7c94ec5069dc 307 break;
stefanrousseau 12:7c94ec5069dc 308 }
stefanrousseau 12:7c94ec5069dc 309 default:
stefanrousseau 12:7c94ec5069dc 310 {
stefanrousseau 12:7c94ec5069dc 311 sprintf(modem_string, "Invalid sensor selected\r\n\r\n");
stefanrousseau 12:7c94ec5069dc 312 break;
stefanrousseau 12:7c94ec5069dc 313 }
stefanrousseau 16:17c5916f2d12 314 } //switch(iSensorsToReport)
stefanrousseau 3:26b3cc155f39 315 } //GenerateModemString
stefanrousseau 3:26b3cc155f39 316
stefanrousseau 3:26b3cc155f39 317
stefanrousseau 3:26b3cc155f39 318 //Periodic timer
stefanrousseau 3:26b3cc155f39 319 Ticker OneMsTicker;
stefanrousseau 3:26b3cc155f39 320 volatile bool bTimerExpiredFlag = false;
stefanrousseau 3:26b3cc155f39 321 int OneMsTicks = 0;
stefanrousseau 3:26b3cc155f39 322 int iTimer1Interval_ms = 1000;
stefanrousseau 3:26b3cc155f39 323 //********************************************************************************************************************************************
stefanrousseau 3:26b3cc155f39 324 //* Periodic 1ms timer tick
stefanrousseau 3:26b3cc155f39 325 //********************************************************************************************************************************************
stefanrousseau 3:26b3cc155f39 326 void OneMsFunction()
stefanrousseau 3:26b3cc155f39 327 {
stefanrousseau 3:26b3cc155f39 328 OneMsTicks++;
stefanrousseau 3:26b3cc155f39 329 if ((OneMsTicks % iTimer1Interval_ms) == 0)
stefanrousseau 3:26b3cc155f39 330 {
stefanrousseau 3:26b3cc155f39 331 bTimerExpiredFlag = true;
stefanrousseau 3:26b3cc155f39 332 }
stefanrousseau 3:26b3cc155f39 333 } //OneMsFunction()
stefanrousseau 3:26b3cc155f39 334
stefanrousseau 16:17c5916f2d12 335 //********************************************************************************************************************************************
stefanrousseau 16:17c5916f2d12 336 //* Set the RGB LED's Color
stefanrousseau 16:17c5916f2d12 337 //* LED Color 0=Off to 7=White. 3 bits represent BGR (bit0=Red, bit1=Green, bit2=Blue)
stefanrousseau 16:17c5916f2d12 338 //********************************************************************************************************************************************
stefanrousseau 16:17c5916f2d12 339 void SetLedColor(unsigned char ucColor)
stefanrousseau 16:17c5916f2d12 340 {
stefanrousseau 16:17c5916f2d12 341 //Note that when an LED is on, you write a 0 to it:
stefanrousseau 16:17c5916f2d12 342 led_red = !(ucColor & 0x1); //bit 0
stefanrousseau 16:17c5916f2d12 343 led_green = !(ucColor & 0x2); //bit 1
stefanrousseau 16:17c5916f2d12 344 led_blue = !(ucColor & 0x4); //bit 2
stefanrousseau 16:17c5916f2d12 345 } //SetLedColor()
stefanrousseau 16:17c5916f2d12 346
stefanrousseau 16:17c5916f2d12 347 //********************************************************************************************************************************************
stefanrousseau 16:17c5916f2d12 348 //* Process JSON response messages
stefanrousseau 16:17c5916f2d12 349 //********************************************************************************************************************************************
stefanrousseau 16:17c5916f2d12 350 bool extract_JSON(char* search_field, char* found_string)
stefanrousseau 16:17c5916f2d12 351 {
stefanrousseau 16:17c5916f2d12 352 char* beginquote;
stefanrousseau 16:17c5916f2d12 353 char* endquote;
stefanrousseau 16:17c5916f2d12 354 beginquote = strchr(search_field, '{'); //start of JSON
stefanrousseau 16:17c5916f2d12 355 endquote = strchr(search_field, '}'); //end of JSON
stefanrousseau 16:17c5916f2d12 356 if (beginquote != 0)
stefanrousseau 16:17c5916f2d12 357 {
stefanrousseau 16:17c5916f2d12 358 uint16_t ifoundlen;
stefanrousseau 16:17c5916f2d12 359 if (endquote != 0)
stefanrousseau 16:17c5916f2d12 360 {
stefanrousseau 16:17c5916f2d12 361 ifoundlen = (uint16_t) (endquote - beginquote) + 1;
stefanrousseau 16:17c5916f2d12 362 strncpy(found_string, beginquote, ifoundlen );
stefanrousseau 16:17c5916f2d12 363 found_string[ifoundlen] = 0; //null terminate
stefanrousseau 16:17c5916f2d12 364 return true;
stefanrousseau 16:17c5916f2d12 365 }
stefanrousseau 16:17c5916f2d12 366 else
stefanrousseau 16:17c5916f2d12 367 {
stefanrousseau 16:17c5916f2d12 368 endquote = strchr(search_field, '\0'); //end of string... sometimes the end bracket is missing
stefanrousseau 16:17c5916f2d12 369 ifoundlen = (uint16_t) (endquote - beginquote) + 1;
stefanrousseau 16:17c5916f2d12 370 strncpy(found_string, beginquote, ifoundlen );
stefanrousseau 16:17c5916f2d12 371 found_string[ifoundlen] = 0; //null terminate
stefanrousseau 16:17c5916f2d12 372 return false;
stefanrousseau 16:17c5916f2d12 373 }
stefanrousseau 16:17c5916f2d12 374 }
stefanrousseau 16:17c5916f2d12 375 else
stefanrousseau 16:17c5916f2d12 376 {
stefanrousseau 16:17c5916f2d12 377 return false;
stefanrousseau 16:17c5916f2d12 378 }
stefanrousseau 16:17c5916f2d12 379 } //extract_JSON
stefanrousseau 16:17c5916f2d12 380
stefanrousseau 16:17c5916f2d12 381 bool parse_JSON(char* json_string)
stefanrousseau 16:17c5916f2d12 382 {
stefanrousseau 16:17c5916f2d12 383 char* beginquote;
stefanrousseau 16:17c5916f2d12 384 char token[] = "\"LED\":\"";
stefanrousseau 16:17c5916f2d12 385 beginquote = strstr(json_string, token );
stefanrousseau 16:17c5916f2d12 386 if ((beginquote != 0))
stefanrousseau 16:17c5916f2d12 387 {
stefanrousseau 16:17c5916f2d12 388 char cLedColor = beginquote[strlen(token)];
stefanrousseau 16:17c5916f2d12 389 printf(GRN "LED Found : %c" DEF "\r\n", cLedColor);
stefanrousseau 16:17c5916f2d12 390 switch(cLedColor)
stefanrousseau 16:17c5916f2d12 391 {
stefanrousseau 16:17c5916f2d12 392 case 'O':
stefanrousseau 16:17c5916f2d12 393 { //Off
stefanrousseau 16:17c5916f2d12 394 SetLedColor(0);
stefanrousseau 16:17c5916f2d12 395 break;
stefanrousseau 16:17c5916f2d12 396 }
stefanrousseau 16:17c5916f2d12 397 case 'R':
stefanrousseau 16:17c5916f2d12 398 { //Red
stefanrousseau 16:17c5916f2d12 399 SetLedColor(1);
stefanrousseau 16:17c5916f2d12 400 break;
stefanrousseau 16:17c5916f2d12 401 }
stefanrousseau 16:17c5916f2d12 402 case 'G':
stefanrousseau 16:17c5916f2d12 403 { //Green
stefanrousseau 16:17c5916f2d12 404 SetLedColor(2);
stefanrousseau 16:17c5916f2d12 405 break;
stefanrousseau 16:17c5916f2d12 406 }
stefanrousseau 16:17c5916f2d12 407 case 'Y':
stefanrousseau 16:17c5916f2d12 408 { //Yellow
stefanrousseau 16:17c5916f2d12 409 SetLedColor(3);
stefanrousseau 16:17c5916f2d12 410 break;
stefanrousseau 16:17c5916f2d12 411 }
stefanrousseau 16:17c5916f2d12 412 case 'B':
stefanrousseau 16:17c5916f2d12 413 { //Blue
stefanrousseau 16:17c5916f2d12 414 SetLedColor(4);
stefanrousseau 16:17c5916f2d12 415 break;
stefanrousseau 16:17c5916f2d12 416 }
stefanrousseau 16:17c5916f2d12 417 case 'M':
stefanrousseau 16:17c5916f2d12 418 { //Magenta
stefanrousseau 16:17c5916f2d12 419 SetLedColor(5);
stefanrousseau 16:17c5916f2d12 420 break;
stefanrousseau 16:17c5916f2d12 421 }
stefanrousseau 16:17c5916f2d12 422 case 'T':
stefanrousseau 16:17c5916f2d12 423 { //Turquoise
stefanrousseau 16:17c5916f2d12 424 SetLedColor(6);
stefanrousseau 16:17c5916f2d12 425 break;
stefanrousseau 16:17c5916f2d12 426 }
stefanrousseau 16:17c5916f2d12 427 case 'W':
stefanrousseau 16:17c5916f2d12 428 { //White
stefanrousseau 16:17c5916f2d12 429 SetLedColor(7);
stefanrousseau 16:17c5916f2d12 430 break;
stefanrousseau 16:17c5916f2d12 431 }
stefanrousseau 16:17c5916f2d12 432 default:
stefanrousseau 16:17c5916f2d12 433 {
stefanrousseau 16:17c5916f2d12 434 break;
stefanrousseau 16:17c5916f2d12 435 }
stefanrousseau 16:17c5916f2d12 436 } //switch(cLedColor)
stefanrousseau 16:17c5916f2d12 437 return true;
stefanrousseau 16:17c5916f2d12 438 }
stefanrousseau 16:17c5916f2d12 439 else
stefanrousseau 16:17c5916f2d12 440 {
stefanrousseau 16:17c5916f2d12 441 return false;
stefanrousseau 16:17c5916f2d12 442 }
stefanrousseau 16:17c5916f2d12 443 } //parse_JSON
stefanrousseau 16:17c5916f2d12 444
JMF 0:9d5134074d84 445 int main() {
JMF 2:0e2ef866af95 446 int i;
JMF 0:9d5134074d84 447 HTS221 hts221;
JMF 0:9d5134074d84 448 pc.baud(115200);
JMF 0:9d5134074d84 449
JMF 0:9d5134074d84 450 void hts221_init(void);
JMF 0:9d5134074d84 451
JMF 1:af7a42f7d465 452 pc.printf(BLU "Hello World from AT&T Shape!\r\n\n\r");
JMF 0:9d5134074d84 453 pc.printf(GRN "Initialize the HTS221\n\r");
JMF 0:9d5134074d84 454
JMF 0:9d5134074d84 455 i = hts221.begin();
JMF 0:9d5134074d84 456 if( i )
JMF 0:9d5134074d84 457 pc.printf(BLU "HTS221 Detected! (0x%02X)\n\r",i);
JMF 0:9d5134074d84 458 else
JMF 0:9d5134074d84 459 pc.printf(RED "HTS221 NOT DETECTED!!\n\r");
JMF 0:9d5134074d84 460
JMF 0:9d5134074d84 461 printf("Temp is: %0.2f F \n\r",CTOF(hts221.readTemperature()));
JMF 0:9d5134074d84 462 printf("Humid is: %02d %%\n\r",hts221.readHumidity());
JMF 0:9d5134074d84 463
stefanrousseau 16:17c5916f2d12 464 SetLedColor(0); //Off
stefanrousseau 11:e6602513730f 465 sensors_init();
stefanrousseau 12:7c94ec5069dc 466 read_sensors();
stefanrousseau 11:e6602513730f 467
JMF 0:9d5134074d84 468 // Initialize the modem
JMF 0:9d5134074d84 469 printf(GRN "Modem initializing... will take up to 60 seconds" DEF "\r\n");
fkellermavnet 14:0c353e212296 470 do {
fkellermavnet 14:0c353e212296 471 i=mdm_init();
fkellermavnet 14:0c353e212296 472 if (!i) {
fkellermavnet 14:0c353e212296 473 pc.printf(RED "Modem initialization failed!" DEF "\n");
fkellermavnet 14:0c353e212296 474 }
fkellermavnet 14:0c353e212296 475 } while (!i);
JMF 0:9d5134074d84 476
JMF 2:0e2ef866af95 477 //Software init
JMF 2:0e2ef866af95 478 software_init_mdm();
JMF 2:0e2ef866af95 479
JMF 2:0e2ef866af95 480 // Resolve URL to IP address to connect to
JMF 2:0e2ef866af95 481 resolve_mdm();
JMF 0:9d5134074d84 482
stefanrousseau 3:26b3cc155f39 483 //Create a 1ms timer tick function:
stefanrousseau 3:26b3cc155f39 484 OneMsTicker.attach(OneMsFunction, 0.001f) ;
stefanrousseau 3:26b3cc155f39 485 iTimer1Interval_ms = 5000; //5 seconds
stefanrousseau 3:26b3cc155f39 486
JMF 2:0e2ef866af95 487 // Send and receive data perpetually
JMF 2:0e2ef866af95 488 while(1) {
stefanrousseau 3:26b3cc155f39 489 if (bTimerExpiredFlag)
stefanrousseau 3:26b3cc155f39 490 {
stefanrousseau 3:26b3cc155f39 491 bTimerExpiredFlag = false;
stefanrousseau 3:26b3cc155f39 492 sprintf(SENSOR_DATA.Temperature, "%0.2f", CTOF(hts221.readTemperature()));
stefanrousseau 3:26b3cc155f39 493 sprintf(SENSOR_DATA.Humidity, "%02d", hts221.readHumidity());
stefanrousseau 4:f83bedd9cab4 494 read_sensors(); //read available external sensors from a PMOD and the on-board motion sensor
stefanrousseau 3:26b3cc155f39 495 sockopen_mdm();
stefanrousseau 3:26b3cc155f39 496 char modem_string[512];
stefanrousseau 3:26b3cc155f39 497 GenerateModemString(&modem_string[0]);
stefanrousseau 16:17c5916f2d12 498 printf(BLU "Sending to modem : %s" DEF "\n", modem_string);
stefanrousseau 3:26b3cc155f39 499 sockwrite_mdm(modem_string);
stefanrousseau 3:26b3cc155f39 500 sockread_mdm(&MySocketData, 1024, 20);
stefanrousseau 16:17c5916f2d12 501 printf(BLU "Read back : %s" DEF "\n", &MySocketData[0]);
stefanrousseau 16:17c5916f2d12 502 char * myJsonResponse;
stefanrousseau 16:17c5916f2d12 503 if (extract_JSON(&MySocketData[0], &myJsonResponse[0]))
stefanrousseau 16:17c5916f2d12 504 {
stefanrousseau 16:17c5916f2d12 505 printf(GRN "JSON : %s" DEF "\n", &myJsonResponse[0]);
stefanrousseau 16:17c5916f2d12 506 parse_JSON(&myJsonResponse[0]);
stefanrousseau 16:17c5916f2d12 507 }
stefanrousseau 16:17c5916f2d12 508 else
stefanrousseau 16:17c5916f2d12 509 {
stefanrousseau 16:17c5916f2d12 510 printf(RED "JSON : %s" DEF "\n", &myJsonResponse[0]); //most likely an incomplete JSON string
stefanrousseau 16:17c5916f2d12 511 parse_JSON(&myJsonResponse[0]); //This is risky, as the string may be corrupted
stefanrousseau 16:17c5916f2d12 512 }
stefanrousseau 3:26b3cc155f39 513 sockclose_mdm();
stefanrousseau 3:26b3cc155f39 514 } //bTimerExpiredFlag
stefanrousseau 3:26b3cc155f39 515 } //forever loop
JMF 2:0e2ef866af95 516
stefanrousseau 12:7c94ec5069dc 517 #if (0)
JMF 2:0e2ef866af95 518 string * pStr;
JMF 2:0e2ef866af95 519 while (1)
JMF 2:0e2ef866af95 520 {
JMF 2:0e2ef866af95 521 send_wnc_cmd("AT", &pStr, WNC_TIMEOUT_MS);
JMF 0:9d5134074d84 522 }
stefanrousseau 12:7c94ec5069dc 523 #endif
JMF 0:9d5134074d84 524 }