Diff: lib_Transmission.h

Revision:

8:7193327bed34

Parent:

7:98b12722e9e2

Child:

9:abd4a4944399

--- a/lib_Transmission.h	Thu Oct 01 11:35:46 2020 +0000
+++ b/lib_Transmission.h	Tue Oct 13 12:08:04 2020 +0000
@@ -26,9 +26,10 @@
 #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")
+#define NDEBUG
+#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 };
@@ -44,7 +45,7 @@
         * @param 
         * @param 
         */
-        Transmission(UnbufferedSerial *serial, EthernetInterface *eth, EventQueue *queue, void(*_init)(void), void(*_processing)(string, const enumTRANSMISSION&));
+        Transmission(UnbufferedSerial *serial, EthernetInterface *eth, void(*init)(void), void(*processing)(string, const enumTRANSMISSION&));
         
         /** 
         *
@@ -97,15 +98,143 @@
         void                http(void);
 
     private:
+        Thread              _queueThread;
+        EventQueue          _queue;
         UnbufferedSerial    *_serial;
         EthernetInterface   *_eth;
-        EventQueue          *_queue;
         TCPSocket           *_clientTCP = NULL;
         TCPSocket           _serverTCP;
 
         /* Transmission */
-        void                (*fn_init)(void);
-        void                (*fn_processing)(string, const enumTRANSMISSION&);
+        void                (*_init)(void);
+        void                (*_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/** 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 NDEBUG
+#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, 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:
+        Thread              _queueThread;
+        EventQueue          _queue;
+        UnbufferedSerial    *_serial;
+        EthernetInterface   *_eth;
+        TCPSocket           *_clientTCP = NULL;
+        TCPSocket           _serverTCP;
+
+        /* Transmission */
+        void                (*_init)(void);
+        void                (*_processing)(string, const enumTRANSMISSION&);
 
         /* EthernetInterface */
         void                eth_state(void);