L475VG-IOT01A+WIFI+MQTT

Dependencies:   HTS221 VL53L0X BSP_B-L475E-IOT01 MQTT

Committer:
cornetlin
Date:
Sat Jan 04 16:47:24 2020 +0000
Revision:
2:a21eb3abb874
Parent:
1:5a9fdc848911
WIFI+MQTT+LORA

Who changed what in which revision?

UserRevisionLine numberNew contents of line
cornetlin 1:5a9fdc848911 1 #ifndef _MQTTNETWORK_H_
cornetlin 1:5a9fdc848911 2 #define _MQTTNETWORK_H_
cornetlin 1:5a9fdc848911 3
cornetlin 1:5a9fdc848911 4 #include "NetworkInterface.h"
cornetlin 1:5a9fdc848911 5 #include "TCPSocket.h"
cornetlin 1:5a9fdc848911 6
cornetlin 1:5a9fdc848911 7 class MQTTNetwork {
cornetlin 1:5a9fdc848911 8 public:
cornetlin 1:5a9fdc848911 9 MQTTNetwork(NetworkInterface* aNetwork) : network(aNetwork) {
cornetlin 1:5a9fdc848911 10 socket = new TCPSocket();
cornetlin 1:5a9fdc848911 11 }
cornetlin 1:5a9fdc848911 12
cornetlin 1:5a9fdc848911 13 ~MQTTNetwork() {
cornetlin 1:5a9fdc848911 14 delete socket;
cornetlin 1:5a9fdc848911 15 }
cornetlin 1:5a9fdc848911 16
cornetlin 1:5a9fdc848911 17 int read(unsigned char* buffer, int len, int timeout) {
cornetlin 1:5a9fdc848911 18 return socket->recv(buffer, len);
cornetlin 1:5a9fdc848911 19 }
cornetlin 1:5a9fdc848911 20
cornetlin 1:5a9fdc848911 21 int write(unsigned char* buffer, int len, int timeout) {
cornetlin 1:5a9fdc848911 22 return socket->send(buffer, len);
cornetlin 1:5a9fdc848911 23 }
cornetlin 1:5a9fdc848911 24
cornetlin 1:5a9fdc848911 25 int connect(const char* hostname, int port) {
cornetlin 1:5a9fdc848911 26 socket->open(network);
cornetlin 1:5a9fdc848911 27 return socket->connect(hostname, port);
cornetlin 1:5a9fdc848911 28 }
cornetlin 1:5a9fdc848911 29
cornetlin 1:5a9fdc848911 30 int disconnect() {
cornetlin 1:5a9fdc848911 31 return socket->close();
cornetlin 1:5a9fdc848911 32 }
cornetlin 1:5a9fdc848911 33
cornetlin 1:5a9fdc848911 34 private:
cornetlin 1:5a9fdc848911 35 NetworkInterface* network;
cornetlin 1:5a9fdc848911 36 TCPSocket* socket;
cornetlin 1:5a9fdc848911 37 };
cornetlin 1:5a9fdc848911 38
cornetlin 1:5a9fdc848911 39 #endif // _MQTTNETWORK_H_