Maxim Integrated / Mbed 2 deprecated DeepCover Embedded Security in IoT

MAXREFDES143#: DeepCover Embedded Security in IoT Authenticated Sensing & Notification

Dependencies:   MaximInterface mbed

The MAXREFDES143# is an Internet of Things (IoT) embedded security reference design, built to protect an industrial sensing node by means of authentication and notification to a web server. The hardware includes a peripheral module representing a protected sensor node monitoring operating temperature and remaining life of a filter (simulated through ambient light sensing) and an mbed shield representing a controller node responsible for monitoring one or more sensor nodes. The design is hierarchical with each controller node communicating data from connected sensor nodes to a web server that maintains a centralized log and dispatches notifications as necessary. The mbed shield contains a Wi-Fi module, a DS2465 coprocessor with 1-Wire® master function, an LCD, LEDs, and pushbuttons. The protected sensor node contains a DS28E15 authenticator, a DS7505 temperature sensor, and a MAX44009 light sensor. The mbed shield communicates to a web server by the onboard Wi-Fi module and to the protected sensor node with I2C and 1-Wire. The MAXREFDES143# is equipped with a standard shield connector for immediate testing using an mbed board such as the MAX32600MBED#. The simplicity of this design enables rapid integration into any star-topology IoT network requiring the heightened security with low overhead provided by the SHA-256 symmetric-key algorithm.

More information about the MAXREFDES143# is available on the Maxim Integrated website.

ESP8266.cpp@32:0a09505a656d, 2017-11-06 (annotated)

