fatih nar / Mbed 2 deprecated Avnet-StarterKit-Writing2InfluxDB

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependencies:   FXOS8700CQ mbed

Fork of AvnetATT_shape_hackathon by Demo Software for Avnet+AT&T IoT kit.

main.cpp@36:515021fabf15, 2017-10-10 (annotated)

Committer:
fenar
Date:
Tue Oct 10 13:57:44 2017 +0000
Revision:
36:515021fabf15
Parent:
35:4a5d307b9692 
Updates for Additional Sensor Type Measurements

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"
stefanrousseau 11:e6602513730f 9 #include "hardware.h"
stefanrousseau 11:e6602513730f 10 I2C i2c(PTC11, PTC10); //SDA, SCL -- define the I2C pins being used
stefanrousseau 11:e6602513730f 11
JMF 0:9d5134074d84 12 // comment out the following line if color is not supported on the terminal
JMF 0:9d5134074d84 13 #define USE_COLOR
JMF 0:9d5134074d84 14 #ifdef USE_COLOR
JMF 0:9d5134074d84 15 #define BLK "\033[30m"
JMF 0:9d5134074d84 16 #define RED "\033[31m"
JMF 0:9d5134074d84 17 #define GRN "\033[32m"
JMF 0:9d5134074d84 18 #define YEL "\033[33m"
JMF 0:9d5134074d84 19 #define BLU "\033[34m"
JMF 0:9d5134074d84 20 #define MAG "\033[35m"
JMF 0:9d5134074d84 21 #define CYN "\033[36m"
JMF 0:9d5134074d84 22 #define WHT "\033[37m"
JMF 0:9d5134074d84 23 #define DEF "\033[39m"
JMF 0:9d5134074d84 24 #else
JMF 0:9d5134074d84 25 #define BLK
JMF 0:9d5134074d84 26 #define RED
JMF 0:9d5134074d84 27 #define GRN
JMF 0:9d5134074d84 28 #define YEL
JMF 0:9d5134074d84 29 #define BLU
JMF 0:9d5134074d84 30 #define MAG
JMF 0:9d5134074d84 31 #define CYN
JMF 0:9d5134074d84 32 #define WHT
JMF 0:9d5134074d84 33 #define DEF
JMF 0:9d5134074d84 34 #endif
JMF 0:9d5134074d84 35
JMF 0:9d5134074d84 36 #define MDM_DBG_OFF 0
JMF 0:9d5134074d84 37 #define MDM_DBG_AT_CMDS (1 << 0)
JMF 0:9d5134074d84 38 int mdm_dbgmask = MDM_DBG_OFF;
JMF 0:9d5134074d84 39
JMF 0:9d5134074d84 40 Serial pc(USBTX, USBRX);
fenar 35:4a5d307b9692 41 SerialBuffered mdm(PTD3, PTD2, 512);
stefanrousseau 16:17c5916f2d12 42 DigitalOut led_green(LED_GREEN);
stefanrousseau 16:17c5916f2d12 43 DigitalOut led_red(LED_RED);
stefanrousseau 16:17c5916f2d12 44 DigitalOut led_blue(LED_BLUE);
JMF 0:9d5134074d84 45
JMF 0:9d5134074d84 46 DigitalOut mdm_uart2_rx_boot_mode_sel(PTC17); // on powerup, 0 = boot mode, 1 = normal boot
JMF 0:9d5134074d84 47 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 48 DigitalOut mdm_wakeup_in(PTC2); // 0 = let modem sleep, 1 = keep modem awake -- Note: pulled high on shield
JMF 0:9d5134074d84 49
fkellermavnet 14:0c353e212296 50 DigitalOut mdm_reset(PTC12); // active high
fkellermavnet 14:0c353e212296 51
JMF 0:9d5134074d84 52 DigitalOut shield_3v3_1v8_sig_trans_ena(PTC4); // 0 = disabled (all signals high impedence, 1 = translation active
JMF 0:9d5134074d84 53 DigitalOut mdm_uart1_cts(PTD0);
JMF 0:9d5134074d84 54
JMF 0:9d5134074d84 55 #define TOUPPER(a) (a) //toupper(a)
JMF 0:9d5134074d84 56
JMF 0:9d5134074d84 57 const char ok_str[] = "OK";
JMF 0:9d5134074d84 58 const char error_str[] = "ERROR";
JMF 0:9d5134074d84 59
JMF 0:9d5134074d84 60 #define MDM_OK 0
JMF 0:9d5134074d84 61 #define MDM_ERR_TIMEOUT -1
JMF 0:9d5134074d84 62
fenar 35:4a5d307b9692 63 #define MAX_AT_RSP_LEN 511
fenar 35:4a5d307b9692 64
fenar 35:4a5d307b9692 65 //Periodic timer
fenar 35:4a5d307b9692 66 Ticker OneMsTicker;
fenar 35:4a5d307b9692 67 volatile bool bTimerExpiredFlag = false;
fenar 35:4a5d307b9692 68 int OneMsTicks = 0;
fenar 35:4a5d307b9692 69 int iTimer1Interval_ms = SENSOR_UPDATE_INTERVAL_MS;
JMF 0:9d5134074d84 70
JMF 0:9d5134074d84 71 ssize_t mdm_getline(char *buff, size_t size, int timeout_ms) {
JMF 0:9d5134074d84 72 int cin = -1;
JMF 0:9d5134074d84 73 int cin_last;
JMF 0:9d5134074d84 74
JMF 0:9d5134074d84 75 if (NULL == buff || size == 0) {
JMF 0:9d5134074d84 76 return -1;
JMF 0:9d5134074d84 77 }
JMF 0:9d5134074d84 78
JMF 0:9d5134074d84 79 size_t len = 0;
JMF 0:9d5134074d84 80 Timer timer;
JMF 0:9d5134074d84 81 timer.start();
JMF 0:9d5134074d84 82 while ((len < (size-1)) && (timer.read_ms() < timeout_ms)) {
JMF 0:9d5134074d84 83 if (mdm.readable()) {
JMF 0:9d5134074d84 84 cin_last = cin;
JMF 0:9d5134074d84 85 cin = mdm.getc();
JMF 0:9d5134074d84 86 if (isprint(cin)) {
JMF 0:9d5134074d84 87 buff[len++] = (char)cin;
JMF 0:9d5134074d84 88 continue;
JMF 0:9d5134074d84 89 } else if (('\r' == cin_last) && ('\n' == cin)) {
JMF 0:9d5134074d84 90 break;
JMF 0:9d5134074d84 91 }
JMF 0:9d5134074d84 92 }
JMF 0:9d5134074d84 93 wait_ms(1);
JMF 0:9d5134074d84 94 }
JMF 2:0e2ef866af95 95 buff[len] = (char)NULL;
JMF 0:9d5134074d84 96
JMF 0:9d5134074d84 97 return len;
JMF 0:9d5134074d84 98 }
JMF 0:9d5134074d84 99
JMF 0:9d5134074d84 100 int mdm_sendAtCmd(const char *cmd, const char **rsp_list, int timeout_ms) {
JMF 0:9d5134074d84 101 if (cmd && strlen(cmd) > 0) {
JMF 0:9d5134074d84 102 if (mdm_dbgmask & MDM_DBG_AT_CMDS) {
JMF 0:9d5134074d84 103 printf(MAG "ATCMD: " DEF "--> " GRN "%s" DEF "\n", cmd);
JMF 0:9d5134074d84 104 }
JMF 0:9d5134074d84 105 mdm.printf("%s\r\n", cmd);
JMF 0:9d5134074d84 106 }
JMF 0:9d5134074d84 107
JMF 0:9d5134074d84 108 if (rsp_list) {
JMF 0:9d5134074d84 109 Timer timer;
JMF 0:9d5134074d84 110 char rsp[MAX_AT_RSP_LEN+1];
JMF 0:9d5134074d84 111 int len;
JMF 0:9d5134074d84 112
JMF 0:9d5134074d84 113 timer.start();
JMF 0:9d5134074d84 114 while (timer.read_ms() < timeout_ms) {
JMF 0:9d5134074d84 115 len = mdm_getline(rsp, sizeof(rsp), timeout_ms - timer.read_ms());
JMF 0:9d5134074d84 116
JMF 0:9d5134074d84 117 if (len < 0)
JMF 0:9d5134074d84 118 return MDM_ERR_TIMEOUT;
JMF 0:9d5134074d84 119
JMF 0:9d5134074d84 120 if (len == 0)
JMF 0:9d5134074d84 121 continue;
JMF 0:9d5134074d84 122
JMF 0:9d5134074d84 123 if (mdm_dbgmask & MDM_DBG_AT_CMDS) {
JMF 0:9d5134074d84 124 printf(MAG "ATRSP: " DEF "<-- " CYN "%s" DEF "\n", rsp);
JMF 0:9d5134074d84 125 }
JMF 0:9d5134074d84 126
JMF 0:9d5134074d84 127 if (rsp_list) {
JMF 0:9d5134074d84 128 int rsp_idx = 0;
JMF 0:9d5134074d84 129 while (rsp_list[rsp_idx]) {
JMF 0:9d5134074d84 130 if (strcasecmp(rsp, rsp_list[rsp_idx]) == 0) {
JMF 0:9d5134074d84 131 return rsp_idx;
JMF 0:9d5134074d84 132 }
JMF 0:9d5134074d84 133 rsp_idx++;
JMF 0:9d5134074d84 134 }
JMF 0:9d5134074d84 135 }
JMF 0:9d5134074d84 136 }
JMF 0:9d5134074d84 137 return MDM_ERR_TIMEOUT;
JMF 0:9d5134074d84 138 }
JMF 0:9d5134074d84 139 return MDM_OK;
JMF 0:9d5134074d84 140 }
JMF 0:9d5134074d84 141
JMF 0:9d5134074d84 142 int mdm_init(void) {
fkellermavnet 14:0c353e212296 143 // Hard reset the modem (doesn't go through
fkellermavnet 14:0c353e212296 144 // the signal level translator)
fkellermavnet 14:0c353e212296 145 mdm_reset = 0;
JMF 17:38a8cc0c6ba5 146
JMF 17:38a8cc0c6ba5 147 // disable signal level translator (necessary
JMF 17:38a8cc0c6ba5 148 // for the modem to boot properly). All signals
JMF 17:38a8cc0c6ba5 149 // except mdm_reset go through the level translator
JMF 17:38a8cc0c6ba5 150 // and have internal pull-up/down in the module. While
JMF 17:38a8cc0c6ba5 151 // the level translator is disabled, these pins will
JMF 17:38a8cc0c6ba5 152 // be in the correct state.
JMF 17:38a8cc0c6ba5 153 shield_3v3_1v8_sig_trans_ena = 0;
JMF 17:38a8cc0c6ba5 154
JMF 17:38a8cc0c6ba5 155 // While the level translator is disabled and ouptut pins
JMF 17:38a8cc0c6ba5 156 // are tristated, make sure the inputs are in the same state
JMF 17:38a8cc0c6ba5 157 // as the WNC Module pins so that when the level translator is
JMF 17:38a8cc0c6ba5 158 // enabled, there are no differences.
JMF 17:38a8cc0c6ba5 159 mdm_uart2_rx_boot_mode_sel = 1; // UART2_RX should be high
JMF 17:38a8cc0c6ba5 160 mdm_power_on = 0; // powr_on should be low
JMF 17:38a8cc0c6ba5 161 mdm_wakeup_in = 1; // wake-up should be high
JMF 17:38a8cc0c6ba5 162 mdm_uart1_cts = 0; // indicate that it is ok to send
JMF 17:38a8cc0c6ba5 163
JMF 17:38a8cc0c6ba5 164 // Now, wait for the WNC Module to perform its initial boot correctly
fkellermavnet 14:0c353e212296 165 wait(1.0);
JMF 17:38a8cc0c6ba5 166
JMF 17:38a8cc0c6ba5 167 // The WNC module initializes comms at 115200 8N1 so set it up
JMF 17:38a8cc0c6ba5 168 mdm.baud(115200);
JMF 0:9d5134074d84 169
JMF 17:38a8cc0c6ba5 170 //Now, enable the level translator, the input pins should now be the
JMF 17:38a8cc0c6ba5 171 //same as how the M14A module is driving them with internal pull ups/downs.
JMF 17:38a8cc0c6ba5 172 //When enabled, there will be no changes in these 4 pins...
JMF 17:38a8cc0c6ba5 173 shield_3v3_1v8_sig_trans_ena = 1;
JMF 2:0e2ef866af95 174
JMF 17:38a8cc0c6ba5 175 // Now, give the modem 60 secons to start responding by
JMF 0:9d5134074d84 176 // sending simple 'AT' commands to modem once per second.
JMF 0:9d5134074d84 177 Timer timer;
JMF 0:9d5134074d84 178 timer.start();
JMF 0:9d5134074d84 179 while (timer.read() < 60) {
JMF 0:9d5134074d84 180 const char * rsp_lst[] = { ok_str, error_str, NULL };
JMF 0:9d5134074d84 181 int rc = mdm_sendAtCmd("AT", rsp_lst, 500);
JMF 0:9d5134074d84 182 if (rc == 0)
fkellermavnet 14:0c353e212296 183 return true; //timer.read();
JMF 0:9d5134074d84 184 wait_ms(1000 - (timer.read_ms() % 1000));
JMF 0:9d5134074d84 185 pc.printf("\r%d",timer.read_ms()/1000);
JMF 0:9d5134074d84 186 }
JMF 0:9d5134074d84 187 return false;
JMF 0:9d5134074d84 188 }
JMF 0:9d5134074d84 189
JMF 2:0e2ef866af95 190 int mdm_sendAtCmdRsp(const char *cmd, const char **rsp_list, int timeout_ms, string * rsp, int * len) {
JMF 2:0e2ef866af95 191 static char cmd_buf[3200]; // Need enough room for the WNC sockreads (over 3000 chars)
fkellermavnet 6:713b4cbf1a7d 192 size_t n = strlen(cmd);
fkellermavnet 6:713b4cbf1a7d 193 if (cmd && n > 0) {
JMF 2:0e2ef866af95 194 if (mdm_dbgmask & MDM_DBG_AT_CMDS) {
JMF 2:0e2ef866af95 195 printf(MAG "ATCMD: " DEF "--> " GRN "%s" DEF "\n", cmd);
JMF 2:0e2ef866af95 196 }
fkellermavnet 6:713b4cbf1a7d 197 while (n--) {
fkellermavnet 6:713b4cbf1a7d 198 mdm.putc(*cmd++);
fkellermavnet 6:713b4cbf1a7d 199 wait_ms(1);
fkellermavnet 6:713b4cbf1a7d 200 };
fkellermavnet 6:713b4cbf1a7d 201 mdm.putc('\r');
fkellermavnet 6:713b4cbf1a7d 202 wait_ms(1);
fkellermavnet 6:713b4cbf1a7d 203 mdm.putc('\n');
fkellermavnet 6:713b4cbf1a7d 204 wait_ms(1);
JMF 2:0e2ef866af95 205 }
JMF 2:0e2ef866af95 206
JMF 2:0e2ef866af95 207 if (rsp_list) {
JMF 2:0e2ef866af95 208 rsp->erase(); // Clean up from prior cmd response
JMF 2:0e2ef866af95 209 *len = 0;
JMF 2:0e2ef866af95 210 Timer timer;
JMF 2:0e2ef866af95 211 timer.start();
JMF 2:0e2ef866af95 212 while (timer.read_ms() < timeout_ms) {
JMF 2:0e2ef866af95 213 int lenCmd = mdm_getline(cmd_buf, sizeof(cmd_buf), timeout_ms - timer.read_ms());
JMF 2:0e2ef866af95 214
JMF 2:0e2ef866af95 215 if (lenCmd == 0)
JMF 2:0e2ef866af95 216 continue;
JMF 2:0e2ef866af95 217
JMF 2:0e2ef866af95 218 if (lenCmd < 0)
JMF 2:0e2ef866af95 219 return MDM_ERR_TIMEOUT;
JMF 2:0e2ef866af95 220 else {
JMF 2:0e2ef866af95 221 *len += lenCmd;
JMF 2:0e2ef866af95 222 *rsp += cmd_buf;
JMF 2:0e2ef866af95 223 }
JMF 2:0e2ef866af95 224
JMF 2:0e2ef866af95 225 if (mdm_dbgmask & MDM_DBG_AT_CMDS) {
JMF 2:0e2ef866af95 226 printf(MAG "ATRSP: " DEF "<-- " CYN "%s" DEF "\n", cmd_buf);
JMF 2:0e2ef866af95 227 }
JMF 2:0e2ef866af95 228
JMF 2:0e2ef866af95 229 int rsp_idx = 0;
JMF 2:0e2ef866af95 230 while (rsp_list[rsp_idx]) {
JMF 2:0e2ef866af95 231 if (strcasecmp(cmd_buf, rsp_list[rsp_idx]) == 0) {
JMF 2:0e2ef866af95 232 return rsp_idx;
JMF 2:0e2ef866af95 233 }
JMF 2:0e2ef866af95 234 rsp_idx++;
JMF 2:0e2ef866af95 235 }
JMF 2:0e2ef866af95 236 }
JMF 2:0e2ef866af95 237 return MDM_ERR_TIMEOUT;
JMF 2:0e2ef866af95 238 }
JMF 2:0e2ef866af95 239 pc.printf("D %s",rsp);
JMF 2:0e2ef866af95 240 return MDM_OK;
JMF 2:0e2ef866af95 241 }
JMF 2:0e2ef866af95 242
JMF 2:0e2ef866af95 243 void reinitialize_mdm(void)
JMF 2:0e2ef866af95 244 {
JMF 2:0e2ef866af95 245 // Initialize the modem
JMF 2:0e2ef866af95 246 printf(GRN "Modem RE-initializing..." DEF "\r\n");
JMF 2:0e2ef866af95 247 if (!mdm_init()) {
JMF 2:0e2ef866af95 248 printf(RED "\n\rModem RE-initialization failed!" DEF "\n");
JMF 2:0e2ef866af95 249 }
JMF 2:0e2ef866af95 250 printf("\r\n");
JMF 2:0e2ef866af95 251 }
JMF 2:0e2ef866af95 252 // These are built on the fly
JMF 2:0e2ef866af95 253 string MyServerIpAddress;
JMF 2:0e2ef866af95 254 string MySocketData;
JMF 2:0e2ef866af95 255
JMF 2:0e2ef866af95 256 // These are to be built on the fly
JMF 2:0e2ef866af95 257 string my_temp;
JMF 2:0e2ef866af95 258 string my_humidity;
JMF 2:0e2ef866af95 259
JMF 0:9d5134074d84 260 #define CTOF(x) ((x)*1.8+32)
JMF 0:9d5134074d84 261
stefanrousseau 3:26b3cc155f39 262 //********************************************************************************************************************************************
stefanrousseau 12:7c94ec5069dc 263 //* Create string with sensor readings that can be sent to flow as an HTTP get
stefanrousseau 3:26b3cc155f39 264 //********************************************************************************************************************************************
stefanrousseau 12:7c94ec5069dc 265 K64F_Sensors_t SENSOR_DATA =
stefanrousseau 3:26b3cc155f39 266 {
stefanrousseau 12:7c94ec5069dc 267 .Temperature = "0",
stefanrousseau 12:7c94ec5069dc 268 .Humidity = "0",
stefanrousseau 12:7c94ec5069dc 269 .AccelX = "0",
stefanrousseau 12:7c94ec5069dc 270 .AccelY = "0",
stefanrousseau 12:7c94ec5069dc 271 .AccelZ = "0",
stefanrousseau 12:7c94ec5069dc 272 .MagnetometerX = "0",
stefanrousseau 12:7c94ec5069dc 273 .MagnetometerY = "0",
stefanrousseau 12:7c94ec5069dc 274 .MagnetometerZ = "0",
stefanrousseau 12:7c94ec5069dc 275 .AmbientLightVis = "0",
stefanrousseau 12:7c94ec5069dc 276 .AmbientLightIr = "0",
stefanrousseau 12:7c94ec5069dc 277 .UVindex = "0",
stefanrousseau 12:7c94ec5069dc 278 .Proximity = "0",
stefanrousseau 12:7c94ec5069dc 279 .Temperature_Si7020 = "0",
stefanrousseau 12:7c94ec5069dc 280 .Humidity_Si7020 = "0"
stefanrousseau 3:26b3cc155f39 281 };
stefanrousseau 12:7c94ec5069dc 282
fenar 35:4a5d307b9692 283 void GenerateModemString(char * modem_string0, char * modem_string1, char * modem_string2, char * modem_string3)
stefanrousseau 3:26b3cc155f39 284 {
stefanrousseau 12:7c94ec5069dc 285 switch(iSensorsToReport)
stefanrousseau 12:7c94ec5069dc 286 {
stefanrousseau 12:7c94ec5069dc 287 case TEMP_HUMIDITY_ONLY:
stefanrousseau 12:7c94ec5069dc 288 {
fenar 35:4a5d307b9692 289 int mimo_length;
fenar 35:4a5d307b9692 290 sprintf(modem_string0, "POST %s%s?db=iot_weather%s%s:%s\r\nAccept: */*\r\n", FLOW_BASE_URL, FLOW_INPUT_NAME, FLOW_URL_TYPE, MY_SERVER_URL, MY_PORT_STR);
fenar 35:4a5d307b9692 291 sprintf(modem_string2, "Content-Type: application/x-www-form-urlencoded\r\n\r\n");
fenar 35:4a5d307b9692 292 mimo_length = sprintf(modem_string3, "datapoints,device=%s temperature=%s,humidity=%s", FLOW_DEVICE_NAME, SENSOR_DATA.Temperature, SENSOR_DATA.Humidity);
fenar 35:4a5d307b9692 293 sprintf(modem_string1, "Content-Length: %d\r\n", mimo_length);
stefanrousseau 12:7c94ec5069dc 294 break;
stefanrousseau 12:7c94ec5069dc 295 }
stefanrousseau 12:7c94ec5069dc 296 case TEMP_HUMIDITY_ACCELEROMETER:
stefanrousseau 12:7c94ec5069dc 297 {
fenar 36:515021fabf15 298 int mimo_length;
fenar 36:515021fabf15 299 sprintf(modem_string0, "POST %s%s?db=iot_weather%s%s:%s\r\nAccept: */*\r\n", FLOW_BASE_URL, FLOW_INPUT_NAME, FLOW_URL_TYPE, MY_SERVER_URL, MY_PORT_STR);
fenar 36:515021fabf15 300 sprintf(modem_string2, "Content-Type: application/x-www-form-urlencoded\r\n\r\n");
fenar 36:515021fabf15 301 mimo_length = sprintf(modem_string3, "datapoints,device=%s temperature=%s,humidity=%s,accelX=%s,accelY=%s,accelZ=%s", FLOW_DEVICE_NAME, SENSOR_DATA.Temperature, SENSOR_DATA.Humidity, SENSOR_DATA.AccelX, SENSOR_DATA.AccelY, SENSOR_DATA.AccelZ);
fenar 36:515021fabf15 302 sprintf(modem_string1, "Content-Length: %d\r\n", mimo_length);
stefanrousseau 12:7c94ec5069dc 303 break;
stefanrousseau 12:7c94ec5069dc 304 }
stefanrousseau 12:7c94ec5069dc 305 case TEMP_HUMIDITY_ACCELEROMETER_PMODSENSORS:
stefanrousseau 12:7c94ec5069dc 306 {
fenar 36:515021fabf15 307 int mimo_length;
fenar 36:515021fabf15 308 sprintf(modem_string0, "POST %s%s?db=iot_weather%s%s:%s\r\nAccept: */*\r\n", FLOW_BASE_URL, FLOW_INPUT_NAME, FLOW_URL_TYPE, MY_SERVER_URL, MY_PORT_STR);
fenar 36:515021fabf15 309 sprintf(modem_string2, "Content-Type: application/x-www-form-urlencoded\r\n\r\n");
fenar 36:515021fabf15 310 mimo_length = sprintf(modem_string3, "datapoints,device=%s temperature=%s,humidity=%s,accelX=%s,accelY=%s,accelZ=%s,proximity=%s,light_uv=%s,light_vis=%s,light_ir=%s", 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);
fenar 36:515021fabf15 311 sprintf(modem_string1, "Content-Length: %d\r\n", mimo_length);
stefanrousseau 12:7c94ec5069dc 312 break;
stefanrousseau 12:7c94ec5069dc 313 }
stefanrousseau 12:7c94ec5069dc 314 default:
stefanrousseau 12:7c94ec5069dc 315 {
fenar 35:4a5d307b9692 316 sprintf(modem_string0, "Invalid sensor selected\r\n\r\n");
stefanrousseau 12:7c94ec5069dc 317 break;
stefanrousseau 12:7c94ec5069dc 318 }
stefanrousseau 16:17c5916f2d12 319 } //switch(iSensorsToReport)
stefanrousseau 3:26b3cc155f39 320 } //GenerateModemString
stefanrousseau 3:26b3cc155f39 321
stefanrousseau 3:26b3cc155f39 322
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
fkellermavnet 20:27a4f27254d0 452 // Set LED to RED until init finishes
fkellermavnet 20:27a4f27254d0 453 SetLedColor(0x1);
fkellermavnet 20:27a4f27254d0 454
fenar 36:515021fabf15 455 pc.printf(BLU "Hello World!\r\n\n\r");
JMF 0:9d5134074d84 456 pc.printf(GRN "Initialize the HTS221\n\r");
JMF 0:9d5134074d84 457
JMF 0:9d5134074d84 458 i = hts221.begin();
JMF 0:9d5134074d84 459 if( i )
JMF 0:9d5134074d84 460 pc.printf(BLU "HTS221 Detected! (0x%02X)\n\r",i);
JMF 0:9d5134074d84 461 else
JMF 0:9d5134074d84 462 pc.printf(RED "HTS221 NOT DETECTED!!\n\r");
JMF 0:9d5134074d84 463
JMF 0:9d5134074d84 464 printf("Temp is: %0.2f F \n\r",CTOF(hts221.readTemperature()));
JMF 0:9d5134074d84 465 printf("Humid is: %02d %%\n\r",hts221.readHumidity());
JMF 0:9d5134074d84 466
stefanrousseau 11:e6602513730f 467 sensors_init();
stefanrousseau 12:7c94ec5069dc 468 read_sensors();
stefanrousseau 11:e6602513730f 469
JMF 0:9d5134074d84 470 // Initialize the modem
JMF 0:9d5134074d84 471 printf(GRN "Modem initializing... will take up to 60 seconds" DEF "\r\n");
fkellermavnet 14:0c353e212296 472 do {
fkellermavnet 14:0c353e212296 473 i=mdm_init();
fkellermavnet 14:0c353e212296 474 if (!i) {
fkellermavnet 14:0c353e212296 475 pc.printf(RED "Modem initialization failed!" DEF "\n");
fkellermavnet 14:0c353e212296 476 }
fkellermavnet 14:0c353e212296 477 } while (!i);
JMF 0:9d5134074d84 478
JMF 2:0e2ef866af95 479 //Software init
JMF 2:0e2ef866af95 480 software_init_mdm();
fkellermavnet 19:f89baed3bd6f 481
JMF 2:0e2ef866af95 482 // Resolve URL to IP address to connect to
JMF 2:0e2ef866af95 483 resolve_mdm();
JMF 0:9d5134074d84 484
stefanrousseau 3:26b3cc155f39 485 //Create a 1ms timer tick function:
stefanrousseau 3:26b3cc155f39 486 OneMsTicker.attach(OneMsFunction, 0.001f) ;
fkellermavnet 26:8d6e7e7cdcae 487
fkellermavnet 26:8d6e7e7cdcae 488 // Open the socket (connect to the server)
fkellermavnet 25:e7996d22a7e6 489 sockopen_mdm();
stefanrousseau 3:26b3cc155f39 490
fkellermavnet 20:27a4f27254d0 491 // Set LED BLUE for partial init
fkellermavnet 20:27a4f27254d0 492 SetLedColor(0x4);
fkellermavnet 20:27a4f27254d0 493
JMF 2:0e2ef866af95 494 // Send and receive data perpetually
JMF 2:0e2ef866af95 495 while(1) {
fkellermavnet 20:27a4f27254d0 496 static unsigned ledOnce = 0;
stefanrousseau 3:26b3cc155f39 497 if (bTimerExpiredFlag)
stefanrousseau 3:26b3cc155f39 498 {
stefanrousseau 3:26b3cc155f39 499 bTimerExpiredFlag = false;
stefanrousseau 3:26b3cc155f39 500 sprintf(SENSOR_DATA.Temperature, "%0.2f", CTOF(hts221.readTemperature()));
stefanrousseau 3:26b3cc155f39 501 sprintf(SENSOR_DATA.Humidity, "%02d", hts221.readHumidity());
stefanrousseau 4:f83bedd9cab4 502 read_sensors(); //read available external sensors from a PMOD and the on-board motion sensor
fenar 36:515021fabf15 503 char msg_part0[128];
fenar 36:515021fabf15 504 char msg_part1[128];
fenar 36:515021fabf15 505 char msg_part2[128];
fenar 36:515021fabf15 506 char msg_part3[128];
fenar 35:4a5d307b9692 507 GenerateModemString(&msg_part0[0],&msg_part1[0],&msg_part2[0],&msg_part3[0]);
fenar 36:515021fabf15 508 char * httprequest = new char[512];
fenar 35:4a5d307b9692 509 std::strcpy(httprequest,msg_part0);
fenar 35:4a5d307b9692 510 std::strcat(httprequest,msg_part1);
fenar 35:4a5d307b9692 511 std::strcat(httprequest,msg_part2);
fenar 35:4a5d307b9692 512 std::strcat(httprequest,msg_part3);
fenar 35:4a5d307b9692 513 sockwrite_mdm(httprequest);
fenar 35:4a5d307b9692 514 printf(BLU "Sending to modem : %s" DEF "\n", httprequest);
fenar 35:4a5d307b9692 515 delete [] httprequest;
stefanrousseau 3:26b3cc155f39 516 sockread_mdm(&MySocketData, 1024, 20);
fkellermavnet 20:27a4f27254d0 517
fkellermavnet 20:27a4f27254d0 518 // If any non-zero response from server, make it GREEN one-time
fkellermavnet 20:27a4f27254d0 519 // then the actual FLOW responses will set the color.
fkellermavnet 20:27a4f27254d0 520 if ((!ledOnce) && (MySocketData.length() > 0))
fkellermavnet 20:27a4f27254d0 521 {
fkellermavnet 20:27a4f27254d0 522 ledOnce = 1;
fkellermavnet 20:27a4f27254d0 523 SetLedColor(0x2);
fkellermavnet 20:27a4f27254d0 524 }
fkellermavnet 20:27a4f27254d0 525
stefanrousseau 16:17c5916f2d12 526 printf(BLU "Read back : %s" DEF "\n", &MySocketData[0]);
stefanrousseau 34:029e07b67a41 527 char myJsonResponse[512];
stefanrousseau 16:17c5916f2d12 528 if (extract_JSON(&MySocketData[0], &myJsonResponse[0]))
stefanrousseau 16:17c5916f2d12 529 {
stefanrousseau 16:17c5916f2d12 530 printf(GRN "JSON : %s" DEF "\n", &myJsonResponse[0]);
stefanrousseau 16:17c5916f2d12 531 parse_JSON(&myJsonResponse[0]);
stefanrousseau 16:17c5916f2d12 532 }
stefanrousseau 16:17c5916f2d12 533 else
stefanrousseau 16:17c5916f2d12 534 {
stefanrousseau 16:17c5916f2d12 535 printf(RED "JSON : %s" DEF "\n", &myJsonResponse[0]); //most likely an incomplete JSON string
stefanrousseau 16:17c5916f2d12 536 parse_JSON(&myJsonResponse[0]); //This is risky, as the string may be corrupted
stefanrousseau 16:17c5916f2d12 537 }
stefanrousseau 3:26b3cc155f39 538 } //bTimerExpiredFlag
stefanrousseau 3:26b3cc155f39 539 } //forever loop
JMF 0:9d5134074d84 540 }