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@100:80ef4bc31b7a, 2019-04-22 (annotated)

Committer:
ocomeni
Date:
Mon Apr 22 18:34:31 2019 +0000
Revision:
100:80ef4bc31b7a
Parent:
99:05398b3184f8
Child:
102:9748f290a1a5
added support for the following response:; - AT_EVENT; - CONNECT_EVENT

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 92:ec9550034276 5 #include "mbed_memory_status.h"
ocomeni 84:7c7add00f4bf 6 //#include "mbed_memory_status.h"
ocomeni 74:f26e846adfe9 7
ocomeni 78:07bb86e3ce14 8 ATCmdManager::ATCmdManager(PinName tx, PinName rx, SMDevicePeripheral *blePeripheral,
ocomeni 79:a2187bbfa407 9 events::EventQueue &event_queue, WiFiManager *wifi,
ocomeni 79:a2187bbfa407 10 MemoryPool<wifi_cmd_message_t, 16> *aT2WiFimPool,
ocomeni 80:e8f0e92e3ac9 11 Queue<wifi_cmd_message_t, 16> *aT2WiFiCmdQueue,
ocomeni 81:637a87eb8170 12 MemoryPool<at_resp_message_t, 16> *wiFi2ATmPool,
ocomeni 81:637a87eb8170 13 Queue<at_resp_message_t, 16> *wiFi2ATCmdQueue,
ocomeni 87:99b37d26ff2a 14 MemoryPool<wifi_data_msg_t, PQDSZ> *aT2WiFiDatamPool,
ocomeni 87:99b37d26ff2a 15 Queue<wifi_data_msg_t, PQDSZ> *aT2WiFiDataQueue,
ocomeni 87:99b37d26ff2a 16 MemoryPool<at_data_msg_t, PQDSZ> *wiFi2ATDatamPool,
ocomeni 87:99b37d26ff2a 17 Queue<at_data_msg_t, PQDSZ> *wiFi2ATDataQueue,
ocomeni 79:a2187bbfa407 18 bool debug)
ocomeni 74:f26e846adfe9 19 :
ocomeni 74:f26e846adfe9 20 _serial(tx, rx, DEFAULT_BAUD_RATE),
ocomeni 78:07bb86e3ce14 21 blePeripheral(blePeripheral),
ocomeni 79:a2187bbfa407 22 _event_queue(event_queue),
ocomeni 79:a2187bbfa407 23 wiFiManager(wiFiManager),
ocomeni 79:a2187bbfa407 24 _aT2WiFimPool(aT2WiFimPool),
ocomeni 80:e8f0e92e3ac9 25 _aT2WiFiCmdQueue(aT2WiFiCmdQueue),
ocomeni 80:e8f0e92e3ac9 26
ocomeni 80:e8f0e92e3ac9 27 _wiFi2ATmPool(wiFi2ATmPool),
ocomeni 80:e8f0e92e3ac9 28 _wiFi2ATCmdQueue(wiFi2ATCmdQueue),
ocomeni 80:e8f0e92e3ac9 29
ocomeni 80:e8f0e92e3ac9 30 _aT2WiFiDatamPool(aT2WiFiDatamPool),
ocomeni 80:e8f0e92e3ac9 31 _aT2WiFiDataQueue(aT2WiFiDataQueue),
ocomeni 80:e8f0e92e3ac9 32
ocomeni 80:e8f0e92e3ac9 33 _wiFi2ATDatamPool(wiFi2ATDatamPool),
ocomeni 80:e8f0e92e3ac9 34 _wiFi2ATDataQueue(wiFi2ATDataQueue),
ocomeni 80:e8f0e92e3ac9 35
ocomeni 80:e8f0e92e3ac9 36 _parser(&_serial)
ocomeni 80:e8f0e92e3ac9 37
ocomeni 74:f26e846adfe9 38
ocomeni 74:f26e846adfe9 39 {
ocomeni 74:f26e846adfe9 40 // constructor
ocomeni 74:f26e846adfe9 41 _serial.set_baud(DEFAULT_BAUD_RATE);
ocomeni 74:f26e846adfe9 42 _parser.debug_on(debug);
ocomeni 74:f26e846adfe9 43 _parser.set_delimiter("\r\n");
ocomeni 99:05398b3184f8 44 _parser.send("+STARTUP\r\n");
ocomeni 81:637a87eb8170 45 _parser.oob("AT\n", callback(this, &ATCmdManager::_oob_ok_hdlr));
ocomeni 75:08eff6258e1b 46 _parser.oob("ATE0", callback(this, &ATCmdManager::_oob_echo_off));
ocomeni 75:08eff6258e1b 47 _parser.oob("ATE1", callback(this, &ATCmdManager::_oob_echo_on));
ocomeni 75:08eff6258e1b 48 _parser.oob("AT+UMRS", callback(this, &ATCmdManager::_oob_uart_setup));
ocomeni 75:08eff6258e1b 49
ocomeni 75:08eff6258e1b 50 _parser.oob("ATO", callback(this, &ATCmdManager::_oob_data_mode));
ocomeni 75:08eff6258e1b 51 _parser.oob("AT+UMLA", callback(this, &ATCmdManager::_oob_get_mac_addr));
ocomeni 75:08eff6258e1b 52 _parser.oob("AT+UBTLE?", callback(this, &ATCmdManager::_oob_get_ble_role));
ocomeni 75:08eff6258e1b 53 _parser.oob("AT+UBTLE=2", callback(this, &ATCmdManager::_oob_ena_ble_peri));
ocomeni 75:08eff6258e1b 54 _parser.oob("AT+CPWROFF", callback(this, &ATCmdManager::_oob_reboot));
ocomeni 75:08eff6258e1b 55 _parser.oob("AT+CGMR", callback(this, &ATCmdManager::_oob_get_fw_ver));
ocomeni 82:10072c1794d3 56 _parser.oob("AT+UWSCAN", callback(this, &ATCmdManager::_oob_scanWiFiNetworks));
ocomeni 98:65c2333a38b6 57 _parser.oob("AT+UWSCA=", callback(this, &ATCmdManager::_oob_WiFiStationConfigAction));
ocomeni 95:290859010c8c 58 //_parser.oob("AT+UWSCD=", callback(this, &ATCmdManager::_oob_disconnectWiFiNetwork));
ocomeni 81:637a87eb8170 59 _parser.oob("AT+UDDRP", callback(this, &ATCmdManager::_oob_setupInternetConnection));
ocomeni 82:10072c1794d3 60 _parser.oob("AT+UWSC=0,2", callback(this, &ATCmdManager::_oob_setWiFiSSID));
ocomeni 82:10072c1794d3 61 _parser.oob("AT+UWSC=0,8", callback(this, &ATCmdManager::_oob_setWiFiPWD));
ocomeni 82:10072c1794d3 62 _parser.oob("AT+UWSC=0,5", callback(this, &ATCmdManager::_oob_setWiFiSecurity));
ocomeni 95:290859010c8c 63 _parser.oob("AT+UNSTAT=", callback(this, &ATCmdManager::_oob_getNetworkStatus));
ocomeni 95:290859010c8c 64 _parser.oob("AT+UWSSTAT", callback(this, &ATCmdManager::_oob_WiFiNetworkStatus));
ocomeni 95:290859010c8c 65
ocomeni 84:7c7add00f4bf 66 //_parser.oob("AT+UWSC=0,5", callback(this, &ATCmdManager::_oob_sendHttpMessage));
ocomeni 81:637a87eb8170 67
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 98:65c2333a38b6 71 debug_flag = 0;
ocomeni 98:65c2333a38b6 72 _event_queue.call_in(10, &print_heap_and_isr_stack_info);
ocomeni 98:65c2333a38b6 73 //print_heap_and_isr_stack_info();
ocomeni 98:65c2333a38b6 74 _event_queue.call_every(3600000,&print_memory_info);
ocomeni 74:f26e846adfe9 75 }
ocomeni 74:f26e846adfe9 76
ocomeni 74:f26e846adfe9 77
ocomeni 74:f26e846adfe9 78 void ATCmdManager::runMain(){
ocomeni 90:ed0267eca7b5 79 printf("\r\n [ATCMD MAN] Thread Id = %X\r\n", (uint32_t)ThisThread::get_id());
ocomeni 74:f26e846adfe9 80 while(true){
ocomeni 74:f26e846adfe9 81 _process_oob(UBLOX_ODIN_W2_RECV_TIMEOUT, true);
ocomeni 81:637a87eb8170 82 wait_ms(MAIN_LOOP_WAIT_TIME_MS); // allow BTLE/WiFi some time
ocomeni 81:637a87eb8170 83 processResponses();
ocomeni 74:f26e846adfe9 84 }
ocomeni 74:f26e846adfe9 85
ocomeni 74:f26e846adfe9 86 }
ocomeni 74:f26e846adfe9 87
ocomeni 81:637a87eb8170 88 void ATCmdManager::processResponses(){
ocomeni 81:637a87eb8170 89 dequeueATresponse();
ocomeni 87:99b37d26ff2a 90 dequeueWiFidataResponse();
ocomeni 98:65c2333a38b6 91 if(debug_flag>0){
ocomeni 98:65c2333a38b6 92 //debug_flag--;
ocomeni 98:65c2333a38b6 93 printf(" back to ProcessResponses in Main loop... at_resp = %d\r\n", at_resp);
ocomeni 98:65c2333a38b6 94 }
ocomeni 95:290859010c8c 95 char * respStr;
ocomeni 98:65c2333a38b6 96 //if(at_resp > AT_COMMAND_FAILED)
ocomeni 98:65c2333a38b6 97 //return;
ocomeni 81:637a87eb8170 98 switch(at_resp){
ocomeni 81:637a87eb8170 99 case AT_RESP_NONE:
ocomeni 98:65c2333a38b6 100 if(debug_flag>0){
ocomeni 98:65c2333a38b6 101 debug_flag--;
ocomeni 98:65c2333a38b6 102 printf(" In IDLE state \r\n");
ocomeni 98:65c2333a38b6 103 }
ocomeni 81:637a87eb8170 104 // IDLE response state
ocomeni 81:637a87eb8170 105 break;
ocomeni 81:637a87eb8170 106 case AT_SCAN_RESP:
ocomeni 81:637a87eb8170 107 // AT_SCAN_RESP response state
ocomeni 96:f5ed273881af 108 printf("\n [ATCMD MAN] WIFI SCAN RESPONSE RECEIVED!!\r\n");
ocomeni 95:290859010c8c 109 //_smutex.lock();
ocomeni 95:290859010c8c 110 //sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 95:290859010c8c 111 //_smutex.unlock();
ocomeni 95:290859010c8c 112 respStr = (char *) resp_data->buffer;
ocomeni 96:f5ed273881af 113 sendAtConfirmationFreeMpool(respStr);
ocomeni 81:637a87eb8170 114 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 115 break;
ocomeni 81:637a87eb8170 116 case AT_DETAILED_SCAN_RESP:
ocomeni 81:637a87eb8170 117 // AT_DETAILED_SCAN_RESP response state
ocomeni 96:f5ed273881af 118 printf("\n [ATCMD MAN] WIFI DETAILED SCAN RESPONSE RECEIVED!!\r\n");
ocomeni 95:290859010c8c 119 //_smutex.lock();
ocomeni 95:290859010c8c 120 //sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 95:290859010c8c 121 //_smutex.unlock();
ocomeni 95:290859010c8c 122 respStr = (char *) resp_data->buffer;
ocomeni 96:f5ed273881af 123 sendAtConfirmationFreeMpool(respStr);
ocomeni 81:637a87eb8170 124 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 125 break;
ocomeni 81:637a87eb8170 126 case AT_CONNECT_RESP:
ocomeni 99:05398b3184f8 127 {
ocomeni 81:637a87eb8170 128 // AT_CONNECT_RESP response state
ocomeni 96:f5ed273881af 129 printf("\n [ATCMD MAN] WIFI CONNECT RESPONSE RECEIVED!!\r\n");
ocomeni 95:290859010c8c 130 //_smutex.lock();
ocomeni 95:290859010c8c 131 //sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 95:290859010c8c 132 respStr = (char *) resp_data->buffer;
ocomeni 96:f5ed273881af 133 sendAtConfirmationFreeMpool(respStr);
ocomeni 99:05398b3184f8 134 char * urc = new char[20];
ocomeni 99:05398b3184f8 135 sprintf(urc, "\r\n%s=%d\r\n", NETWORK_UP_URC, WIFI_INTERFACE_ID);
ocomeni 99:05398b3184f8 136 sendAtEvent(urc);
ocomeni 99:05398b3184f8 137 delete urc;
ocomeni 95:290859010c8c 138 //_smutex.unlock();
ocomeni 81:637a87eb8170 139 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 140 break;
ocomeni 99:05398b3184f8 141 }
ocomeni 81:637a87eb8170 142 case AT_DISCONNECT_RESP:
ocomeni 81:637a87eb8170 143 // AT_DISCONNECT_RESP response state
ocomeni 84:7c7add00f4bf 144 //////_smutex.lock();
ocomeni 96:f5ed273881af 145 printf("\n [ATCMD MAN] WIFI DISCONNECT RESPONSE RECEIVED!!\r\n");
ocomeni 95:290859010c8c 146 //_smutex.lock();
ocomeni 95:290859010c8c 147 //sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 95:290859010c8c 148 //_smutex.unlock();
ocomeni 95:290859010c8c 149 respStr = (char *) resp_data->buffer;
ocomeni 96:f5ed273881af 150 sendAtConfirmationFreeMpool(respStr);
ocomeni 81:637a87eb8170 151 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 152 break;
ocomeni 82:10072c1794d3 153 case AT_CONFIG_RESP:
ocomeni 82:10072c1794d3 154 // AT_CONFIG_RESP response state
ocomeni 84:7c7add00f4bf 155 //////_smutex.lock();
ocomeni 96:f5ed273881af 156 printf("\n [ATCMD MAN] WIFI CONFIG RESPONSE RECEIVED!!\r\n");
ocomeni 96:f5ed273881af 157 //_smutex.lock();
ocomeni 95:290859010c8c 158 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 159 //_smutex.unlock();
ocomeni 84:7c7add00f4bf 160 at_resp = AT_RESP_NONE;
ocomeni 84:7c7add00f4bf 161 break;
ocomeni 95:290859010c8c 162 case AT_NETWORK_STATUS_RESP:
ocomeni 95:290859010c8c 163 // AT_CONFIG_RESP response state
ocomeni 95:290859010c8c 164 //////_smutex.lock();
ocomeni 96:f5ed273881af 165 printf("\n [ATCMD MAN] NETWORK STATUS RESPONSE RECEIVED!!\r\n");
ocomeni 95:290859010c8c 166 respStr = (char *) resp_data->buffer;
ocomeni 96:f5ed273881af 167 sendAtConfirmationFreeMpool(respStr);
ocomeni 95:290859010c8c 168 at_resp = AT_RESP_NONE;
ocomeni 95:290859010c8c 169 break;
ocomeni 95:290859010c8c 170 case AT_WIFI_STATUS_RESP:
ocomeni 95:290859010c8c 171 // AT_CONFIG_RESP response state
ocomeni 95:290859010c8c 172 //////_smutex.lock();
ocomeni 96:f5ed273881af 173 printf("\n [ATCMD MAN] WIFI RESPONSE RECEIVED!!\r\n");
ocomeni 95:290859010c8c 174 respStr = (char *) resp_data->buffer;
ocomeni 96:f5ed273881af 175 sendAtConfirmationFreeMpool(respStr);
ocomeni 95:290859010c8c 176 at_resp = AT_RESP_NONE;
ocomeni 95:290859010c8c 177 break;
ocomeni 84:7c7add00f4bf 178 case AT_INTERNET_CONFIG_RESP:
ocomeni 84:7c7add00f4bf 179 // AT_CONFIG_RESP response state
ocomeni 96:f5ed273881af 180 printf("\n [ATCMD MAN] WIFI INTERNET_CONFIG RESPONSE RECEIVED!!\r\n");
ocomeni 95:290859010c8c 181 //_smutex.lock();
ocomeni 96:f5ed273881af 182 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 95:290859010c8c 183 //_smutex.unlock();
ocomeni 96:f5ed273881af 184 //respStr = (char *) resp_data->buffer;
ocomeni 96:f5ed273881af 185 //sendAtConfirmationFreeMpool(respStr);
ocomeni 84:7c7add00f4bf 186 at_resp = AT_RESP_NONE;
ocomeni 84:7c7add00f4bf 187 break;
ocomeni 84:7c7add00f4bf 188 case AT_HTTPS_RESP:
ocomeni 84:7c7add00f4bf 189 // AT_HTTP_RESP response state
ocomeni 96:f5ed273881af 190 printf("\n [ATCMD MAN] WIFI HTTPS RESPONSE RECEIVED!!\r\n");
ocomeni 87:99b37d26ff2a 191 return_response();
ocomeni 96:f5ed273881af 192 //_smutex.lock();
ocomeni 95:290859010c8c 193 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 194 //_smutex.unlock();
ocomeni 81:637a87eb8170 195 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 196 break;
ocomeni 89:45f6db09a76d 197 case AT_HTTPS_RESP_DOWNLOAD:
ocomeni 89:45f6db09a76d 198 // AT_HTTPS_RESP_DOWNLOAD response state
ocomeni 96:f5ed273881af 199 printf("\n [ATCMD MAN] WIFI HTTPS DOWNLOAD RESPONSE RECEIVED!!\r\n");
ocomeni 89:45f6db09a76d 200 return_response(true); // set download paramter to true
ocomeni 96:f5ed273881af 201 //_smutex.lock();
ocomeni 95:290859010c8c 202 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 203 //_smutex.unlock();
ocomeni 89:45f6db09a76d 204 at_resp = AT_RESP_NONE;
ocomeni 89:45f6db09a76d 205 break;
ocomeni 81:637a87eb8170 206 case AT_HTTP_RESP:
ocomeni 81:637a87eb8170 207 // AT_HTTP_RESP response state
ocomeni 96:f5ed273881af 208 printf("\n [ATCMD MAN] WIFI HTTP RESPONSE RECEIVED!!\r\n");
ocomeni 89:45f6db09a76d 209 return_response();
ocomeni 96:f5ed273881af 210 //_smutex.lock();
ocomeni 95:290859010c8c 211 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 212 //_smutex.unlock();
ocomeni 89:45f6db09a76d 213 at_resp = AT_RESP_NONE;
ocomeni 89:45f6db09a76d 214 break;
ocomeni 89:45f6db09a76d 215 case AT_HTTP_RESP_DOWNLOAD:
ocomeni 89:45f6db09a76d 216 // AT_HTTP_RESP response state
ocomeni 96:f5ed273881af 217 printf("\n [ATCMD MAN] WIFI HTTP RESPONSE RECEIVED!!\r\n");
ocomeni 89:45f6db09a76d 218 return_response(true); // set download paramter to true
ocomeni 95:290859010c8c 219 //_smutex.lock();
ocomeni 95:290859010c8c 220 //sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 95:290859010c8c 221 //_smutex.unlock();
ocomeni 81:637a87eb8170 222 at_resp = AT_RESP_NONE;
ocomeni 81:637a87eb8170 223 break;
ocomeni 99:05398b3184f8 224 case CONNECT_EVENT:
ocomeni 99:05398b3184f8 225 {
ocomeni 99:05398b3184f8 226 // Connect Event state
ocomeni 99:05398b3184f8 227 printf("\n [ATCMD MAN] CONNECT EVENT RECEIVED!!\r\n");
ocomeni 99:05398b3184f8 228 sendConnectEvent(resp_data->buffer, resp_data->dataLen);
ocomeni 99:05398b3184f8 229 at_resp = AT_RESP_NONE;
ocomeni 99:05398b3184f8 230 break;
ocomeni 99:05398b3184f8 231 }
ocomeni 100:80ef4bc31b7a 232 case AT_EVENT:
ocomeni 100:80ef4bc31b7a 233 {
ocomeni 100:80ef4bc31b7a 234 // AT Event state
ocomeni 100:80ef4bc31b7a 235 printf("\n [ATCMD MAN] AT EVENT RECEIVED!!\r\n");
ocomeni 100:80ef4bc31b7a 236 respStr = (char *) resp_data->buffer;
ocomeni 100:80ef4bc31b7a 237 sendAtEvent(respStr);
ocomeni 100:80ef4bc31b7a 238 at_resp = AT_RESP_NONE;
ocomeni 100:80ef4bc31b7a 239 break;
ocomeni 100:80ef4bc31b7a 240 }
ocomeni 93:06e755a80187 241 case AT_COMMAND_FAILED:
ocomeni 98:65c2333a38b6 242 {
ocomeni 93:06e755a80187 243 // AT_HTTP_RESP response state
ocomeni 96:f5ed273881af 244 printf("\n [ATCMD MAN] WIFI COMMAND FAILED!!\r\n");
ocomeni 95:290859010c8c 245 //_smutex.lock();
ocomeni 95:290859010c8c 246 //_parser.send("\r\nNACK\r\n");
ocomeni 95:290859010c8c 247 //_smutex.unlock();
ocomeni 98:65c2333a38b6 248 respStr = (char *) resp_data->buffer;
ocomeni 96:f5ed273881af 249 sendAtConfirmationFreeMpool(respStr);
ocomeni 98:65c2333a38b6 250 at_resp = AT_RESP_NONE;
ocomeni 93:06e755a80187 251 break;
ocomeni 98:65c2333a38b6 252 }
ocomeni 100:80ef4bc31b7a 253 default:
ocomeni 100:80ef4bc31b7a 254 //UNKNOWN response state
ocomeni 95:290859010c8c 255 //_smutex.lock();
ocomeni 100:80ef4bc31b7a 256 printf("\n [ATCMD MAN] UNKNOWN RESPONSE RECEIVED!!\r\n");
ocomeni 100:80ef4bc31b7a 257 sendAtConfirmationFreeMpool(ERROR_RESP); //_parser.send(OK_RESP);
ocomeni 95:290859010c8c 258 //_smutex.unlock();
ocomeni 100:80ef4bc31b7a 259 at_resp = AT_RESP_NONE;
ocomeni 100:80ef4bc31b7a 260 break;
ocomeni 81:637a87eb8170 261 }
ocomeni 81:637a87eb8170 262 }
ocomeni 81:637a87eb8170 263
ocomeni 96:f5ed273881af 264
ocomeni 96:f5ed273881af 265 void ATCmdManager::sendAtConfirmationFreeMpool(const char *buf)
ocomeni 96:f5ed273881af 266 {
ocomeni 96:f5ed273881af 267 sendAtConfirmation(buf);
ocomeni 96:f5ed273881af 268 _wiFi2ATDatamPool->free(resp_data);
ocomeni 96:f5ed273881af 269 resp_data = NULL;
ocomeni 96:f5ed273881af 270 }
ocomeni 96:f5ed273881af 271
ocomeni 96:f5ed273881af 272
ocomeni 89:45f6db09a76d 273 void ATCmdManager::printBufferInHex(uint8_t *buf, int pLen)
ocomeni 89:45f6db09a76d 274 {
ocomeni 89:45f6db09a76d 275 for(int i =0;i<pLen;i++){
ocomeni 89:45f6db09a76d 276 if(i%8==0) printf("\n[%3d]",i);
ocomeni 89:45f6db09a76d 277 printf("%02x ", buf[i]);
ocomeni 89:45f6db09a76d 278 }
ocomeni 89:45f6db09a76d 279 printf("\n");
ocomeni 89:45f6db09a76d 280 }
ocomeni 81:637a87eb8170 281
ocomeni 83:9c271a50a70b 282 bool ATCmdManager::validate(edm_header_t edm_header)
ocomeni 83:9c271a50a70b 283 {
ocomeni 83:9c271a50a70b 284 if(edm_header.startByte != EDM_START_BYTE)return false; // unexpected start byte found!
ocomeni 99:05398b3184f8 285 if(edm_header.payloadID != CONNECT_EVENT_ID &&
ocomeni 99:05398b3184f8 286 edm_header.payloadID != DISCONNECT_EVENT_ID &&
ocomeni 99:05398b3184f8 287 edm_header.payloadID != DATA_EVENT_ID &&
ocomeni 99:05398b3184f8 288 edm_header.payloadID != DATA_COMMAND_ID &&
ocomeni 99:05398b3184f8 289 edm_header.payloadID != AT_REQUEST_ID &&
ocomeni 99:05398b3184f8 290 edm_header.payloadID != AT_CONFIRMATION_ID &&
ocomeni 99:05398b3184f8 291 edm_header.payloadID != AT_EVENT_ID
ocomeni 83:9c271a50a70b 292 )return false; // unexpected payload ID found!
ocomeni 83:9c271a50a70b 293 if(edm_header.payloadLen > MAX_EDM_PAYLOAD_LEN ||
ocomeni 83:9c271a50a70b 294 edm_header.payloadLen < MIN_EDM_PAYLOAD_LEN
ocomeni 83:9c271a50a70b 295 ) return false; // unexpected length received!
ocomeni 90:ed0267eca7b5 296 if(edm_header.channel_id != WIFI_CHANNEL &&
ocomeni 90:ed0267eca7b5 297 edm_header.channel_id != BLE_CHANNEL
ocomeni 90:ed0267eca7b5 298 ) return false; // unexpected channel_id received!
ocomeni 83:9c271a50a70b 299 return true;
ocomeni 83:9c271a50a70b 300 }
ocomeni 74:f26e846adfe9 301
ocomeni 84:7c7add00f4bf 302 http_method ATCmdManager::str2HttpMethod(const char * methodStr)
ocomeni 84:7c7add00f4bf 303 {
ocomeni 84:7c7add00f4bf 304 http_method _http_method;
ocomeni 84:7c7add00f4bf 305 if(strstr(methodStr, "POST")!= NULL){
ocomeni 84:7c7add00f4bf 306 _http_method = HTTP_POST;
ocomeni 84:7c7add00f4bf 307 }
ocomeni 84:7c7add00f4bf 308 else if(strstr(methodStr, "GET")!= NULL){
ocomeni 84:7c7add00f4bf 309 _http_method = HTTP_GET;
ocomeni 84:7c7add00f4bf 310 }
ocomeni 84:7c7add00f4bf 311 else{
ocomeni 84:7c7add00f4bf 312 _http_method = HTTP_DELETE; // unsupported method - set to HTTP_DELETE
ocomeni 84:7c7add00f4bf 313 }
ocomeni 84:7c7add00f4bf 314 return _http_method;
ocomeni 84:7c7add00f4bf 315 }
ocomeni 84:7c7add00f4bf 316 bool ATCmdManager::createHttpRequest()
ocomeni 84:7c7add00f4bf 317 {
ocomeni 90:ed0267eca7b5 318 http_request_t *http_req; // = new http_request_t;
ocomeni 90:ed0267eca7b5 319 wifi_data_msg_t data_msg;
ocomeni 90:ed0267eca7b5 320 http_req = (http_request_t *)data_msg.buffer;
ocomeni 84:7c7add00f4bf 321 char s1[32];
ocomeni 84:7c7add00f4bf 322 char s2[32];
ocomeni 84:7c7add00f4bf 323 char s3[32];
ocomeni 90:ed0267eca7b5 324 int len = 0;
ocomeni 90:ed0267eca7b5 325 int n;
ocomeni 90:ed0267eca7b5 326 char * strPtr = (char *)rx_buf_ptr;
ocomeni 84:7c7add00f4bf 327 char * p;
ocomeni 84:7c7add00f4bf 328 char * p2 = strstr(strPtr, "\r\n\r\n");
ocomeni 84:7c7add00f4bf 329 char * nxtPtr = strPtr;
ocomeni 90:ed0267eca7b5 330 char * outPtr;
ocomeni 84:7c7add00f4bf 331 char * bodyPtr = p2+4;
ocomeni 84:7c7add00f4bf 332 printf("\nstrPtr address= %x",strPtr);
ocomeni 84:7c7add00f4bf 333 printf("\np2 address= %x", p2);
ocomeni 84:7c7add00f4bf 334 for(int i = 0; i < 5; i++){
ocomeni 84:7c7add00f4bf 335 if(i == 0)// firstline scan method uri and http_ver
ocomeni 84:7c7add00f4bf 336 {
ocomeni 84:7c7add00f4bf 337 n = sscanf(nxtPtr,"%s %s %s", s1, s2, s3);
ocomeni 90:ed0267eca7b5 338 if(n!=3) return false; // error in input abort
ocomeni 84:7c7add00f4bf 339 printf("\nmethod = %s\nuri = %s\nhttp_ver = %s",s1, s2, s3 );
ocomeni 84:7c7add00f4bf 340 //http_req.method = str2HttpMethod(s1.c_str());
ocomeni 90:ed0267eca7b5 341 http_req->method = str2HttpMethod(s1);
ocomeni 90:ed0267eca7b5 342 http_req->request_URI = (char *) http_req->buffer; // point 1st string to start of buffer
ocomeni 90:ed0267eca7b5 343 len = strlen(s2)+1;
ocomeni 90:ed0267eca7b5 344 strncpy(http_req->request_URI, s2, len);
ocomeni 90:ed0267eca7b5 345 http_req->http_version = http_req->request_URI + len; // point 2nd string to after 1st
ocomeni 90:ed0267eca7b5 346 len = strlen(s3)+1;
ocomeni 90:ed0267eca7b5 347 strncpy(http_req->http_version, s3, len);
ocomeni 90:ed0267eca7b5 348 printf("\nhttp_request 1st line:\n method = %d\nuri = %s\nhttp_ver = %s",http_req->method,
ocomeni 90:ed0267eca7b5 349 http_req->request_URI,
ocomeni 90:ed0267eca7b5 350 http_req->http_version );
ocomeni 90:ed0267eca7b5 351 printf("\nhttp_request str ptrs\nuri = %X\nhttp_ver = %X",http_req->request_URI,
ocomeni 90:ed0267eca7b5 352 http_req->http_version );
ocomeni 90:ed0267eca7b5 353 outPtr = http_req->http_version + len; // point output buffer ptr to after 2nd string
ocomeni 84:7c7add00f4bf 354 }
ocomeni 84:7c7add00f4bf 355 else{ // scan header pairs
ocomeni 84:7c7add00f4bf 356 //n = sscanf(nxtPtr,"%s %s", &s1[0], &s2[0]);
ocomeni 84:7c7add00f4bf 357 n = sscanf(nxtPtr,"%s %s", s1, s2);
ocomeni 90:ed0267eca7b5 358 if(n!=2) return false; // error in input abort
ocomeni 84:7c7add00f4bf 359 p = strstr(s1,":");
ocomeni 84:7c7add00f4bf 360 *p = NULL;
ocomeni 84:7c7add00f4bf 361 printf("\nname = %s value = %s",s1, s2);
ocomeni 86:04fc2fcda7ec 362 if(strstr(s1, "Host")!= NULL){
ocomeni 90:ed0267eca7b5 363 http_req->hostName = outPtr;
ocomeni 90:ed0267eca7b5 364 len = strlen(s2)+1;
ocomeni 90:ed0267eca7b5 365 strncpy(outPtr, s2, len);
ocomeni 90:ed0267eca7b5 366 printf("\nname = %s value = %s",s1, outPtr);
ocomeni 90:ed0267eca7b5 367 outPtr += len; // point output buffer ptr to after current string
ocomeni 86:04fc2fcda7ec 368 }
ocomeni 86:04fc2fcda7ec 369 else if(strstr(s1, "Accept")!= NULL){
ocomeni 90:ed0267eca7b5 370 http_req->AcceptVal = outPtr;
ocomeni 90:ed0267eca7b5 371 len = strlen(s2)+1;
ocomeni 90:ed0267eca7b5 372 strncpy(outPtr, s2, len);
ocomeni 90:ed0267eca7b5 373 printf("\nname = %s value = %s",s1, outPtr);
ocomeni 90:ed0267eca7b5 374 outPtr += len; // point output buffer ptr to after current string
ocomeni 86:04fc2fcda7ec 375 }
ocomeni 86:04fc2fcda7ec 376 else if(strstr(s1, "Content-Type")!= NULL){
ocomeni 90:ed0267eca7b5 377 http_req->contentType = outPtr;
ocomeni 90:ed0267eca7b5 378 len = strlen(s2)+1;
ocomeni 90:ed0267eca7b5 379 strncpy(outPtr, s2, len);
ocomeni 90:ed0267eca7b5 380 printf("\nname = %s value = %s",s1, outPtr);
ocomeni 90:ed0267eca7b5 381 outPtr += len; // point output buffer ptr to after current string
ocomeni 86:04fc2fcda7ec 382 }
ocomeni 86:04fc2fcda7ec 383 else if(strstr(s1, "Content-Length")!= NULL){
ocomeni 90:ed0267eca7b5 384 //http_req.contentLen.assign(s2);
ocomeni 90:ed0267eca7b5 385 http_req->contentLen = outPtr;
ocomeni 90:ed0267eca7b5 386 len = strlen(s2)+1;
ocomeni 90:ed0267eca7b5 387 strncpy(outPtr, s2, len);
ocomeni 90:ed0267eca7b5 388 printf("\nname = %s value = %s",s1, outPtr);
ocomeni 90:ed0267eca7b5 389 outPtr += len; // point output buffer ptr to after current string
ocomeni 84:7c7add00f4bf 390 }
ocomeni 84:7c7add00f4bf 391
ocomeni 90:ed0267eca7b5 392 printf("\noutPtr = %X len = %d\n", outPtr, len);
ocomeni 84:7c7add00f4bf 393 }
ocomeni 84:7c7add00f4bf 394 nxtPtr = strstr(nxtPtr, "\r\n")+2; // goto next line
ocomeni 84:7c7add00f4bf 395 if(nxtPtr >= p2) break;
ocomeni 84:7c7add00f4bf 396 }
ocomeni 90:ed0267eca7b5 397 // print header from http_req_struct
ocomeni 90:ed0267eca7b5 398 printf("\nhttp request header: \n %s\n", http_req->buffer);
ocomeni 84:7c7add00f4bf 399 int bodyLen = edm_hdr.payloadLen -(p2+7-strPtr);
ocomeni 84:7c7add00f4bf 400 printf("\nLen = %d\n", bodyLen);
ocomeni 90:ed0267eca7b5 401 http_req->body = (uint8_t *) outPtr;
ocomeni 90:ed0267eca7b5 402 memcpy(outPtr, bodyPtr, bodyLen);
ocomeni 90:ed0267eca7b5 403 if(bodyLen > 10){
ocomeni 90:ed0267eca7b5 404 printf("\n Message Body:\n");
ocomeni 90:ed0267eca7b5 405 printBufferInHex(http_req->body, bodyLen);
ocomeni 90:ed0267eca7b5 406 }
ocomeni 90:ed0267eca7b5 407 outPtr += bodyLen; // move output pointer to end output (header + body)
ocomeni 84:7c7add00f4bf 408 // package and send on wifi data queue
ocomeni 84:7c7add00f4bf 409 data_msg.wifi_cmd = WIFI_CMD_SEND_HTTPS_REQ;
ocomeni 90:ed0267eca7b5 410 printf("\nsizeof(http_req) on population = %d\n", sizeof(*http_req));
ocomeni 90:ed0267eca7b5 411 data_msg.dataLen = (uint8_t *)outPtr - http_req->buffer;//sizeof(http_request_t);
ocomeni 90:ed0267eca7b5 412 printf("\ndata_msg.dataLen = %d\n", data_msg.dataLen);
ocomeni 84:7c7add00f4bf 413 // queue next data request
ocomeni 84:7c7add00f4bf 414 queueWiFiDataRequest(data_msg);
ocomeni 84:7c7add00f4bf 415 return true;
ocomeni 84:7c7add00f4bf 416 }
ocomeni 74:f26e846adfe9 417 // OOB processing
ocomeni 74:f26e846adfe9 418 void ATCmdManager::_process_oob(uint32_t timeout, bool all){
ocomeni 74:f26e846adfe9 419 set_timeout(timeout);
ocomeni 92:ec9550034276 420 int cnt = 0;
ocomeni 84:7c7add00f4bf 421 int start;
ocomeni 90:ed0267eca7b5 422 //channel_id_t chan_id;
ocomeni 83:9c271a50a70b 423 if(dataMode == AT_EXT_DATA_MODE)
ocomeni 83:9c271a50a70b 424 {
ocomeni 83:9c271a50a70b 425 int n;
ocomeni 87:99b37d26ff2a 426 //if(cnt++ % 10 == 0)printf("In EDM mode\n");
ocomeni 84:7c7add00f4bf 427 uint8_t edm[EDM_HDR_LEN];
ocomeni 92:ec9550034276 428 char cmdType[16];
ocomeni 83:9c271a50a70b 429 // Poll for edm packets
ocomeni 83:9c271a50a70b 430 do{
ocomeni 92:ec9550034276 431 n = _parser.read((char *)edm, EDM_HDR_LEN-1);
ocomeni 84:7c7add00f4bf 432 edm_hdr.startByte = edm[0];
ocomeni 84:7c7add00f4bf 433 edm_hdr.payloadLen = edm[1]*256 + edm[2];
ocomeni 84:7c7add00f4bf 434 edm_hdr.payloadID = edm[3]*256 + edm[4];
ocomeni 92:ec9550034276 435 edm_hdr.channel_id = (channel_id_t) 0;
ocomeni 84:7c7add00f4bf 436 start = Kernel::get_ms_count();
ocomeni 83:9c271a50a70b 437 if(n == -1) break; // break if it times out
ocomeni 92:ec9550034276 438 int pT;
ocomeni 99:05398b3184f8 439 if(edm_hdr.payloadID < AT_REQUEST_ID) //
ocomeni 92:ec9550034276 440 {
ocomeni 92:ec9550034276 441 n += _parser.read((char *)edm, 1);
ocomeni 92:ec9550034276 442 edm_hdr.channel_id = (channel_id_t) edm[0];
ocomeni 92:ec9550034276 443 pT = 0;
ocomeni 92:ec9550034276 444 strcpy(cmdType, "DATA COMMAND");
ocomeni 92:ec9550034276 445 }
ocomeni 92:ec9550034276 446 else
ocomeni 92:ec9550034276 447 {
ocomeni 92:ec9550034276 448 pT = 1;
ocomeni 92:ec9550034276 449 strcpy(cmdType, "AT REQUEST");
ocomeni 92:ec9550034276 450 }
ocomeni 92:ec9550034276 451 //printf("%d bytes read! : type = %s\n", n, cmdType2str(edm_hdr.payloadID));
ocomeni 92:ec9550034276 452 printf("%d bytes read! : CMD type = %s\n", n, cmdType);
ocomeni 92:ec9550034276 453 if(n==(EDM_HDR_LEN-pT))
ocomeni 90:ed0267eca7b5 454 printf("Start = %d, payloadID = %d len = %d chan_id = %d\n", edm_hdr.startByte,
ocomeni 90:ed0267eca7b5 455 edm_hdr.payloadID,
ocomeni 90:ed0267eca7b5 456 edm_hdr.payloadLen,
ocomeni 90:ed0267eca7b5 457 edm_hdr.channel_id);
ocomeni 92:ec9550034276 458 if(n == (EDM_HDR_LEN-pT) && validate(edm_hdr)) // if AT command use process oob to decode
ocomeni 83:9c271a50a70b 459 {
ocomeni 99:05398b3184f8 460 if(edm_hdr.payloadID == AT_REQUEST_ID)
ocomeni 83:9c271a50a70b 461 {
ocomeni 92:ec9550034276 462 //_parser.process_oob();
ocomeni 92:ec9550034276 463 while (_parser.process_oob() && all) {
ocomeni 98:65c2333a38b6 464 if(debug_flag>0){
ocomeni 98:65c2333a38b6 465 printf("finished queuing WIFI CONNECT CMD -- back to process_oob loop \r\n");
ocomeni 98:65c2333a38b6 466 }
ocomeni 92:ec9550034276 467 }
ocomeni 83:9c271a50a70b 468 break;
ocomeni 83:9c271a50a70b 469 }
ocomeni 83:9c271a50a70b 470 else
ocomeni 83:9c271a50a70b 471 {
ocomeni 92:ec9550034276 472 int pLen = edm_hdr.payloadLen-2-pT;
ocomeni 83:9c271a50a70b 473 rx_buf_ptr = (uint8_t *) malloc (pLen); // we already read 2 bytes from payload but expect 1 stop byte
ocomeni 83:9c271a50a70b 474 rx_buf_ptr[pLen-1] = 0x00; // clear last byte so the readback value is as expected
ocomeni 83:9c271a50a70b 475 n = _parser.read((char *)rx_buf_ptr, pLen);
ocomeni 83:9c271a50a70b 476 if(n == -1) break; // timeout!
ocomeni 83:9c271a50a70b 477 printf("%d bytes read - expected %d!\n", n, pLen);
ocomeni 89:45f6db09a76d 478 printBufferInHex(rx_buf_ptr, pLen);
ocomeni 83:9c271a50a70b 479 printf("rx_buf_ptr[pLen-1] = %0x\n",rx_buf_ptr[pLen-1]);
ocomeni 83:9c271a50a70b 480 if(rx_buf_ptr[pLen-1] != EDM_STOP_BYTE) {
ocomeni 90:ed0267eca7b5 481 _smutex.lock();
ocomeni 90:ed0267eca7b5 482 _parser.send("ERR");
ocomeni 90:ed0267eca7b5 483 _smutex.unlock();
ocomeni 97:0aa46e5ef15d 484 free(rx_buf_ptr); // make sure to free buffer
ocomeni 97:0aa46e5ef15d 485 rx_buf_ptr = NULL;
ocomeni 90:ed0267eca7b5 486 break; // exit if stop byte not found - possible data corruption!
ocomeni 83:9c271a50a70b 487 }
ocomeni 83:9c271a50a70b 488 switch(edm_hdr.payloadID)
ocomeni 83:9c271a50a70b 489 {
ocomeni 99:05398b3184f8 490 case CONNECT_EVENT_ID:
ocomeni 83:9c271a50a70b 491 printf("Connection Event received!\n");
ocomeni 83:9c271a50a70b 492 break;
ocomeni 99:05398b3184f8 493 case DISCONNECT_EVENT_ID:
ocomeni 83:9c271a50a70b 494 printf("DISCONNECT_EVENT received!\n");
ocomeni 83:9c271a50a70b 495 break;
ocomeni 99:05398b3184f8 496 case DATA_EVENT_ID:
ocomeni 83:9c271a50a70b 497 printf("DATA_EVENT received!\n");
ocomeni 83:9c271a50a70b 498 break;
ocomeni 99:05398b3184f8 499 case DATA_COMMAND_ID:
ocomeni 98:65c2333a38b6 500 {
ocomeni 83:9c271a50a70b 501 printf("DATA_COMMAND received!\n");
ocomeni 96:f5ed273881af 502 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 84:7c7add00f4bf 503 if(createHttpRequest() == true){
ocomeni 96:f5ed273881af 504 //_smutex.lock();
ocomeni 96:f5ed273881af 505 //sendAtConfirmation(OK_RESP); //sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 506 //_smutex.unlock();
ocomeni 83:9c271a50a70b 507 }
ocomeni 84:7c7add00f4bf 508 else{
ocomeni 90:ed0267eca7b5 509 _smutex.lock();
ocomeni 84:7c7add00f4bf 510 _parser.send("NACK");
ocomeni 90:ed0267eca7b5 511 _smutex.unlock();
ocomeni 84:7c7add00f4bf 512 }
ocomeni 92:ec9550034276 513 free(rx_buf_ptr);
ocomeni 96:f5ed273881af 514 rx_buf_ptr = NULL;
ocomeni 84:7c7add00f4bf 515 int stop = Kernel::get_ms_count();
ocomeni 84:7c7add00f4bf 516 printf("\n Time Elapsed = %d\n", stop-start);
ocomeni 83:9c271a50a70b 517 break;
ocomeni 98:65c2333a38b6 518 }
ocomeni 99:05398b3184f8 519 case AT_REQUEST_ID:
ocomeni 83:9c271a50a70b 520 printf("AT_REQUEST received!\n");
ocomeni 83:9c271a50a70b 521 break;
ocomeni 99:05398b3184f8 522 case AT_CONFIRMATION_ID:
ocomeni 83:9c271a50a70b 523 printf("AT_CONFIRMATION received!\n");
ocomeni 83:9c271a50a70b 524 break;
ocomeni 99:05398b3184f8 525 case AT_EVENT_ID:
ocomeni 83:9c271a50a70b 526 printf("AT_EVENT received!\n");
ocomeni 83:9c271a50a70b 527 break;
ocomeni 83:9c271a50a70b 528 default:
ocomeni 83:9c271a50a70b 529 printf("UNKNOWN MESSAGE received!\n");
ocomeni 83:9c271a50a70b 530 break;
ocomeni 83:9c271a50a70b 531 }
ocomeni 83:9c271a50a70b 532 }
ocomeni 83:9c271a50a70b 533 //_parser.process_oob();
ocomeni 83:9c271a50a70b 534 }
ocomeni 83:9c271a50a70b 535 else // incorrect # of bytes received abort!!
ocomeni 83:9c271a50a70b 536 {
ocomeni 83:9c271a50a70b 537 break;
ocomeni 83:9c271a50a70b 538 }
ocomeni 83:9c271a50a70b 539 }while (all); // continue to process until timeout
ocomeni 74:f26e846adfe9 540 }
ocomeni 83:9c271a50a70b 541 else
ocomeni 83:9c271a50a70b 542 {
ocomeni 83:9c271a50a70b 543 // Poll for inbound packets
ocomeni 98:65c2333a38b6 544 static int msgCnt = 0;
ocomeni 83:9c271a50a70b 545 while (_parser.process_oob() && all) {
ocomeni 98:65c2333a38b6 546 printf("inbound message found... msgCnt = %d \r\n", ++msgCnt);
ocomeni 98:65c2333a38b6 547 if(debug_flag>0){
ocomeni 98:65c2333a38b6 548 printf("finished queuing WIFI CONNECT CMD -- back to process_oob loop \r\n");
ocomeni 98:65c2333a38b6 549 }
ocomeni 83:9c271a50a70b 550 }
ocomeni 83:9c271a50a70b 551 }
ocomeni 74:f26e846adfe9 552 set_timeout();
ocomeni 74:f26e846adfe9 553 }
ocomeni 74:f26e846adfe9 554
ocomeni 74:f26e846adfe9 555
ocomeni 74:f26e846adfe9 556 // OOB message handlers
ocomeni 74:f26e846adfe9 557 void ATCmdManager::_oob_startup_hdlr(){
ocomeni 74:f26e846adfe9 558 }
ocomeni 74:f26e846adfe9 559
ocomeni 81:637a87eb8170 560 void ATCmdManager::_oob_ok_hdlr(){
ocomeni 96:f5ed273881af 561 //_smutex.lock();
ocomeni 95:290859010c8c 562 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 563 //_smutex.unlock();
ocomeni 81:637a87eb8170 564 }
ocomeni 81:637a87eb8170 565
ocomeni 74:f26e846adfe9 566
ocomeni 74:f26e846adfe9 567 void ATCmdManager::_oob_bleRole_hdlr(){
ocomeni 74:f26e846adfe9 568 }
ocomeni 74:f26e846adfe9 569
ocomeni 74:f26e846adfe9 570
ocomeni 74:f26e846adfe9 571 void ATCmdManager::_oob_wifiMode_err(){
ocomeni 74:f26e846adfe9 572 }
ocomeni 74:f26e846adfe9 573
ocomeni 74:f26e846adfe9 574
ocomeni 74:f26e846adfe9 575 void ATCmdManager::_oob_conn_already(){
ocomeni 74:f26e846adfe9 576 }
ocomeni 74:f26e846adfe9 577
ocomeni 74:f26e846adfe9 578
ocomeni 74:f26e846adfe9 579 void ATCmdManager::_oob_err(){
ocomeni 74:f26e846adfe9 580 }
ocomeni 74:f26e846adfe9 581
ocomeni 79:a2187bbfa407 582 void ATCmdManager::_oob_get_fw_ver()
ocomeni 79:a2187bbfa407 583 {
ocomeni 79:a2187bbfa407 584 }
ocomeni 79:a2187bbfa407 585
ocomeni 79:a2187bbfa407 586
ocomeni 75:08eff6258e1b 587 void ATCmdManager::_oob_uart_setup(){
ocomeni 75:08eff6258e1b 588 int uOpts[NUM_UART_OPTIONS];
ocomeni 75:08eff6258e1b 589 //if(_parser.recv("=%d,%d,%d,%d,%d,%d", &uOpts[0], &uOpts[1], &uOpts[2], &uOpts[3], &uOpts[4], &uOpts[5])) {
ocomeni 75:08eff6258e1b 590 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 591 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 592 //AT+UMRS=230400,2,8,1,1,1
ocomeni 81:637a87eb8170 593 printf("\n Changing Baud Rate to %d\n", uOpts[0]);
ocomeni 81:637a87eb8170 594
ocomeni 95:290859010c8c 595 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 92:ec9550034276 596 wait(0.1);
ocomeni 81:637a87eb8170 597 _serial.set_baud(uOpts[0]);
ocomeni 92:ec9550034276 598 wait(0.1);
ocomeni 81:637a87eb8170 599 printf("\n Baud Rate now %d\n", uOpts[0]);
ocomeni 81:637a87eb8170 600
ocomeni 75:08eff6258e1b 601 } else {
ocomeni 75:08eff6258e1b 602 printf("\nATCmdParser: Retrieving Uart Options failed");
ocomeni 75:08eff6258e1b 603 }
ocomeni 75:08eff6258e1b 604 }
ocomeni 75:08eff6258e1b 605
ocomeni 74:f26e846adfe9 606 void ATCmdManager::set_timeout(uint32_t timeout_ms)
ocomeni 74:f26e846adfe9 607 {
ocomeni 74:f26e846adfe9 608 _parser.set_timeout(timeout_ms);
ocomeni 74:f26e846adfe9 609 }
ocomeni 74:f26e846adfe9 610
ocomeni 75:08eff6258e1b 611
ocomeni 75:08eff6258e1b 612 void ATCmdManager::_oob_echo_off()
ocomeni 75:08eff6258e1b 613 {
ocomeni 96:f5ed273881af 614 //_smutex.lock();
ocomeni 75:08eff6258e1b 615 printf("\n Received ATEO OOB command!!\n");
ocomeni 75:08eff6258e1b 616 printf("\n turning echo OFF!!\n");
ocomeni 75:08eff6258e1b 617 _parser.debug_on(false);
ocomeni 95:290859010c8c 618 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 619 //_smutex.unlock();
ocomeni 75:08eff6258e1b 620 }
ocomeni 75:08eff6258e1b 621
ocomeni 75:08eff6258e1b 622
ocomeni 75:08eff6258e1b 623 void ATCmdManager::_oob_echo_on()
ocomeni 75:08eff6258e1b 624 {
ocomeni 96:f5ed273881af 625 //_smutex.lock();
ocomeni 75:08eff6258e1b 626 printf("\n Received ATE1 OOB command!!\n");
ocomeni 75:08eff6258e1b 627 printf("\n turning echo ON!!\n");
ocomeni 75:08eff6258e1b 628 _parser.debug_on(true);
ocomeni 95:290859010c8c 629 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 630 //_smutex.unlock();
ocomeni 75:08eff6258e1b 631 }
ocomeni 75:08eff6258e1b 632
ocomeni 75:08eff6258e1b 633
ocomeni 75:08eff6258e1b 634 void ATCmdManager::_oob_data_mode(){
ocomeni 96:f5ed273881af 635 //_smutex.lock();
ocomeni 75:08eff6258e1b 636 printf("\n Received EDM mode command!!\n");
ocomeni 75:08eff6258e1b 637 if(_parser.scanf("%d", &dataMode) >0) {
ocomeni 99:05398b3184f8 638 printf("\nATCmdParser: Data mode=%d\r\n", dataMode);
ocomeni 96:f5ed273881af 639 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 75:08eff6258e1b 640 switch(dataMode)
ocomeni 75:08eff6258e1b 641 {
ocomeni 75:08eff6258e1b 642 case 0:
ocomeni 83:9c271a50a70b 643 printf("\nATCmdParser: Command Mode request received\n");
ocomeni 81:637a87eb8170 644 dataMode = AT_CMD_DATA_MODE;
ocomeni 75:08eff6258e1b 645 break;
ocomeni 75:08eff6258e1b 646 case 1:
ocomeni 83:9c271a50a70b 647 printf("\nATCmdParser: Data Mode request received\n");
ocomeni 81:637a87eb8170 648 dataMode = AT_STD_DATA_MODE;
ocomeni 75:08eff6258e1b 649 break;
ocomeni 75:08eff6258e1b 650 case 2:
ocomeni 83:9c271a50a70b 651 printf("\nATCmdParser: Extended data Mode request received\n");
ocomeni 81:637a87eb8170 652 dataMode = AT_EXT_DATA_MODE;
ocomeni 98:65c2333a38b6 653 _event_queue.call_in(10, &print_heap_and_isr_stack_info);
ocomeni 98:65c2333a38b6 654 //print_heap_and_isr_stack_info();
ocomeni 75:08eff6258e1b 655 break;
ocomeni 75:08eff6258e1b 656 default:
ocomeni 75:08eff6258e1b 657 printf("\nATCmdParser: ERROR - UNKNOWN DATA MODE RECEIVED!!! \n");
ocomeni 75:08eff6258e1b 658 break;
ocomeni 75:08eff6258e1b 659 }
ocomeni 75:08eff6258e1b 660 } else {
ocomeni 83:9c271a50a70b 661 printf("\nATCmdParser: Retrieving Uart Options failed\n");
ocomeni 75:08eff6258e1b 662 }
ocomeni 96:f5ed273881af 663 //_smutex.unlock();
ocomeni 75:08eff6258e1b 664 }
ocomeni 75:08eff6258e1b 665
ocomeni 75:08eff6258e1b 666 void ATCmdManager::_oob_get_mac_addr(){
ocomeni 75:08eff6258e1b 667 int bleOrWifi;
ocomeni 96:f5ed273881af 668 //_smutex.lock();
ocomeni 75:08eff6258e1b 669 if(_parser.scanf("=%d", &bleOrWifi) >0) {
ocomeni 75:08eff6258e1b 670 switch(bleOrWifi)
ocomeni 75:08eff6258e1b 671 {
ocomeni 75:08eff6258e1b 672 case 1:
ocomeni 75:08eff6258e1b 673 printf("\nATCmdParser: BLE MAC Address request received");
ocomeni 75:08eff6258e1b 674 break;
ocomeni 75:08eff6258e1b 675 case 2:
ocomeni 75:08eff6258e1b 676 printf("\nATCmdParser: WiFi MAC Address request received");
ocomeni 75:08eff6258e1b 677 break;
ocomeni 75:08eff6258e1b 678 default:
ocomeni 75:08eff6258e1b 679 printf("\nATCmdParser: ERROR - UNKNOWN MAC ADDRESS REQUEST RECEIVED!!! \n");
ocomeni 75:08eff6258e1b 680 break;
ocomeni 75:08eff6258e1b 681 }
ocomeni 75:08eff6258e1b 682 } else {
ocomeni 75:08eff6258e1b 683 printf("\nATCmdParser: Retrieving Uart Options failed");
ocomeni 75:08eff6258e1b 684 }
ocomeni 95:290859010c8c 685 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 686 //_smutex.unlock();
ocomeni 75:08eff6258e1b 687 }
ocomeni 75:08eff6258e1b 688
ocomeni 75:08eff6258e1b 689 void ATCmdManager::_oob_get_ble_role(){
ocomeni 96:f5ed273881af 690 //_smutex.lock();
ocomeni 75:08eff6258e1b 691 printf("\n Received get BLE role command!!\n");
ocomeni 95:290859010c8c 692 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 693 //_smutex.unlock();
ocomeni 75:08eff6258e1b 694 }
ocomeni 75:08eff6258e1b 695
ocomeni 75:08eff6258e1b 696 void ATCmdManager::_oob_ena_ble_peri(){
ocomeni 96:f5ed273881af 697 //_smutex.lock();
ocomeni 75:08eff6258e1b 698 printf("\n Received enable BLE Peripheral command!!\n");
ocomeni 95:290859010c8c 699 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 700 //_smutex.unlock();
ocomeni 75:08eff6258e1b 701 }
ocomeni 75:08eff6258e1b 702
ocomeni 75:08eff6258e1b 703 void ATCmdManager::_oob_reboot(){
ocomeni 96:f5ed273881af 704 //_smutex.lock();
ocomeni 75:08eff6258e1b 705 printf("\n Received reboot command!!\n");
ocomeni 95:290859010c8c 706 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 75:08eff6258e1b 707 _parser.send("System Resetting....\n");
ocomeni 75:08eff6258e1b 708 system_reset();
ocomeni 96:f5ed273881af 709 //_smutex.unlock();
ocomeni 75:08eff6258e1b 710 }
ocomeni 75:08eff6258e1b 711
ocomeni 79:a2187bbfa407 712 const char * ATCmdManager::sec2str(nsapi_security_t sec)
ocomeni 79:a2187bbfa407 713 {
ocomeni 79:a2187bbfa407 714 switch (sec) {
ocomeni 79:a2187bbfa407 715 case NSAPI_SECURITY_NONE:
ocomeni 79:a2187bbfa407 716 return "None";
ocomeni 79:a2187bbfa407 717 case NSAPI_SECURITY_WEP:
ocomeni 79:a2187bbfa407 718 return "WEP";
ocomeni 79:a2187bbfa407 719 case NSAPI_SECURITY_WPA:
ocomeni 79:a2187bbfa407 720 return "WPA";
ocomeni 79:a2187bbfa407 721 case NSAPI_SECURITY_WPA2:
ocomeni 79:a2187bbfa407 722 return "WPA2";
ocomeni 79:a2187bbfa407 723 case NSAPI_SECURITY_WPA_WPA2:
ocomeni 79:a2187bbfa407 724 return "WPA/WPA2";
ocomeni 79:a2187bbfa407 725 case NSAPI_SECURITY_UNKNOWN:
ocomeni 79:a2187bbfa407 726 default:
ocomeni 79:a2187bbfa407 727 return "Unknown";
ocomeni 79:a2187bbfa407 728 }
ocomeni 79:a2187bbfa407 729 }
ocomeni 81:637a87eb8170 730
ocomeni 81:637a87eb8170 731 bool ATCmdManager::setNextResponse(at_cmd_resp_t resp)
ocomeni 81:637a87eb8170 732 {
ocomeni 81:637a87eb8170 733 if(at_resp == AT_RESP_NONE){
ocomeni 81:637a87eb8170 734 at_resp = resp;
ocomeni 81:637a87eb8170 735 return true; // success
ocomeni 81:637a87eb8170 736 }
ocomeni 81:637a87eb8170 737 return false; // wiFiManager busy
ocomeni 79:a2187bbfa407 738 }
ocomeni 79:a2187bbfa407 739
ocomeni 81:637a87eb8170 740
ocomeni 79:a2187bbfa407 741 void ATCmdManager::_oob_scanWiFiNetworks(){
ocomeni 96:f5ed273881af 742 //_smutex.lock();
ocomeni 79:a2187bbfa407 743 printf("\n Received scanWiFiNetworks command!!\n");
ocomeni 95:290859010c8c 744 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 96:f5ed273881af 745 //_smutex.unlock();
ocomeni 79:a2187bbfa407 746 wifi_cmd_t cmd = WIFI_CMD_SCAN;
ocomeni 79:a2187bbfa407 747 // queue next command
ocomeni 79:a2187bbfa407 748 queueWiFiCommand(cmd);
ocomeni 81:637a87eb8170 749 return;
ocomeni 75:08eff6258e1b 750 }
ocomeni 75:08eff6258e1b 751
ocomeni 95:290859010c8c 752
ocomeni 95:290859010c8c 753
ocomeni 98:65c2333a38b6 754 void ATCmdManager::_oob_WiFiStationConfigAction()
ocomeni 79:a2187bbfa407 755 {
ocomeni 98:65c2333a38b6 756 int if_id; // interface id for request
ocomeni 98:65c2333a38b6 757 int aId; // interface id for request
ocomeni 98:65c2333a38b6 758 _parser.recv("%d,%d", &if_id, &aId);
ocomeni 92:ec9550034276 759 //_smutex.lock();
ocomeni 98:65c2333a38b6 760 printf("\n Received WiFi Configuration Action command %d %d!!\r\n", if_id, aId);
ocomeni 95:290859010c8c 761 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 98:65c2333a38b6 762 if(if_id == WIFI_CONFIG_ID && aId <5){
ocomeni 95:290859010c8c 763 wifi_cmd_t cmd;
ocomeni 98:65c2333a38b6 764 action_id_t action_id = (action_id_t) aId;
ocomeni 95:290859010c8c 765 switch(action_id){
ocomeni 95:290859010c8c 766 case WIFI_CONFIG_RESET:
ocomeni 95:290859010c8c 767 break;
ocomeni 95:290859010c8c 768 case WIFI_CONFIG_STORE:
ocomeni 95:290859010c8c 769 break;
ocomeni 95:290859010c8c 770 case WIFI_CONFIG_LOAD:
ocomeni 95:290859010c8c 771 break;
ocomeni 95:290859010c8c 772 case WIFI_CONFIG_ACTIVATE:
ocomeni 95:290859010c8c 773 cmd = WIFI_CMD_CONNECT;
ocomeni 95:290859010c8c 774 printf("\n About to Queue wifi cmd = %d!!\n", cmd);
ocomeni 95:290859010c8c 775 //_smutex.unlock();
ocomeni 95:290859010c8c 776 // queue next command
ocomeni 95:290859010c8c 777 queueWiFiCommand(cmd);
ocomeni 95:290859010c8c 778 break;
ocomeni 95:290859010c8c 779 case WIFI_CONFIG_DEACTIVATE:
ocomeni 95:290859010c8c 780 cmd = WIFI_CMD_DISCONNECT;
ocomeni 95:290859010c8c 781 printf("\n About to Queue wifi cmd = %d!!\n", cmd);
ocomeni 95:290859010c8c 782 //_smutex.unlock();
ocomeni 95:290859010c8c 783 // queue next command
ocomeni 95:290859010c8c 784 queueWiFiCommand(cmd);
ocomeni 95:290859010c8c 785 break;
ocomeni 95:290859010c8c 786 default:
ocomeni 95:290859010c8c 787 break;
ocomeni 95:290859010c8c 788 }
ocomeni 95:290859010c8c 789 }
ocomeni 98:65c2333a38b6 790 if(debug_flag>0){
ocomeni 98:65c2333a38b6 791 printf("finished queuing WIFI CONNECT CMD \r\n");
ocomeni 98:65c2333a38b6 792 }
ocomeni 81:637a87eb8170 793 return;
ocomeni 79:a2187bbfa407 794 }
ocomeni 79:a2187bbfa407 795
ocomeni 79:a2187bbfa407 796
ocomeni 79:a2187bbfa407 797 void ATCmdManager::_oob_disconnectWiFiNetwork()
ocomeni 79:a2187bbfa407 798 {
ocomeni 96:f5ed273881af 799 //_smutex.lock();
ocomeni 92:ec9550034276 800 printf("\n Received WiFi Disconnect command!!\n");
ocomeni 95:290859010c8c 801 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 81:637a87eb8170 802 wifi_cmd_t cmd = WIFI_CMD_DISCONNECT;
ocomeni 96:f5ed273881af 803 //_smutex.unlock();
ocomeni 81:637a87eb8170 804 // queue next command
ocomeni 81:637a87eb8170 805 queueWiFiCommand(cmd);
ocomeni 81:637a87eb8170 806 return;
ocomeni 81:637a87eb8170 807 }
ocomeni 81:637a87eb8170 808
ocomeni 81:637a87eb8170 809 void ATCmdManager::_oob_setupInternetConnection()
ocomeni 81:637a87eb8170 810 {
ocomeni 90:ed0267eca7b5 811 char str[MAX_URL_LEN];
ocomeni 90:ed0267eca7b5 812 char url[MAX_URL_LEN];
ocomeni 81:637a87eb8170 813 int n;
ocomeni 81:637a87eb8170 814 internet_config_t internet_config;
ocomeni 96:f5ed273881af 815 //_smutex.lock();
ocomeni 84:7c7add00f4bf 816 printf("sizeof internet_config_t = %d\n", sizeof(internet_config_t));
ocomeni 90:ed0267eca7b5 817 n = ReadBytes((uint8_t *)str, MAX_URL_LEN);
ocomeni 84:7c7add00f4bf 818 str[n]=NULL;
ocomeni 84:7c7add00f4bf 819 printf("\n read string = %s , n = %d\n", str, n);
ocomeni 90:ed0267eca7b5 820 //n = sscanf(str, "=%1d,%199[^,],%1d", &(uint8_t)internet_config.peer_id,
ocomeni 90:ed0267eca7b5 821 n = sscanf(str, "=%1d,%99[^,],%1d", &internet_config.peer_id,
ocomeni 92:ec9550034276 822 url, //internet_config.url,
ocomeni 92:ec9550034276 823 &internet_config.connectionScheme);
ocomeni 92:ec9550034276 824 char *p = strstr(url,"\"");
ocomeni 92:ec9550034276 825 if(p!=NULL)
ocomeni 92:ec9550034276 826 {
ocomeni 92:ec9550034276 827 strncpy(internet_config.url, &p[1], strlen(url));
ocomeni 92:ec9550034276 828 p = strstr(internet_config.url,"\"");
ocomeni 92:ec9550034276 829 *p = NULL;
ocomeni 92:ec9550034276 830 }
ocomeni 92:ec9550034276 831 else
ocomeni 92:ec9550034276 832 {
ocomeni 92:ec9550034276 833 strncpy(internet_config.url, url, strlen(url)+1);
ocomeni 92:ec9550034276 834 }
ocomeni 90:ed0267eca7b5 835 printf("\n read string = %s , n = %d -- strlen(url) = %d\n", internet_config.url, n, strlen(internet_config.url));
ocomeni 81:637a87eb8170 836 if(n>0)
ocomeni 81:637a87eb8170 837 {
ocomeni 81:637a87eb8170 838 printf("peer_id = %1d, url = %s, connScheme = %1d\n", internet_config.peer_id,
ocomeni 90:ed0267eca7b5 839 internet_config.url,
ocomeni 90:ed0267eca7b5 840 internet_config.connectionScheme);
ocomeni 81:637a87eb8170 841 // package and send on wifi data queue
ocomeni 90:ed0267eca7b5 842 wifi_data_msg_t data_msg;
ocomeni 81:637a87eb8170 843 data_msg.wifi_cmd = WIFI_CMD_INTERNET_CONFIG;
ocomeni 84:7c7add00f4bf 844 data_msg.dataLen = sizeof(internet_config_t); // + strlen(internet_config.url);
ocomeni 84:7c7add00f4bf 845 printf("\n url size = %d url str = %s\n",strlen(internet_config.url), internet_config.url );
ocomeni 81:637a87eb8170 846 memcpy(data_msg.buffer,&internet_config, data_msg.dataLen);
ocomeni 96:f5ed273881af 847 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 82:10072c1794d3 848 // queue next data request
ocomeni 81:637a87eb8170 849 queueWiFiDataRequest(data_msg);
ocomeni 84:7c7add00f4bf 850 print_memory_info();
ocomeni 81:637a87eb8170 851 } else {
ocomeni 96:f5ed273881af 852 printf("\n[ATCMD MAN]: internet configuration failed %d fields parsed \r\n", n);
ocomeni 82:10072c1794d3 853 _parser.send("NAK\n");
ocomeni 82:10072c1794d3 854 }
ocomeni 96:f5ed273881af 855 //_smutex.unlock();
ocomeni 82:10072c1794d3 856 }
ocomeni 82:10072c1794d3 857
ocomeni 82:10072c1794d3 858 wifi_config_t ATCmdManager::init_wifi_config()
ocomeni 82:10072c1794d3 859 {
ocomeni 82:10072c1794d3 860 wifi_config_t wifi_cfg;
ocomeni 82:10072c1794d3 861 wifi_cfg.ssid[0] = NULL;
ocomeni 82:10072c1794d3 862 wifi_cfg.pass[0] = NULL;
ocomeni 82:10072c1794d3 863 wifi_cfg.security = NSAPI_SECURITY_UNKNOWN;
ocomeni 82:10072c1794d3 864 return wifi_cfg;
ocomeni 82:10072c1794d3 865 }
ocomeni 83:9c271a50a70b 866 /* read ASCII characters into buffer and null terminate */
ocomeni 83:9c271a50a70b 867 int ATCmdManager::readStringBytes(uint8_t *buf, int maxBytes)
ocomeni 82:10072c1794d3 868 {
ocomeni 82:10072c1794d3 869 int c;
ocomeni 82:10072c1794d3 870 int sptr = 0;
ocomeni 93:06e755a80187 871 int quoteCnt = 0;
ocomeni 82:10072c1794d3 872 for(int i=0;i<maxBytes;i++){
ocomeni 82:10072c1794d3 873 c = _parser.getc();
ocomeni 93:06e755a80187 874 if(c== '"')quoteCnt++;
ocomeni 93:06e755a80187 875 if(c==-1 || quoteCnt==2){
ocomeni 83:9c271a50a70b 876 buf[sptr] = NULL; // null terminate if string
ocomeni 82:10072c1794d3 877 return i;
ocomeni 82:10072c1794d3 878 }
ocomeni 82:10072c1794d3 879 if(c != ',' && c!= '"'){
ocomeni 82:10072c1794d3 880 buf[sptr++] = (uint8_t) c;
ocomeni 82:10072c1794d3 881 }
ocomeni 81:637a87eb8170 882 }
ocomeni 83:9c271a50a70b 883 return maxBytes;
ocomeni 83:9c271a50a70b 884 }
ocomeni 83:9c271a50a70b 885
ocomeni 83:9c271a50a70b 886 int ATCmdManager::ReadBytes(uint8_t *buf, int maxBytes)
ocomeni 83:9c271a50a70b 887 {
ocomeni 83:9c271a50a70b 888 int c;
ocomeni 83:9c271a50a70b 889 int sptr = 0;
ocomeni 83:9c271a50a70b 890 for(int i=0;i<maxBytes;i++){
ocomeni 83:9c271a50a70b 891 c = _parser.getc();
ocomeni 83:9c271a50a70b 892 if(c==-1){
ocomeni 83:9c271a50a70b 893 return i;
ocomeni 83:9c271a50a70b 894 }
ocomeni 83:9c271a50a70b 895 buf[sptr++] = (uint8_t) c;
ocomeni 83:9c271a50a70b 896 }
ocomeni 83:9c271a50a70b 897 return maxBytes;
ocomeni 82:10072c1794d3 898 }
ocomeni 82:10072c1794d3 899
ocomeni 82:10072c1794d3 900 void ATCmdManager::_oob_setWiFiSSID()
ocomeni 82:10072c1794d3 901 {
ocomeni 82:10072c1794d3 902 int n;
ocomeni 82:10072c1794d3 903 wifi_config_t wifi_cfg = init_wifi_config();
ocomeni 96:f5ed273881af 904 //_smutex.lock();
ocomeni 83:9c271a50a70b 905 n = readStringBytes((uint8_t *)wifi_cfg.ssid, 32);
ocomeni 82:10072c1794d3 906 printf("[ATCMD MAN]: number of bytes read = %d\n", n);
ocomeni 82:10072c1794d3 907 if(n>0)
ocomeni 82:10072c1794d3 908 {
ocomeni 82:10072c1794d3 909 printf("[ATCMD MAN]: wifi_cfg.ssid = %s\n", wifi_cfg.ssid);
ocomeni 82:10072c1794d3 910 // package and send on wifi data queue
ocomeni 82:10072c1794d3 911 wifi_data_msg_t data_msg;
ocomeni 82:10072c1794d3 912 data_msg.wifi_cmd = WIFI_CMD_CONFIG;
ocomeni 82:10072c1794d3 913 data_msg.dataLen = sizeof(wifi_config_t);
ocomeni 82:10072c1794d3 914 memcpy(data_msg.buffer,&wifi_cfg, data_msg.dataLen);
ocomeni 96:f5ed273881af 915 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 82:10072c1794d3 916 queueWiFiDataRequest(data_msg);
ocomeni 82:10072c1794d3 917 } else {
ocomeni 82:10072c1794d3 918 printf("\n[ATCMD MAN]: wifi configuration failed \n");
ocomeni 82:10072c1794d3 919 _parser.send("NAK\n");
ocomeni 82:10072c1794d3 920 }
ocomeni 96:f5ed273881af 921 //_smutex.unlock();
ocomeni 82:10072c1794d3 922 }
ocomeni 82:10072c1794d3 923
ocomeni 82:10072c1794d3 924 void ATCmdManager::_oob_setWiFiPWD()
ocomeni 82:10072c1794d3 925 {
ocomeni 82:10072c1794d3 926 int n;
ocomeni 82:10072c1794d3 927 wifi_config_t wifi_cfg = init_wifi_config();
ocomeni 96:f5ed273881af 928 //_smutex.lock();
ocomeni 82:10072c1794d3 929 //n = _parser.scanf("%31[^\r\n]", wifi_cfg.pass);
ocomeni 83:9c271a50a70b 930 n = readStringBytes((uint8_t *)wifi_cfg.pass, 32);
ocomeni 82:10072c1794d3 931 if(n>0)
ocomeni 82:10072c1794d3 932 {
ocomeni 92:ec9550034276 933 printf("ATCMD MAN]: wifi_cfg.pass = %s\n", "****************");
ocomeni 82:10072c1794d3 934 // package and send on wifi data queue
ocomeni 82:10072c1794d3 935 wifi_data_msg_t data_msg;
ocomeni 82:10072c1794d3 936 data_msg.wifi_cmd = WIFI_CMD_CONFIG;
ocomeni 82:10072c1794d3 937 data_msg.dataLen = sizeof(wifi_config_t);
ocomeni 82:10072c1794d3 938 memcpy(data_msg.buffer,&wifi_cfg, data_msg.dataLen);
ocomeni 96:f5ed273881af 939 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 82:10072c1794d3 940 queueWiFiDataRequest(data_msg);
ocomeni 82:10072c1794d3 941 } else {
ocomeni 82:10072c1794d3 942 printf("\n[ATCMD MAN]: wifi configuration failed \n");
ocomeni 82:10072c1794d3 943 _parser.send("NAK\n");
ocomeni 82:10072c1794d3 944 }
ocomeni 96:f5ed273881af 945 //_smutex.unlock();
ocomeni 82:10072c1794d3 946 }
ocomeni 82:10072c1794d3 947
ocomeni 82:10072c1794d3 948 void ATCmdManager::_oob_setWiFiSecurity()
ocomeni 82:10072c1794d3 949 {
ocomeni 82:10072c1794d3 950 int n;
ocomeni 82:10072c1794d3 951 wifi_config_t wifi_cfg = init_wifi_config();
ocomeni 90:ed0267eca7b5 952 _smutex.lock();
ocomeni 82:10072c1794d3 953 n = _parser.scanf(",%d", &wifi_cfg.security);
ocomeni 90:ed0267eca7b5 954 _smutex.unlock();
ocomeni 82:10072c1794d3 955 if(n>0)
ocomeni 82:10072c1794d3 956 {
ocomeni 82:10072c1794d3 957 printf("ATCMD MAN]: wifi_cfg.security = %s\n", sec2str(wifi_cfg.security));
ocomeni 82:10072c1794d3 958 // package and send on wifi data queue
ocomeni 82:10072c1794d3 959 wifi_data_msg_t data_msg;
ocomeni 82:10072c1794d3 960 data_msg.wifi_cmd = WIFI_CMD_CONFIG;
ocomeni 82:10072c1794d3 961 data_msg.dataLen = sizeof(wifi_config_t);
ocomeni 82:10072c1794d3 962 memcpy(data_msg.buffer,&wifi_cfg, data_msg.dataLen);
ocomeni 96:f5ed273881af 963 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 82:10072c1794d3 964 queueWiFiDataRequest(data_msg);
ocomeni 82:10072c1794d3 965 } else {
ocomeni 82:10072c1794d3 966 printf("\n[ATCMD MAN]: wifi configuration failed \n");
ocomeni 90:ed0267eca7b5 967 _smutex.lock();
ocomeni 82:10072c1794d3 968 _parser.send("NAK\n");
ocomeni 90:ed0267eca7b5 969 _smutex.unlock();
ocomeni 82:10072c1794d3 970 }
ocomeni 84:7c7add00f4bf 971 //_smutex.unlock();
ocomeni 79:a2187bbfa407 972 }
ocomeni 81:637a87eb8170 973
ocomeni 83:9c271a50a70b 974
ocomeni 95:290859010c8c 975
ocomeni 95:290859010c8c 976 void ATCmdManager::_oob_getNetworkStatus()
ocomeni 95:290859010c8c 977 {
ocomeni 95:290859010c8c 978 uint8_t if_id; // interface id for request
ocomeni 95:290859010c8c 979 _parser.scanf(",%d", &if_id);
ocomeni 95:290859010c8c 980 //_smutex.lock();
ocomeni 95:290859010c8c 981 printf("\n Received Get Network Status command!!\n");
ocomeni 95:290859010c8c 982 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 95:290859010c8c 983 if(if_id == WIFI_INTERFACE_ID){
ocomeni 95:290859010c8c 984 wifi_cmd_t cmd = WIFI_CMD_NETWORK_STATUS;
ocomeni 95:290859010c8c 985 printf("\n About to Queue wifi cmd = %d!!\n", cmd);
ocomeni 95:290859010c8c 986 //_smutex.unlock();
ocomeni 95:290859010c8c 987 // queue next command
ocomeni 95:290859010c8c 988 queueWiFiCommand(cmd);
ocomeni 95:290859010c8c 989 }
ocomeni 95:290859010c8c 990 return;
ocomeni 95:290859010c8c 991 }
ocomeni 95:290859010c8c 992
ocomeni 95:290859010c8c 993
ocomeni 95:290859010c8c 994 void ATCmdManager::_oob_WiFiNetworkStatus()
ocomeni 95:290859010c8c 995 {
ocomeni 95:290859010c8c 996 //_smutex.lock();
ocomeni 95:290859010c8c 997 printf("\n Received Get WiFi Network Status command!!\n");
ocomeni 95:290859010c8c 998 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 95:290859010c8c 999 wifi_cmd_t cmd = WIFI_CMD_WIFI_STATUS;
ocomeni 95:290859010c8c 1000 printf("\n About to Queue wifi cmd = %d!!\n", cmd);
ocomeni 95:290859010c8c 1001 //_smutex.unlock();
ocomeni 95:290859010c8c 1002 // queue next command
ocomeni 95:290859010c8c 1003 queueWiFiCommand(cmd);
ocomeni 95:290859010c8c 1004 return;
ocomeni 95:290859010c8c 1005 }
ocomeni 95:290859010c8c 1006
ocomeni 83:9c271a50a70b 1007 void ATCmdManager::_oob_sendHttpMessage()
ocomeni 83:9c271a50a70b 1008 {
ocomeni 83:9c271a50a70b 1009 int n;
ocomeni 84:7c7add00f4bf 1010 http_request_t http_post_request;
ocomeni 84:7c7add00f4bf 1011 //_smutex.lock();
ocomeni 83:9c271a50a70b 1012 /*
ocomeni 83:9c271a50a70b 1013 n = _parser.scanf(",%d", &wifi_cfg.security);
ocomeni 83:9c271a50a70b 1014 if(n>0)
ocomeni 83:9c271a50a70b 1015 {
ocomeni 83:9c271a50a70b 1016 printf("ATCMD MAN]: wifi_cfg.security = %s\n", sec2str(wifi_cfg.security));
ocomeni 83:9c271a50a70b 1017 // package and send on wifi data queue
ocomeni 83:9c271a50a70b 1018 wifi_data_msg_t data_msg;
ocomeni 83:9c271a50a70b 1019 data_msg.wifi_cmd = WIFI_CMD_CONFIG;
ocomeni 83:9c271a50a70b 1020 data_msg.dataLen = sizeof(wifi_config_t);
ocomeni 83:9c271a50a70b 1021 memcpy(data_msg.buffer,&wifi_cfg, data_msg.dataLen);
ocomeni 83:9c271a50a70b 1022 queueWiFiDataRequest(data_msg);
ocomeni 95:290859010c8c 1023 sendAtConfirmation(OK_RESP); //_parser.send(OK_RESP);
ocomeni 83:9c271a50a70b 1024 } else {
ocomeni 83:9c271a50a70b 1025 printf("\n[ATCMD MAN]: wifi configuration failed \n");
ocomeni 83:9c271a50a70b 1026 _parser.send("NAK\n");
ocomeni 83:9c271a50a70b 1027 }
ocomeni 83:9c271a50a70b 1028 */
ocomeni 84:7c7add00f4bf 1029 //_smutex.unlock();
ocomeni 83:9c271a50a70b 1030
ocomeni 83:9c271a50a70b 1031 }
ocomeni 83:9c271a50a70b 1032
ocomeni 81:637a87eb8170 1033 bool ATCmdManager::queueWiFiCommand(wifi_cmd_t cmd){
ocomeni 92:ec9550034276 1034 printf("[ATCMD MAN] about to be queued with wifi_cmd = %d\n", cmd);
ocomeni 92:ec9550034276 1035 #ifndef USE_MALLOC_FOR_COMMAND_MEMORY_POOL
ocomeni 81:637a87eb8170 1036 wifi_cmd_message_t *wifiCmd = _aT2WiFimPool->alloc();
ocomeni 92:ec9550034276 1037 if(wifiCmd == NULL){
ocomeni 92:ec9550034276 1038 printf("[ATCMD MAN] queued memory allocation failed\n");
ocomeni 92:ec9550034276 1039 return false;
ocomeni 92:ec9550034276 1040 }
ocomeni 92:ec9550034276 1041 #else
ocomeni 92:ec9550034276 1042 wifi_cmd_message_t *wifiCmd = (wifi_cmd_message_t *) malloc(sizeof(wifi_cmd_message_t));
ocomeni 92:ec9550034276 1043 if(wifiCmd == NULL){
ocomeni 98:65c2333a38b6 1044 printf("[ATCMD MAN] try malloc() : queued memory allocation failed\n");
ocomeni 98:65c2333a38b6 1045 //_event_queue.call_in(10, &print_memory_info);
ocomeni 98:65c2333a38b6 1046 _event_queue.call_in(10, &print_heap_and_isr_stack_info);
ocomeni 98:65c2333a38b6 1047 //print_memory_info();
ocomeni 98:65c2333a38b6 1048 //print_heap_and_isr_stack_info();
ocomeni 92:ec9550034276 1049 return false;
ocomeni 92:ec9550034276 1050 }
ocomeni 92:ec9550034276 1051 #endif
ocomeni 81:637a87eb8170 1052 wifiCmd->wifi_cmd = cmd;
ocomeni 81:637a87eb8170 1053 _aT2WiFiCmdQueue->put(wifiCmd);
ocomeni 92:ec9550034276 1054 printf("[ATCMD MAN] queued wifi_cmd = %d\n", wifiCmd->wifi_cmd);
ocomeni 98:65c2333a38b6 1055 if((int)cmd == 5)
ocomeni 98:65c2333a38b6 1056 debug_flag = 3;
ocomeni 81:637a87eb8170 1057 return true;
ocomeni 81:637a87eb8170 1058 }
ocomeni 81:637a87eb8170 1059
ocomeni 81:637a87eb8170 1060 bool ATCmdManager::dequeueATresponse(){
ocomeni 98:65c2333a38b6 1061 if(debug_flag>0){
ocomeni 98:65c2333a38b6 1062 debug_flag--;
ocomeni 98:65c2333a38b6 1063 printf("Called dequeueATresponse after WIFI CONNECT CMD \r\n");
ocomeni 98:65c2333a38b6 1064 }
ocomeni 81:637a87eb8170 1065 if(at_resp != AT_RESP_NONE) return false; // busy
ocomeni 81:637a87eb8170 1066 osEvent evt = _wiFi2ATCmdQueue->get(0);
ocomeni 81:637a87eb8170 1067 if(evt.status == osEventMessage){
ocomeni 81:637a87eb8170 1068 at_resp_message_t *resp = (at_resp_message_t*)evt.value.p;
ocomeni 81:637a87eb8170 1069 setNextResponse(resp->at_resp);
ocomeni 100:80ef4bc31b7a 1070 printf("[ATCMD MAN] dequeued AT CMD : at_resp = %d\n", resp->at_resp);
ocomeni 92:ec9550034276 1071 #ifndef USE_MALLOC_FOR_COMMAND_MEMORY_POOL
ocomeni 81:637a87eb8170 1072 _wiFi2ATmPool->free(resp);
ocomeni 96:f5ed273881af 1073 resp = NULL;
ocomeni 92:ec9550034276 1074 #else
ocomeni 92:ec9550034276 1075 free(resp);
ocomeni 96:f5ed273881af 1076 resp = NULL;
ocomeni 92:ec9550034276 1077 #endif
ocomeni 81:637a87eb8170 1078 }
ocomeni 81:637a87eb8170 1079 return true;
ocomeni 81:637a87eb8170 1080 }
ocomeni 81:637a87eb8170 1081
ocomeni 81:637a87eb8170 1082 bool ATCmdManager::queueWiFiDataRequest(wifi_data_msg_t data_req){
ocomeni 93:06e755a80187 1083 //print_memory_info();
ocomeni 98:65c2333a38b6 1084 _event_queue.call_in(10, &print_heap_and_isr_stack_info);
ocomeni 98:65c2333a38b6 1085 //print_heap_and_isr_stack_info();
ocomeni 81:637a87eb8170 1086 wifi_data_msg_t *wifiData = _aT2WiFiDatamPool->alloc();
ocomeni 81:637a87eb8170 1087 wifiData->wifi_cmd = data_req.wifi_cmd;
ocomeni 81:637a87eb8170 1088 wifiData->dataLen = data_req.dataLen;
ocomeni 81:637a87eb8170 1089 memcpy(wifiData->buffer, data_req.buffer, data_req.dataLen);
ocomeni 81:637a87eb8170 1090 _aT2WiFiDataQueue->put(wifiData);
ocomeni 81:637a87eb8170 1091 printf("[ATCMD MAN] queued data size = %d : wifi_cmd = %d\n", data_req.dataLen, data_req.wifi_cmd);
ocomeni 84:7c7add00f4bf 1092 //free(&data_req);
ocomeni 81:637a87eb8170 1093 return true;
ocomeni 81:637a87eb8170 1094 }
ocomeni 81:637a87eb8170 1095
ocomeni 87:99b37d26ff2a 1096 bool ATCmdManager::dequeueWiFidataResponse(){
ocomeni 98:65c2333a38b6 1097 if(debug_flag>0){
ocomeni 98:65c2333a38b6 1098 debug_flag--;
ocomeni 98:65c2333a38b6 1099 printf("Called dequeueWiFidataResponse after WIFI CONNECT CMD \r\n");
ocomeni 98:65c2333a38b6 1100 }
ocomeni 81:637a87eb8170 1101 if(at_resp != AT_RESP_NONE) return false; // busy
ocomeni 81:637a87eb8170 1102 osEvent evt = _wiFi2ATDataQueue->get(0);
ocomeni 81:637a87eb8170 1103 if(evt.status == osEventMessage){
ocomeni 81:637a87eb8170 1104 resp_data = (at_data_msg_t*)evt.value.p;
ocomeni 81:637a87eb8170 1105 setNextResponse(resp_data->at_resp);
ocomeni 100:80ef4bc31b7a 1106 printf("[ATCMD MAN] dequeued data size = %d : at_resp = %d\n", resp_data->dataLen, resp_data->at_resp);
ocomeni 98:65c2333a38b6 1107 _event_queue.call_in(10, &print_heap_and_isr_stack_info);
ocomeni 98:65c2333a38b6 1108 //print_heap_and_isr_stack_info();
ocomeni 81:637a87eb8170 1109 }
ocomeni 81:637a87eb8170 1110 return true;
ocomeni 81:637a87eb8170 1111 }
ocomeni 81:637a87eb8170 1112
ocomeni 93:06e755a80187 1113
ocomeni 93:06e755a80187 1114 void ATCmdManager::sendAtConfirmation(const char *buf)
ocomeni 93:06e755a80187 1115 {
ocomeni 96:f5ed273881af 1116 _smutex.lock();
ocomeni 95:290859010c8c 1117 switch(dataMode){
ocomeni 95:290859010c8c 1118 case AT_CMD_DATA_MODE:
ocomeni 98:65c2333a38b6 1119 _parser.send("%s", buf);
ocomeni 95:290859010c8c 1120 break;
ocomeni 95:290859010c8c 1121 case AT_STD_DATA_MODE:
ocomeni 98:65c2333a38b6 1122 _parser.send("%s", buf);
ocomeni 95:290859010c8c 1123 break;
ocomeni 95:290859010c8c 1124 case AT_EXT_DATA_MODE:
ocomeni 98:65c2333a38b6 1125 {
ocomeni 96:f5ed273881af 1126 int len = strlen(buf);
ocomeni 95:290859010c8c 1127 outputEDMdata((const uint8_t *) buf, len, AT_MSG_ID, CONFIRMATION_MSG_TYPE, NO_CHANNEL);
ocomeni 95:290859010c8c 1128 break;
ocomeni 98:65c2333a38b6 1129 }
ocomeni 95:290859010c8c 1130 default:
ocomeni 98:65c2333a38b6 1131 _parser.send("%s", buf);
ocomeni 95:290859010c8c 1132 break;
ocomeni 95:290859010c8c 1133 }
ocomeni 96:f5ed273881af 1134 //wait_ms(1);
ocomeni 96:f5ed273881af 1135 _smutex.unlock();
ocomeni 93:06e755a80187 1136 }
ocomeni 93:06e755a80187 1137 void ATCmdManager::sendAtEvent(const char *buf)
ocomeni 93:06e755a80187 1138 {
ocomeni 96:f5ed273881af 1139 _smutex.lock();
ocomeni 95:290859010c8c 1140 switch(dataMode){
ocomeni 95:290859010c8c 1141 case AT_CMD_DATA_MODE:
ocomeni 95:290859010c8c 1142 _parser.send(buf);
ocomeni 95:290859010c8c 1143 break;
ocomeni 95:290859010c8c 1144 case AT_STD_DATA_MODE:
ocomeni 95:290859010c8c 1145 _parser.send(buf);
ocomeni 95:290859010c8c 1146 break;
ocomeni 95:290859010c8c 1147 case AT_EXT_DATA_MODE:
ocomeni 99:05398b3184f8 1148 {
ocomeni 96:f5ed273881af 1149 int len = strlen(buf);
ocomeni 95:290859010c8c 1150 outputEDMdata((const uint8_t *) buf, len, AT_MSG_ID, EVENT_MSG_TYPE, NO_CHANNEL);
ocomeni 95:290859010c8c 1151 break;
ocomeni 99:05398b3184f8 1152 }
ocomeni 99:05398b3184f8 1153 default:
ocomeni 99:05398b3184f8 1154 _parser.send(buf);
ocomeni 99:05398b3184f8 1155 break;
ocomeni 95:290859010c8c 1156 }
ocomeni 96:f5ed273881af 1157 _smutex.unlock();
ocomeni 100:80ef4bc31b7a 1158 _wiFi2ATDatamPool->free(resp_data);
ocomeni 100:80ef4bc31b7a 1159 resp_data = NULL;
ocomeni 93:06e755a80187 1160 }
ocomeni 93:06e755a80187 1161
ocomeni 99:05398b3184f8 1162
ocomeni 99:05398b3184f8 1163 void ATCmdManager::sendConnectEvent(const uint8_t *buf, int len)
ocomeni 99:05398b3184f8 1164 {
ocomeni 99:05398b3184f8 1165 //_smutex.lock();
ocomeni 99:05398b3184f8 1166 switch(dataMode){
ocomeni 99:05398b3184f8 1167 case AT_CMD_DATA_MODE:
ocomeni 99:05398b3184f8 1168 _parser.send((const char*) buf);
ocomeni 99:05398b3184f8 1169 break;
ocomeni 99:05398b3184f8 1170 case AT_STD_DATA_MODE:
ocomeni 99:05398b3184f8 1171 _parser.send((const char*)buf);
ocomeni 99:05398b3184f8 1172 break;
ocomeni 99:05398b3184f8 1173 case AT_EXT_DATA_MODE:
ocomeni 99:05398b3184f8 1174 outputEDMdata((const uint8_t *) buf, len, CONNECT_MSG_ID, EVENT_MSG_TYPE, WIFI_CHANNEL);
ocomeni 99:05398b3184f8 1175 break;
ocomeni 99:05398b3184f8 1176 }
ocomeni 100:80ef4bc31b7a 1177 _wiFi2ATDatamPool->free(resp_data);
ocomeni 100:80ef4bc31b7a 1178 resp_data = NULL;
ocomeni 100:80ef4bc31b7a 1179
ocomeni 99:05398b3184f8 1180 }
ocomeni 99:05398b3184f8 1181
ocomeni 99:05398b3184f8 1182
ocomeni 90:ed0267eca7b5 1183 void ATCmdManager::outputEDMdata(const uint8_t *buf, int pLen,
ocomeni 91:d6b6319ad681 1184 edm_msg_id_t identifier, edm_msg_type_t type,
ocomeni 91:d6b6319ad681 1185 channel_id_t channel_id)
ocomeni 90:ed0267eca7b5 1186 {
ocomeni 90:ed0267eca7b5 1187 int epLen = pLen + 2; // edm payload length = data length + 2
ocomeni 96:f5ed273881af 1188 if(channel_id != NO_CHANNEL)
ocomeni 96:f5ed273881af 1189 epLen += 1;
ocomeni 90:ed0267eca7b5 1190 _smutex.lock();
ocomeni 90:ed0267eca7b5 1191 // send EDM Message start byte
ocomeni 90:ed0267eca7b5 1192 _parser.putc(EDM_START_BYTE);
ocomeni 90:ed0267eca7b5 1193 // send EDM Message length
ocomeni 90:ed0267eca7b5 1194 _parser.putc(epLen>>8);
ocomeni 90:ed0267eca7b5 1195 _parser.putc(epLen%256);
ocomeni 90:ed0267eca7b5 1196 // send EDM Identifier + Type
ocomeni 90:ed0267eca7b5 1197 _parser.putc(identifier>>8);
ocomeni 90:ed0267eca7b5 1198 _parser.putc(identifier%256 | type);
ocomeni 93:06e755a80187 1199 // send channel id if valid
ocomeni 93:06e755a80187 1200 if(channel_id != NO_CHANNEL)
ocomeni 93:06e755a80187 1201 _parser.putc(channel_id);
ocomeni 90:ed0267eca7b5 1202 // send the data
ocomeni 90:ed0267eca7b5 1203 _parser.write((const char *)buf, pLen);
ocomeni 90:ed0267eca7b5 1204 // send EDM Message stop byte
ocomeni 90:ed0267eca7b5 1205 _parser.putc(EDM_STOP_BYTE);
ocomeni 98:65c2333a38b6 1206 _smutex.unlock();
ocomeni 96:f5ed273881af 1207 int msWait = (pLen + 5+20)/20;
ocomeni 96:f5ed273881af 1208 wait_ms(msWait);
ocomeni 90:ed0267eca7b5 1209 }
ocomeni 81:637a87eb8170 1210
ocomeni 89:45f6db09a76d 1211 void ATCmdManager::return_response(bool download) {
ocomeni 87:99b37d26ff2a 1212 char * resp = (char *) resp_data->buffer;
ocomeni 98:65c2333a38b6 1213 //_smutex.lock();
ocomeni 87:99b37d26ff2a 1214 printf("\n[ATCMD MAN] received response:\n");
ocomeni 89:45f6db09a76d 1215 if(download == false) // not download must be ascii header
ocomeni 89:45f6db09a76d 1216 {
ocomeni 89:45f6db09a76d 1217 printf("%.*s\r\n", resp_data->dataLen, resp);
ocomeni 89:45f6db09a76d 1218 }
ocomeni 89:45f6db09a76d 1219 else // dump payload as hex
ocomeni 89:45f6db09a76d 1220 {
ocomeni 89:45f6db09a76d 1221 printBufferInHex((uint8_t *)resp, resp_data->dataLen);
ocomeni 89:45f6db09a76d 1222 }
ocomeni 90:ed0267eca7b5 1223 //_parser.write(resp, resp_data->dataLen);
ocomeni 91:d6b6319ad681 1224 outputEDMdata((const uint8_t *)resp, resp_data->dataLen, DATA_MSG_ID,
ocomeni 91:d6b6319ad681 1225 EVENT_MSG_TYPE, WIFI_CHANNEL);
ocomeni 98:65c2333a38b6 1226 //_smutex.unlock();
ocomeni 87:99b37d26ff2a 1227 _wiFi2ATDatamPool->free(resp_data);
ocomeni 96:f5ed273881af 1228 resp_data = NULL;
ocomeni 93:06e755a80187 1229 //print_memory_info();
ocomeni 98:65c2333a38b6 1230 _event_queue.call_in(10, &print_heap_and_isr_stack_info);
ocomeni 98:65c2333a38b6 1231 //print_heap_and_isr_stack_info();
ocomeni 87:99b37d26ff2a 1232 }