Diff: MQTTNetwork.h

Revision:

0:238f0d0c0ba3

Child:

5:d9570dbf2f82

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/MQTTNetwork.h	Fri Mar 26 16:15:14 2021 +0000
@@ -0,0 +1,34 @@
+#ifndef _MQTTNETWORK_H_
+#define _MQTTNETWORK_H_
+
+#include "EthernetInterface.h"
+#include "TCPSocket.h"
+
+class   MQTTNetwork
+{
+public:
+    MQTTNetwork(EthernetInterface* aNetwork) :
+    network(aNetwork)
+    {
+        socket = new TCPSocket();
+    }
+
+    ~   MQTTNetwork()                                       { delete socket; }
+    int read(unsigned char* buffer, int len, int timeout)   { return socket->recv(buffer, len); }
+    int write(unsigned char* buffer, int len, int timeout)  { return socket->send(buffer, len); }
+    int connect(const char* hostname, uint16_t port)
+    {
+        SocketAddress   addr;
+
+        socket->open(network);
+        addr.set_ip_address(hostname);
+        addr.set_port(port);
+        return socket->connect(addr);
+    }
+
+    int disconnect()    { return socket->close(); }
+private:
+    EthernetInterface*  network;
+    TCPSocket*          socket;
+};
+#endif // _MQTTNETWORK_H_