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.

Committer:
IanBenzMaxim
Date:
Thu Apr 14 19:48:01 2016 +0000
Revision:
1:e1c7c1c636af
Child:
6:b6bafd0a7013
Add initial source files.

Who changed what in which revision?

UserRevisionLine numberNew 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 1:e1c7c1c636af 34 #include "ESP8266.hpp"
IanBenzMaxim 1:e1c7c1c636af 35
IanBenzMaxim 1:e1c7c1c636af 36 ESP8266* ESP8266::defaultInstance = NULL;
IanBenzMaxim 1:e1c7c1c636af 37
IanBenzMaxim 1:e1c7c1c636af 38 static inline void disableRecvData()
IanBenzMaxim 1:e1c7c1c636af 39 {
IanBenzMaxim 1:e1c7c1c636af 40 __disable_irq();
IanBenzMaxim 1:e1c7c1c636af 41 }
IanBenzMaxim 1:e1c7c1c636af 42
IanBenzMaxim 1:e1c7c1c636af 43 static inline void enableRecvData()
IanBenzMaxim 1:e1c7c1c636af 44 {
IanBenzMaxim 1:e1c7c1c636af 45 __enable_irq();
IanBenzMaxim 1:e1c7c1c636af 46 }
IanBenzMaxim 1:e1c7c1c636af 47
IanBenzMaxim 1:e1c7c1c636af 48 void ESP8266::setDefaultInstance(ESP8266 * const instance)
IanBenzMaxim 1:e1c7c1c636af 49 {
IanBenzMaxim 1:e1c7c1c636af 50 if (instance != NULL)
IanBenzMaxim 1:e1c7c1c636af 51 defaultInstance = instance;
IanBenzMaxim 1:e1c7c1c636af 52 }
IanBenzMaxim 1:e1c7c1c636af 53
IanBenzMaxim 1:e1c7c1c636af 54 ESP8266** ESP8266::getDefaultInstance()
IanBenzMaxim 1:e1c7c1c636af 55 {
IanBenzMaxim 1:e1c7c1c636af 56 return &defaultInstance;
IanBenzMaxim 1:e1c7c1c636af 57 }
IanBenzMaxim 1:e1c7c1c636af 58
IanBenzMaxim 1:e1c7c1c636af 59 ESP8266::ESP8266(const PinName tx, const PinName rx, const PinName rst, const PinName CH_PD, const int baud, Serial * debugMsgIntf)
IanBenzMaxim 1:e1c7c1c636af 60 : AT_intf(tx, rx), resetPin(rst), powerDownPin(CH_PD), debugMsg(debugMsgIntf), parseRecvReset(false)
IanBenzMaxim 1:e1c7c1c636af 61 {
IanBenzMaxim 1:e1c7c1c636af 62 AT_intf.baud(baud);
IanBenzMaxim 1:e1c7c1c636af 63 AT_intf.attach(this, &ESP8266::recv_AT_data_cb);
IanBenzMaxim 1:e1c7c1c636af 64
IanBenzMaxim 1:e1c7c1c636af 65 // Ensure that device is not held in reset
IanBenzMaxim 1:e1c7c1c636af 66 if (resetPin.is_connected())
IanBenzMaxim 1:e1c7c1c636af 67 resetPin = 1;
IanBenzMaxim 1:e1c7c1c636af 68 // Power down device at startup due to high current demand
IanBenzMaxim 1:e1c7c1c636af 69 setPowered(false);
IanBenzMaxim 1:e1c7c1c636af 70
IanBenzMaxim 1:e1c7c1c636af 71 if (defaultInstance == NULL)
IanBenzMaxim 1:e1c7c1c636af 72 defaultInstance = this;
IanBenzMaxim 1:e1c7c1c636af 73 }
IanBenzMaxim 1:e1c7c1c636af 74
IanBenzMaxim 1:e1c7c1c636af 75 ESP8266::~ESP8266()
IanBenzMaxim 1:e1c7c1c636af 76 {
IanBenzMaxim 1:e1c7c1c636af 77 if (defaultInstance == this)
IanBenzMaxim 1:e1c7c1c636af 78 defaultInstance = NULL;
IanBenzMaxim 1:e1c7c1c636af 79 }
IanBenzMaxim 1:e1c7c1c636af 80
IanBenzMaxim 1:e1c7c1c636af 81 void ESP8266::reset()
IanBenzMaxim 1:e1c7c1c636af 82 {
IanBenzMaxim 1:e1c7c1c636af 83 if (resetPin.is_connected())
IanBenzMaxim 1:e1c7c1c636af 84 {
IanBenzMaxim 1:e1c7c1c636af 85 resetPin = 0;
IanBenzMaxim 1:e1c7c1c636af 86 wait_ms(10);
IanBenzMaxim 1:e1c7c1c636af 87 resetPin = 1;
IanBenzMaxim 1:e1c7c1c636af 88 wait_ms(1000);
IanBenzMaxim 1:e1c7c1c636af 89 }
IanBenzMaxim 1:e1c7c1c636af 90 }
IanBenzMaxim 1:e1c7c1c636af 91
IanBenzMaxim 1:e1c7c1c636af 92 bool ESP8266::powered() const
IanBenzMaxim 1:e1c7c1c636af 93 {
IanBenzMaxim 1:e1c7c1c636af 94 bool isPowered;
IanBenzMaxim 1:e1c7c1c636af 95 if (powerDownPin.is_connected())
IanBenzMaxim 1:e1c7c1c636af 96 {
IanBenzMaxim 1:e1c7c1c636af 97 isPowered = powerDownPin.read();
IanBenzMaxim 1:e1c7c1c636af 98 }
IanBenzMaxim 1:e1c7c1c636af 99 else
IanBenzMaxim 1:e1c7c1c636af 100 {
IanBenzMaxim 1:e1c7c1c636af 101 isPowered = false;
IanBenzMaxim 1:e1c7c1c636af 102 }
IanBenzMaxim 1:e1c7c1c636af 103 return isPowered;
IanBenzMaxim 1:e1c7c1c636af 104 }
IanBenzMaxim 1:e1c7c1c636af 105
IanBenzMaxim 1:e1c7c1c636af 106 void ESP8266::setPowered(bool powered)
IanBenzMaxim 1:e1c7c1c636af 107 {
IanBenzMaxim 1:e1c7c1c636af 108 if (powerDownPin.is_connected())
IanBenzMaxim 1:e1c7c1c636af 109 powerDownPin = powered;
IanBenzMaxim 1:e1c7c1c636af 110 }
IanBenzMaxim 1:e1c7c1c636af 111
IanBenzMaxim 1:e1c7c1c636af 112 ESP8266::CmdResult ESP8266::performSelfTest()
IanBenzMaxim 1:e1c7c1c636af 113 {
IanBenzMaxim 1:e1c7c1c636af 114 return sendCommand(CmdBuilder(""));
IanBenzMaxim 1:e1c7c1c636af 115 }
IanBenzMaxim 1:e1c7c1c636af 116
IanBenzMaxim 1:e1c7c1c636af 117 ESP8266::CmdResult ESP8266::setCurrentWifiMode(const ESP8266::WifiMode mode)
IanBenzMaxim 1:e1c7c1c636af 118 {
IanBenzMaxim 1:e1c7c1c636af 119 CmdBuilder builder("CWMODE_CUR");
IanBenzMaxim 1:e1c7c1c636af 120 builder.addRawArgument(mode);
IanBenzMaxim 1:e1c7c1c636af 121 return sendCommand(builder);
IanBenzMaxim 1:e1c7c1c636af 122 }
IanBenzMaxim 1:e1c7c1c636af 123
IanBenzMaxim 1:e1c7c1c636af 124 ESP8266::CmdResult ESP8266::joinCurrentAccessPoint(const std::string & ssid, const std::string & pwd, const std::string & bssid)
IanBenzMaxim 1:e1c7c1c636af 125 {
IanBenzMaxim 1:e1c7c1c636af 126 CmdBuilder builder("CWJAP_CUR");
IanBenzMaxim 1:e1c7c1c636af 127 builder.addStringArgument(ssid);
IanBenzMaxim 1:e1c7c1c636af 128 builder.addStringArgument(pwd);
IanBenzMaxim 1:e1c7c1c636af 129 if (bssid != "")
IanBenzMaxim 1:e1c7c1c636af 130 builder.addStringArgument(bssid);
IanBenzMaxim 1:e1c7c1c636af 131 return sendCommand(builder);
IanBenzMaxim 1:e1c7c1c636af 132 }
IanBenzMaxim 1:e1c7c1c636af 133
IanBenzMaxim 1:e1c7c1c636af 134 ESP8266::CmdResult ESP8266::quitAccessPoint()
IanBenzMaxim 1:e1c7c1c636af 135 {
IanBenzMaxim 1:e1c7c1c636af 136 return sendCommand(CmdBuilder("CWQAP"));
IanBenzMaxim 1:e1c7c1c636af 137 }
IanBenzMaxim 1:e1c7c1c636af 138
IanBenzMaxim 1:e1c7c1c636af 139 ESP8266::CmdResult ESP8266::setMaxRFTXPower(const float power_dBm)
IanBenzMaxim 1:e1c7c1c636af 140 {
IanBenzMaxim 1:e1c7c1c636af 141 int power_arg = (int)(power_dBm * 4);
IanBenzMaxim 1:e1c7c1c636af 142 if (power_arg > 82)
IanBenzMaxim 1:e1c7c1c636af 143 power_arg = 82;
IanBenzMaxim 1:e1c7c1c636af 144 else if (power_arg < 0)
IanBenzMaxim 1:e1c7c1c636af 145 power_arg = 0;
IanBenzMaxim 1:e1c7c1c636af 146
IanBenzMaxim 1:e1c7c1c636af 147 CmdBuilder builder("RFPOWER");
IanBenzMaxim 1:e1c7c1c636af 148 builder.addRawArgument(power_arg);
IanBenzMaxim 1:e1c7c1c636af 149 return sendCommand(builder);
IanBenzMaxim 1:e1c7c1c636af 150 }
IanBenzMaxim 1:e1c7c1c636af 151
IanBenzMaxim 1:e1c7c1c636af 152 ESP8266::CmdResult ESP8266::ping(const std::string & IP)
IanBenzMaxim 1:e1c7c1c636af 153 {
IanBenzMaxim 1:e1c7c1c636af 154 CmdBuilder builder("PING");
IanBenzMaxim 1:e1c7c1c636af 155 builder.addStringArgument(IP);
IanBenzMaxim 1:e1c7c1c636af 156 return sendCommand(builder);
IanBenzMaxim 1:e1c7c1c636af 157 }
IanBenzMaxim 1:e1c7c1c636af 158
IanBenzMaxim 1:e1c7c1c636af 159 ESP8266::CmdResult ESP8266::openConnection(const ESP8266::ConnType type, const std::string & remoteIP, const unsigned int remotePort)
IanBenzMaxim 1:e1c7c1c636af 160 {
IanBenzMaxim 1:e1c7c1c636af 161 CmdBuilder builder("CIPSTART");
IanBenzMaxim 1:e1c7c1c636af 162 builder.addStringArgument((type == TCP) ? "TCP" : "UDP");
IanBenzMaxim 1:e1c7c1c636af 163 builder.addStringArgument(remoteIP);
IanBenzMaxim 1:e1c7c1c636af 164 builder.addRawArgument(remotePort);
IanBenzMaxim 1:e1c7c1c636af 165 return sendCommand(builder);
IanBenzMaxim 1:e1c7c1c636af 166 }
IanBenzMaxim 1:e1c7c1c636af 167
IanBenzMaxim 1:e1c7c1c636af 168 ESP8266::CmdResult ESP8266::closeConnection()
IanBenzMaxim 1:e1c7c1c636af 169 {
IanBenzMaxim 1:e1c7c1c636af 170 return sendCommand(CmdBuilder("CIPCLOSE"));
IanBenzMaxim 1:e1c7c1c636af 171 }
IanBenzMaxim 1:e1c7c1c636af 172
IanBenzMaxim 1:e1c7c1c636af 173 ESP8266::CmdResult ESP8266::sendData(const std::string & data)
IanBenzMaxim 1:e1c7c1c636af 174 {
IanBenzMaxim 1:e1c7c1c636af 175 CmdBuilder builder("CIPSEND");
IanBenzMaxim 1:e1c7c1c636af 176 builder.addRawArgument(data.length());
IanBenzMaxim 1:e1c7c1c636af 177 ESP8266::CmdResult result = sendCommand(builder);
IanBenzMaxim 1:e1c7c1c636af 178 if (result == ESP8266::AT_OK)
IanBenzMaxim 1:e1c7c1c636af 179 result = send_AT_data(data, false);
IanBenzMaxim 1:e1c7c1c636af 180 return result;
IanBenzMaxim 1:e1c7c1c636af 181 }
IanBenzMaxim 1:e1c7c1c636af 182
IanBenzMaxim 1:e1c7c1c636af 183 ESP8266::CmdResult ESP8266::sendCommand(const CmdBuilder & cmd)
IanBenzMaxim 1:e1c7c1c636af 184 {
IanBenzMaxim 1:e1c7c1c636af 185 return send_AT_data(cmd.str(), true);
IanBenzMaxim 1:e1c7c1c636af 186 }
IanBenzMaxim 1:e1c7c1c636af 187
IanBenzMaxim 1:e1c7c1c636af 188 bool ESP8266::recvIpDataReadable()
IanBenzMaxim 1:e1c7c1c636af 189 {
IanBenzMaxim 1:e1c7c1c636af 190 bool result;
IanBenzMaxim 1:e1c7c1c636af 191
IanBenzMaxim 1:e1c7c1c636af 192 disableRecvData(); // Lock queue access
IanBenzMaxim 1:e1c7c1c636af 193
IanBenzMaxim 1:e1c7c1c636af 194 result = !recvIpDataBuffer.empty();
IanBenzMaxim 1:e1c7c1c636af 195
IanBenzMaxim 1:e1c7c1c636af 196 enableRecvData(); // Unlock queue access
IanBenzMaxim 1:e1c7c1c636af 197
IanBenzMaxim 1:e1c7c1c636af 198 return result;
IanBenzMaxim 1:e1c7c1c636af 199 }
IanBenzMaxim 1:e1c7c1c636af 200
IanBenzMaxim 1:e1c7c1c636af 201 char ESP8266::getcRecvIpData()
IanBenzMaxim 1:e1c7c1c636af 202 {
IanBenzMaxim 1:e1c7c1c636af 203 char received;
IanBenzMaxim 1:e1c7c1c636af 204
IanBenzMaxim 1:e1c7c1c636af 205 disableRecvData(); // Lock queue access
IanBenzMaxim 1:e1c7c1c636af 206
IanBenzMaxim 1:e1c7c1c636af 207 // Pop next char or set to NTC if not data in buffer
IanBenzMaxim 1:e1c7c1c636af 208 if (!recvIpDataBuffer.pop(received))
IanBenzMaxim 1:e1c7c1c636af 209 received = '\0';
IanBenzMaxim 1:e1c7c1c636af 210
IanBenzMaxim 1:e1c7c1c636af 211 enableRecvData(); // Unlock queue access
IanBenzMaxim 1:e1c7c1c636af 212
IanBenzMaxim 1:e1c7c1c636af 213 return received;
IanBenzMaxim 1:e1c7c1c636af 214 }
IanBenzMaxim 1:e1c7c1c636af 215
IanBenzMaxim 1:e1c7c1c636af 216 void ESP8266::clearRecvData()
IanBenzMaxim 1:e1c7c1c636af 217 {
IanBenzMaxim 1:e1c7c1c636af 218 disableRecvData(); // Lock queue access
IanBenzMaxim 1:e1c7c1c636af 219
IanBenzMaxim 1:e1c7c1c636af 220 recvIpDataBuffer.reset();
IanBenzMaxim 1:e1c7c1c636af 221 parseRecvReset = true;
IanBenzMaxim 1:e1c7c1c636af 222
IanBenzMaxim 1:e1c7c1c636af 223 enableRecvData(); // Unlock queue access
IanBenzMaxim 1:e1c7c1c636af 224 }
IanBenzMaxim 1:e1c7c1c636af 225
IanBenzMaxim 1:e1c7c1c636af 226 ESP8266::CmdResult ESP8266::send_AT_data(const std::string & cmdString, const bool expectEcho)
IanBenzMaxim 1:e1c7c1c636af 227 {
IanBenzMaxim 1:e1c7c1c636af 228 const int timeout_ms = 10000;
IanBenzMaxim 1:e1c7c1c636af 229
IanBenzMaxim 1:e1c7c1c636af 230 Timer timer;
IanBenzMaxim 1:e1c7c1c636af 231 ESP8266::CmdResult result = ESP8266::HardwareError;
IanBenzMaxim 1:e1c7c1c636af 232 std::string response;
IanBenzMaxim 1:e1c7c1c636af 233
IanBenzMaxim 1:e1c7c1c636af 234 disableRecvData(); // Lock for manual data handling in this procedure
IanBenzMaxim 1:e1c7c1c636af 235
IanBenzMaxim 1:e1c7c1c636af 236 // Flush receive buffer
IanBenzMaxim 1:e1c7c1c636af 237 while (AT_intf.readable())
IanBenzMaxim 1:e1c7c1c636af 238 AT_intf.getc();
IanBenzMaxim 1:e1c7c1c636af 239
IanBenzMaxim 1:e1c7c1c636af 240 // Begin counting for timeout
IanBenzMaxim 1:e1c7c1c636af 241 timer.start();
IanBenzMaxim 1:e1c7c1c636af 242
IanBenzMaxim 1:e1c7c1c636af 243 for (size_t i = 0; i < cmdString.length(); i++)
IanBenzMaxim 1:e1c7c1c636af 244 {
IanBenzMaxim 1:e1c7c1c636af 245 // Write next character
IanBenzMaxim 1:e1c7c1c636af 246 while (!AT_intf.writeable())
IanBenzMaxim 1:e1c7c1c636af 247 {
IanBenzMaxim 1:e1c7c1c636af 248 if (timer.read_ms() > timeout_ms)
IanBenzMaxim 1:e1c7c1c636af 249 {
IanBenzMaxim 1:e1c7c1c636af 250 result = TimeoutError;
IanBenzMaxim 1:e1c7c1c636af 251 goto exit;
IanBenzMaxim 1:e1c7c1c636af 252 }
IanBenzMaxim 1:e1c7c1c636af 253 }
IanBenzMaxim 1:e1c7c1c636af 254 AT_intf.putc(cmdString[i]);
IanBenzMaxim 1:e1c7c1c636af 255 // Wait for echo
IanBenzMaxim 1:e1c7c1c636af 256 if (expectEcho && (cmdString[i] != '\r') && (cmdString[i] != '\n'))
IanBenzMaxim 1:e1c7c1c636af 257 {
IanBenzMaxim 1:e1c7c1c636af 258 while (!AT_intf.readable())
IanBenzMaxim 1:e1c7c1c636af 259 {
IanBenzMaxim 1:e1c7c1c636af 260 if (timer.read_ms() > timeout_ms)
IanBenzMaxim 1:e1c7c1c636af 261 {
IanBenzMaxim 1:e1c7c1c636af 262 result = TimeoutError;
IanBenzMaxim 1:e1c7c1c636af 263 goto exit;
IanBenzMaxim 1:e1c7c1c636af 264 }
IanBenzMaxim 1:e1c7c1c636af 265 }
IanBenzMaxim 1:e1c7c1c636af 266 // Compare to written character
IanBenzMaxim 1:e1c7c1c636af 267 if (AT_intf.getc() != cmdString[i])
IanBenzMaxim 1:e1c7c1c636af 268 {
IanBenzMaxim 1:e1c7c1c636af 269 // Handle error
IanBenzMaxim 1:e1c7c1c636af 270 result = ESP8266::HardwareError;
IanBenzMaxim 1:e1c7c1c636af 271 goto exit;
IanBenzMaxim 1:e1c7c1c636af 272 }
IanBenzMaxim 1:e1c7c1c636af 273 }
IanBenzMaxim 1:e1c7c1c636af 274 }
IanBenzMaxim 1:e1c7c1c636af 275
IanBenzMaxim 1:e1c7c1c636af 276 while (result == ESP8266::HardwareError)
IanBenzMaxim 1:e1c7c1c636af 277 {
IanBenzMaxim 1:e1c7c1c636af 278 // Wait to receive something
IanBenzMaxim 1:e1c7c1c636af 279 response.clear();
IanBenzMaxim 1:e1c7c1c636af 280 while (!read_line(response)) ;
IanBenzMaxim 1:e1c7c1c636af 281
IanBenzMaxim 1:e1c7c1c636af 282 // Check if valid response
IanBenzMaxim 1:e1c7c1c636af 283 if (response == "OK")
IanBenzMaxim 1:e1c7c1c636af 284 result = ESP8266::AT_OK;
IanBenzMaxim 1:e1c7c1c636af 285 else if (response == "FAIL")
IanBenzMaxim 1:e1c7c1c636af 286 result = ESP8266::AT_FAIL;
IanBenzMaxim 1:e1c7c1c636af 287 else if (response == "ERROR")
IanBenzMaxim 1:e1c7c1c636af 288 result = ESP8266::AT_ERROR;
IanBenzMaxim 1:e1c7c1c636af 289 else if (response == "SEND OK") // Used by AT+CIPSEND
IanBenzMaxim 1:e1c7c1c636af 290 result = ESP8266::AT_OK;
IanBenzMaxim 1:e1c7c1c636af 291 else if (response == "ALREADY CONNECT") // Used by AT+CIPSTART
IanBenzMaxim 1:e1c7c1c636af 292 result = ESP8266::AT_OK;
IanBenzMaxim 1:e1c7c1c636af 293
IanBenzMaxim 1:e1c7c1c636af 294 if (timer.read_ms() > timeout_ms)
IanBenzMaxim 1:e1c7c1c636af 295 {
IanBenzMaxim 1:e1c7c1c636af 296 result = TimeoutError;
IanBenzMaxim 1:e1c7c1c636af 297 break;
IanBenzMaxim 1:e1c7c1c636af 298 }
IanBenzMaxim 1:e1c7c1c636af 299 }
IanBenzMaxim 1:e1c7c1c636af 300
IanBenzMaxim 1:e1c7c1c636af 301 exit:
IanBenzMaxim 1:e1c7c1c636af 302 enableRecvData(); // Enable interrupt processing
IanBenzMaxim 1:e1c7c1c636af 303 return result;
IanBenzMaxim 1:e1c7c1c636af 304 }
IanBenzMaxim 1:e1c7c1c636af 305
IanBenzMaxim 1:e1c7c1c636af 306 bool ESP8266::read_line(std::string & line)
IanBenzMaxim 1:e1c7c1c636af 307 {
IanBenzMaxim 1:e1c7c1c636af 308 char received;
IanBenzMaxim 1:e1c7c1c636af 309
IanBenzMaxim 1:e1c7c1c636af 310 while (AT_intf.readable())
IanBenzMaxim 1:e1c7c1c636af 311 {
IanBenzMaxim 1:e1c7c1c636af 312 received = AT_intf.getc();
IanBenzMaxim 1:e1c7c1c636af 313 if (received == '\n')
IanBenzMaxim 1:e1c7c1c636af 314 {
IanBenzMaxim 1:e1c7c1c636af 315 return true;
IanBenzMaxim 1:e1c7c1c636af 316 }
IanBenzMaxim 1:e1c7c1c636af 317 else if (received != '\r')
IanBenzMaxim 1:e1c7c1c636af 318 {
IanBenzMaxim 1:e1c7c1c636af 319 line.push_back(received);
IanBenzMaxim 1:e1c7c1c636af 320 }
IanBenzMaxim 1:e1c7c1c636af 321 }
IanBenzMaxim 1:e1c7c1c636af 322 return false;
IanBenzMaxim 1:e1c7c1c636af 323 }
IanBenzMaxim 1:e1c7c1c636af 324
IanBenzMaxim 1:e1c7c1c636af 325 void ESP8266::recv_AT_data_cb()
IanBenzMaxim 1:e1c7c1c636af 326 {
IanBenzMaxim 1:e1c7c1c636af 327 while (AT_intf.readable())
IanBenzMaxim 1:e1c7c1c636af 328 {
IanBenzMaxim 1:e1c7c1c636af 329 char received = AT_intf.getc();
IanBenzMaxim 1:e1c7c1c636af 330 parseRecvIpData(received);
IanBenzMaxim 1:e1c7c1c636af 331 parseRecvConnClosedMsg(received);
IanBenzMaxim 1:e1c7c1c636af 332 parseRecvReset = false;
IanBenzMaxim 1:e1c7c1c636af 333 }
IanBenzMaxim 1:e1c7c1c636af 334 }
IanBenzMaxim 1:e1c7c1c636af 335
IanBenzMaxim 1:e1c7c1c636af 336 void ESP8266::parseRecvIpData(const char received)
IanBenzMaxim 1:e1c7c1c636af 337 {
IanBenzMaxim 1:e1c7c1c636af 338 enum DataRecvState
IanBenzMaxim 1:e1c7c1c636af 339 {
IanBenzMaxim 1:e1c7c1c636af 340 Header,
IanBenzMaxim 1:e1c7c1c636af 341 Length,
IanBenzMaxim 1:e1c7c1c636af 342 Data,
IanBenzMaxim 1:e1c7c1c636af 343 Reset
IanBenzMaxim 1:e1c7c1c636af 344 };
IanBenzMaxim 1:e1c7c1c636af 345
IanBenzMaxim 1:e1c7c1c636af 346 static const char findChars[] = "+IPD,";
IanBenzMaxim 1:e1c7c1c636af 347 static const size_t maxSizeDigits = 4;
IanBenzMaxim 1:e1c7c1c636af 348
IanBenzMaxim 1:e1c7c1c636af 349 static size_t dataFinishedSize = 0;
IanBenzMaxim 1:e1c7c1c636af 350 static int index = 0;
IanBenzMaxim 1:e1c7c1c636af 351 static char sizeDigits[] = { '\0', '\0', '\0', '\0', '\0' };
IanBenzMaxim 1:e1c7c1c636af 352 static DataRecvState state = Header;
IanBenzMaxim 1:e1c7c1c636af 353
IanBenzMaxim 1:e1c7c1c636af 354 if (parseRecvReset)
IanBenzMaxim 1:e1c7c1c636af 355 state = Reset;
IanBenzMaxim 1:e1c7c1c636af 356
IanBenzMaxim 1:e1c7c1c636af 357 switch (state)
IanBenzMaxim 1:e1c7c1c636af 358 {
IanBenzMaxim 1:e1c7c1c636af 359 case Reset:
IanBenzMaxim 1:e1c7c1c636af 360 default:
IanBenzMaxim 1:e1c7c1c636af 361 index = 0;
IanBenzMaxim 1:e1c7c1c636af 362 dataFinishedSize = 0;
IanBenzMaxim 1:e1c7c1c636af 363 state = Header;
IanBenzMaxim 1:e1c7c1c636af 364 // Continue processing switch
IanBenzMaxim 1:e1c7c1c636af 365
IanBenzMaxim 1:e1c7c1c636af 366 case Header:
IanBenzMaxim 1:e1c7c1c636af 367 if (received == findChars[index])
IanBenzMaxim 1:e1c7c1c636af 368 {
IanBenzMaxim 1:e1c7c1c636af 369 if (findChars[++index] == '\0')
IanBenzMaxim 1:e1c7c1c636af 370 {
IanBenzMaxim 1:e1c7c1c636af 371 index = 0;
IanBenzMaxim 1:e1c7c1c636af 372 state = Length;
IanBenzMaxim 1:e1c7c1c636af 373 }
IanBenzMaxim 1:e1c7c1c636af 374 }
IanBenzMaxim 1:e1c7c1c636af 375 else
IanBenzMaxim 1:e1c7c1c636af 376 {
IanBenzMaxim 1:e1c7c1c636af 377 state = Reset;
IanBenzMaxim 1:e1c7c1c636af 378 }
IanBenzMaxim 1:e1c7c1c636af 379 break;
IanBenzMaxim 1:e1c7c1c636af 380
IanBenzMaxim 1:e1c7c1c636af 381 case Length:
IanBenzMaxim 1:e1c7c1c636af 382 if ((received <= '9') && (received >= '0'))
IanBenzMaxim 1:e1c7c1c636af 383 {
IanBenzMaxim 1:e1c7c1c636af 384 if (index < maxSizeDigits)
IanBenzMaxim 1:e1c7c1c636af 385 {
IanBenzMaxim 1:e1c7c1c636af 386 sizeDigits[index++] = received;
IanBenzMaxim 1:e1c7c1c636af 387 }
IanBenzMaxim 1:e1c7c1c636af 388 else
IanBenzMaxim 1:e1c7c1c636af 389 {
IanBenzMaxim 1:e1c7c1c636af 390 state = Reset;
IanBenzMaxim 1:e1c7c1c636af 391 }
IanBenzMaxim 1:e1c7c1c636af 392 }
IanBenzMaxim 1:e1c7c1c636af 393 else if (received == ':')
IanBenzMaxim 1:e1c7c1c636af 394 {
IanBenzMaxim 1:e1c7c1c636af 395 dataFinishedSize = atoi(sizeDigits);
IanBenzMaxim 1:e1c7c1c636af 396 if (dataFinishedSize == 0)
IanBenzMaxim 1:e1c7c1c636af 397 {
IanBenzMaxim 1:e1c7c1c636af 398 state = Reset;
IanBenzMaxim 1:e1c7c1c636af 399 }
IanBenzMaxim 1:e1c7c1c636af 400 else
IanBenzMaxim 1:e1c7c1c636af 401 {
IanBenzMaxim 1:e1c7c1c636af 402 index = 0;
IanBenzMaxim 1:e1c7c1c636af 403 state = Data;
IanBenzMaxim 1:e1c7c1c636af 404 }
IanBenzMaxim 1:e1c7c1c636af 405 }
IanBenzMaxim 1:e1c7c1c636af 406 else
IanBenzMaxim 1:e1c7c1c636af 407 {
IanBenzMaxim 1:e1c7c1c636af 408 state = Reset;
IanBenzMaxim 1:e1c7c1c636af 409 }
IanBenzMaxim 1:e1c7c1c636af 410 break;
IanBenzMaxim 1:e1c7c1c636af 411
IanBenzMaxim 1:e1c7c1c636af 412 case Data:
IanBenzMaxim 1:e1c7c1c636af 413 if (index < dataFinishedSize)
IanBenzMaxim 1:e1c7c1c636af 414 {
IanBenzMaxim 1:e1c7c1c636af 415 recvIpDataBuffer.push(received);
IanBenzMaxim 1:e1c7c1c636af 416 index++;
IanBenzMaxim 1:e1c7c1c636af 417 }
IanBenzMaxim 1:e1c7c1c636af 418 else
IanBenzMaxim 1:e1c7c1c636af 419 {
IanBenzMaxim 1:e1c7c1c636af 420 state = Reset;
IanBenzMaxim 1:e1c7c1c636af 421 }
IanBenzMaxim 1:e1c7c1c636af 422 break;
IanBenzMaxim 1:e1c7c1c636af 423 };
IanBenzMaxim 1:e1c7c1c636af 424 }
IanBenzMaxim 1:e1c7c1c636af 425
IanBenzMaxim 1:e1c7c1c636af 426 void ESP8266::parseRecvConnClosedMsg(const char received)
IanBenzMaxim 1:e1c7c1c636af 427 {
IanBenzMaxim 1:e1c7c1c636af 428 static const char findChars[] = "CLOSED";
IanBenzMaxim 1:e1c7c1c636af 429
IanBenzMaxim 1:e1c7c1c636af 430 static int index = 0;
IanBenzMaxim 1:e1c7c1c636af 431
IanBenzMaxim 1:e1c7c1c636af 432 bool shouldReset = parseRecvReset;
IanBenzMaxim 1:e1c7c1c636af 433
IanBenzMaxim 1:e1c7c1c636af 434 if (received == findChars[index])
IanBenzMaxim 1:e1c7c1c636af 435 {
IanBenzMaxim 1:e1c7c1c636af 436 if (findChars[++index] == '\0')
IanBenzMaxim 1:e1c7c1c636af 437 {
IanBenzMaxim 1:e1c7c1c636af 438 printDbgMsg(findChars);
IanBenzMaxim 1:e1c7c1c636af 439 shouldReset = true;
IanBenzMaxim 1:e1c7c1c636af 440 }
IanBenzMaxim 1:e1c7c1c636af 441 }
IanBenzMaxim 1:e1c7c1c636af 442 else
IanBenzMaxim 1:e1c7c1c636af 443 {
IanBenzMaxim 1:e1c7c1c636af 444 shouldReset = true;
IanBenzMaxim 1:e1c7c1c636af 445 }
IanBenzMaxim 1:e1c7c1c636af 446
IanBenzMaxim 1:e1c7c1c636af 447 if (shouldReset)
IanBenzMaxim 1:e1c7c1c636af 448 {
IanBenzMaxim 1:e1c7c1c636af 449 index = 0;
IanBenzMaxim 1:e1c7c1c636af 450 }
IanBenzMaxim 1:e1c7c1c636af 451 }
IanBenzMaxim 1:e1c7c1c636af 452
IanBenzMaxim 1:e1c7c1c636af 453 void ESP8266::printDbgMsg(const char * message)
IanBenzMaxim 1:e1c7c1c636af 454 {
IanBenzMaxim 1:e1c7c1c636af 455 if (debugMsg != NULL)
IanBenzMaxim 1:e1c7c1c636af 456 debugMsg->printf("%s", message);
IanBenzMaxim 1:e1c7c1c636af 457 }
IanBenzMaxim 1:e1c7c1c636af 458
IanBenzMaxim 1:e1c7c1c636af 459 ESP8266::CmdBuilder::CmdBuilder(const std::string & cmd)
IanBenzMaxim 1:e1c7c1c636af 460 {
IanBenzMaxim 1:e1c7c1c636af 461 clear(cmd);
IanBenzMaxim 1:e1c7c1c636af 462 }
IanBenzMaxim 1:e1c7c1c636af 463
IanBenzMaxim 1:e1c7c1c636af 464 void ESP8266::CmdBuilder::clear(const std::string & cmd)
IanBenzMaxim 1:e1c7c1c636af 465 {
IanBenzMaxim 1:e1c7c1c636af 466 numArgs = 0;
IanBenzMaxim 1:e1c7c1c636af 467 cmdStream.str("");
IanBenzMaxim 1:e1c7c1c636af 468
IanBenzMaxim 1:e1c7c1c636af 469 cmdStream << "AT";
IanBenzMaxim 1:e1c7c1c636af 470 if (cmd != "")
IanBenzMaxim 1:e1c7c1c636af 471 cmdStream << "+" << cmd;
IanBenzMaxim 1:e1c7c1c636af 472 }
IanBenzMaxim 1:e1c7c1c636af 473
IanBenzMaxim 1:e1c7c1c636af 474 void ESP8266::CmdBuilder::addStringArgument(const std::string & arg)
IanBenzMaxim 1:e1c7c1c636af 475 {
IanBenzMaxim 1:e1c7c1c636af 476 std::ostringstream argStream;
IanBenzMaxim 1:e1c7c1c636af 477 argStream << "\"" << arg << "\"";
IanBenzMaxim 1:e1c7c1c636af 478 addRawArgument<std::string>(argStream.str());
IanBenzMaxim 1:e1c7c1c636af 479 }
IanBenzMaxim 1:e1c7c1c636af 480
IanBenzMaxim 1:e1c7c1c636af 481 std::string ESP8266::CmdBuilder::str() const
IanBenzMaxim 1:e1c7c1c636af 482 {
IanBenzMaxim 1:e1c7c1c636af 483 std::string cmdString = cmdStream.str();
IanBenzMaxim 1:e1c7c1c636af 484 cmdString.append("\r\n");
IanBenzMaxim 1:e1c7c1c636af 485 return cmdString;
IanBenzMaxim 1:e1c7c1c636af 486 }