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