Committer:
IanBenzMaxim
Date:
Mon Nov 06 17:34:13 2017 -0600
Revision:
32:0a09505a656d
Parent:
30:0784010d6975 
Updated to use MaximInterface library.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
IanBenzMaxim 29:590a7561318b 1 /*******************************************************************************
IanBenzMaxim 29:590a7561318b 2 * Copyright (C) 2016 Maxim Integrated Products, Inc., All Rights Reserved.
IanBenzMaxim 29:590a7561318b 3 *
IanBenzMaxim 29:590a7561318b 4 * Permission is hereby granted, free of charge, to any person obtaining a
IanBenzMaxim 29:590a7561318b 5 * copy of this software and associated documentation files (the "Software"),
IanBenzMaxim 29:590a7561318b 6 * to deal in the Software without restriction, including without limitation
IanBenzMaxim 29:590a7561318b 7 * the rights to use, copy, modify, merge, publish, distribute, sublicense,
IanBenzMaxim 29:590a7561318b 8 * and/or sell copies of the Software, and to permit persons to whom the
IanBenzMaxim 29:590a7561318b 9 * Software is furnished to do so, subject to the following conditions:
IanBenzMaxim 29:590a7561318b 10 *
IanBenzMaxim 29:590a7561318b 11 * The above copyright notice and this permission notice shall be included
IanBenzMaxim 29:590a7561318b 12 * in all copies or substantial portions of the Software.
IanBenzMaxim 29:590a7561318b 13 *
IanBenzMaxim 29:590a7561318b 14 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
IanBenzMaxim 29:590a7561318b 15 * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
IanBenzMaxim 29:590a7561318b 16 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
IanBenzMaxim 29:590a7561318b 17 * IN NO EVENT SHALL MAXIM INTEGRATED BE LIABLE FOR ANY CLAIM, DAMAGES
IanBenzMaxim 29:590a7561318b 18 * OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
IanBenzMaxim 29:590a7561318b 19 * ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
IanBenzMaxim 29:590a7561318b 20 * OTHER DEALINGS IN THE SOFTWARE.
IanBenzMaxim 29:590a7561318b 21 *
IanBenzMaxim 29:590a7561318b 22 * Except as contained in this notice, the name of Maxim Integrated
IanBenzMaxim 29:590a7561318b 23 * Products, Inc. shall not be used except as stated in the Maxim Integrated
IanBenzMaxim 29:590a7561318b 24 * Products, Inc. Branding Policy.
IanBenzMaxim 29:590a7561318b 25 *
IanBenzMaxim 29:590a7561318b 26 * The mere transfer of this software does not imply any licenses
IanBenzMaxim 29:590a7561318b 27 * of trade secrets, proprietary technology, copyrights, patents,
IanBenzMaxim 29:590a7561318b 28 * trademarks, maskwork rights, or any other form of intellectual
IanBenzMaxim 29:590a7561318b 29 * property whatsoever. Maxim Integrated Products, Inc. retains all
IanBenzMaxim 29:590a7561318b 30 * ownership rights.
IanBenzMaxim 32:0a09505a656d 31 *******************************************************************************/
IanBenzMaxim 29:590a7561318b 32
IanBenzMaxim 29:590a7561318b 33 #include <cstdlib>
IanBenzMaxim 32:0a09505a656d 34 #include <Timer.h>
IanBenzMaxim 32:0a09505a656d 35 #include <wait_api.h>
IanBenzMaxim 29:590a7561318b 36 #include "ESP8266.hpp"
IanBenzMaxim 29:590a7561318b 37
IanBenzMaxim 32:0a09505a656d 38 static inline void disableRecvData() { __disable_irq(); }
IanBenzMaxim 29:590a7561318b 39
IanBenzMaxim 32:0a09505a656d 40 static inline void enableRecvData() { __enable_irq(); }
IanBenzMaxim 29:590a7561318b 41
IanBenzMaxim 32:0a09505a656d 42 ESP8266::ESP8266(const PinName tx, const PinName rx, const PinName rst,
IanBenzMaxim 32:0a09505a656d 43 const PinName CH_PD, const int baud,
IanBenzMaxim 32:0a09505a656d 44 mbed::Serial * debugMsgIntf)
IanBenzMaxim 32:0a09505a656d 45 : AT_intf(tx, rx), resetPin(rst), powerDownPin(CH_PD),
IanBenzMaxim 32:0a09505a656d 46 debugMsg(debugMsgIntf), parseRecvReset(false) {
IanBenzMaxim 29:590a7561318b 47 AT_intf.baud(baud);
IanBenzMaxim 29:590a7561318b 48 AT_intf.attach(this, &ESP8266::recv_AT_data_cb);
IanBenzMaxim 32:0a09505a656d 49
IanBenzMaxim 29:590a7561318b 50 // Ensure that device is not held in reset
IanBenzMaxim 29:590a7561318b 51 if (resetPin.is_connected())
IanBenzMaxim 29:590a7561318b 52 resetPin = 1;
IanBenzMaxim 29:590a7561318b 53 // Power down device at startup due to high current demand
IanBenzMaxim 29:590a7561318b 54 setPowered(false);
IanBenzMaxim 29:590a7561318b 55 }
IanBenzMaxim 29:590a7561318b 56
IanBenzMaxim 32:0a09505a656d 57 void ESP8266::reset() {
IanBenzMaxim 32:0a09505a656d 58 if (resetPin.is_connected()) {
IanBenzMaxim 29:590a7561318b 59 resetPin = 0;
IanBenzMaxim 29:590a7561318b 60 wait_ms(100);
IanBenzMaxim 29:590a7561318b 61 resetPin = 1;
IanBenzMaxim 29:590a7561318b 62 wait_ms(1000);
IanBenzMaxim 29:590a7561318b 63 }
IanBenzMaxim 29:590a7561318b 64 }
IanBenzMaxim 29:590a7561318b 65
IanBenzMaxim 32:0a09505a656d 66 bool ESP8266::powered() const {
IanBenzMaxim 29:590a7561318b 67 bool isPowered;
IanBenzMaxim 32:0a09505a656d 68 if (powerDownPin.is_connected()) {
IanBenzMaxim 29:590a7561318b 69 isPowered = powerDownPin.read();
IanBenzMaxim 32:0a09505a656d 70 } else {
IanBenzMaxim 29:590a7561318b 71 isPowered = false;
IanBenzMaxim 29:590a7561318b 72 }
IanBenzMaxim 29:590a7561318b 73 return isPowered;
IanBenzMaxim 29:590a7561318b 74 }
IanBenzMaxim 29:590a7561318b 75
IanBenzMaxim 32:0a09505a656d 76 void ESP8266::setPowered(bool powered) {
IanBenzMaxim 29:590a7561318b 77 if (powerDownPin.is_connected())
IanBenzMaxim 29:590a7561318b 78 powerDownPin = powered;
IanBenzMaxim 29:590a7561318b 79 }
IanBenzMaxim 29:590a7561318b 80
IanBenzMaxim 32:0a09505a656d 81 ESP8266::CmdResult ESP8266::performSelfTest() {
IanBenzMaxim 29:590a7561318b 82 return sendCommand(CmdBuilder(""));
IanBenzMaxim 29:590a7561318b 83 }
IanBenzMaxim 29:590a7561318b 84
IanBenzMaxim 32:0a09505a656d 85 ESP8266::CmdResult ESP8266::setCurrentWifiMode(const ESP8266::WifiMode mode) {
IanBenzMaxim 29:590a7561318b 86 CmdBuilder builder("CWMODE_CUR");
IanBenzMaxim 29:590a7561318b 87 builder.addRawArgument(mode);
IanBenzMaxim 29:590a7561318b 88 return sendCommand(builder);
IanBenzMaxim 29:590a7561318b 89 }
IanBenzMaxim 29:590a7561318b 90
IanBenzMaxim 32:0a09505a656d 91 ESP8266::CmdResult ESP8266::joinCurrentAccessPoint(const std::string & ssid,
IanBenzMaxim 32:0a09505a656d 92 const std::string & pwd,
IanBenzMaxim 32:0a09505a656d 93 const std::string & bssid) {
IanBenzMaxim 29:590a7561318b 94 CmdBuilder builder("CWJAP_CUR");
IanBenzMaxim 29:590a7561318b 95 builder.addStringArgument(ssid);
IanBenzMaxim 29:590a7561318b 96 builder.addStringArgument(pwd);
IanBenzMaxim 29:590a7561318b 97 if (bssid != "")
IanBenzMaxim 29:590a7561318b 98 builder.addStringArgument(bssid);
IanBenzMaxim 29:590a7561318b 99 return sendCommand(builder);
IanBenzMaxim 29:590a7561318b 100 }
IanBenzMaxim 29:590a7561318b 101
IanBenzMaxim 32:0a09505a656d 102 ESP8266::CmdResult ESP8266::quitAccessPoint() {
IanBenzMaxim 29:590a7561318b 103 return sendCommand(CmdBuilder("CWQAP"));
IanBenzMaxim 29:590a7561318b 104 }
IanBenzMaxim 29:590a7561318b 105
IanBenzMaxim 32:0a09505a656d 106 ESP8266::CmdResult ESP8266::setMaxRFTXPower(const float power_dBm) {
IanBenzMaxim 29:590a7561318b 107 int power_arg = (int)(power_dBm * 4);
IanBenzMaxim 29:590a7561318b 108 if (power_arg > 82)
IanBenzMaxim 29:590a7561318b 109 power_arg = 82;
IanBenzMaxim 29:590a7561318b 110 else if (power_arg < 0)
IanBenzMaxim 29:590a7561318b 111 power_arg = 0;
IanBenzMaxim 32:0a09505a656d 112
IanBenzMaxim 29:590a7561318b 113 CmdBuilder builder("RFPOWER");
IanBenzMaxim 29:590a7561318b 114 builder.addRawArgument(power_arg);
IanBenzMaxim 29:590a7561318b 115 return sendCommand(builder);
IanBenzMaxim 29:590a7561318b 116 }
IanBenzMaxim 29:590a7561318b 117
IanBenzMaxim 32:0a09505a656d 118 ESP8266::CmdResult ESP8266::ping(const std::string & IP) {
IanBenzMaxim 29:590a7561318b 119 CmdBuilder builder("PING");
IanBenzMaxim 29:590a7561318b 120 builder.addStringArgument(IP);
IanBenzMaxim 29:590a7561318b 121 return sendCommand(builder);
IanBenzMaxim 29:590a7561318b 122 }
IanBenzMaxim 29:590a7561318b 123
IanBenzMaxim 32:0a09505a656d 124 ESP8266::CmdResult ESP8266::openConnection(const ESP8266::ConnType type,
IanBenzMaxim 32:0a09505a656d 125 const std::string & remoteIP,
IanBenzMaxim 32:0a09505a656d 126 const unsigned int remotePort) {
IanBenzMaxim 29:590a7561318b 127 CmdBuilder builder("CIPSTART");
IanBenzMaxim 29:590a7561318b 128 builder.addStringArgument((type == TCP) ? "TCP" : "UDP");
IanBenzMaxim 29:590a7561318b 129 builder.addStringArgument(remoteIP);
IanBenzMaxim 29:590a7561318b 130 builder.addRawArgument(remotePort);
IanBenzMaxim 29:590a7561318b 131 return sendCommand(builder);
IanBenzMaxim 29:590a7561318b 132 }
IanBenzMaxim 29:590a7561318b 133
IanBenzMaxim 32:0a09505a656d 134 ESP8266::CmdResult ESP8266::closeConnection() {
IanBenzMaxim 29:590a7561318b 135 return sendCommand(CmdBuilder("CIPCLOSE"));
IanBenzMaxim 29:590a7561318b 136 }
IanBenzMaxim 29:590a7561318b 137
IanBenzMaxim 32:0a09505a656d 138 ESP8266::CmdResult ESP8266::sendData(const std::string & data) {
IanBenzMaxim 29:590a7561318b 139 CmdBuilder builder("CIPSEND");
IanBenzMaxim 29:590a7561318b 140 builder.addRawArgument(data.length());
IanBenzMaxim 29:590a7561318b 141 ESP8266::CmdResult result = sendCommand(builder);
IanBenzMaxim 29:590a7561318b 142 if (result == ESP8266::AT_OK)
IanBenzMaxim 29:590a7561318b 143 result = send_AT_data(data, false);
IanBenzMaxim 29:590a7561318b 144 return result;
IanBenzMaxim 29:590a7561318b 145 }
IanBenzMaxim 29:590a7561318b 146
IanBenzMaxim 32:0a09505a656d 147 ESP8266::CmdResult ESP8266::sendCommand(const CmdBuilder & cmd) {
IanBenzMaxim 29:590a7561318b 148 return send_AT_data(cmd.str(), true);
IanBenzMaxim 29:590a7561318b 149 }
IanBenzMaxim 29:590a7561318b 150
IanBenzMaxim 32:0a09505a656d 151 bool ESP8266::recvIpDataReadable() {
IanBenzMaxim 29:590a7561318b 152 bool result;
IanBenzMaxim 32:0a09505a656d 153
IanBenzMaxim 29:590a7561318b 154 disableRecvData(); // Lock queue access
IanBenzMaxim 32:0a09505a656d 155
IanBenzMaxim 29:590a7561318b 156 result = !recvIpDataBuffer.empty();
IanBenzMaxim 32:0a09505a656d 157
IanBenzMaxim 29:590a7561318b 158 enableRecvData(); // Unlock queue access
IanBenzMaxim 32:0a09505a656d 159
IanBenzMaxim 29:590a7561318b 160 return result;
IanBenzMaxim 29:590a7561318b 161 }
IanBenzMaxim 29:590a7561318b 162
IanBenzMaxim 32:0a09505a656d 163 char ESP8266::getcRecvIpData() {
IanBenzMaxim 29:590a7561318b 164 char received;
IanBenzMaxim 32:0a09505a656d 165
IanBenzMaxim 29:590a7561318b 166 disableRecvData(); // Lock queue access
IanBenzMaxim 32:0a09505a656d 167
IanBenzMaxim 29:590a7561318b 168 // Pop next char or set to NTC if not data in buffer
IanBenzMaxim 29:590a7561318b 169 if (!recvIpDataBuffer.pop(received))
IanBenzMaxim 29:590a7561318b 170 received = '\0';
IanBenzMaxim 32:0a09505a656d 171
IanBenzMaxim 29:590a7561318b 172 enableRecvData(); // Unlock queue access
IanBenzMaxim 32:0a09505a656d 173
IanBenzMaxim 29:590a7561318b 174 return received;
IanBenzMaxim 29:590a7561318b 175 }
IanBenzMaxim 29:590a7561318b 176
IanBenzMaxim 32:0a09505a656d 177 void ESP8266::clearRecvData() {
IanBenzMaxim 32:0a09505a656d 178 disableRecvData(); // Lock queue access
IanBenzMaxim 32:0a09505a656d 179
IanBenzMaxim 32:0a09505a656d 180 recvIpDataBuffer.reset();
IanBenzMaxim 32:0a09505a656d 181 parseRecvReset = true;
IanBenzMaxim 32:0a09505a656d 182
IanBenzMaxim 32:0a09505a656d 183 enableRecvData(); // Unlock queue access
IanBenzMaxim 29:590a7561318b 184 }
IanBenzMaxim 29:590a7561318b 185
IanBenzMaxim 32:0a09505a656d 186 ESP8266::CmdResult ESP8266::send_AT_data(const std::string & cmdString,
IanBenzMaxim 32:0a09505a656d 187 const bool expectEcho) {
IanBenzMaxim 29:590a7561318b 188 const int timeout_ms = 10000;
IanBenzMaxim 32:0a09505a656d 189
IanBenzMaxim 29:590a7561318b 190 mbed::Timer timer;
IanBenzMaxim 29:590a7561318b 191 ESP8266::CmdResult result = ESP8266::HardwareError;
IanBenzMaxim 29:590a7561318b 192 std::string response;
IanBenzMaxim 32:0a09505a656d 193
IanBenzMaxim 29:590a7561318b 194 disableRecvData(); // Lock for manual data handling in this procedure
IanBenzMaxim 32:0a09505a656d 195
IanBenzMaxim 29:590a7561318b 196 // Flush receive buffer
IanBenzMaxim 29:590a7561318b 197 while (AT_intf.readable())
IanBenzMaxim 29:590a7561318b 198 AT_intf.getc();
IanBenzMaxim 32:0a09505a656d 199
IanBenzMaxim 29:590a7561318b 200 // Begin counting for timeout
IanBenzMaxim 29:590a7561318b 201 timer.start();
IanBenzMaxim 32:0a09505a656d 202
IanBenzMaxim 32:0a09505a656d 203 for (size_t i = 0; i < cmdString.length(); i++) {
IanBenzMaxim 29:590a7561318b 204 // Write next character
IanBenzMaxim 32:0a09505a656d 205 while (!AT_intf.writeable()) {
IanBenzMaxim 32:0a09505a656d 206 if (timer.read_ms() > timeout_ms) {
IanBenzMaxim 29:590a7561318b 207 result = TimeoutError;
IanBenzMaxim 29:590a7561318b 208 goto exit;
IanBenzMaxim 29:590a7561318b 209 }
IanBenzMaxim 29:590a7561318b 210 }
IanBenzMaxim 29:590a7561318b 211 AT_intf.putc(cmdString[i]);
IanBenzMaxim 29:590a7561318b 212 // Wait for echo
IanBenzMaxim 32:0a09505a656d 213 if (expectEcho && (cmdString[i] != '\r') && (cmdString[i] != '\n')) {
IanBenzMaxim 32:0a09505a656d 214 while (!AT_intf.readable()) {
IanBenzMaxim 32:0a09505a656d 215 if (timer.read_ms() > timeout_ms) {
IanBenzMaxim 29:590a7561318b 216 result = TimeoutError;
IanBenzMaxim 29:590a7561318b 217 goto exit;
IanBenzMaxim 29:590a7561318b 218 }
IanBenzMaxim 29:590a7561318b 219 }
IanBenzMaxim 29:590a7561318b 220 // Compare to written character
IanBenzMaxim 32:0a09505a656d 221 if (AT_intf.getc() != cmdString[i]) {
IanBenzMaxim 29:590a7561318b 222 // Handle error
IanBenzMaxim 29:590a7561318b 223 result = ESP8266::HardwareError;
IanBenzMaxim 29:590a7561318b 224 goto exit;
IanBenzMaxim 29:590a7561318b 225 }
IanBenzMaxim 29:590a7561318b 226 }
IanBenzMaxim 29:590a7561318b 227 }
IanBenzMaxim 32:0a09505a656d 228
IanBenzMaxim 32:0a09505a656d 229 while (result == ESP8266::HardwareError) {
IanBenzMaxim 29:590a7561318b 230 // Wait to receive something
IanBenzMaxim 29:590a7561318b 231 response.clear();
IanBenzMaxim 32:0a09505a656d 232 while (!read_line(response))
IanBenzMaxim 32:0a09505a656d 233 ;
IanBenzMaxim 32:0a09505a656d 234
IanBenzMaxim 29:590a7561318b 235 // Check if valid response
IanBenzMaxim 29:590a7561318b 236 if (response == "OK")
IanBenzMaxim 29:590a7561318b 237 result = ESP8266::AT_OK;
IanBenzMaxim 29:590a7561318b 238 else if (response == "FAIL")
IanBenzMaxim 29:590a7561318b 239 result = ESP8266::AT_FAIL;
IanBenzMaxim 29:590a7561318b 240 else if (response == "ERROR")
IanBenzMaxim 29:590a7561318b 241 result = ESP8266::AT_ERROR;
IanBenzMaxim 29:590a7561318b 242 else if (response == "SEND OK") // Used by AT+CIPSEND
IanBenzMaxim 29:590a7561318b 243 result = ESP8266::AT_OK;
IanBenzMaxim 29:590a7561318b 244 else if (response == "ALREADY CONNECT") // Used by AT+CIPSTART
IanBenzMaxim 29:590a7561318b 245 result = ESP8266::AT_OK;
IanBenzMaxim 32:0a09505a656d 246
IanBenzMaxim 32:0a09505a656d 247 if (timer.read_ms() > timeout_ms) {
IanBenzMaxim 29:590a7561318b 248 result = TimeoutError;
IanBenzMaxim 29:590a7561318b 249 break;
IanBenzMaxim 29:590a7561318b 250 }
IanBenzMaxim 29:590a7561318b 251 }
IanBenzMaxim 32:0a09505a656d 252
IanBenzMaxim 29:590a7561318b 253 exit:
IanBenzMaxim 29:590a7561318b 254 enableRecvData(); // Enable interrupt processing
IanBenzMaxim 29:590a7561318b 255 return result;
IanBenzMaxim 29:590a7561318b 256 }
IanBenzMaxim 29:590a7561318b 257
IanBenzMaxim 32:0a09505a656d 258 bool ESP8266::read_line(std::string & line) {
IanBenzMaxim 29:590a7561318b 259 char received;
IanBenzMaxim 32:0a09505a656d 260
IanBenzMaxim 32:0a09505a656d 261 while (AT_intf.readable()) {
IanBenzMaxim 29:590a7561318b 262 received = AT_intf.getc();
IanBenzMaxim 32:0a09505a656d 263 if (received == '\n') {
IanBenzMaxim 29:590a7561318b 264 return true;
IanBenzMaxim 32:0a09505a656d 265 } else if (received != '\r') {
IanBenzMaxim 29:590a7561318b 266 line.push_back(received);
IanBenzMaxim 29:590a7561318b 267 }
IanBenzMaxim 29:590a7561318b 268 }
IanBenzMaxim 29:590a7561318b 269 return false;
IanBenzMaxim 29:590a7561318b 270 }
IanBenzMaxim 29:590a7561318b 271
IanBenzMaxim 32:0a09505a656d 272 void ESP8266::recv_AT_data_cb() {
IanBenzMaxim 32:0a09505a656d 273 while (AT_intf.readable()) {
IanBenzMaxim 29:590a7561318b 274 char received = AT_intf.getc();
IanBenzMaxim 29:590a7561318b 275 parseRecvIpData(received);
IanBenzMaxim 29:590a7561318b 276 parseRecvConnClosedMsg(received);
IanBenzMaxim 29:590a7561318b 277 parseRecvReset = false;
IanBenzMaxim 29:590a7561318b 278 }
IanBenzMaxim 29:590a7561318b 279 }
IanBenzMaxim 29:590a7561318b 280
IanBenzMaxim 32:0a09505a656d 281 void ESP8266::parseRecvIpData(const char received) {
IanBenzMaxim 32:0a09505a656d 282 enum DataRecvState { Header, Length, Data, Reset };
IanBenzMaxim 32:0a09505a656d 283
IanBenzMaxim 29:590a7561318b 284 static const char findChars[] = "+IPD,";
IanBenzMaxim 29:590a7561318b 285 static const size_t maxSizeDigits = 4;
IanBenzMaxim 32:0a09505a656d 286
IanBenzMaxim 29:590a7561318b 287 static size_t dataFinishedSize = 0;
IanBenzMaxim 29:590a7561318b 288 static size_t index = 0;
IanBenzMaxim 32:0a09505a656d 289 static char sizeDigits[] = {'\0', '\0', '\0', '\0', '\0'};
IanBenzMaxim 29:590a7561318b 290 static DataRecvState state = Header;
IanBenzMaxim 32:0a09505a656d 291
IanBenzMaxim 29:590a7561318b 292 if (parseRecvReset)
IanBenzMaxim 29:590a7561318b 293 state = Reset;
IanBenzMaxim 32:0a09505a656d 294
IanBenzMaxim 32:0a09505a656d 295 switch (state) {
IanBenzMaxim 29:590a7561318b 296 case Reset:
IanBenzMaxim 29:590a7561318b 297 default:
IanBenzMaxim 29:590a7561318b 298 index = 0;
IanBenzMaxim 29:590a7561318b 299 dataFinishedSize = 0;
IanBenzMaxim 29:590a7561318b 300 state = Header;
IanBenzMaxim 29:590a7561318b 301 // Continue processing switch
IanBenzMaxim 32:0a09505a656d 302
IanBenzMaxim 29:590a7561318b 303 case Header:
IanBenzMaxim 32:0a09505a656d 304 if (received == findChars[index]) {
IanBenzMaxim 32:0a09505a656d 305 if (findChars[++index] == '\0') {
IanBenzMaxim 29:590a7561318b 306 index = 0;
IanBenzMaxim 29:590a7561318b 307 state = Length;
IanBenzMaxim 29:590a7561318b 308 }
IanBenzMaxim 32:0a09505a656d 309 } else {
IanBenzMaxim 29:590a7561318b 310 state = Reset;
IanBenzMaxim 29:590a7561318b 311 }
IanBenzMaxim 29:590a7561318b 312 break;
IanBenzMaxim 32:0a09505a656d 313
IanBenzMaxim 32:0a09505a656d 314 case Length:
IanBenzMaxim 32:0a09505a656d 315 if ((received <= '9') && (received >= '0')) {
IanBenzMaxim 32:0a09505a656d 316 if (index < maxSizeDigits) {
IanBenzMaxim 29:590a7561318b 317 sizeDigits[index++] = received;
IanBenzMaxim 32:0a09505a656d 318 } else {
IanBenzMaxim 29:590a7561318b 319 state = Reset;
IanBenzMaxim 29:590a7561318b 320 }
IanBenzMaxim 32:0a09505a656d 321 } else if (received == ':') {
IanBenzMaxim 29:590a7561318b 322 dataFinishedSize = std::atoi(sizeDigits);
IanBenzMaxim 32:0a09505a656d 323 if (dataFinishedSize == 0) {
IanBenzMaxim 29:590a7561318b 324 state = Reset;
IanBenzMaxim 32:0a09505a656d 325 } else {
IanBenzMaxim 29:590a7561318b 326 index = 0;
IanBenzMaxim 29:590a7561318b 327 state = Data;
IanBenzMaxim 29:590a7561318b 328 }
IanBenzMaxim 32:0a09505a656d 329 } else {
IanBenzMaxim 29:590a7561318b 330 state = Reset;
IanBenzMaxim 29:590a7561318b 331 }
IanBenzMaxim 29:590a7561318b 332 break;
IanBenzMaxim 32:0a09505a656d 333
IanBenzMaxim 29:590a7561318b 334 case Data:
IanBenzMaxim 32:0a09505a656d 335 if (index < dataFinishedSize) {
IanBenzMaxim 29:590a7561318b 336 recvIpDataBuffer.push(received);
IanBenzMaxim 29:590a7561318b 337 index++;
IanBenzMaxim 32:0a09505a656d 338 } else {
IanBenzMaxim 29:590a7561318b 339 state = Reset;
IanBenzMaxim 29:590a7561318b 340 }
IanBenzMaxim 29:590a7561318b 341 break;
IanBenzMaxim 29:590a7561318b 342 };
IanBenzMaxim 29:590a7561318b 343 }
IanBenzMaxim 29:590a7561318b 344
IanBenzMaxim 32:0a09505a656d 345 void ESP8266::parseRecvConnClosedMsg(const char received) {
IanBenzMaxim 29:590a7561318b 346 static const char findChars[] = "CLOSED";
IanBenzMaxim 32:0a09505a656d 347
IanBenzMaxim 29:590a7561318b 348 static int index = 0;
IanBenzMaxim 32:0a09505a656d 349
IanBenzMaxim 29:590a7561318b 350 bool shouldReset = parseRecvReset;
IanBenzMaxim 32:0a09505a656d 351
IanBenzMaxim 32:0a09505a656d 352 if (received == findChars[index]) {
IanBenzMaxim 32:0a09505a656d 353 if (findChars[++index] == '\0') {
IanBenzMaxim 29:590a7561318b 354 printDbgMsg(findChars);
IanBenzMaxim 29:590a7561318b 355 shouldReset = true;
IanBenzMaxim 29:590a7561318b 356 }
IanBenzMaxim 32:0a09505a656d 357 } else {
IanBenzMaxim 29:590a7561318b 358 shouldReset = true;
IanBenzMaxim 29:590a7561318b 359 }
IanBenzMaxim 32:0a09505a656d 360
IanBenzMaxim 32:0a09505a656d 361 if (shouldReset) {
IanBenzMaxim 29:590a7561318b 362 index = 0;
IanBenzMaxim 29:590a7561318b 363 }
IanBenzMaxim 29:590a7561318b 364 }
IanBenzMaxim 29:590a7561318b 365
IanBenzMaxim 32:0a09505a656d 366 void ESP8266::printDbgMsg(const char * message) {
IanBenzMaxim 29:590a7561318b 367 if (debugMsg != NULL)
IanBenzMaxim 29:590a7561318b 368 debugMsg->printf("%s", message);
IanBenzMaxim 29:590a7561318b 369 }
IanBenzMaxim 29:590a7561318b 370
IanBenzMaxim 32:0a09505a656d 371 ESP8266::CmdBuilder::CmdBuilder(const std::string & cmd) { clear(cmd); }
IanBenzMaxim 29:590a7561318b 372
IanBenzMaxim 32:0a09505a656d 373 void ESP8266::CmdBuilder::clear(const std::string & cmd) {
IanBenzMaxim 29:590a7561318b 374 numArgs = 0;
IanBenzMaxim 29:590a7561318b 375 cmdStream.str("");
IanBenzMaxim 32:0a09505a656d 376
IanBenzMaxim 29:590a7561318b 377 cmdStream << "AT";
IanBenzMaxim 29:590a7561318b 378 if (cmd != "")
IanBenzMaxim 29:590a7561318b 379 cmdStream << "+" << cmd;
IanBenzMaxim 29:590a7561318b 380 }
IanBenzMaxim 29:590a7561318b 381
IanBenzMaxim 32:0a09505a656d 382 void ESP8266::CmdBuilder::addStringArgument(const std::string & arg) {
IanBenzMaxim 29:590a7561318b 383 std::ostringstream argStream;
IanBenzMaxim 29:590a7561318b 384 argStream << "\"" << arg << "\"";
IanBenzMaxim 29:590a7561318b 385 addRawArgument<std::string>(argStream.str());
IanBenzMaxim 29:590a7561318b 386 }
IanBenzMaxim 29:590a7561318b 387
IanBenzMaxim 32:0a09505a656d 388 std::string ESP8266::CmdBuilder::str() const {
IanBenzMaxim 29:590a7561318b 389 std::string cmdString = cmdStream.str();
IanBenzMaxim 29:590a7561318b 390 cmdString.append("\r\n");
IanBenzMaxim 29:590a7561318b 391 return cmdString;
IanBenzMaxim 29:590a7561318b 392 }