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