Vergil Cola
/
MQTTGatewayK64
Fork of my MQTTGateway
easy-connect/esp8266-driver/ESP8266/ATParser/ATParser.h
- Committer:
- vpcola
- Date:
- 2017-04-08
- Revision:
- 0:f1d3878b8dd9
File content as of revision 0:f1d3878b8dd9:
/* Copyright (c) 2015 ARM Limited * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * * @section DESCRIPTION * * Parser for the AT command syntax * */ #ifndef AT_PARSER_H #define AT_PARSER_H #include "mbed.h" #include <cstdarg> #include <vector> #include "BufferedSerial.h" #include "Callback.h" /** * Parser class for parsing AT commands * * Here are some examples: * @code * ATParser at = ATParser(serial, "\r\n"); * int value; * char buffer[100]; * * at.send("AT") && at.recv("OK"); * at.send("AT+CWMODE=%d", 3) && at.recv("OK"); * at.send("AT+CWMODE?") && at.recv("+CWMODE:%d\r\nOK", &value); * at.recv("+IPD,%d:", &value); * at.read(buffer, value); * at.recv("OK"); * @endcode */ class ATParser { private: // Serial information BufferedSerial *_serial; int _buffer_size; char *_buffer; int _timeout; // Parsing information const char *_delimiter; int _delim_size; bool dbg_on; struct oob { unsigned len; const char *prefix; mbed::Callback<void()> cb; }; std::vector<oob> _oobs; public: /** * Constructor * * @param serial serial interface to use for AT commands * @param buffer_size size of internal buffer for transaction * @param timeout timeout of the connection * @param delimiter string of characters to use as line delimiters */ ATParser(BufferedSerial &serial, const char *delimiter = "\r\n", int buffer_size = 256, int timeout = 8000, bool debug = false) : _serial(&serial), _buffer_size(buffer_size) { _buffer = new char[buffer_size]; setTimeout(timeout); setDelimiter(delimiter); debugOn(debug); } /** * Destructor */ ~ATParser() { delete [] _buffer; } /** * Allows timeout to be changed between commands * * @param timeout timeout of the connection */ void setTimeout(int timeout) { _timeout = timeout; } /** * Sets string of characters to use as line delimiters * * @param delimiter string of characters to use as line delimiters */ void setDelimiter(const char *delimiter) { _delimiter = delimiter; _delim_size = strlen(delimiter); } /** * Allows echo to be on or off * * @param echo 1 for echo and 0 turns it off */ void debugOn(uint8_t on) { dbg_on = (on) ? 1 : 0; } /** * Sends an AT command * * Sends a formatted command using printf style formatting * @see ::printf * * @param command printf-like format string of command to send which * is appended with the specified delimiter * @param ... all printf-like arguments to insert into command * @return true only if command is successfully sent */ bool send(const char *command, ...); bool vsend(const char *command, va_list args); /** * Recieve an AT response * * Recieves a formatted response using scanf style formatting * @see ::scanf * * Responses are parsed line at a time using the specified delimiter. * Any recieved data that does not match the response is ignored until * a timeout occurs. * * @param response scanf-like format string of response to expect * @param ... all scanf-like arguments to extract from response * @return true only if response is successfully matched */ bool recv(const char *response, ...); bool vrecv(const char *response, va_list args); /** * Write a single byte to the underlying stream * * @param c The byte to write * @return The byte that was written or -1 during a timeout */ int putc(char c); /** * Get a single byte from the underlying stream * * @return The byte that was read or -1 during a timeout */ int getc(); /** * Write an array of bytes to the underlying stream * * @param data the array of bytes to write * @param size number of bytes to write * @return number of bytes written or -1 on failure */ int write(const char *data, int size); /** * Read an array of bytes from the underlying stream * * @param data the destination for the read bytes * @param size number of bytes to read * @return number of bytes read or -1 on failure */ int read(char *data, int size); /** * Direct printf to underlying stream * @see ::printf * * @param format format string to pass to printf * @param ... arguments to printf * @return number of bytes written or -1 on failure */ int printf(const char *format, ...); int vprintf(const char *format, va_list args); /** * Direct scanf on underlying stream * @see ::scanf * * @param format format string to pass to scanf * @param ... arguments to scanf * @return number of bytes read or -1 on failure */ int scanf(const char *format, ...); int vscanf(const char *format, va_list args); /** * Attach a callback for out-of-band data * * @param prefix string on when to initiate callback * @param func callback to call when string is read * @note out-of-band data is only processed during a scanf call */ void oob(const char *prefix, mbed::Callback<void()> func); /** * Attach a callback for out-of-band data * * @param prefix string on when to initiate callback * @param obj pointer to object to call member function on * @param method callback to call when string is read * @note out-of-band data is only processed during a scanf call */ template <typename T, typename M> void oob(const char *prefix, T *obj, M method) { return oob(prefix, mbed::Callback<void()>(obj, method)); } /** * Flushes the underlying stream */ void flush(); }; #endif