Merge pull request #23 from cail/v2

InfluxDB V2 HTTPS cloud access

Author: tobiasschuerg

InfluxDb.cpp

@@ -81,11 +81,31 @@ void Influxdb::setVersion(uint16_t version){
   begin();
 }
 
+#if defined(ESP8266)
+/**
+ * Set servers finger print for HTTPS v2 Influx proto
+ * @param version accepts 1 for version 1.x or 2 for version 2.x
+ */
+void Influxdb::setFingerPrint(char *fingerPrint){
+  _fingerPrint = fingerPrint;
+  begin();
+}
+#endif
+
 void Influxdb::begin() {
   // TODO: recreate HttpClient on db change?
   if(_db_v == 2){
-    http.begin(_host, _port, "/api/v2/write?org=" + _org + "&bucket=" + _bucket);
-    http.addHeader("Authorization", "Token " + _token);
+#if defined(ESP8266)
+    if (_port == 443) {
+        if (_fingerPrint)
+          client.setFingerprint(_fingerPrint);
+        http.begin(client, _host, _port, "/api/v2/write?org=" + _org + "&bucket=" + _bucket, true);
+    }
+    else
+#endif
+    {
+        http.begin(_host, _port, "/api/v2/write?org=" + _org + "&bucket=" + _bucket);
+    }
   } else {
     if (_user && _pass) {
       http.begin(_host, _port, "/write?u=" + _user + "&p=" + _pass + "&db=" + _db);
@@ -137,6 +157,8 @@ boolean Influxdb::write(String data) {
     Serial.print(" --> writing to " + _db + ":\n");
     Serial.println(data);
   }
+  if(_db_v == 2)
+    http.addHeader("Authorization", "Token " + _token);
   int httpResponseCode = http.POST(data);
   Serial.print(" <-- Response: ");
   Serial.print(httpResponseCode);

InfluxDb.h

@@ -8,6 +8,7 @@
 */
 #if defined(ESP8266)
 #include <ESP8266HTTPClient.h>
+#include <WiFiClientSecure.h>
 #elif defined(ESP32)
 #include <WiFi.h>
 #include <HTTPClient.h>
@@ -30,6 +31,9 @@ class Influxdb {
   void setOrg(String org);
   void setToken(String token);
   void setPort(uint16_t port);
+#if defined(ESP8266)
+  void setFingerPrint(char *fingerPrint);
+#endif
 
   void prepare(InfluxData data);
   boolean write();
@@ -39,6 +43,9 @@ class Influxdb {
 
  private:
   HTTPClient http;
+#if defined(ESP8266)
+  WiFiClientSecure client;
+#endif
   String _host;
   uint16_t _port;
   String _db;
@@ -48,6 +55,9 @@ class Influxdb {
   String _org;
   String _token;
   uint16_t _db_v;
+#if defined(ESP8266)
+  char *_fingerPrint;
+#endif
 
   std::list<InfluxData> prepared;