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