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?
User | Revision | Line number | New 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 | } |