Simplify using of UnbufferedSerial(Serial), USBCDC, TCP, SMTP, NTP Fork : https://github.com/YSI-LPS/lib_Transmission

Dependents:   lib_Transmission_Serial_example 2022_TICE_Electrolyse lib_Transmission_TCP_example

lib_Transmission.h

Committer:
YSI
Date:
2020-10-01
Revision:
7:98b12722e9e2
Parent:
6:d6a07fd1548a
Child:
8:7193327bed34

File content as of revision 7:98b12722e9e2:

/** Transmission class
*
* @purpose       library for Transmission
*
* Use to Transmission
*
* Example:
* @code
* #include "mbed.h"
*  
* int main()
* {
*     while(1)
*     {
*     }
* }
* @endcode
* @file          lib_Transmission.h 
* @date          Jun 2020
* @author        Yannic Simon
*/
#ifndef TRANSMISSION_H
#define TRANSMISSION_H

#include "mbed.h"
#include "EthernetInterface.h"
#include <sstream>

#define REQUEST_TIMEOUT      100                 // config client bloquante avec timeout sinon limite de transmission a 1072 octets
#define SMTP_SERVER             "129.175.212.70"    // IP sinon utilisation du DNS avec eth.getHostByName("smtp.u-psud.fr")
#define NTP_SERVER              "129.175.34.43"     // IP sinon utilisation du DNS avec eth.getHostByName("ntp.u-psud.fr")

enum    enumTRANSMISSION    { TCP, SERIAL, BOTH };
enum    enumTRANSTATUS      { WHITE, CYAN, MAGENTA_ACCEPT, BLUE_CLIENT, YELLOW_CONNECTING, GREEN_GLOBAL_UP, RED_DISCONNECTED, BLACK_INITIALIZE };

/** Transmission class
 */
class Transmission
{
    public:
        /** make new Transmission instance
        * connected to 
        *
        * @param 
        * @param 
        */
        Transmission(UnbufferedSerial *serial, EthernetInterface *eth, EventQueue *queue, void(*_init)(void), void(*_processing)(string, const enumTRANSMISSION&));
        
        /** 
        *
        * @param 
        * @param 
        * @returns none
        */
        void                set(bool TCP, const char* IP="", uint16_t PORT=80);
        /** 
        *
        * @param 
        * @param 
        * @returns none
        */
        string              get(void);
        /** 
        *
        * @param 
        * @param 
        * @returns none
        */
        enumTRANSTATUS      recv(void);
        /** 
        *
        * @param 
        * @param 
        * @returns none
        */
        nsapi_error_t       send(const string& BUFFER, const enumTRANSMISSION& TYPE);
        /** 
        *
        * @param 
        * @param 
        * @returns none
        */
        bool                smtp(const char* MAIL, const char* FROM="", const char* SUBJECT="", const char* DATA="");
        /** 
        *
        * @param 
        * @param 
        * @returns none
        */
        time_t              ntp(void);
        /** 
        *
        * @param 
        * @param 
        * @returns none
        */
        void                http(void);

    private:
        UnbufferedSerial    *_serial;
        EthernetInterface   *_eth;
        EventQueue          *_queue;
        TCPSocket           *_clientTCP = NULL;
        TCPSocket           _serverTCP;

        /* Transmission */
        void                (*fn_init)(void);
        void                (*fn_processing)(string, const enumTRANSMISSION&);

        /* EthernetInterface */
        void                eth_state(void);
        bool                eth_connect(void);
        void                eth_event(nsapi_event_t, intptr_t);
        intptr_t            eth_status(const string&, const intptr_t&);
        nsapi_error_t       eth_error(const string& SOURCE, const nsapi_error_t& CODE);

        /* serverTCP */
        bool                serverTCP_connect(void);
        void                serverTCP_accept(void);
        void                serverTCP_event(void);

        struct  typeTRANSMISSION { string buffer[2]; enumTRANSTATUS status; bool TCP; bool HTTP; bool BREAK; bool DHCP; bool CONNECT; string IP; uint16_t PORT; }
                message = { {"", ""}, RED_DISCONNECTED, false, false, false, false, false, "", 80 };
};

#endif