wifi test
Dependencies: X_NUCLEO_IKS01A2 mbed-http
Diff: easy-connect/wnc14a2a-driver/WNC14A2AInterface/WNC14A2AInterface.h
- Revision:
- 0:24d3eb812fd4
diff -r 000000000000 -r 24d3eb812fd4 easy-connect/wnc14a2a-driver/WNC14A2AInterface/WNC14A2AInterface.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/easy-connect/wnc14a2a-driver/WNC14A2AInterface/WNC14A2AInterface.h Wed Sep 05 14:28:24 2018 +0000 @@ -0,0 +1,508 @@ +/** +* copyright (c) 2017-2018, James Flynn +* SPDX-License-Identifier: Apache-2.0 +*/ + +/* +* 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. +*/ + +/** +* @file WNC14A2AInterface.h +* @brief Implements a standard NetworkInterface class for use with WNC M14A2A +* data module. +* +* @author James Flynn +* +* @date 1-Feb-2018 +* +*/ + +#ifndef WNC14A2A_INTERFACE_H +#define WNC14A2A_INTERFACE_H + +#include <stdint.h> + +#include "mbed.h" +#include "Callback.h" +#include "WNCDebug.h" +#include "WncControllerK64F/WncControllerK64F.h" + +#define WNC14A2A_SOCKET_COUNT WncController::MAX_NUM_WNC_SOCKETS + +// If target board does not support Arduino pins, define pins as Not Connected +#if defined(TARGET_FF_ARDUINO) +#if !defined(MBED_CONF_WNC14A2A_LIBRARY_WNC_RX_BOOT_SEL) +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_RX_BOOT_SEL D1 +#endif +#if !defined(MBED_CONF_WNC14A2A_LIBRARY_WNC_POWER_ON) +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_POWER_ON D2 +#endif +#if !defined(MBED_CONF_WNC14A2A_LIBRARY_WNC_WAKEUP) +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_WAKEUP D6 +#endif +#if !defined(MBED_CONF_WNC14A2A_LIBRARY_WNC_RESET) +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_RESET D8 +#endif +#if !defined(MBED_CONF_WNC14A2A_LIBRARY_WNC_LVLTRANSLATOR) +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_LVLTRANSLATOR D9 +#endif +#if !defined(MBED_CONF_WNC14A2A_LIBRARY_WNC_CTS) +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_CTS D10 +#endif +#if !defined(MBED_CONF_WNC14A2A_LIBRARY_WNC_RXD) +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_RXD D11 +#endif +#if !defined(MBED_CONF_WNC14A2A_LIBRARY_WNC_TXD) +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_TXD D12 +#endif +#else // !defined(TARGET_FF_ARDUINO) +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_RX_BOOT_SEL NC +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_POWER_ON NC +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_WAKEUP NC +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_RESET NC +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_LVLTRANSLATOR NC +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_CTS NC +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_RXD NC +#define MBED_CONF_WNC14A2A_LIBRARY_WNC_TXD NC +#endif // !defined(TARGET_FF_ARDUINO) + +typedef struct smsmsg_t { + string number; + string date; + string time; + string msg; + } IOTSMS; + +typedef struct socket_t { + int socket; //index of this socket + string url; + SocketAddress addr; //address info for this socket + bool opened; //is the socket opened + bool connected; //is the socket connected + int proto; //this is a TCP or UDP socket + void (*_callback)(void*); //callback used with attach + void *_cb_data; //callback data to be returned + } WNCSOCKET; + +typedef struct rx_event_t { + int m_rx_wnc_state; //state of the socket receive + int m_rx_socket; //which socket is being rcvd on + uint8_t *m_rx_dptr; //pointer to the users data buffer + uint32_t m_rx_req_size; //Requested number of bytes to receive + uint32_t m_rx_total_cnt; //Total number of bytes received + int m_rx_timer; //Rx Timeout Timer + int m_rx_disTO; //Flag to disable Timeout Timer + void (*m_rx_callback)(void*); //callback used with attach + void *m_rx_cb_data; //callback data to be returned + uint32_t m_rx_return_cnt; //number of bytes the Event Queue is returning + } RXEVENT; + +typedef struct tx_event_t { + // Transmit Interrupt simulation to enabled non-blocking operation + int m_tx_wnc_state; + int m_tx_socket; + uint8_t *m_tx_dptr; + unsigned m_tx_orig_size; + uint32_t m_tx_req_size; + uint32_t m_tx_total_sent; + void (*m_tx_callback)(void*); + void *m_tx_cb_data; + } TXEVENT; + +#define WNC_DEBUG 0 //1=enable the WNC startup debug output + //0=disable the WNC startup debug output +#define STOP_ON_FE 1 //1=hang forever if a fatal error occurs + //0=simply return failed response for all socket calls +#define DISPLAY_FE 1 //1 to display the fatal error when it occurs + //0 to NOT display the fatal error +#define RESETON_FE 0 //1 to cause the MCU to reset on fatal error + //0 to NOT reset the MCU + +#define APN_DEFAULT "m2m.com.attz" + +/** Error Handling macros & data +* @brief The macros CHK_WNCFE is used to check if a fatal error has occured. If it has +* then execute the action specified: fail, void, null, resume +* +* CHK_WNCFE( condition-to-check, fail|void|null|resume ) +* +* 'fail' if you want FATAL_WNC_ERROR to be called. +* 'void' if you want to execute a void return +* 'null' if you want to execute a null return +* 'resume' if you simply want to resume program execution +* +* There are several settings that control how FATAL_WNC_ERROR behaves: +* 1) RESETON_FE determines if the system will reset or hang. +* 2) DISPLAY_FE determine if an error message is generated or not +* +* The DISPLAY_FE setting determines if a failure message is displayed. +* If set to 1, user sees this messageo: +* +* WNC FAILED @ source-file-name:source-file-line-number +* +* if not set, nothing is displayed. +*/ + +#define FATAL_FLAG WncController::WNC_NO_RESPONSE +#define WNC_GOOD WncController::WNC_ON + +#define RETfail return -1 +#define RETvoid return +#define RETnull return NULL +#define RETresume + +#define DORET(x) RET##x + +#define TOSTR(x) #x +#define INTSTR(x) TOSTR(x) +#define FATAL_STR (char*)(__FILE__ ":" INTSTR(__LINE__)) + +#if RESETON_FE == 1 //reset on fatal error +#define MCURESET ((*((volatile unsigned long *)0xE000ED0CU))=(unsigned long)((0x5fa<<16) | 0x04L)) +#define RSTMSG "RESET MCU! " +#else +#define MCURESET +#define RSTMSG "" +#endif + +#if DISPLAY_FE == 1 //display fatal error message +#define PFE {if(_debugUart)_debugUart->printf((char*)RSTMSG "\r\n>>WNC FAILED @ %s\r\n", FATAL_STR);} +#else +#define PFE +#endif + +#if STOP_ON_FE == 1 //halt cpu on fatal error +#define FATAL_WNC_ERROR(v) {_fatal_err_loc=FATAL_STR;PFE;MCURESET;while(1);} +#else +#define FATAL_WNC_ERROR(v) {_fatal_err_loc=FATAL_STR;PFE;DORET(v);} +#endif + +#define CHK_WNCFE(x,y) if( x ){FATAL_WNC_ERROR(y);} + +#define FIRMWARE_REV(x) (((WNC14A2AInterface*)x)->getWNCRev()) +#define DBGMSG_DRV 0x04 +#define DBGMSG_EQ 0x08 +#define DBGMSG_SMS 0x10 +#define DBGMSG_ARRY 0x20 + +#define MAX_SMS_MSGS 3 + +using namespace WncController_fk; + +/** WNC14A2AInterface class + * Implementation of the NetworkInterface for WNC14A2A + */ +class WNC14A2AInterface : public NetworkStack, public NetworkInterface +{ +public: + + /** WNC14A2AInterface Constructor. + * @param optionally include a pointer to WNCDEBUG object for + * debug information to be displayed. + */ + WNC14A2AInterface(WNCDebug *_dbgUart = NULL); + virtual ~WNC14A2AInterface(); + + /** Set the cellular network credentials + * + * @param apn Optional, APN of network + * @param user Optional, username --not used-- + * @param pass Optional, password --not used-- + * @return nsapi_error_t + */ + virtual nsapi_error_t set_credentials(const char *apn = 0, + const char *username = 0, const char *password = 0); + + /** Connect to the network + * + * @param apn Optional, APN of network + * @param user Optional, username --not used-- + * @param pass Optional, password --not used-- + * @return nsapi_error_t + */ + virtual nsapi_error_t connect(const char *apn, + const char *username = 0, const char *password = 0); + + /** Connect to the network (no parameters) + * + * @return nsapi_error_t + */ + virtual nsapi_error_t connect(); + + /** disconnect from the network + * + * provided for completness, but function does nothing becase + * WNC part can not disconnect from network once connected. + * + * @return nsapi_error_t + */ + virtual nsapi_error_t disconnect(); + + /** Get the IP address of WNC device. From NetworkStack Class + * + * @return IP address string or null + */ + virtual const char *get_ip_address(); + + /** Get the network assigned IP address. + * + * @return IP address or null + */ + const char *get_my_ip_address(); + + /** Get the MAC address of the WNC device. + * + * @return MAC address of the interface + */ + virtual const char *get_mac_address(); + + /** Attach a callback function for when a SMS is recevied + * + * @param function pointer to call + */ + void sms_attach(void (*callback)(IOTSMS *)); + + /** Set the level of Debug output + * + * @param bit field + * basic AT command info= 0x01 + * more AT command info = 0x02 + * mbed driver info = 0x04 + * dump buffers = 0x08 + * all debug = 0x0f + */ + void doDebug(int v); + + /** Return the WNC reported Firmware Revision + * + * @param none. + */ + const char* getWNCRev(void); + + /** Query registered state of WNC + * + * @return true if registerd, false if not + */ + bool registered(); + + /** Start the SMS monitoring service + */ + void sms_start(void); + + /** start listening for incomming SMS messages + * + * @param time in msec to check + */ + void sms_listen(uint16_t=1000); // Configure device to listen for text messages + + /** retrieve a SMS message + * + * @param pointer to an array of IOTSMS messages + */ + int getSMS(IOTSMS **msg); + + /** send a SMS message + * + * @param a string containing number to send message to + * @param a string containing message to send + * @return true on success, 0 on failure + */ + int sendIOTSms(const string&, const string&); + + /** return this devices SMS number + * + * @brief The IOTSMS number used, isn't phone number, it is device ICCID. + * + * @return this devices IOTSMS number + */ + char* getSMSnbr(); + + +protected: + + /** Get Host IP by name. + * + * @return nsapi_error_t + */ + virtual nsapi_error_t gethostbyname(const char* name, SocketAddress *address, nsapi_version_t version); + + + /** return a pointer to the NetworkStack object + * + * @return The underlying NetworkStack object + */ + virtual NetworkStack *get_stack(); + + /** Open a socket. + * + * @param handle Handle in which to store new socket + * @param proto Type of socket to open, NSAPI_TCP or NSAPI_UDP + * @return 0 on success, negative on failure + */ + virtual int socket_open(void **handle, nsapi_protocol_t proto); + + /** Close the socket. + * + * @param handle Socket handle + * @return 0 on success, negative on failure + */ + virtual int socket_close(void *handle); + + /** Bind a server socket to a specific port. + * + * @brief Bind the socket to a specific port + * @param handle Socket handle + * @param address address to listen for + * @return 0; + */ + virtual int socket_bind(void *handle, const SocketAddress &address); + + /** Start listening for incoming connections. + * + * @brief NOT SUPPORTED + * @param handle Socket handle + * @param backlog Number of pending connections that can be queued up at any + * one time [Default: 1] + * @return NSAPI_ERROR_UNSUPPORTED; + * @note This function causes the receive time-out to be ignored resulting in continuous + * monitoring of received data. This is non-standard behaviour but it is how the + * mbed-cloud servcies use it... + */ + virtual int socket_listen(void *handle, int backlog); + + /** Accept a new connection. + * + * @brief NOT SUPPORTED + * @return NSAPI_ERROR_UNSUPPORTED; + */ + virtual int socket_accept(nsapi_socket_t server, + nsapi_socket_t *handle, SocketAddress *address=0); + + /** Connects this socket to the server. + * + * @param handle Socket handle + * @param address SocketAddress + * @return 0 on success, negative on failure + */ + virtual int socket_connect(void *handle, const SocketAddress &address); + + /** Send data to the remote host. + * + * @param handle Socket handle + * @param data buffer to send + * @param size length of buffer + * @return Number of bytes written or negative on failure + * + * @note This call is blocking. + */ + virtual int socket_send(void *handle, const void *data, unsigned size); + + /** Receive data from the remote host. + * + * @param handle Socket handle + * @param data buffer to store the recived data + * @param size bytes to receive + * @return received bytes received, negative on failure + * + * @note This call is not-blocking + */ + virtual int socket_recv(void *handle, void *data, unsigned size); + + /** Send a packet to a remote endpoint. + * + * @param handle Socket handle + * @param address SocketAddress + * @param data data to send + * @param size number of bytes to send + * @return the number of bytes sent or negative on failure + * + * @note This call is blocking. + */ + virtual int socket_sendto(void *handle, const SocketAddress &address, const void *data, unsigned size); + + /** Receive packet remote endpoint + * + * @param handle Socket handle + * @param address SocketAddress + * @param buffer buffer to store data to + * @param size number of bytes to receive + * @return the number bytes received or negative on failure + * + * @note This call is not-blocking. + */ + virtual int socket_recvfrom(void *handle, SocketAddress *address, void *buffer, unsigned size); + + /** Register a callback on state change of the socket + * + * @param handle Socket handle + * @param callback Function to call on state change + * @param data Argument to pass to callback + * + * @note Callback may be called in an interrupt context. + */ + virtual void socket_attach(void *handle, void (*callback)(void *), void *data); + + /** get the status of internal errors + * + * @brief Called after any WNC14A2A operation to determine error specifics + * @param none. + */ + uint16_t wnc14a2a_chk_error(void) { return m_errors; } + +private: + + //! WncController Class for interacting with the 14A2a hardware + friend class WncControllerK64F; + + bool m_wncpoweredup; //track if WNC has been power-up + unsigned m_debug; + + WncIpStats myNetStats; //maintaint the network statistics + WncControllerK64F_fk::WncControllerK64F *m_pwnc; //pointer to the WncController instance + + WNCDebug *_debugUart; // Serial object for parser to communicate with radio + char *_fatal_err_loc; // holds string containing location of fatal error + nsapi_error_t m_errors; + + bool m_smsmoning; // Track if the SMS monitoring thread is running + EventQueue sms_queue; // Queue used to schedule for SMS checks + void (*_sms_cb)(IOTSMS *); // Callback when text message is received. User must define this as + // a static function because I'm not handling an object offset + IOTSMS m_MsgText, m_MsgText_array[MAX_SMS_MSGS]; // Used to pass SMS message to the user + struct WncController::WncSmsList m_smsmsgs; //use the WncSmsList structure to hold messages + + EventQueue wnc_queue; // Queue used to schedule for receiving data + void handle_sms_event(); // SMS tx/rx handler + void wnc_eq_event(); // Simulated ISR + int rx_event(RXEVENT *); // receive data handler + int tx_event(TXEVENT *); // tx data handler + + char _mac_address[NSAPI_MAC_SIZE]; // local Mac + void _dbOut(const char *format, ...); + void _dbDump_arry( const uint8_t* data, unsigned int size ); + + WNCSOCKET _sockets[WNC14A2A_SOCKET_COUNT]; //WNC supports 8 open sockets but driver only supports 1 currently + TXEVENT _socTxS[WNC14A2A_SOCKET_COUNT]; + RXEVENT _socRxS[WNC14A2A_SOCKET_COUNT]; + Thread _smsThread, _eqThread; //Event Queue thread for SMS and Rx/Tx data + Mutex _pwnc_mutex; + int _active_socket; + + UARTSerial mdmUart; + WncIO wnc_io; +}; + +#endif +