separated MQTTTransfort into individual files

Author: tuanpmt

libraries/ESP8266MQTTClient/src/MQTTTransport.cpp

@@ -0,0 +1,38 @@
+#include <Arduino.h>
+#include <ESP8266WiFi.h>
+#include <WiFiClientSecure.h>
+#include <StreamString.h>
+#include <base64.h>
+#include "ESP8266MQTTClient.h"
+#include "MQTTTransport.h"
+
+MQTTTransportTraits::~MQTTTransportTraits()
+{
+}
+
+std::unique_ptr<WiFiClient> MQTTTransportTraits::create()
+{
+	return std::unique_ptr<WiFiClient>(new WiFiClient());
+}
+
+bool MQTTTransportTraits::verify(WiFiClient& client, const char* host)
+{
+	return true;
+}
+
+
+MQTTTLSTraits::MQTTTLSTraits(const String& fingerprint) :
+	_fingerprint(fingerprint)
+{
+}
+
+std::unique_ptr<WiFiClient> MQTTTLSTraits::create()
+{
+	return std::unique_ptr<WiFiClient>(new WiFiClientSecure());
+}
+
+bool MQTTTLSTraits::verify(WiFiClient& client, const char* host)
+{
+	auto wcs = reinterpret_cast<WiFiClientSecure&>(client);
+	return wcs.verify(_fingerprint.c_str(), host);
+}

libraries/ESP8266MQTTClient/src/MQTTTransport.h

@@ -0,0 +1,36 @@
+#ifndef _MQTT_TRANSPORT_H_
+#define _MQTT_TRANSPORT_H_
+// WebSocket protocol constants
+// First byte
+#define WS_FIN            0x80
+#define WS_OPCODE_TEXT    0x01
+#define WS_OPCODE_BINARY  0x02
+#define WS_OPCODE_CLOSE   0x08
+#define WS_OPCODE_PING    0x09
+#define WS_OPCODE_PONG    0x0a
+// Second byte
+#define WS_MASK           0x80
+#define WS_SIZE16         126
+#define WS_SIZE64         127
+
+
+class MQTTTransportTraits
+{
+public:
+    virtual ~MQTTTransportTraits();
+    virtual std::unique_ptr<WiFiClient> create();
+    virtual bool verify(WiFiClient& client, const char* host);
+protected:
+	std::unique_ptr<WiFiClient> _tcp;
+};
+
+class MQTTTLSTraits : public MQTTTransportTraits
+{
+public:
+    MQTTTLSTraits(const String& fingerprint);
+    std::unique_ptr<WiFiClient> create();
+    bool verify(WiFiClient& client, const char* host);
+protected:
+    String _fingerprint;
+};
+#endif