Alexander Rao / Mbed 2 deprecated weather_clock

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:   mbed MbedJSONValue mbed-rtos 4DGL-uLCD-SE ESP8266NodeMCUInterface

main.cpp@12:513a0fd7c426, 2019-05-24 (annotated)

Committer:
alexhrao
Date:
Fri May 24 23:36:32 2019 +0000
Revision:
12:513a0fd7c426
Parent:
11:643f66b447b8
Child:
13:65946a58123e
Add demo for new node support

Who changed what in which revision?

UserRevisionLine numberNew contents of line
alexhrao 11:643f66b447b8 1 // Change below to 1 to compile for the new node
alexhrao 12:513a0fd7c426 2 #define ESP8226_NEW_NODE 1
alexhrao 0:4ffa136585a2 3 #include "mbed.h"
alexhrao 1:0620ba35d2e8 4 #include "uLCD_4DGL.h"
alexhrao 1:0620ba35d2e8 5 #include "ESP8266Interface.h"
alexhrao 1:0620ba35d2e8 6 #include "TCPSocketConnection.h"
alexhrao 1:0620ba35d2e8 7 #include "rtos.h"
alexhrao 3:7bf41989ff8f 8 #include "MbedJSONValue.h"
alexhrao 3:7bf41989ff8f 9 #include <string>
alexhrao 3:7bf41989ff8f 10
alexhrao 3:7bf41989ff8f 11 #define BUF_SIZE 4096
alexhrao 1:0620ba35d2e8 12
alexhrao 12:513a0fd7c426 13 #if ESP8226_NEW_NODE == 0
alexhrao 12:513a0fd7c426 14 #define ESP8226_BAUD_RATE 9600
alexhrao 12:513a0fd7c426 15 #else
alexhrao 12:513a0fd7c426 16 #define ESP8226_BAUD_RATE 115200
alexhrao 12:513a0fd7c426 17 #endif
alexhrao 12:513a0fd7c426 18
alexhrao 1:0620ba35d2e8 19 // We need this for being able to reset the MBED (similar to watch dogs)
alexhrao 1:0620ba35d2e8 20 extern "C" void mbed_reset();
alexhrao 1:0620ba35d2e8 21
alexhrao 1:0620ba35d2e8 22 // LCD Screen
alexhrao 1:0620ba35d2e8 23 uLCD_4DGL uLCD(p9, p10, p11);
alexhrao 1:0620ba35d2e8 24 Mutex lcd_lock;
alexhrao 1:0620ba35d2e8 25
alexhrao 1:0620ba35d2e8 26 // File System
alexhrao 1:0620ba35d2e8 27 LocalFileSystem fs("local");
alexhrao 1:0620ba35d2e8 28
alexhrao 1:0620ba35d2e8 29 // Bluetooth
alexhrao 1:0620ba35d2e8 30 RawSerial pc(USBTX, USBRX);
alexhrao 1:0620ba35d2e8 31 RawSerial dev(p28,p27);
alexhrao 1:0620ba35d2e8 32
alexhrao 1:0620ba35d2e8 33 // Error LED
alexhrao 1:0620ba35d2e8 34 DigitalOut err_led(LED1);
alexhrao 1:0620ba35d2e8 35
alexhrao 1:0620ba35d2e8 36 // WiFi
alexhrao 12:513a0fd7c426 37 ESP8266Interface wifi(p13, p14, p15, ESP8226_BAUD_RATE, 10000);
alexhrao 1:0620ba35d2e8 38
alexhrao 1:0620ba35d2e8 39 // Time
alexhrao 1:0620ba35d2e8 40 Thread time_thread;
alexhrao 1:0620ba35d2e8 41
alexhrao 3:7bf41989ff8f 42 // Location
alexhrao 3:7bf41989ff8f 43 double latitude = 0;
alexhrao 3:7bf41989ff8f 44 double longitude = 0;
alexhrao 0:4ffa136585a2 45
alexhrao 4:55f0c303f56a 46 // Credentials
alexhrao 4:55f0c303f56a 47 char ssid[256];
alexhrao 4:55f0c303f56a 48 char pass[256];
alexhrao 4:55f0c303f56a 49 char ip_api_key[256];
alexhrao 4:55f0c303f56a 50 char time_api_key[256];
alexhrao 4:55f0c303f56a 51 char weather_api_key[256];
alexhrao 4:55f0c303f56a 52
alexhrao 8:d323c6406b47 53 void time_updater()
alexhrao 8:d323c6406b47 54 {
alexhrao 1:0620ba35d2e8 55 // We're not an interrupt, so take as much time as we need. Infinite loop
alexhrao 1:0620ba35d2e8 56 // but wait 1 second between each loop
alexhrao 1:0620ba35d2e8 57 struct tm* ltm;
alexhrao 1:0620ba35d2e8 58 time_t now;
alexhrao 8:d323c6406b47 59
alexhrao 1:0620ba35d2e8 60 now = time(NULL);
alexhrao 1:0620ba35d2e8 61 ltm = localtime(&now);
alexhrao 8:d323c6406b47 62
alexhrao 1:0620ba35d2e8 63 // Buffer for time string. Max length is 23:59 + \0
alexhrao 4:55f0c303f56a 64 int max_time_len = 8;
alexhrao 1:0620ba35d2e8 65 char ftime[max_time_len];
alexhrao 4:55f0c303f56a 66 ftime[0] = ' ';
alexhrao 4:55f0c303f56a 67 ftime[1] = ' ';
alexhrao 1:0620ba35d2e8 68 int min = -1;
alexhrao 8:d323c6406b47 69
alexhrao 1:0620ba35d2e8 70 while (true) {
alexhrao 1:0620ba35d2e8 71 // if the minute has changed, update.
alexhrao 1:0620ba35d2e8 72 now = time(NULL);
alexhrao 1:0620ba35d2e8 73 ltm = localtime(&now);
alexhrao 1:0620ba35d2e8 74 if(ltm->tm_min != min) {
alexhrao 1:0620ba35d2e8 75 // Get the new time
alexhrao 8:d323c6406b47 76 strftime(ftime + 2, max_time_len, "%H:%M", ltm);
alexhrao 1:0620ba35d2e8 77 // Update time! Lock the lcd mutex
alexhrao 1:0620ba35d2e8 78 lcd_lock.lock();
alexhrao 1:0620ba35d2e8 79 uLCD.text_width(2);
alexhrao 1:0620ba35d2e8 80 uLCD.text_height(2);
alexhrao 1:0620ba35d2e8 81 uLCD.text_string(ftime, 0, 2, FONT_8X8, GREEN);
alexhrao 1:0620ba35d2e8 82 // Done updating - unlock!
alexhrao 1:0620ba35d2e8 83 lcd_lock.unlock();
alexhrao 1:0620ba35d2e8 84 min = ltm->tm_min;
alexhrao 1:0620ba35d2e8 85 }
alexhrao 1:0620ba35d2e8 86 // Wait 1 second
alexhrao 1:0620ba35d2e8 87 Thread::wait(1.0f);
alexhrao 8:d323c6406b47 88 }
alexhrao 1:0620ba35d2e8 89 }
alexhrao 1:0620ba35d2e8 90
alexhrao 8:d323c6406b47 91 void dev_recv()
alexhrao 8:d323c6406b47 92 {
alexhrao 1:0620ba35d2e8 93 // Continually check if we have stuff...
alexhrao 1:0620ba35d2e8 94 char buf[1024];
alexhrao 1:0620ba35d2e8 95 int ind = 0;
alexhrao 1:0620ba35d2e8 96 while (true) {
alexhrao 10:16356570821e 97 while (ind < 1023) {
alexhrao 1:0620ba35d2e8 98 // get stuff. If we encounter \r or \n, that's a complete command!
alexhrao 1:0620ba35d2e8 99 char tmp = dev.getc();
alexhrao 1:0620ba35d2e8 100 if (tmp == '\n' || tmp == '\r') {
alexhrao 1:0620ba35d2e8 101 break;
alexhrao 1:0620ba35d2e8 102 }
alexhrao 1:0620ba35d2e8 103 buf[ind++] = tmp;
alexhrao 1:0620ba35d2e8 104 Thread::wait(0.01);
alexhrao 1:0620ba35d2e8 105 }
alexhrao 1:0620ba35d2e8 106 buf[ind] = '\0';
alexhrao 1:0620ba35d2e8 107 // read command and respond
alexhrao 10:16356570821e 108 if (strcmp(buf, "reset wifi") == 0) {
alexhrao 10:16356570821e 109 dev.printf("Are you sure? y/[n]\n");
alexhrao 10:16356570821e 110 if (dev.getc() == 'y') {
alexhrao 10:16356570821e 111 // Remove the WIFI.TXT file
alexhrao 10:16356570821e 112 remove("/local/wifi.txt");
alexhrao 10:16356570821e 113 mbed_reset();
alexhrao 10:16356570821e 114 }
alexhrao 10:16356570821e 115 } else if (strcmp(buf, "reset api") == 0) {
alexhrao 1:0620ba35d2e8 116 dev.printf("Are you sure? y/[n]\n");
alexhrao 10:16356570821e 117 if (dev.getc() == 'y') {
alexhrao 10:16356570821e 118 // Remove api_keys.txt
alexhrao 10:16356570821e 119 remove("/local/api_keys.txt");
alexhrao 10:16356570821e 120 mbed_reset();
alexhrao 10:16356570821e 121 }
alexhrao 10:16356570821e 122 } else if (strcmp(buf, "info") == 0) {
alexhrao 10:16356570821e 123 // Print basic info
alexhrao 10:16356570821e 124 dev.printf("WiFi Connected with Address %s\r\n",
alexhrao 10:16356570821e 125 wifi.getIPAddress());
alexhrao 10:16356570821e 126 time_t curr_time = time(NULL);
alexhrao 10:16356570821e 127 dev.printf("Current Time: %s\r\n", ctime(&curr_time));
alexhrao 1:0620ba35d2e8 128 }
alexhrao 1:0620ba35d2e8 129 buf[0] = '\0';
alexhrao 1:0620ba35d2e8 130 ind = 0;
alexhrao 1:0620ba35d2e8 131 Thread::wait(0.01);
alexhrao 1:0620ba35d2e8 132 }
alexhrao 2:f7d19812bdc5 133 }
alexhrao 0:4ffa136585a2 134
alexhrao 8:d323c6406b47 135 int kelvin2farenheit(int temp)
alexhrao 8:d323c6406b47 136 {
alexhrao 8:d323c6406b47 137 return (int)((((temp - 273.15f) * 9.0f) / 5.0f) + 32.0f);
alexhrao 4:55f0c303f56a 138 }
alexhrao 4:55f0c303f56a 139
alexhrao 8:d323c6406b47 140 void clock_init()
alexhrao 8:d323c6406b47 141 {
alexhrao 1:0620ba35d2e8 142 // Set up bluetooth
alexhrao 1:0620ba35d2e8 143 dev.baud(9600);
alexhrao 1:0620ba35d2e8 144 pc.baud(9600);
alexhrao 8:d323c6406b47 145
alexhrao 1:0620ba35d2e8 146 // Tell user we're initializing...
alexhrao 1:0620ba35d2e8 147 lcd_lock.lock();
alexhrao 1:0620ba35d2e8 148 uLCD.cls();
alexhrao 1:0620ba35d2e8 149 uLCD.text_height(2);
alexhrao 6:ec7829f7cd38 150 uLCD.text_width(2);
alexhrao 6:ec7829f7cd38 151 uLCD.text_string("PLEASE", 0, 2, FONT_7X8, WHITE);
alexhrao 6:ec7829f7cd38 152 uLCD.text_string("WAIT", 0, 5, FONT_7X8, WHITE);
alexhrao 1:0620ba35d2e8 153 lcd_lock.unlock();
alexhrao 8:d323c6406b47 154
alexhrao 1:0620ba35d2e8 155 // Need to get wifi settings. If we don't have local file, then ask!
alexhrao 10:16356570821e 156 FILE* fid = fopen("/local/api_keys.txt", "r");
alexhrao 10:16356570821e 157 char settings_buf[1024];
alexhrao 10:16356570821e 158 int settings_ind = 0;
alexhrao 10:16356570821e 159 int counter = 0;
alexhrao 10:16356570821e 160 if (fid == NULL) {
alexhrao 10:16356570821e 161 lcd_lock.lock();
alexhrao 10:16356570821e 162 uLCD.cls();
alexhrao 10:16356570821e 163 uLCD.text_height(2);
alexhrao 10:16356570821e 164 uLCD.text_width(2);
alexhrao 10:16356570821e 165 uLCD.text_string("SEE", 0, 2, FONT_7X8, RED);
alexhrao 10:16356570821e 166 uLCD.text_string("DEVICE", 0, 5, FONT_7X8, RED);
alexhrao 10:16356570821e 167 lcd_lock.unlock();
alexhrao 10:16356570821e 168 // Ask
alexhrao 10:16356570821e 169 // Get the API key
alexhrao 10:16356570821e 170 dev.printf("Please provide the IP Stack API key\n");
alexhrao 10:16356570821e 171 while (!dev.readable()) {
alexhrao 10:16356570821e 172 wait(0.001);
alexhrao 10:16356570821e 173 }
alexhrao 10:16356570821e 174 int ind = 0;
alexhrao 10:16356570821e 175 while (ind < 255) {
alexhrao 10:16356570821e 176 char tmp = dev.getc();
alexhrao 10:16356570821e 177 if (tmp == '\n' || tmp == '\r') {
alexhrao 10:16356570821e 178 break;
alexhrao 10:16356570821e 179 }
alexhrao 10:16356570821e 180 ip_api_key[ind++] = tmp;
alexhrao 10:16356570821e 181 wait(0.01);
alexhrao 10:16356570821e 182 }
alexhrao 10:16356570821e 183
alexhrao 10:16356570821e 184 ip_api_key[ind] = '\0';
alexhrao 8:d323c6406b47 185
alexhrao 10:16356570821e 186 dev.printf("Please provide the TimeZoneDB API key\n");
alexhrao 10:16356570821e 187 while (!dev.readable()) {
alexhrao 10:16356570821e 188 wait(0.001);
alexhrao 10:16356570821e 189 }
alexhrao 10:16356570821e 190 ind = 0;
alexhrao 10:16356570821e 191 while (ind < 255) {
alexhrao 10:16356570821e 192 char tmp = dev.getc();
alexhrao 10:16356570821e 193 if (tmp == '\r' || tmp == '\n') {
alexhrao 10:16356570821e 194 break;
alexhrao 10:16356570821e 195 }
alexhrao 10:16356570821e 196 time_api_key[ind++] = tmp;
alexhrao 10:16356570821e 197 wait(0.01);
alexhrao 2:f7d19812bdc5 198 }
alexhrao 10:16356570821e 199 time_api_key[ind] = '\0';
alexhrao 10:16356570821e 200
alexhrao 10:16356570821e 201 dev.printf("Please provide the OpenWeather API key\n");
alexhrao 10:16356570821e 202 while (!dev.readable()) {
alexhrao 10:16356570821e 203 wait(0.001);
alexhrao 2:f7d19812bdc5 204 }
alexhrao 10:16356570821e 205 ind = 0;
alexhrao 10:16356570821e 206 while (ind < 255) {
alexhrao 10:16356570821e 207 char tmp = dev.getc();
alexhrao 10:16356570821e 208 if (tmp == '\r' || tmp == '\n') {
alexhrao 10:16356570821e 209 break;
alexhrao 10:16356570821e 210 }
alexhrao 10:16356570821e 211 weather_api_key[ind++] = tmp;
alexhrao 10:16356570821e 212 wait(0.01);
alexhrao 10:16356570821e 213 }
alexhrao 10:16356570821e 214 weather_api_key[ind] = '\0';
alexhrao 10:16356570821e 215 // Create file
alexhrao 10:16356570821e 216 fid = fopen("/local/api_keys.txt", "w");
alexhrao 10:16356570821e 217 fprintf(fid, "%s\n%s\n%s\n", ip_api_key, time_api_key, weather_api_key);
alexhrao 10:16356570821e 218 fclose(fid);
alexhrao 10:16356570821e 219 } else {
alexhrao 10:16356570821e 220 // Read from file
alexhrao 4:55f0c303f56a 221 fgets(settings_buf, 1024, fid);
alexhrao 4:55f0c303f56a 222 counter = 0;
alexhrao 4:55f0c303f56a 223 while (settings_buf[counter] != '\n') {
alexhrao 4:55f0c303f56a 224 ip_api_key[settings_ind++] = settings_buf[counter++];
alexhrao 4:55f0c303f56a 225 }
alexhrao 4:55f0c303f56a 226 ip_api_key[settings_ind] = '\0';
alexhrao 4:55f0c303f56a 227 settings_ind = 0;
alexhrao 4:55f0c303f56a 228 fgets(settings_buf, 1024, fid);
alexhrao 4:55f0c303f56a 229 counter = 0;
alexhrao 2:f7d19812bdc5 230 while (settings_buf[counter] != '\n') {
alexhrao 4:55f0c303f56a 231 time_api_key[settings_ind++] = settings_buf[counter++];
alexhrao 2:f7d19812bdc5 232 }
alexhrao 4:55f0c303f56a 233 time_api_key[settings_ind] = '\0';
alexhrao 4:55f0c303f56a 234 settings_ind = 0;
alexhrao 4:55f0c303f56a 235 fgets(settings_buf, 1024, fid);
alexhrao 4:55f0c303f56a 236 counter = 0;
alexhrao 4:55f0c303f56a 237 while (settings_buf[counter] != '\n') {
alexhrao 4:55f0c303f56a 238 weather_api_key[settings_ind++] = settings_buf[counter++];
alexhrao 4:55f0c303f56a 239 }
alexhrao 4:55f0c303f56a 240 weather_api_key[settings_ind] = '\0';
alexhrao 2:f7d19812bdc5 241 fclose(fid);
alexhrao 10:16356570821e 242 }
alexhrao 10:16356570821e 243
alexhrao 10:16356570821e 244 fid = fopen("/local/wifi.txt", "r");
alexhrao 10:16356570821e 245
alexhrao 10:16356570821e 246 if (fid != NULL) {
alexhrao 10:16356570821e 247 // Read WiFi Settings
alexhrao 10:16356570821e 248 // Guaranteed to be 2 lines
alexhrao 10:16356570821e 249 //
alexhrao 10:16356570821e 250 fgets(settings_buf, 1024, fid);
alexhrao 10:16356570821e 251 // find \n
alexhrao 10:16356570821e 252 settings_ind = 0;
alexhrao 10:16356570821e 253 counter = 0;
alexhrao 10:16356570821e 254 while (settings_buf[counter] != '\n') {
alexhrao 10:16356570821e 255 ssid[settings_ind++] = settings_buf[counter++];
alexhrao 10:16356570821e 256 }
alexhrao 10:16356570821e 257 ssid[settings_ind] = '\0';
alexhrao 10:16356570821e 258 settings_ind = 0;
alexhrao 10:16356570821e 259 fgets(settings_buf, 1024, fid);
alexhrao 10:16356570821e 260 counter = 0;
alexhrao 10:16356570821e 261 while (settings_buf[counter] != '\n') {
alexhrao 10:16356570821e 262 pass[settings_ind++] = settings_buf[counter++];
alexhrao 10:16356570821e 263 }
alexhrao 10:16356570821e 264 pass[settings_ind] = '\0';
alexhrao 10:16356570821e 265 fclose(fid);
alexhrao 1:0620ba35d2e8 266 } else {
alexhrao 1:0620ba35d2e8 267 lcd_lock.lock();
alexhrao 1:0620ba35d2e8 268 uLCD.cls();
alexhrao 1:0620ba35d2e8 269 uLCD.text_height(2);
alexhrao 1:0620ba35d2e8 270 uLCD.text_width(2);
alexhrao 1:0620ba35d2e8 271 uLCD.text_string("SEE", 0, 2, FONT_7X8, RED);
alexhrao 1:0620ba35d2e8 272 uLCD.text_string("DEVICE", 0, 5, FONT_7X8, RED);
alexhrao 1:0620ba35d2e8 273 lcd_lock.unlock();
alexhrao 8:d323c6406b47 274
alexhrao 1:0620ba35d2e8 275 // Ask!
alexhrao 1:0620ba35d2e8 276 dev.printf("Please provide the name of a WiFi Network\n");
alexhrao 8:d323c6406b47 277
alexhrao 1:0620ba35d2e8 278 // Wait for them to respond
alexhrao 1:0620ba35d2e8 279 while (!dev.readable()) {
alexhrao 1:0620ba35d2e8 280 wait(0.001);
alexhrao 1:0620ba35d2e8 281 }
alexhrao 1:0620ba35d2e8 282 int ind = 0;
alexhrao 8:d323c6406b47 283
alexhrao 1:0620ba35d2e8 284 // Read response
alexhrao 1:0620ba35d2e8 285 while (ind < 255) {
alexhrao 1:0620ba35d2e8 286 char tmp = dev.getc();
alexhrao 1:0620ba35d2e8 287 if (tmp == '\n' || tmp == '\r') {
alexhrao 1:0620ba35d2e8 288 break;
alexhrao 1:0620ba35d2e8 289 }
alexhrao 1:0620ba35d2e8 290 ssid[ind++] = tmp;
alexhrao 1:0620ba35d2e8 291 wait(0.01);
alexhrao 1:0620ba35d2e8 292 }
alexhrao 1:0620ba35d2e8 293 ssid[ind] = '\0';
alexhrao 8:d323c6406b47 294
alexhrao 1:0620ba35d2e8 295 // flush device
alexhrao 1:0620ba35d2e8 296 while (dev.readable()) {
alexhrao 1:0620ba35d2e8 297 dev.getc();
alexhrao 1:0620ba35d2e8 298 wait(0.01);
alexhrao 1:0620ba35d2e8 299 }
alexhrao 8:d323c6406b47 300
alexhrao 2:f7d19812bdc5 301 // Get the password
alexhrao 1:0620ba35d2e8 302 dev.printf("Please provide the password\n");
alexhrao 1:0620ba35d2e8 303 while (!dev.readable()) {
alexhrao 1:0620ba35d2e8 304 wait(0.001);
alexhrao 1:0620ba35d2e8 305 }
alexhrao 1:0620ba35d2e8 306 ind = 0;
alexhrao 1:0620ba35d2e8 307 while (ind < 255) {
alexhrao 1:0620ba35d2e8 308 char tmp = dev.getc();
alexhrao 1:0620ba35d2e8 309 if (tmp == '\n' || tmp == '\r') {
alexhrao 1:0620ba35d2e8 310 break;
alexhrao 1:0620ba35d2e8 311 }
alexhrao 1:0620ba35d2e8 312 pass[ind++] = tmp;
alexhrao 1:0620ba35d2e8 313 wait(0.01);
alexhrao 1:0620ba35d2e8 314 }
alexhrao 1:0620ba35d2e8 315 pass[ind] = '\0';
alexhrao 8:d323c6406b47 316 // Because this is a simple proof of concept, we store the password in
alexhrao 8:d323c6406b47 317 // plaintext. It should be noted, however, that you **should never do
alexhrao 1:0620ba35d2e8 318 // this in "real life"**
alexhrao 10:16356570821e 319 fid = fopen("/local/wifi.txt", "w");
alexhrao 10:16356570821e 320 fprintf(fid, "%s\n%s\n", ssid, pass);
alexhrao 4:55f0c303f56a 321 fclose(fid);
alexhrao 1:0620ba35d2e8 322 }
alexhrao 6:ec7829f7cd38 323 /*
alexhrao 4:55f0c303f56a 324 dev.printf("\r\n** CREDENTIALS **\r\n");
alexhrao 4:55f0c303f56a 325 dev.printf("SSID: **%s** (%d)\r\n", ssid, strlen(ssid));
alexhrao 4:55f0c303f56a 326 dev.printf("PASS: **%s** (%d)\r\n", pass, strlen(pass));
alexhrao 4:55f0c303f56a 327 dev.printf("IP STACK: **%s**\r\n", ip_api_key);
alexhrao 4:55f0c303f56a 328 dev.printf("TIMEZONEDB: **%s**\r\n", time_api_key);
alexhrao 4:55f0c303f56a 329 dev.printf("WEATHERMAP: **%s**\r\n", weather_api_key);
alexhrao 6:ec7829f7cd38 330 */
alexhrao 1:0620ba35d2e8 331 bool res = wifi.init();
alexhrao 4:55f0c303f56a 332
alexhrao 1:0620ba35d2e8 333 // Set up the WiFi Access Point
alexhrao 1:0620ba35d2e8 334 dev.printf("Connecting to WiFi %s with Password %s\n", ssid, pass);
alexhrao 8:d323c6406b47 335
alexhrao 5:b77a717feada 336 res = wifi.connect(ssid, pass);
alexhrao 2:f7d19812bdc5 337 if (!res) {
alexhrao 2:f7d19812bdc5 338 dev.printf("Connection Failed... Resetting Device\n");
alexhrao 2:f7d19812bdc5 339 err_led = 1;
alexhrao 11:643f66b447b8 340 while (true);
alexhrao 2:f7d19812bdc5 341 mbed_reset();
alexhrao 2:f7d19812bdc5 342 }
alexhrao 8:d323c6406b47 343
alexhrao 2:f7d19812bdc5 344 dev.printf("Connected with IP Address: %s\n", wifi.getIPAddress());
alexhrao 8:d323c6406b47 345
alexhrao 4:55f0c303f56a 346 /** API REQUESTS **/
alexhrao 8:d323c6406b47 347
alexhrao 4:55f0c303f56a 348 int header_ind = 0;
alexhrao 4:55f0c303f56a 349 int footer_ind = 0;
alexhrao 4:55f0c303f56a 350 int read_len = 0;
alexhrao 4:55f0c303f56a 351 char buffer[BUF_SIZE];
alexhrao 4:55f0c303f56a 352 char cmd[512];
alexhrao 4:55f0c303f56a 353
alexhrao 3:7bf41989ff8f 354 TCPSocketConnection tcp;
alexhrao 3:7bf41989ff8f 355 tcp.connect("api.ipstack.com", 80);
alexhrao 8:d323c6406b47 356
alexhrao 8:d323c6406b47 357 sprintf(cmd,
alexhrao 8:d323c6406b47 358 "GET /check?access_key=%s HTTP/1.1\r\nHost: api.ipstack.com\r\n\r\n",
alexhrao 8:d323c6406b47 359 ip_api_key);
alexhrao 4:55f0c303f56a 360 tcp.send_all(cmd, strlen(cmd));
alexhrao 8:d323c6406b47 361
alexhrao 4:55f0c303f56a 362 wait(5);
alexhrao 8:d323c6406b47 363
alexhrao 4:55f0c303f56a 364 read_len = wifi.recv(buffer, BUF_SIZE - 1, 0);
alexhrao 3:7bf41989ff8f 365 buffer[read_len] = '\0';
alexhrao 8:d323c6406b47 366
alexhrao 4:55f0c303f56a 367 // Cleanup
alexhrao 8:d323c6406b47 368
alexhrao 4:55f0c303f56a 369 while (header_ind < read_len) {
alexhrao 4:55f0c303f56a 370 // if we are \r, look ahead to see \n\r\n:
alexhrao 4:55f0c303f56a 371 if(buffer[header_ind] == '\r' &&
alexhrao 8:d323c6406b47 372 buffer[header_ind+1] == '\n' &&
alexhrao 8:d323c6406b47 373 buffer[header_ind+2] == '\r' &&
alexhrao 8:d323c6406b47 374 buffer[header_ind+3] == '\n') {
alexhrao 4:55f0c303f56a 375 // Increment header_ind, look for JSON
alexhrao 4:55f0c303f56a 376 // Now just look for {
alexhrao 4:55f0c303f56a 377 header_ind += 4;
alexhrao 4:55f0c303f56a 378 while (header_ind < read_len) {
alexhrao 4:55f0c303f56a 379 if (buffer[header_ind] == '{') {
alexhrao 4:55f0c303f56a 380 // we got it!
alexhrao 4:55f0c303f56a 381 break;
alexhrao 4:55f0c303f56a 382 }
alexhrao 4:55f0c303f56a 383 header_ind++;
alexhrao 4:55f0c303f56a 384 }
alexhrao 4:55f0c303f56a 385 break;
alexhrao 4:55f0c303f56a 386 }
alexhrao 4:55f0c303f56a 387 header_ind++;
alexhrao 4:55f0c303f56a 388 }
alexhrao 4:55f0c303f56a 389 for (footer_ind = read_len - 1; footer_ind > header_ind; footer_ind--) {
alexhrao 4:55f0c303f56a 390 if(buffer[footer_ind] == '}') {
alexhrao 4:55f0c303f56a 391 break;
alexhrao 4:55f0c303f56a 392 }
alexhrao 4:55f0c303f56a 393 }
alexhrao 4:55f0c303f56a 394 buffer[footer_ind + 1] = '\0';
alexhrao 6:ec7829f7cd38 395
alexhrao 9:299eb69af04e 396 MbedJSONValue* parser = new MbedJSONValue();
alexhrao 9:299eb69af04e 397 parse(*parser, buffer + header_ind);
alexhrao 8:d323c6406b47 398
alexhrao 9:299eb69af04e 399 latitude = (*parser)["latitude"].get<double>();
alexhrao 9:299eb69af04e 400 longitude = (*parser)["longitude"].get<double>();
alexhrao 9:299eb69af04e 401 delete(parser);
alexhrao 4:55f0c303f56a 402 // Get the Time
alexhrao 4:55f0c303f56a 403 TCPSocketConnection time_tcp;
alexhrao 4:55f0c303f56a 404
alexhrao 12:513a0fd7c426 405 #if ESP8226_NEW_NODE == 1
alexhrao 12:513a0fd7c426 406 time_tcp.connect("www.google.com", 443);
alexhrao 12:513a0fd7c426 407 #else
alexhrao 4:55f0c303f56a 408 time_tcp.connect("api.timezonedb.com", 80);
alexhrao 12:513a0fd7c426 409 #endif
alexhrao 4:55f0c303f56a 410 sprintf(cmd,
alexhrao 12:513a0fd7c426 411 #if ESP8226_NEW_NODE == 1
alexhrao 12:513a0fd7c426 412 "GET / HTTP/1.1\r\nHost: www.google.com\r\nConnection: keep-alive\r\nAccept: */*\r\n\r\n");
alexhrao 12:513a0fd7c426 413 #else
alexhrao 8:d323c6406b47 414 "GET /v2.1/get-time-zone?key=%s&format=json&by=position&lat=%0.4f&lng=%0.4f HTTP/1.1\r\nHost: api.timezonedb.com\r\n\r\n",
alexhrao 8:d323c6406b47 415 time_api_key,
alexhrao 8:d323c6406b47 416 latitude,
alexhrao 8:d323c6406b47 417 longitude);
alexhrao 12:513a0fd7c426 418 #endif
alexhrao 4:55f0c303f56a 419
alexhrao 4:55f0c303f56a 420 time_tcp.send_all(cmd, strlen(cmd));
alexhrao 6:ec7829f7cd38 421
alexhrao 4:55f0c303f56a 422 wait(5);
alexhrao 6:ec7829f7cd38 423
alexhrao 4:55f0c303f56a 424 read_len = wifi.recv(buffer, BUF_SIZE - 1, 0);
alexhrao 3:7bf41989ff8f 425 buffer[read_len] = '\0';
alexhrao 8:d323c6406b47 426
alexhrao 4:55f0c303f56a 427 // Cleanup
alexhrao 8:d323c6406b47 428
alexhrao 4:55f0c303f56a 429 // Clean up front
alexhrao 4:55f0c303f56a 430 // Read through headers (\r\n\r\n)
alexhrao 4:55f0c303f56a 431 header_ind = 0;
alexhrao 4:55f0c303f56a 432 while (header_ind < read_len) {
alexhrao 4:55f0c303f56a 433 // if we are \r, look ahead to see \n\r\n:
alexhrao 4:55f0c303f56a 434 if(buffer[header_ind] == '\r' &&
alexhrao 8:d323c6406b47 435 buffer[header_ind+1] == '\n' &&
alexhrao 8:d323c6406b47 436 buffer[header_ind+2] == '\r' &&
alexhrao 8:d323c6406b47 437 buffer[header_ind+3] == '\n') {
alexhrao 4:55f0c303f56a 438 // Increment header_ind, look for JSON
alexhrao 4:55f0c303f56a 439 // Now just look for {
alexhrao 4:55f0c303f56a 440 header_ind += 4;
alexhrao 4:55f0c303f56a 441 while (header_ind < read_len) {
alexhrao 4:55f0c303f56a 442 if (buffer[header_ind] == '{') {
alexhrao 4:55f0c303f56a 443 // we got it!
alexhrao 4:55f0c303f56a 444 break;
alexhrao 4:55f0c303f56a 445 }
alexhrao 4:55f0c303f56a 446 header_ind++;
alexhrao 4:55f0c303f56a 447 }
alexhrao 4:55f0c303f56a 448 break;
alexhrao 4:55f0c303f56a 449 }
alexhrao 4:55f0c303f56a 450 header_ind++;
alexhrao 4:55f0c303f56a 451 }
alexhrao 4:55f0c303f56a 452
alexhrao 4:55f0c303f56a 453 for (footer_ind = read_len - 1; footer_ind > header_ind; footer_ind--) {
alexhrao 4:55f0c303f56a 454 if(buffer[footer_ind] == '}') {
alexhrao 4:55f0c303f56a 455 break;
alexhrao 4:55f0c303f56a 456 }
alexhrao 4:55f0c303f56a 457 }
alexhrao 4:55f0c303f56a 458 buffer[footer_ind + 1] = '\0';
alexhrao 12:513a0fd7c426 459 #if ESP8226_NEW_NODE == 0
alexhrao 9:299eb69af04e 460 parser = new MbedJSONValue();
alexhrao 9:299eb69af04e 461 parse(*parser, buffer + header_ind);
alexhrao 4:55f0c303f56a 462
alexhrao 4:55f0c303f56a 463 // Add 5 so that we make up for the wait(5)
alexhrao 6:ec7829f7cd38 464 // Add 3 so that we make up for TCP request - empirically...
alexhrao 9:299eb69af04e 465 set_time((*parser)["timestamp"].get<int>() + 5 + 3);
alexhrao 9:299eb69af04e 466 delete(parser);
alexhrao 12:513a0fd7c426 467 #else
alexhrao 12:513a0fd7c426 468 set_time(100000);
alexhrao 12:513a0fd7c426 469 #endif
alexhrao 9:299eb69af04e 470 lcd_lock.lock();
alexhrao 9:299eb69af04e 471 uLCD.cls();
alexhrao 9:299eb69af04e 472 lcd_lock.unlock();
alexhrao 4:55f0c303f56a 473 // Now that we know what time it is, set up our Time Thread
alexhrao 4:55f0c303f56a 474 time_thread.start(time_updater);
alexhrao 8:d323c6406b47 475
alexhrao 4:55f0c303f56a 476 TCPSocketConnection forecast_sck;
alexhrao 6:ec7829f7cd38 477
alexhrao 4:55f0c303f56a 478 forecast_sck.connect("api.openweathermap.org", 80);
alexhrao 6:ec7829f7cd38 479
alexhrao 4:55f0c303f56a 480 sprintf(cmd,
alexhrao 9:299eb69af04e 481 "GET /data/2.5/forecast?lat=%0.4f&lon=%0.4f&APPID=%s&cnt=1\r\nHost: api.openweathermap.org\r\n\r\n",
alexhrao 8:d323c6406b47 482 latitude, longitude, weather_api_key);
alexhrao 4:55f0c303f56a 483 forecast_sck.send_all(cmd, strlen(cmd));
alexhrao 6:ec7829f7cd38 484
alexhrao 4:55f0c303f56a 485 wait(5);
alexhrao 4:55f0c303f56a 486
alexhrao 9:299eb69af04e 487 read_len = wifi.recv(buffer, BUF_SIZE - 1, 0);
alexhrao 6:ec7829f7cd38 488 buffer[read_len] = '\0';
alexhrao 8:d323c6406b47 489
alexhrao 6:ec7829f7cd38 490 // We don't have enough memory for another parser (why?), so just
alexhrao 6:ec7829f7cd38 491 // look for the word "temp" 0 hopefully won't have a city named "temp"!
alexhrao 4:55f0c303f56a 492 char* ind = strstr(buffer, "temp");
alexhrao 4:55f0c303f56a 493 char num_buf[16];
alexhrao 4:55f0c303f56a 494 int num_ind = 0;
alexhrao 4:55f0c303f56a 495 // go until we find numbers
alexhrao 4:55f0c303f56a 496 while (char tmp = *ind++) {
alexhrao 4:55f0c303f56a 497 if (tmp > '0' && tmp < '9') {
alexhrao 4:55f0c303f56a 498 num_buf[num_ind++] = tmp;
alexhrao 4:55f0c303f56a 499 break;
alexhrao 4:55f0c303f56a 500 }
alexhrao 4:55f0c303f56a 501 }
alexhrao 4:55f0c303f56a 502 // Keep moving until no more numbers
alexhrao 4:55f0c303f56a 503 while (char tmp = *ind++) {
alexhrao 4:55f0c303f56a 504 if (tmp > '9' || tmp < '0') {
alexhrao 4:55f0c303f56a 505 num_buf[num_ind] = '\0';
alexhrao 4:55f0c303f56a 506 break;
alexhrao 4:55f0c303f56a 507 } else {
alexhrao 4:55f0c303f56a 508 num_buf[num_ind++] = tmp;
alexhrao 4:55f0c303f56a 509 }
alexhrao 4:55f0c303f56a 510 }
alexhrao 4:55f0c303f56a 511 int temp = atoi(num_buf);
alexhrao 9:299eb69af04e 512
alexhrao 4:55f0c303f56a 513 // Convert
alexhrao 6:ec7829f7cd38 514 temp = kelvin2farenheit(temp);
alexhrao 4:55f0c303f56a 515 char temp_buf[12];
alexhrao 4:55f0c303f56a 516 sprintf(temp_buf, " %dF", temp);
alexhrao 8:d323c6406b47 517
alexhrao 2:f7d19812bdc5 518 lcd_lock.lock();
alexhrao 4:55f0c303f56a 519 uLCD.text_width(2);
alexhrao 4:55f0c303f56a 520 uLCD.text_height(2);
alexhrao 4:55f0c303f56a 521 uLCD.text_string(temp_buf, 0, 5, FONT_8X8, WHITE);
alexhrao 2:f7d19812bdc5 522 lcd_lock.unlock();
alexhrao 6:ec7829f7cd38 523
alexhrao 6:ec7829f7cd38 524 time_t prev_time = time(NULL);
alexhrao 1:0620ba35d2e8 525 while(true) {
alexhrao 3:7bf41989ff8f 526 time_t curr_time = time(NULL);
alexhrao 6:ec7829f7cd38 527 // Wait for 60 seconds
alexhrao 6:ec7829f7cd38 528 if ((prev_time + 60) < curr_time) {
alexhrao 4:55f0c303f56a 529 sprintf(cmd,
alexhrao 8:d323c6406b47 530 "GET /data/2.5/weather?lat=%0.4f&lon=%0.4f&APPID=%s\r\nHost: api.openweathermap.org\r\n\r\n",
alexhrao 8:d323c6406b47 531 latitude, longitude, weather_api_key);
alexhrao 4:55f0c303f56a 532 forecast_sck.connect("api.openweathermap.org", 80);
alexhrao 4:55f0c303f56a 533 wait(10);
alexhrao 4:55f0c303f56a 534 forecast_sck.send_all(cmd, strlen(cmd));
alexhrao 4:55f0c303f56a 535 wait(5);
alexhrao 4:55f0c303f56a 536
alexhrao 6:ec7829f7cd38 537 read_len = wifi.recv(buffer, BUF_SIZE - 1, 0);
alexhrao 4:55f0c303f56a 538
alexhrao 6:ec7829f7cd38 539 buffer[read_len] = '\0';
alexhrao 4:55f0c303f56a 540
alexhrao 4:55f0c303f56a 541 ind = strstr(buffer, "temp");
alexhrao 4:55f0c303f56a 542 num_ind = 0;
alexhrao 4:55f0c303f56a 543 // go until we find numbers
alexhrao 4:55f0c303f56a 544 while (char tmp = *ind++) {
alexhrao 4:55f0c303f56a 545 if (tmp > '0' && tmp < '9') {
alexhrao 4:55f0c303f56a 546 num_buf[num_ind++] = tmp;
alexhrao 4:55f0c303f56a 547 break;
alexhrao 4:55f0c303f56a 548 }
alexhrao 4:55f0c303f56a 549 }
alexhrao 4:55f0c303f56a 550 // Keep moving until no more numbers
alexhrao 4:55f0c303f56a 551 while (char tmp = *ind++) {
alexhrao 4:55f0c303f56a 552 if (tmp > '9' || tmp < '0') {
alexhrao 4:55f0c303f56a 553 num_buf[num_ind] = '\0';
alexhrao 4:55f0c303f56a 554 break;
alexhrao 4:55f0c303f56a 555 } else {
alexhrao 4:55f0c303f56a 556 num_buf[num_ind++] = tmp;
alexhrao 4:55f0c303f56a 557 }
alexhrao 4:55f0c303f56a 558 }
alexhrao 4:55f0c303f56a 559 temp = atoi(num_buf);
alexhrao 6:ec7829f7cd38 560
alexhrao 4:55f0c303f56a 561 // Convert
alexhrao 6:ec7829f7cd38 562 temp = kelvin2farenheit(temp);
alexhrao 4:55f0c303f56a 563 sprintf(temp_buf, " %dF", temp);
alexhrao 4:55f0c303f56a 564 lcd_lock.lock();
alexhrao 4:55f0c303f56a 565 uLCD.text_width(2);
alexhrao 4:55f0c303f56a 566 uLCD.text_height(2);
alexhrao 4:55f0c303f56a 567 uLCD.text_string(temp_buf, 0, 5, FONT_8X8, WHITE);
alexhrao 4:55f0c303f56a 568 lcd_lock.unlock();
alexhrao 3:7bf41989ff8f 569 }
alexhrao 0:4ffa136585a2 570 }
alexhrao 0:4ffa136585a2 571 }
alexhrao 4:55f0c303f56a 572
alexhrao 8:d323c6406b47 573 int main()
alexhrao 8:d323c6406b47 574 {
alexhrao 4:55f0c303f56a 575 clock_init();
alexhrao 4:55f0c303f56a 576 }