Okundu Omeni / Mbed OS wifi-https-ble-sm-uart-atcmd-5-13-1

this is using the mbed os version 5-13-1

Dependencies:   mbed-http

source/ATCmdManager.cpp@89:45f6db09a76d, 2019-04-01 (annotated)

Committer:
ocomeni
Date:
Mon Apr 01 08:00:41 2019 +0000
Revision:
89:45f6db09a76d
Parent:
88:7ffa053be662
Child:
90:ed0267eca7b5
download working ok. still need to fix memory leak.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
ocomeni 74:f26e846adfe9 1 #include "ATCmdManager.h"
ocomeni 74:f26e846adfe9 2 #include "common_config.h"
ocomeni 79:a2187bbfa407 3 #include "common_types.h"
ocomeni 84:7c7add00f4bf 4 #include "http_request.h"
ocomeni 84:7c7add00f4bf 5 //#include "mbed_memory_status.h"
ocomeni 74:f26e846adfe9 6
ocomeni 78:07bb86e3ce14 7 ATCmdManager::ATCmdManager(PinName tx, PinName rx, SMDevicePeripheral *blePeripheral,
ocomeni 79:a2187bbfa407 8 events::EventQueue &event_queue, WiFiManager *wifi,
ocomeni 79:a2187bbfa407 9 MemoryPool<wifi_cmd_message_t, 16> *aT2WiFimPool,
ocomeni 80:e8f0e92e3ac9 10 Queue<wifi_cmd_message_t, 16> *aT2WiFiCmdQueue,
ocomeni 81:637a87eb8170 11 MemoryPool<at_resp_message_t, 16> *wiFi2ATmPool,
ocomeni 81:637a87eb8170 12 Queue<at_resp_message_t, 16> *wiFi2ATCmdQueue,
ocomeni 87:99b37d26ff2a 13 MemoryPool<wifi_data_msg_t, PQDSZ> *aT2WiFiDatamPool,
ocomeni 87:99b37d26ff2a 14 Queue<wifi_data_msg_t, PQDSZ> *aT2WiFiDataQueue,
ocomeni 87:99b37d26ff2a 15 MemoryPool<at_data_msg_t, PQDSZ> *wiFi2ATDatamPool,
ocomeni 87:99b37d26ff2a 16 Queue<at_data_msg_t, PQDSZ> *wiFi2ATDataQueue,
ocomeni 79:a2187bbfa407 17 bool debug)
ocomeni 74:f26e846adfe9 18 :
ocomeni 74:f26e846adfe9 19 _serial(tx, rx, DEFAULT_BAUD_RATE),
ocomeni 78:07bb86e3ce14 20 blePeripheral(blePeripheral),
ocomeni 79:a2187bbfa407 21 _event_queue(event_queue),
ocomeni 79:a2187bbfa407 22 wiFiManager(wiFiManager),
ocomeni 79:a2187bbfa407 23 _aT2WiFimPool(aT2WiFimPool),
ocomeni 80:e8f0e92e3ac9 24 _aT2WiFiCmdQueue(aT2WiFiCmdQueue),
ocomeni 80:e8f0e92e3ac9 25
ocomeni 80:e8f0e92e3ac9 26 _wiFi2ATmPool(wiFi2ATmPool),
ocomeni 80:e8f0e92e3ac9 27 _wiFi2ATCmdQueue(wiFi2ATCmdQueue),
ocomeni 80:e8f0e92e3ac9 28
ocomeni 80:e8f0e92e3ac9 29 _aT2WiFiDatamPool(aT2WiFiDatamPool),
ocomeni 80:e8f0e92e3ac9 30 _aT2WiFiDataQueue(aT2WiFiDataQueue),
ocomeni 80:e8f0e92e3ac9 31
ocomeni 80:e8f0e92e3ac9 32 _wiFi2ATDatamPool(wiFi2ATDatamPool),
ocomeni 80:e8f0e92e3ac9 33 _wiFi2ATDataQueue(wiFi2ATDataQueue),
ocomeni 80:e8f0e92e3ac9 34
ocomeni 80:e8f0e92e3ac9 35 _parser(&_serial)
ocomeni 80:e8f0e92e3ac9 36
ocomeni 74:f26e846adfe9 37
ocomeni 74:f26e846adfe9 38 {
ocomeni 74:f26e846adfe9 39 // constructor
ocomeni 74:f26e846adfe9 40 _serial.set_baud(DEFAULT_BAUD_RATE);
ocomeni 74:f26e846adfe9 41 _parser.debug_on(debug);
ocomeni 74:f26e846adfe9 42 _parser.set_delimiter("\r\n");
ocomeni 75:08eff6258e1b 43 _parser.send("+STARTUP");
ocomeni 81:637a87eb8170 44 _parser.oob("AT\n", callback(this, &ATCmdManager::_oob_ok_hdlr));
ocomeni 75:08eff6258e1b 45 _parser.oob("ATE0", callback(this, &ATCmdManager::_oob_echo_off));
ocomeni 75:08eff6258e1b 46 _parser.oob("ATE1", callback(this, &ATCmdManager::_oob_echo_on));
ocomeni 75:08eff6258e1b 47 _parser.oob("AT+UMRS", callback(this, &ATCmdManager::_oob_uart_setup));
ocomeni 75:08eff6258e1b 48
ocomeni 75:08eff6258e1b 49 _parser.oob("ATO", callback(this, &ATCmdManager::_oob_data_mode));
ocomeni 75:08eff6258e1b 50 _parser.oob("AT+UMLA", callback(this, &ATCmdManager::_oob_get_mac_addr));
ocomeni 75:08eff6258e1b 51 _parser.oob("AT+UBTLE?", callback(this, &ATCmdManager::_oob_get_ble_role));
ocomeni 75:08eff6258e1b 52 _parser.oob("AT+UBTLE=2", callback(this, &ATCmdManager::_oob_ena_ble_peri));
ocomeni 75:08eff6258e1b 53 _parser.oob("AT+CPWROFF", callback(this, &ATCmdManager::_oob_reboot));
ocomeni 75:08eff6258e1b 54 _parser.oob("AT+CGMR", callback(this, &ATCmdManager::_oob_get_fw_ver));
ocomeni 82:10072c1794d3 55 _parser.oob("AT+UWSCAN", callback(this, &ATCmdManager::_oob_scanWiFiNetworks));
ocomeni 79:a2187bbfa407 56 _parser.oob("AT+UWSCA=", callback(this, &ATCmdManager::_oob_connect2WiFiNetwork));
ocomeni 81:637a87eb8170 57 _parser.oob("AT+UWSCD=", callback(this, &ATCmdManager::_oob_disconnectWiFiNetwork));
ocomeni 81:637a87eb8170 58 _parser.oob("AT+UDDRP", callback(this, &ATCmdManager::_oob_setupInternetConnection));
ocomeni 82:10072c1794d3 59 _parser.oob("AT+UWSC=0,2", callback(this, &ATCmdManager::_oob_setWiFiSSID));
ocomeni 82:10072c1794d3 60 _parser.oob("AT+UWSC=0,8", callback(this, &ATCmdManager::_oob_setWiFiPWD));
ocomeni 82:10072c1794d3 61 _parser.oob("AT+UWSC=0,5", callback(this, &ATCmdManager::_oob_setWiFiSecurity));
ocomeni 84:7c7add00f4bf 62 //_parser.oob("AT+UWSC=0,5", callback(this, &ATCmdManager::_oob_sendHttpMessage));
ocomeni 81:637a87eb8170 63
ocomeni 82:10072c1794d3 64 //AT+UWSC=0,2,<SSID>
ocomeni 82:10072c1794d3 65 //AT+UWSC=0,8,<PWD>
ocomeni 82:10072c1794d3 66 //AT+UWSC=0,5,2 (WPA)
ocomeni 75:08eff6258e1b 67 //_parser.oob("ATE0", callback(this, &ATCmdManager::_oob_startup_hdlr));
ocomeni 74:f26e846adfe9 68 printf("\n --- ATCmdManager constructor completed ---\n");
ocomeni 81:637a87eb8170 69 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 70 dataMode = AT_CMD_DATA_MODE;
ocomeni 89:45f6db09a76d 71 event_queue.call_every(3600000,&print_memory_info);
ocomeni 75:08eff6258e1b 72 //AT+UMRS=230400,2,8,1,1,1
ocomeni 74:f26e846adfe9 73 // AT+UBTLE
ocomeni 74:f26e846adfe9 74 }
ocomeni 74:f26e846adfe9 75
ocomeni 74:f26e846adfe9 76
ocomeni 74:f26e846adfe9 77 void ATCmdManager::runMain(){
ocomeni 87:99b37d26ff2a 78 printf("\r\n [ATCMD MAN] Thread Id = %d\r\n", Thread::gettid());
ocomeni 74:f26e846adfe9 79 while(true){
ocomeni 74:f26e846adfe9 80 _process_oob(UBLOX_ODIN_W2_RECV_TIMEOUT, true);
ocomeni 81:637a87eb8170 81 wait_ms(MAIN_LOOP_WAIT_TIME_MS); // allow BTLE/WiFi some time
ocomeni 81:637a87eb8170 82 processResponses();
ocomeni 74:f26e846adfe9 83 }
ocomeni 74:f26e846adfe9 84
ocomeni 74:f26e846adfe9 85 }
ocomeni 74:f26e846adfe9 86
ocomeni 81:637a87eb8170 87 void ATCmdManager::processResponses(){
ocomeni 81:637a87eb8170 88 dequeueATresponse();
ocomeni 87:99b37d26ff2a 89 dequeueWiFidataResponse();
ocomeni 81:637a87eb8170 90 switch(at_resp){
ocomeni 81:637a87eb8170 91 case AT_RESP_NONE:
ocomeni 81:637a87eb8170 92 // IDLE response state
ocomeni 81:637a87eb8170 93 break;
ocomeni 81:637a87eb8170 94 case AT_SCAN_RESP:
ocomeni 81:637a87eb8170 95 // AT_SCAN_RESP response state
ocomeni 84:7c7add00f4bf 96 //////_smutex.lock();
ocomeni 81:637a87eb8170 97 printf("\n [ATCMD MAN] WIFI SCAN RESPONSE RECEIVED!!\n");
ocomeni 81:637a87eb8170 98 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 99 //////_smutex.unlock();
ocomeni 81:637a87eb8170 100 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 101 break;
ocomeni 81:637a87eb8170 102 case AT_DETAILED_SCAN_RESP:
ocomeni 81:637a87eb8170 103 // AT_DETAILED_SCAN_RESP response state
ocomeni 84:7c7add00f4bf 104 //////_smutex.lock();
ocomeni 81:637a87eb8170 105 printf("\n [ATCMD MAN] WIFI DETAILED SCAN RESPONSE RECEIVED!!\n");
ocomeni 81:637a87eb8170 106 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 107 //////_smutex.unlock();
ocomeni 81:637a87eb8170 108 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 109 break;
ocomeni 81:637a87eb8170 110 case AT_CONNECT_RESP:
ocomeni 81:637a87eb8170 111 // AT_CONNECT_RESP response state
ocomeni 84:7c7add00f4bf 112 //////_smutex.lock();
ocomeni 81:637a87eb8170 113 printf("\n [ATCMD MAN] WIFI CONNECT RESPONSE RECEIVED!!\n");
ocomeni 81:637a87eb8170 114 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 115 //////_smutex.unlock();
ocomeni 81:637a87eb8170 116 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 117 break;
ocomeni 81:637a87eb8170 118 case AT_DISCONNECT_RESP:
ocomeni 81:637a87eb8170 119 // AT_DISCONNECT_RESP response state
ocomeni 84:7c7add00f4bf 120 //////_smutex.lock();
ocomeni 81:637a87eb8170 121 printf("\n [ATCMD MAN] WIFI DISCONNECT RESPONSE RECEIVED!!\n");
ocomeni 81:637a87eb8170 122 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 123 //////_smutex.unlock();
ocomeni 81:637a87eb8170 124 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 125 break;
ocomeni 82:10072c1794d3 126 case AT_CONFIG_RESP:
ocomeni 82:10072c1794d3 127 // AT_CONFIG_RESP response state
ocomeni 84:7c7add00f4bf 128 //////_smutex.lock();
ocomeni 82:10072c1794d3 129 printf("\n [ATCMD MAN] WIFI CONFIG RESPONSE RECEIVED!!\n");
ocomeni 81:637a87eb8170 130 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 131 //////_smutex.unlock();
ocomeni 84:7c7add00f4bf 132 at_resp = AT_RESP_NONE;
ocomeni 84:7c7add00f4bf 133 break;
ocomeni 84:7c7add00f4bf 134 case AT_INTERNET_CONFIG_RESP:
ocomeni 84:7c7add00f4bf 135 // AT_CONFIG_RESP response state
ocomeni 84:7c7add00f4bf 136 //////_smutex.lock();
ocomeni 84:7c7add00f4bf 137 printf("\n [ATCMD MAN] WIFI INTERNET_CONFIG RESPONSE RECEIVED!!\n");
ocomeni 84:7c7add00f4bf 138 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 139 //////_smutex.unlock();
ocomeni 84:7c7add00f4bf 140 at_resp = AT_RESP_NONE;
ocomeni 84:7c7add00f4bf 141 break;
ocomeni 84:7c7add00f4bf 142 case AT_HTTPS_RESP:
ocomeni 84:7c7add00f4bf 143 // AT_HTTP_RESP response state
ocomeni 84:7c7add00f4bf 144 //////_smutex.lock();
ocomeni 84:7c7add00f4bf 145 printf("\n [ATCMD MAN] WIFI HTTPS RESPONSE RECEIVED!!\n");
ocomeni 87:99b37d26ff2a 146 return_response();
ocomeni 84:7c7add00f4bf 147 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 148 //////_smutex.unlock();
ocomeni 81:637a87eb8170 149 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 150 break;
ocomeni 89:45f6db09a76d 151 case AT_HTTPS_RESP_DOWNLOAD:
ocomeni 89:45f6db09a76d 152 // AT_HTTPS_RESP_DOWNLOAD response state
ocomeni 89:45f6db09a76d 153 //////_smutex.lock();
ocomeni 89:45f6db09a76d 154 printf("\n [ATCMD MAN] WIFI HTTPS DOWNLOAD RESPONSE RECEIVED!!\n");
ocomeni 89:45f6db09a76d 155 return_response(true); // set download paramter to true
ocomeni 89:45f6db09a76d 156 _parser.send("OK\n");
ocomeni 89:45f6db09a76d 157 //////_smutex.unlock();
ocomeni 89:45f6db09a76d 158 at_resp = AT_RESP_NONE;
ocomeni 89:45f6db09a76d 159 break;
ocomeni 81:637a87eb8170 160 case AT_HTTP_RESP:
ocomeni 81:637a87eb8170 161 // AT_HTTP_RESP response state
ocomeni 84:7c7add00f4bf 162 //////_smutex.lock();
ocomeni 81:637a87eb8170 163 printf("\n [ATCMD MAN] WIFI HTTP RESPONSE RECEIVED!!\n");
ocomeni 89:45f6db09a76d 164 return_response();
ocomeni 89:45f6db09a76d 165 _parser.send("OK\n");
ocomeni 89:45f6db09a76d 166 //////_smutex.unlock();
ocomeni 89:45f6db09a76d 167 at_resp = AT_RESP_NONE;
ocomeni 89:45f6db09a76d 168 break;
ocomeni 89:45f6db09a76d 169 case AT_HTTP_RESP_DOWNLOAD:
ocomeni 89:45f6db09a76d 170 // AT_HTTP_RESP response state
ocomeni 89:45f6db09a76d 171 //////_smutex.lock();
ocomeni 89:45f6db09a76d 172 printf("\n [ATCMD MAN] WIFI HTTP RESPONSE RECEIVED!!\n");
ocomeni 89:45f6db09a76d 173 return_response(true); // set download paramter to true
ocomeni 81:637a87eb8170 174 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 175 //////_smutex.unlock();
ocomeni 81:637a87eb8170 176 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 177 break;
ocomeni 81:637a87eb8170 178 default:
ocomeni 81:637a87eb8170 179 // UNKNOWN response state
ocomeni 84:7c7add00f4bf 180 //////_smutex.lock();
ocomeni 82:10072c1794d3 181 printf("\n [ATCMD MAN] UNKNOWN RESPONSE RECEIVED!!\n");
ocomeni 82:10072c1794d3 182 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 183 //////_smutex.unlock();
ocomeni 81:637a87eb8170 184 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 185 break;
ocomeni 81:637a87eb8170 186 }
ocomeni 81:637a87eb8170 187 }
ocomeni 81:637a87eb8170 188
ocomeni 89:45f6db09a76d 189 void ATCmdManager::printBufferInHex(uint8_t *buf, int pLen)
ocomeni 89:45f6db09a76d 190 {
ocomeni 89:45f6db09a76d 191 for(int i =0;i<pLen;i++){
ocomeni 89:45f6db09a76d 192 if(i%8==0) printf("\n[%3d]",i);
ocomeni 89:45f6db09a76d 193 printf("%02x ", buf[i]);
ocomeni 89:45f6db09a76d 194 }
ocomeni 89:45f6db09a76d 195 printf("\n");
ocomeni 89:45f6db09a76d 196 }
ocomeni 81:637a87eb8170 197
ocomeni 83:9c271a50a70b 198 bool ATCmdManager::validate(edm_header_t edm_header)
ocomeni 83:9c271a50a70b 199 {
ocomeni 83:9c271a50a70b 200 if(edm_header.startByte != EDM_START_BYTE)return false; // unexpected start byte found!
ocomeni 83:9c271a50a70b 201 if(edm_header.payloadID != CONNECT_EVENT &&
ocomeni 83:9c271a50a70b 202 edm_header.payloadID != DISCONNECT_EVENT &&
ocomeni 83:9c271a50a70b 203 edm_header.payloadID != DATA_EVENT &&
ocomeni 83:9c271a50a70b 204 edm_header.payloadID != DATA_COMMAND &&
ocomeni 83:9c271a50a70b 205 edm_header.payloadID != AT_REQUEST &&
ocomeni 83:9c271a50a70b 206 edm_header.payloadID != AT_CONFIRMATION &&
ocomeni 83:9c271a50a70b 207 edm_header.payloadID != AT_EVENT
ocomeni 83:9c271a50a70b 208 )return false; // unexpected payload ID found!
ocomeni 83:9c271a50a70b 209 if(edm_header.payloadLen > MAX_EDM_PAYLOAD_LEN ||
ocomeni 83:9c271a50a70b 210 edm_header.payloadLen < MIN_EDM_PAYLOAD_LEN
ocomeni 83:9c271a50a70b 211 ) return false; // unexpected length received!
ocomeni 83:9c271a50a70b 212 return true;
ocomeni 83:9c271a50a70b 213 }
ocomeni 74:f26e846adfe9 214
ocomeni 84:7c7add00f4bf 215 http_method ATCmdManager::str2HttpMethod(const char * methodStr)
ocomeni 84:7c7add00f4bf 216 {
ocomeni 84:7c7add00f4bf 217 http_method _http_method;
ocomeni 84:7c7add00f4bf 218 if(strstr(methodStr, "POST")!= NULL){
ocomeni 84:7c7add00f4bf 219 _http_method = HTTP_POST;
ocomeni 84:7c7add00f4bf 220 }
ocomeni 84:7c7add00f4bf 221 else if(strstr(methodStr, "GET")!= NULL){
ocomeni 84:7c7add00f4bf 222 _http_method = HTTP_GET;
ocomeni 84:7c7add00f4bf 223 }
ocomeni 84:7c7add00f4bf 224 else{
ocomeni 84:7c7add00f4bf 225 _http_method = HTTP_DELETE; // unsupported method - set to HTTP_DELETE
ocomeni 84:7c7add00f4bf 226 }
ocomeni 84:7c7add00f4bf 227 return _http_method;
ocomeni 84:7c7add00f4bf 228 }
ocomeni 84:7c7add00f4bf 229 bool ATCmdManager::createHttpRequest()
ocomeni 84:7c7add00f4bf 230 {
ocomeni 84:7c7add00f4bf 231 http_request_t http_req;
ocomeni 87:99b37d26ff2a 232 printf("\nsizeof(http_req) on creation = %d\n", sizeof(http_req));
ocomeni 87:99b37d26ff2a 233
ocomeni 84:7c7add00f4bf 234 char s1[32];
ocomeni 84:7c7add00f4bf 235 char s2[32];
ocomeni 84:7c7add00f4bf 236 char s3[32];
ocomeni 84:7c7add00f4bf 237 int n = 0;
ocomeni 84:7c7add00f4bf 238 int pos = 0;
ocomeni 84:7c7add00f4bf 239 char * strPtr = (char *)&rx_buf_ptr[1];
ocomeni 84:7c7add00f4bf 240 char * p;
ocomeni 84:7c7add00f4bf 241 char * p2 = strstr(strPtr, "\r\n\r\n");
ocomeni 84:7c7add00f4bf 242 char * nxtPtr = strPtr;
ocomeni 84:7c7add00f4bf 243 char * bodyPtr = p2+4;
ocomeni 84:7c7add00f4bf 244 printf("\nstrPtr address= %x",strPtr);
ocomeni 84:7c7add00f4bf 245 printf("\np2 address= %x", p2);
ocomeni 84:7c7add00f4bf 246 for(int i = 0; i < 5; i++){
ocomeni 84:7c7add00f4bf 247 if(i == 0)// firstline scan method uri and http_ver
ocomeni 84:7c7add00f4bf 248 {
ocomeni 84:7c7add00f4bf 249 //n = sscanf(nxtPtr,"%s %s %s", &s1[0], &s2[0], &s3[0]);
ocomeni 84:7c7add00f4bf 250 n = sscanf(nxtPtr,"%s %s %s", s1, s2, s3);
ocomeni 84:7c7add00f4bf 251 printf("\nmethod = %s\nuri = %s\nhttp_ver = %s",s1, s2, s3 );
ocomeni 84:7c7add00f4bf 252 //http_req.method = str2HttpMethod(s1.c_str());
ocomeni 84:7c7add00f4bf 253 http_req.method = str2HttpMethod(s1);
ocomeni 84:7c7add00f4bf 254 http_req.request_URI.assign(s2);
ocomeni 84:7c7add00f4bf 255 http_req.http_version.assign(s3);
ocomeni 88:7ffa053be662 256 printf("\nhttp_req.method = %d \n", http_req.method);
ocomeni 84:7c7add00f4bf 257 }
ocomeni 84:7c7add00f4bf 258 else{ // scan header pairs
ocomeni 84:7c7add00f4bf 259 //n = sscanf(nxtPtr,"%s %s", &s1[0], &s2[0]);
ocomeni 84:7c7add00f4bf 260 n = sscanf(nxtPtr,"%s %s", s1, s2);
ocomeni 84:7c7add00f4bf 261 p = strstr(s1,":");
ocomeni 84:7c7add00f4bf 262 *p = NULL;
ocomeni 84:7c7add00f4bf 263 //pos = s1.find(":");
ocomeni 84:7c7add00f4bf 264 //s1.replace(pos,1,"");
ocomeni 84:7c7add00f4bf 265 printf("\nname = %s value = %s",s1, s2);
ocomeni 84:7c7add00f4bf 266 //if(s1.find("Host")!= string::npos){
ocomeni 86:04fc2fcda7ec 267 if(strstr(s1, "Host")!= NULL){
ocomeni 86:04fc2fcda7ec 268 http_req.hostName.assign(s2);
ocomeni 86:04fc2fcda7ec 269 }
ocomeni 86:04fc2fcda7ec 270 else if(strstr(s1, "Accept")!= NULL){
ocomeni 86:04fc2fcda7ec 271 http_req.AcceptVal.assign(s2);
ocomeni 86:04fc2fcda7ec 272 }
ocomeni 86:04fc2fcda7ec 273 else if(strstr(s1, "Content-Type")!= NULL){
ocomeni 86:04fc2fcda7ec 274 http_req.contentType.assign(s2);
ocomeni 86:04fc2fcda7ec 275 }
ocomeni 86:04fc2fcda7ec 276 else if(strstr(s1, "Content-Length")!= NULL){
ocomeni 86:04fc2fcda7ec 277 http_req.contentLen.assign(s2);
ocomeni 84:7c7add00f4bf 278 }
ocomeni 84:7c7add00f4bf 279
ocomeni 84:7c7add00f4bf 280
ocomeni 84:7c7add00f4bf 281 }
ocomeni 84:7c7add00f4bf 282 nxtPtr = strstr(nxtPtr, "\r\n")+2; // goto next line
ocomeni 84:7c7add00f4bf 283 if(nxtPtr >= p2) break;
ocomeni 84:7c7add00f4bf 284 }
ocomeni 84:7c7add00f4bf 285 int bodyLen = edm_hdr.payloadLen -(p2+7-strPtr);
ocomeni 84:7c7add00f4bf 286 printf("\nLen = %d\n", bodyLen);
ocomeni 84:7c7add00f4bf 287 memcpy(http_req.body, bodyPtr, bodyLen);
ocomeni 84:7c7add00f4bf 288 // package and send on wifi data queue
ocomeni 84:7c7add00f4bf 289 wifi_data_msg_t data_msg;
ocomeni 84:7c7add00f4bf 290 data_msg.wifi_cmd = WIFI_CMD_SEND_HTTPS_REQ;
ocomeni 87:99b37d26ff2a 291 printf("\nsizeof(http_req) on population = %d\n", sizeof(http_req));
ocomeni 88:7ffa053be662 292
ocomeni 85:9f896e1e041c 293 data_msg.dataLen = sizeof(http_req.method) +
ocomeni 85:9f896e1e041c 294 sizeof(http_req.body) +
ocomeni 85:9f896e1e041c 295 http_req.request_URI.capacity() +
ocomeni 85:9f896e1e041c 296 http_req.http_version.capacity() +
ocomeni 85:9f896e1e041c 297 http_req.hostName.capacity() +
ocomeni 85:9f896e1e041c 298 http_req.AcceptVal.capacity() +
ocomeni 85:9f896e1e041c 299 http_req.contentType.capacity() +
ocomeni 85:9f896e1e041c 300 http_req.contentLen.capacity();
ocomeni 88:7ffa053be662 301
ocomeni 88:7ffa053be662 302 /*
ocomeni 87:99b37d26ff2a 303 data_msg.dataLen = sizeof(http_req.method) +
ocomeni 87:99b37d26ff2a 304 sizeof(http_req.body) +
ocomeni 87:99b37d26ff2a 305 http_req.request_URI.size() +
ocomeni 87:99b37d26ff2a 306 http_req.http_version.size() +
ocomeni 87:99b37d26ff2a 307 http_req.hostName.size() +
ocomeni 87:99b37d26ff2a 308 http_req.AcceptVal.size() +
ocomeni 87:99b37d26ff2a 309 http_req.contentType.size() +
ocomeni 87:99b37d26ff2a 310 http_req.contentLen.size();
ocomeni 88:7ffa053be662 311 */
ocomeni 84:7c7add00f4bf 312 memcpy(data_msg.buffer,&http_req, data_msg.dataLen);
ocomeni 84:7c7add00f4bf 313 // queue next data request
ocomeni 84:7c7add00f4bf 314 queueWiFiDataRequest(data_msg);
ocomeni 84:7c7add00f4bf 315 return true;
ocomeni 84:7c7add00f4bf 316 }
ocomeni 74:f26e846adfe9 317 // OOB processing
ocomeni 74:f26e846adfe9 318 void ATCmdManager::_process_oob(uint32_t timeout, bool all){
ocomeni 74:f26e846adfe9 319 set_timeout(timeout);
ocomeni 83:9c271a50a70b 320 static int cnt = 0;
ocomeni 84:7c7add00f4bf 321 int start;
ocomeni 83:9c271a50a70b 322 if(dataMode == AT_EXT_DATA_MODE)
ocomeni 83:9c271a50a70b 323 {
ocomeni 83:9c271a50a70b 324 int n;
ocomeni 87:99b37d26ff2a 325 //if(cnt++ % 10 == 0)printf("In EDM mode\n");
ocomeni 84:7c7add00f4bf 326 uint8_t edm[EDM_HDR_LEN];
ocomeni 84:7c7add00f4bf 327
ocomeni 83:9c271a50a70b 328 // Poll for edm packets
ocomeni 83:9c271a50a70b 329 do{
ocomeni 84:7c7add00f4bf 330 n = _parser.read((char *)edm, EDM_HDR_LEN);
ocomeni 84:7c7add00f4bf 331 edm_hdr.startByte = edm[0];
ocomeni 84:7c7add00f4bf 332 edm_hdr.payloadLen = edm[1]*256 + edm[2];
ocomeni 84:7c7add00f4bf 333 edm_hdr.payloadID = edm[3]*256 + edm[4];
ocomeni 84:7c7add00f4bf 334 start = Kernel::get_ms_count();
ocomeni 83:9c271a50a70b 335 if(n == -1) break; // break if it times out
ocomeni 83:9c271a50a70b 336 printf("%d bytes read!\n", n);
ocomeni 83:9c271a50a70b 337 if(n==5)
ocomeni 83:9c271a50a70b 338 printf("Start = %d, payloadID = %d len = %d\n", edm_hdr.startByte,
ocomeni 83:9c271a50a70b 339 edm_hdr.payloadID,
ocomeni 83:9c271a50a70b 340 edm_hdr.payloadLen);
ocomeni 83:9c271a50a70b 341 if(n == EDM_HDR_LEN && validate(edm_hdr)) // if AT command use process oob to decode
ocomeni 83:9c271a50a70b 342 {
ocomeni 83:9c271a50a70b 343 if(edm_hdr.payloadID == AT_REQUEST)
ocomeni 83:9c271a50a70b 344 {
ocomeni 83:9c271a50a70b 345 _parser.process_oob();
ocomeni 83:9c271a50a70b 346 break;
ocomeni 83:9c271a50a70b 347 }
ocomeni 83:9c271a50a70b 348 else
ocomeni 83:9c271a50a70b 349 {
ocomeni 83:9c271a50a70b 350 int pLen = edm_hdr.payloadLen-1;
ocomeni 83:9c271a50a70b 351 rx_buf_ptr = (uint8_t *) malloc (pLen); // we already read 2 bytes from payload but expect 1 stop byte
ocomeni 83:9c271a50a70b 352 rx_buf_ptr[pLen-1] = 0x00; // clear last byte so the readback value is as expected
ocomeni 83:9c271a50a70b 353 n = _parser.read((char *)rx_buf_ptr, pLen);
ocomeni 83:9c271a50a70b 354 if(n == -1) break; // timeout!
ocomeni 83:9c271a50a70b 355 printf("%d bytes read - expected %d!\n", n, pLen);
ocomeni 89:45f6db09a76d 356 printBufferInHex(rx_buf_ptr, pLen);
ocomeni 83:9c271a50a70b 357 printf("rx_buf_ptr[pLen-1] = %0x\n",rx_buf_ptr[pLen-1]);
ocomeni 83:9c271a50a70b 358 if(rx_buf_ptr[pLen-1] != EDM_STOP_BYTE) {
ocomeni 83:9c271a50a70b 359 break; // exit if stop byte now found - possible data corruption!
ocomeni 83:9c271a50a70b 360 }
ocomeni 83:9c271a50a70b 361 switch(edm_hdr.payloadID)
ocomeni 83:9c271a50a70b 362 {
ocomeni 83:9c271a50a70b 363 case CONNECT_EVENT:
ocomeni 83:9c271a50a70b 364 printf("Connection Event received!\n");
ocomeni 83:9c271a50a70b 365 break;
ocomeni 83:9c271a50a70b 366 case DISCONNECT_EVENT:
ocomeni 83:9c271a50a70b 367 printf("DISCONNECT_EVENT received!\n");
ocomeni 83:9c271a50a70b 368 break;
ocomeni 83:9c271a50a70b 369 case DATA_EVENT:
ocomeni 83:9c271a50a70b 370 printf("DATA_EVENT received!\n");
ocomeni 83:9c271a50a70b 371 break;
ocomeni 83:9c271a50a70b 372 case DATA_COMMAND:
ocomeni 83:9c271a50a70b 373 printf("DATA_COMMAND received!\n");
ocomeni 84:7c7add00f4bf 374 if(createHttpRequest() == true){
ocomeni 84:7c7add00f4bf 375 _parser.send("OK");
ocomeni 83:9c271a50a70b 376 }
ocomeni 84:7c7add00f4bf 377 else{
ocomeni 84:7c7add00f4bf 378 _parser.send("NACK");
ocomeni 84:7c7add00f4bf 379 }
ocomeni 84:7c7add00f4bf 380 int stop = Kernel::get_ms_count();
ocomeni 84:7c7add00f4bf 381 printf("\n Time Elapsed = %d\n", stop-start);
ocomeni 83:9c271a50a70b 382 break;
ocomeni 83:9c271a50a70b 383 case AT_REQUEST:
ocomeni 83:9c271a50a70b 384 printf("AT_REQUEST received!\n");
ocomeni 83:9c271a50a70b 385 break;
ocomeni 83:9c271a50a70b 386 case AT_CONFIRMATION:
ocomeni 83:9c271a50a70b 387 printf("AT_CONFIRMATION received!\n");
ocomeni 83:9c271a50a70b 388 break;
ocomeni 83:9c271a50a70b 389 case AT_EVENT:
ocomeni 83:9c271a50a70b 390 printf("AT_EVENT received!\n");
ocomeni 83:9c271a50a70b 391 break;
ocomeni 83:9c271a50a70b 392 default:
ocomeni 83:9c271a50a70b 393 printf("UNKNOWN MESSAGE received!\n");
ocomeni 83:9c271a50a70b 394 break;
ocomeni 83:9c271a50a70b 395 }
ocomeni 83:9c271a50a70b 396 }
ocomeni 83:9c271a50a70b 397 //_parser.process_oob();
ocomeni 83:9c271a50a70b 398 }
ocomeni 83:9c271a50a70b 399 else // incorrect # of bytes received abort!!
ocomeni 83:9c271a50a70b 400 {
ocomeni 83:9c271a50a70b 401 break;
ocomeni 83:9c271a50a70b 402 }
ocomeni 83:9c271a50a70b 403 }while (all); // continue to process until timeout
ocomeni 74:f26e846adfe9 404 }
ocomeni 83:9c271a50a70b 405 else
ocomeni 83:9c271a50a70b 406 {
ocomeni 83:9c271a50a70b 407 // Poll for inbound packets
ocomeni 83:9c271a50a70b 408 while (_parser.process_oob() && all) {
ocomeni 83:9c271a50a70b 409 }
ocomeni 83:9c271a50a70b 410 }
ocomeni 74:f26e846adfe9 411 set_timeout();
ocomeni 74:f26e846adfe9 412 }
ocomeni 74:f26e846adfe9 413
ocomeni 74:f26e846adfe9 414
ocomeni 74:f26e846adfe9 415 // OOB message handlers
ocomeni 74:f26e846adfe9 416 void ATCmdManager::_oob_startup_hdlr(){
ocomeni 74:f26e846adfe9 417 }
ocomeni 74:f26e846adfe9 418
ocomeni 81:637a87eb8170 419 void ATCmdManager::_oob_ok_hdlr(){
ocomeni 84:7c7add00f4bf 420 //_smutex.lock();
ocomeni 81:637a87eb8170 421 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 422 //_smutex.unlock();
ocomeni 81:637a87eb8170 423 }
ocomeni 81:637a87eb8170 424
ocomeni 74:f26e846adfe9 425
ocomeni 74:f26e846adfe9 426 void ATCmdManager::_oob_bleRole_hdlr(){
ocomeni 74:f26e846adfe9 427 }
ocomeni 74:f26e846adfe9 428
ocomeni 74:f26e846adfe9 429
ocomeni 74:f26e846adfe9 430 void ATCmdManager::_oob_wifiMode_err(){
ocomeni 74:f26e846adfe9 431 }
ocomeni 74:f26e846adfe9 432
ocomeni 74:f26e846adfe9 433
ocomeni 74:f26e846adfe9 434 void ATCmdManager::_oob_conn_already(){
ocomeni 74:f26e846adfe9 435 }
ocomeni 74:f26e846adfe9 436
ocomeni 74:f26e846adfe9 437
ocomeni 74:f26e846adfe9 438 void ATCmdManager::_oob_err(){
ocomeni 74:f26e846adfe9 439 }
ocomeni 74:f26e846adfe9 440
ocomeni 79:a2187bbfa407 441 void ATCmdManager::_oob_get_fw_ver()
ocomeni 79:a2187bbfa407 442 {
ocomeni 79:a2187bbfa407 443 }
ocomeni 79:a2187bbfa407 444
ocomeni 79:a2187bbfa407 445
ocomeni 75:08eff6258e1b 446 void ATCmdManager::_oob_uart_setup(){
ocomeni 75:08eff6258e1b 447 int uOpts[NUM_UART_OPTIONS];
ocomeni 75:08eff6258e1b 448 //if(_parser.recv("=%d,%d,%d,%d,%d,%d", &uOpts[0], &uOpts[1], &uOpts[2], &uOpts[3], &uOpts[4], &uOpts[5])) {
ocomeni 75:08eff6258e1b 449 if(_parser.scanf("=%d,%d,%d,%d,%d,%d", &uOpts[0], &uOpts[1], &uOpts[2], &uOpts[3], &uOpts[4], &uOpts[5]) >0) {
ocomeni 75:08eff6258e1b 450 printf("\nATCmdParser: Uart Options=%d,%d,%d,%d,%d,%d\n", uOpts[0], uOpts[1], uOpts[2], uOpts[3], uOpts[4], uOpts[5]);
ocomeni 81:637a87eb8170 451 //AT+UMRS=230400,2,8,1,1,1
ocomeni 81:637a87eb8170 452 printf("\n Changing Baud Rate to %d\n", uOpts[0]);
ocomeni 81:637a87eb8170 453
ocomeni 81:637a87eb8170 454 _serial.set_baud(uOpts[0]);
ocomeni 81:637a87eb8170 455 printf("\n Baud Rate now %d\n", uOpts[0]);
ocomeni 81:637a87eb8170 456
ocomeni 75:08eff6258e1b 457 } else {
ocomeni 75:08eff6258e1b 458 printf("\nATCmdParser: Retrieving Uart Options failed");
ocomeni 75:08eff6258e1b 459 }
ocomeni 75:08eff6258e1b 460 }
ocomeni 75:08eff6258e1b 461
ocomeni 74:f26e846adfe9 462 void ATCmdManager::set_timeout(uint32_t timeout_ms)
ocomeni 74:f26e846adfe9 463 {
ocomeni 74:f26e846adfe9 464 _parser.set_timeout(timeout_ms);
ocomeni 74:f26e846adfe9 465 }
ocomeni 74:f26e846adfe9 466
ocomeni 75:08eff6258e1b 467
ocomeni 75:08eff6258e1b 468 void ATCmdManager::_oob_echo_off()
ocomeni 75:08eff6258e1b 469 {
ocomeni 84:7c7add00f4bf 470 //_smutex.lock();
ocomeni 75:08eff6258e1b 471 printf("\n Received ATEO OOB command!!\n");
ocomeni 75:08eff6258e1b 472 printf("\n turning echo OFF!!\n");
ocomeni 75:08eff6258e1b 473 _parser.debug_on(false);
ocomeni 75:08eff6258e1b 474 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 475 //_smutex.unlock();
ocomeni 75:08eff6258e1b 476 }
ocomeni 75:08eff6258e1b 477
ocomeni 75:08eff6258e1b 478
ocomeni 75:08eff6258e1b 479 void ATCmdManager::_oob_echo_on()
ocomeni 75:08eff6258e1b 480 {
ocomeni 84:7c7add00f4bf 481 //_smutex.lock();
ocomeni 75:08eff6258e1b 482 printf("\n Received ATE1 OOB command!!\n");
ocomeni 75:08eff6258e1b 483 printf("\n turning echo ON!!\n");
ocomeni 75:08eff6258e1b 484 _parser.debug_on(true);
ocomeni 75:08eff6258e1b 485 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 486 //_smutex.unlock();
ocomeni 75:08eff6258e1b 487 }
ocomeni 75:08eff6258e1b 488
ocomeni 75:08eff6258e1b 489
ocomeni 75:08eff6258e1b 490 void ATCmdManager::_oob_data_mode(){
ocomeni 84:7c7add00f4bf 491 //_smutex.lock();
ocomeni 75:08eff6258e1b 492 printf("\n Received EDM mode command!!\n");
ocomeni 75:08eff6258e1b 493 if(_parser.scanf("%d", &dataMode) >0) {
ocomeni 75:08eff6258e1b 494 printf("\nATCmdParser: Data mode=%d\n", dataMode);
ocomeni 75:08eff6258e1b 495 switch(dataMode)
ocomeni 75:08eff6258e1b 496 {
ocomeni 75:08eff6258e1b 497 case 0:
ocomeni 83:9c271a50a70b 498 printf("\nATCmdParser: Command Mode request received\n");
ocomeni 81:637a87eb8170 499 dataMode = AT_CMD_DATA_MODE;
ocomeni 75:08eff6258e1b 500 break;
ocomeni 75:08eff6258e1b 501 case 1:
ocomeni 83:9c271a50a70b 502 printf("\nATCmdParser: Data Mode request received\n");
ocomeni 81:637a87eb8170 503 dataMode = AT_STD_DATA_MODE;
ocomeni 75:08eff6258e1b 504 break;
ocomeni 75:08eff6258e1b 505 case 2:
ocomeni 83:9c271a50a70b 506 printf("\nATCmdParser: Extended data Mode request received\n");
ocomeni 81:637a87eb8170 507 dataMode = AT_EXT_DATA_MODE;
ocomeni 75:08eff6258e1b 508 break;
ocomeni 75:08eff6258e1b 509 default:
ocomeni 75:08eff6258e1b 510 printf("\nATCmdParser: ERROR - UNKNOWN DATA MODE RECEIVED!!! \n");
ocomeni 75:08eff6258e1b 511 break;
ocomeni 75:08eff6258e1b 512 }
ocomeni 75:08eff6258e1b 513 } else {
ocomeni 83:9c271a50a70b 514 printf("\nATCmdParser: Retrieving Uart Options failed\n");
ocomeni 75:08eff6258e1b 515 }
ocomeni 75:08eff6258e1b 516 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 517 //_smutex.unlock();
ocomeni 75:08eff6258e1b 518 }
ocomeni 75:08eff6258e1b 519
ocomeni 75:08eff6258e1b 520 void ATCmdManager::_oob_get_mac_addr(){
ocomeni 75:08eff6258e1b 521 int bleOrWifi;
ocomeni 84:7c7add00f4bf 522 //_smutex.lock();
ocomeni 75:08eff6258e1b 523 if(_parser.scanf("=%d", &bleOrWifi) >0) {
ocomeni 75:08eff6258e1b 524 switch(bleOrWifi)
ocomeni 75:08eff6258e1b 525 {
ocomeni 75:08eff6258e1b 526 case 1:
ocomeni 75:08eff6258e1b 527 printf("\nATCmdParser: BLE MAC Address request received");
ocomeni 75:08eff6258e1b 528 break;
ocomeni 75:08eff6258e1b 529 case 2:
ocomeni 75:08eff6258e1b 530 printf("\nATCmdParser: WiFi MAC Address request received");
ocomeni 75:08eff6258e1b 531 break;
ocomeni 75:08eff6258e1b 532 default:
ocomeni 75:08eff6258e1b 533 printf("\nATCmdParser: ERROR - UNKNOWN MAC ADDRESS REQUEST RECEIVED!!! \n");
ocomeni 75:08eff6258e1b 534 break;
ocomeni 75:08eff6258e1b 535 }
ocomeni 75:08eff6258e1b 536 } else {
ocomeni 75:08eff6258e1b 537 printf("\nATCmdParser: Retrieving Uart Options failed");
ocomeni 75:08eff6258e1b 538 }
ocomeni 75:08eff6258e1b 539 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 540 //_smutex.unlock();
ocomeni 75:08eff6258e1b 541 }
ocomeni 75:08eff6258e1b 542
ocomeni 75:08eff6258e1b 543 void ATCmdManager::_oob_get_ble_role(){
ocomeni 84:7c7add00f4bf 544 //_smutex.lock();
ocomeni 75:08eff6258e1b 545 printf("\n Received get BLE role command!!\n");
ocomeni 75:08eff6258e1b 546 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 547 //_smutex.unlock();
ocomeni 75:08eff6258e1b 548 }
ocomeni 75:08eff6258e1b 549
ocomeni 75:08eff6258e1b 550 void ATCmdManager::_oob_ena_ble_peri(){
ocomeni 84:7c7add00f4bf 551 //_smutex.lock();
ocomeni 75:08eff6258e1b 552 printf("\n Received enable BLE Peripheral command!!\n");
ocomeni 75:08eff6258e1b 553 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 554 //_smutex.unlock();
ocomeni 75:08eff6258e1b 555 }
ocomeni 75:08eff6258e1b 556
ocomeni 75:08eff6258e1b 557 void ATCmdManager::_oob_reboot(){
ocomeni 84:7c7add00f4bf 558 //_smutex.lock();
ocomeni 75:08eff6258e1b 559 printf("\n Received reboot command!!\n");
ocomeni 75:08eff6258e1b 560 _parser.send("OK\n");
ocomeni 75:08eff6258e1b 561 _parser.send("System Resetting....\n");
ocomeni 75:08eff6258e1b 562 system_reset();
ocomeni 84:7c7add00f4bf 563 //_smutex.unlock();
ocomeni 75:08eff6258e1b 564 }
ocomeni 75:08eff6258e1b 565
ocomeni 79:a2187bbfa407 566 const char * ATCmdManager::sec2str(nsapi_security_t sec)
ocomeni 79:a2187bbfa407 567 {
ocomeni 79:a2187bbfa407 568 switch (sec) {
ocomeni 79:a2187bbfa407 569 case NSAPI_SECURITY_NONE:
ocomeni 79:a2187bbfa407 570 return "None";
ocomeni 79:a2187bbfa407 571 case NSAPI_SECURITY_WEP:
ocomeni 79:a2187bbfa407 572 return "WEP";
ocomeni 79:a2187bbfa407 573 case NSAPI_SECURITY_WPA:
ocomeni 79:a2187bbfa407 574 return "WPA";
ocomeni 79:a2187bbfa407 575 case NSAPI_SECURITY_WPA2:
ocomeni 79:a2187bbfa407 576 return "WPA2";
ocomeni 79:a2187bbfa407 577 case NSAPI_SECURITY_WPA_WPA2:
ocomeni 79:a2187bbfa407 578 return "WPA/WPA2";
ocomeni 79:a2187bbfa407 579 case NSAPI_SECURITY_UNKNOWN:
ocomeni 79:a2187bbfa407 580 default:
ocomeni 79:a2187bbfa407 581 return "Unknown";
ocomeni 79:a2187bbfa407 582 }
ocomeni 79:a2187bbfa407 583 }
ocomeni 81:637a87eb8170 584
ocomeni 81:637a87eb8170 585 bool ATCmdManager::setNextResponse(at_cmd_resp_t resp)
ocomeni 81:637a87eb8170 586 {
ocomeni 81:637a87eb8170 587 if(at_resp == AT_RESP_NONE){
ocomeni 81:637a87eb8170 588 at_resp = resp;
ocomeni 81:637a87eb8170 589 return true; // success
ocomeni 81:637a87eb8170 590 }
ocomeni 81:637a87eb8170 591 return false; // wiFiManager busy
ocomeni 79:a2187bbfa407 592 }
ocomeni 79:a2187bbfa407 593
ocomeni 81:637a87eb8170 594
ocomeni 79:a2187bbfa407 595 void ATCmdManager::_oob_scanWiFiNetworks(){
ocomeni 84:7c7add00f4bf 596 //_smutex.lock();
ocomeni 79:a2187bbfa407 597 printf("\n Received scanWiFiNetworks command!!\n");
ocomeni 75:08eff6258e1b 598 _parser.send("OK\n");
ocomeni 84:7c7add00f4bf 599 //_smutex.unlock();
ocomeni 79:a2187bbfa407 600 wifi_cmd_t cmd = WIFI_CMD_SCAN;
ocomeni 79:a2187bbfa407 601 // queue next command
ocomeni 79:a2187bbfa407 602 queueWiFiCommand(cmd);
ocomeni 81:637a87eb8170 603 return;
ocomeni 75:08eff6258e1b 604 }
ocomeni 75:08eff6258e1b 605
ocomeni 79:a2187bbfa407 606 void ATCmdManager::_oob_connect2WiFiNetwork()
ocomeni 79:a2187bbfa407 607 {
ocomeni 81:637a87eb8170 608 wifi_cmd_t cmd = WIFI_CMD_CONNECT;
ocomeni 81:637a87eb8170 609 // queue next command
ocomeni 81:637a87eb8170 610 queueWiFiCommand(cmd);
ocomeni 81:637a87eb8170 611 return;
ocomeni 79:a2187bbfa407 612 }
ocomeni 79:a2187bbfa407 613
ocomeni 79:a2187bbfa407 614
ocomeni 79:a2187bbfa407 615 void ATCmdManager::_oob_disconnectWiFiNetwork()
ocomeni 79:a2187bbfa407 616 {
ocomeni 81:637a87eb8170 617 wifi_cmd_t cmd = WIFI_CMD_DISCONNECT;
ocomeni 81:637a87eb8170 618 // queue next command
ocomeni 81:637a87eb8170 619 queueWiFiCommand(cmd);
ocomeni 81:637a87eb8170 620 return;
ocomeni 81:637a87eb8170 621 }
ocomeni 81:637a87eb8170 622
ocomeni 81:637a87eb8170 623 void ATCmdManager::_oob_setupInternetConnection()
ocomeni 81:637a87eb8170 624 {
ocomeni 85:9f896e1e041c 625 char str[200];
ocomeni 85:9f896e1e041c 626 char url[60];
ocomeni 81:637a87eb8170 627 int n;
ocomeni 81:637a87eb8170 628 internet_config_t internet_config;
ocomeni 85:9f896e1e041c 629 //_smutex.lock();
ocomeni 84:7c7add00f4bf 630 printf("sizeof internet_config_t = %d\n", sizeof(internet_config_t));
ocomeni 84:7c7add00f4bf 631 n = ReadBytes((uint8_t *)str, 199);
ocomeni 84:7c7add00f4bf 632 str[n]=NULL;
ocomeni 84:7c7add00f4bf 633 printf("\n read string = %s , n = %d\n", str, n);
ocomeni 84:7c7add00f4bf 634 n = sscanf(str, "=%1d,%199[^,],%1d", &internet_config.peer_id,
ocomeni 81:637a87eb8170 635 url,
ocomeni 81:637a87eb8170 636 &internet_config.connectionScheme);
ocomeni 84:7c7add00f4bf 637 strncpy(internet_config.url, url, strlen(url)+1);
ocomeni 84:7c7add00f4bf 638 printf("\n read string = %s , n = %d -- strlen(url) = %d\n", internet_config.url, n, strlen(url));
ocomeni 81:637a87eb8170 639 if(n>0)
ocomeni 81:637a87eb8170 640 {
ocomeni 81:637a87eb8170 641 printf("peer_id = %1d, url = %s, connScheme = %1d\n", internet_config.peer_id,
ocomeni 84:7c7add00f4bf 642 internet_config.url, ///->c_str(),
ocomeni 81:637a87eb8170 643 internet_config.connectionScheme);
ocomeni 81:637a87eb8170 644 // package and send on wifi data queue
ocomeni 84:7c7add00f4bf 645 wifi_data_msg_t data_msg; // = (wifi_data_msg_t *) malloc(sizeof(wifi_data_msg_t));
ocomeni 81:637a87eb8170 646 data_msg.wifi_cmd = WIFI_CMD_INTERNET_CONFIG;
ocomeni 84:7c7add00f4bf 647 data_msg.dataLen = sizeof(internet_config_t); // + strlen(internet_config.url);
ocomeni 84:7c7add00f4bf 648 printf("\n url size = %d url str = %s\n",strlen(internet_config.url), internet_config.url );
ocomeni 81:637a87eb8170 649 memcpy(data_msg.buffer,&internet_config, data_msg.dataLen);
ocomeni 82:10072c1794d3 650 // queue next data request
ocomeni 81:637a87eb8170 651 queueWiFiDataRequest(data_msg);
ocomeni 84:7c7add00f4bf 652 print_memory_info();
ocomeni 82:10072c1794d3 653 _parser.send("OK\n");
ocomeni 81:637a87eb8170 654 } else {
ocomeni 81:637a87eb8170 655 printf("\n[ATCMD MAN]: internet configuration failed %d fields parsed \n", n);
ocomeni 82:10072c1794d3 656 _parser.send("NAK\n");
ocomeni 82:10072c1794d3 657 }
ocomeni 84:7c7add00f4bf 658 //_smutex.unlock();
ocomeni 82:10072c1794d3 659 }
ocomeni 82:10072c1794d3 660
ocomeni 82:10072c1794d3 661 wifi_config_t ATCmdManager::init_wifi_config()
ocomeni 82:10072c1794d3 662 {
ocomeni 82:10072c1794d3 663 wifi_config_t wifi_cfg;
ocomeni 82:10072c1794d3 664 wifi_cfg.ssid[0] = NULL;
ocomeni 82:10072c1794d3 665 wifi_cfg.pass[0] = NULL;
ocomeni 82:10072c1794d3 666 wifi_cfg.security = NSAPI_SECURITY_UNKNOWN;
ocomeni 82:10072c1794d3 667 return wifi_cfg;
ocomeni 82:10072c1794d3 668 }
ocomeni 83:9c271a50a70b 669 /* read ASCII characters into buffer and null terminate */
ocomeni 83:9c271a50a70b 670 int ATCmdManager::readStringBytes(uint8_t *buf, int maxBytes)
ocomeni 82:10072c1794d3 671 {
ocomeni 82:10072c1794d3 672 int c;
ocomeni 82:10072c1794d3 673 int sptr = 0;
ocomeni 82:10072c1794d3 674 for(int i=0;i<maxBytes;i++){
ocomeni 82:10072c1794d3 675 c = _parser.getc();
ocomeni 82:10072c1794d3 676 if(c==-1){
ocomeni 83:9c271a50a70b 677 buf[sptr] = NULL; // null terminate if string
ocomeni 82:10072c1794d3 678 return i;
ocomeni 82:10072c1794d3 679 }
ocomeni 82:10072c1794d3 680 if(c != ',' && c!= '"'){
ocomeni 82:10072c1794d3 681 buf[sptr++] = (uint8_t) c;
ocomeni 82:10072c1794d3 682 }
ocomeni 81:637a87eb8170 683 }
ocomeni 83:9c271a50a70b 684 return maxBytes;
ocomeni 83:9c271a50a70b 685 }
ocomeni 83:9c271a50a70b 686
ocomeni 83:9c271a50a70b 687 int ATCmdManager::ReadBytes(uint8_t *buf, int maxBytes)
ocomeni 83:9c271a50a70b 688 {
ocomeni 83:9c271a50a70b 689 int c;
ocomeni 83:9c271a50a70b 690 int sptr = 0;
ocomeni 83:9c271a50a70b 691 for(int i=0;i<maxBytes;i++){
ocomeni 83:9c271a50a70b 692 c = _parser.getc();
ocomeni 83:9c271a50a70b 693 if(c==-1){
ocomeni 83:9c271a50a70b 694 return i;
ocomeni 83:9c271a50a70b 695 }
ocomeni 83:9c271a50a70b 696 buf[sptr++] = (uint8_t) c;
ocomeni 83:9c271a50a70b 697 }
ocomeni 83:9c271a50a70b 698 return maxBytes;
ocomeni 82:10072c1794d3 699 }
ocomeni 82:10072c1794d3 700
ocomeni 82:10072c1794d3 701 void ATCmdManager::_oob_setWiFiSSID()
ocomeni 82:10072c1794d3 702 {
ocomeni 82:10072c1794d3 703 int n;
ocomeni 82:10072c1794d3 704 wifi_config_t wifi_cfg = init_wifi_config();
ocomeni 84:7c7add00f4bf 705 //_smutex.lock();
ocomeni 83:9c271a50a70b 706 n = readStringBytes((uint8_t *)wifi_cfg.ssid, 32);
ocomeni 82:10072c1794d3 707 printf("[ATCMD MAN]: number of bytes read = %d\n", n);
ocomeni 82:10072c1794d3 708 if(n>0)
ocomeni 82:10072c1794d3 709 {
ocomeni 82:10072c1794d3 710 printf("[ATCMD MAN]: wifi_cfg.ssid = %s\n", wifi_cfg.ssid);
ocomeni 82:10072c1794d3 711 // package and send on wifi data queue
ocomeni 82:10072c1794d3 712 wifi_data_msg_t data_msg;
ocomeni 82:10072c1794d3 713 data_msg.wifi_cmd = WIFI_CMD_CONFIG;
ocomeni 82:10072c1794d3 714 data_msg.dataLen = sizeof(wifi_config_t);
ocomeni 82:10072c1794d3 715 memcpy(data_msg.buffer,&wifi_cfg, data_msg.dataLen);
ocomeni 82:10072c1794d3 716 queueWiFiDataRequest(data_msg);
ocomeni 82:10072c1794d3 717 _parser.send("OK\n");
ocomeni 82:10072c1794d3 718 } else {
ocomeni 82:10072c1794d3 719 printf("\n[ATCMD MAN]: wifi configuration failed \n");
ocomeni 82:10072c1794d3 720 _parser.send("NAK\n");
ocomeni 82:10072c1794d3 721 }
ocomeni 84:7c7add00f4bf 722 //_smutex.unlock();
ocomeni 82:10072c1794d3 723 }
ocomeni 82:10072c1794d3 724
ocomeni 82:10072c1794d3 725 void ATCmdManager::_oob_setWiFiPWD()
ocomeni 82:10072c1794d3 726 {
ocomeni 82:10072c1794d3 727 int n;
ocomeni 82:10072c1794d3 728 wifi_config_t wifi_cfg = init_wifi_config();
ocomeni 84:7c7add00f4bf 729 //_smutex.lock();
ocomeni 82:10072c1794d3 730 //n = _parser.scanf("%31[^\r\n]", wifi_cfg.pass);
ocomeni 83:9c271a50a70b 731 n = readStringBytes((uint8_t *)wifi_cfg.pass, 32);
ocomeni 82:10072c1794d3 732 if(n>0)
ocomeni 82:10072c1794d3 733 {
ocomeni 82:10072c1794d3 734 printf("ATCMD MAN]: wifi_cfg.pass = %s\n", wifi_cfg.pass);
ocomeni 82:10072c1794d3 735 // package and send on wifi data queue
ocomeni 82:10072c1794d3 736 wifi_data_msg_t data_msg;
ocomeni 82:10072c1794d3 737 data_msg.wifi_cmd = WIFI_CMD_CONFIG;
ocomeni 82:10072c1794d3 738 data_msg.dataLen = sizeof(wifi_config_t);
ocomeni 82:10072c1794d3 739 memcpy(data_msg.buffer,&wifi_cfg, data_msg.dataLen);
ocomeni 82:10072c1794d3 740 queueWiFiDataRequest(data_msg);
ocomeni 82:10072c1794d3 741 _parser.send("OK\n");
ocomeni 82:10072c1794d3 742 } else {
ocomeni 82:10072c1794d3 743 printf("\n[ATCMD MAN]: wifi configuration failed \n");
ocomeni 82:10072c1794d3 744 _parser.send("NAK\n");
ocomeni 82:10072c1794d3 745 }
ocomeni 84:7c7add00f4bf 746 //_smutex.unlock();
ocomeni 82:10072c1794d3 747 }
ocomeni 82:10072c1794d3 748
ocomeni 82:10072c1794d3 749 void ATCmdManager::_oob_setWiFiSecurity()
ocomeni 82:10072c1794d3 750 {
ocomeni 82:10072c1794d3 751 int n;
ocomeni 82:10072c1794d3 752 wifi_config_t wifi_cfg = init_wifi_config();
ocomeni 84:7c7add00f4bf 753 //_smutex.lock();
ocomeni 82:10072c1794d3 754 n = _parser.scanf(",%d", &wifi_cfg.security);
ocomeni 82:10072c1794d3 755 if(n>0)
ocomeni 82:10072c1794d3 756 {
ocomeni 82:10072c1794d3 757 printf("ATCMD MAN]: wifi_cfg.security = %s\n", sec2str(wifi_cfg.security));
ocomeni 82:10072c1794d3 758 // package and send on wifi data queue
ocomeni 82:10072c1794d3 759 wifi_data_msg_t data_msg;
ocomeni 82:10072c1794d3 760 data_msg.wifi_cmd = WIFI_CMD_CONFIG;
ocomeni 82:10072c1794d3 761 data_msg.dataLen = sizeof(wifi_config_t);
ocomeni 82:10072c1794d3 762 memcpy(data_msg.buffer,&wifi_cfg, data_msg.dataLen);
ocomeni 82:10072c1794d3 763 queueWiFiDataRequest(data_msg);
ocomeni 82:10072c1794d3 764 _parser.send("OK\n");
ocomeni 82:10072c1794d3 765 } else {
ocomeni 82:10072c1794d3 766 printf("\n[ATCMD MAN]: wifi configuration failed \n");
ocomeni 82:10072c1794d3 767 _parser.send("NAK\n");
ocomeni 82:10072c1794d3 768 }
ocomeni 84:7c7add00f4bf 769 //_smutex.unlock();
ocomeni 79:a2187bbfa407 770 }
ocomeni 81:637a87eb8170 771
ocomeni 83:9c271a50a70b 772
ocomeni 83:9c271a50a70b 773 void ATCmdManager::_oob_sendHttpMessage()
ocomeni 83:9c271a50a70b 774 {
ocomeni 83:9c271a50a70b 775 int n;
ocomeni 84:7c7add00f4bf 776 http_request_t http_post_request;
ocomeni 84:7c7add00f4bf 777 //_smutex.lock();
ocomeni 83:9c271a50a70b 778 /*
ocomeni 83:9c271a50a70b 779 n = _parser.scanf(",%d", &wifi_cfg.security);
ocomeni 83:9c271a50a70b 780 if(n>0)
ocomeni 83:9c271a50a70b 781 {
ocomeni 83:9c271a50a70b 782 printf("ATCMD MAN]: wifi_cfg.security = %s\n", sec2str(wifi_cfg.security));
ocomeni 83:9c271a50a70b 783 // package and send on wifi data queue
ocomeni 83:9c271a50a70b 784 wifi_data_msg_t data_msg;
ocomeni 83:9c271a50a70b 785 data_msg.wifi_cmd = WIFI_CMD_CONFIG;
ocomeni 83:9c271a50a70b 786 data_msg.dataLen = sizeof(wifi_config_t);
ocomeni 83:9c271a50a70b 787 memcpy(data_msg.buffer,&wifi_cfg, data_msg.dataLen);
ocomeni 83:9c271a50a70b 788 queueWiFiDataRequest(data_msg);
ocomeni 83:9c271a50a70b 789 _parser.send("OK\n");
ocomeni 83:9c271a50a70b 790 } else {
ocomeni 83:9c271a50a70b 791 printf("\n[ATCMD MAN]: wifi configuration failed \n");
ocomeni 83:9c271a50a70b 792 _parser.send("NAK\n");
ocomeni 83:9c271a50a70b 793 }
ocomeni 83:9c271a50a70b 794 */
ocomeni 84:7c7add00f4bf 795 //_smutex.unlock();
ocomeni 83:9c271a50a70b 796
ocomeni 83:9c271a50a70b 797 }
ocomeni 83:9c271a50a70b 798
ocomeni 81:637a87eb8170 799 bool ATCmdManager::queueWiFiCommand(wifi_cmd_t cmd){
ocomeni 81:637a87eb8170 800 wifi_cmd_message_t *wifiCmd = _aT2WiFimPool->alloc();
ocomeni 81:637a87eb8170 801 wifiCmd->wifi_cmd = cmd;
ocomeni 81:637a87eb8170 802 _aT2WiFiCmdQueue->put(wifiCmd);
ocomeni 81:637a87eb8170 803 return true;
ocomeni 81:637a87eb8170 804 }
ocomeni 81:637a87eb8170 805
ocomeni 81:637a87eb8170 806 bool ATCmdManager::dequeueATresponse(){
ocomeni 81:637a87eb8170 807 if(at_resp != AT_RESP_NONE) return false; // busy
ocomeni 81:637a87eb8170 808 osEvent evt = _wiFi2ATCmdQueue->get(0);
ocomeni 81:637a87eb8170 809 if(evt.status == osEventMessage){
ocomeni 81:637a87eb8170 810 at_resp_message_t *resp = (at_resp_message_t*)evt.value.p;
ocomeni 81:637a87eb8170 811 setNextResponse(resp->at_resp);
ocomeni 81:637a87eb8170 812 _wiFi2ATmPool->free(resp);
ocomeni 81:637a87eb8170 813 }
ocomeni 81:637a87eb8170 814 return true;
ocomeni 81:637a87eb8170 815 }
ocomeni 81:637a87eb8170 816
ocomeni 81:637a87eb8170 817 bool ATCmdManager::queueWiFiDataRequest(wifi_data_msg_t data_req){
ocomeni 81:637a87eb8170 818 wifi_data_msg_t *wifiData = _aT2WiFiDatamPool->alloc();
ocomeni 81:637a87eb8170 819 wifiData->wifi_cmd = data_req.wifi_cmd;
ocomeni 81:637a87eb8170 820 wifiData->dataLen = data_req.dataLen;
ocomeni 81:637a87eb8170 821 memcpy(wifiData->buffer, data_req.buffer, data_req.dataLen);
ocomeni 81:637a87eb8170 822 _aT2WiFiDataQueue->put(wifiData);
ocomeni 81:637a87eb8170 823 printf("[ATCMD MAN] queued data size = %d : wifi_cmd = %d\n", data_req.dataLen, data_req.wifi_cmd);
ocomeni 84:7c7add00f4bf 824 //free(&data_req);
ocomeni 81:637a87eb8170 825 return true;
ocomeni 81:637a87eb8170 826 }
ocomeni 81:637a87eb8170 827
ocomeni 87:99b37d26ff2a 828 bool ATCmdManager::dequeueWiFidataResponse(){
ocomeni 81:637a87eb8170 829 if(at_resp != AT_RESP_NONE) return false; // busy
ocomeni 81:637a87eb8170 830 osEvent evt = _wiFi2ATDataQueue->get(0);
ocomeni 81:637a87eb8170 831 if(evt.status == osEventMessage){
ocomeni 81:637a87eb8170 832 resp_data = (at_data_msg_t*)evt.value.p;
ocomeni 81:637a87eb8170 833 setNextResponse(resp_data->at_resp);
ocomeni 81:637a87eb8170 834 //_wiFi2ATDatamPool->free(resp_data);
ocomeni 81:637a87eb8170 835 }
ocomeni 81:637a87eb8170 836 return true;
ocomeni 81:637a87eb8170 837 }
ocomeni 81:637a87eb8170 838
ocomeni 81:637a87eb8170 839
ocomeni 89:45f6db09a76d 840 void ATCmdManager::return_response(bool download) {
ocomeni 87:99b37d26ff2a 841 char * resp = (char *) resp_data->buffer;
ocomeni 87:99b37d26ff2a 842 printf("\n[ATCMD MAN] received response:\n");
ocomeni 89:45f6db09a76d 843 if(download == false) // not download must be ascii header
ocomeni 89:45f6db09a76d 844 {
ocomeni 89:45f6db09a76d 845 printf("%.*s\r\n", resp_data->dataLen, resp);
ocomeni 89:45f6db09a76d 846 }
ocomeni 89:45f6db09a76d 847 else // dump payload as hex
ocomeni 89:45f6db09a76d 848 {
ocomeni 89:45f6db09a76d 849 printBufferInHex((uint8_t *)resp, resp_data->dataLen);
ocomeni 89:45f6db09a76d 850 }
ocomeni 88:7ffa053be662 851 _parser.write(resp, resp_data->dataLen);
ocomeni 87:99b37d26ff2a 852 _wiFi2ATDatamPool->free(resp_data);
ocomeni 87:99b37d26ff2a 853
ocomeni 88:7ffa053be662 854
ocomeni 87:99b37d26ff2a 855 }