Merge pull request #76 from bonitoo-io/fix/debug_compilation

vlastahajek · web-flow · commit 6e47386e560d · 2020-07-07T10:51:25.000+02:00
Fix/debug compilation
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,4 +1,11 @@
 # Changelog
+## Version 3.3.0 (in progress)
+ - [NEW] Added possibility skip server certification validation (`setInsecure()` method)
+ - [NEW] Added possibility to query flux on InfuxDB 1.8 using V1 approach
+ - [NEW] `validateConnection()` can be used also for the [forward compatibility](https://docs.influxdata.com/influxdb/latest/tools/api/#influxdb-2-0-api-compatibility-endpoints) connection to InfluxDB 1.8
+ - [FIX] Debug compilation error
+ - [FIX] SecureBatchWrite compile error
+ 
 ## Version 3.2.0 (2020-06-09)
 - [NEW] Added possibility to read data from InfluxDB using Flux queries
 - [NEW] `timeSync` utility function for synchronous time synchronization using NTP 
diff --git a/examples/SecureBatchWrite/SecureBatchWrite.ino b/examples/SecureBatchWrite/SecureBatchWrite.ino
@@ -22,7 +22,7 @@ ESP8266WiFiMulti wifiMulti;
 #define WIFI_AUTH_OPEN ENC_TYPE_NONE
 #endif
 
-#include <InfluxDbClient.h
+#include <InfluxDbClient.h>
 #include <InfluxDbCloud.h>
 
 // WiFi AP SSID
@@ -44,6 +44,10 @@ ESP8266WiFiMulti wifiMulti;
 //  Japanesse:      "JST-9"
 //  Central Europe: "CET-1CEST,M3.5.0,M10.5.0/3"
 #define TZ_INFO "CET-1CEST,M3.5.0,M10.5.0/3"
+// NTP servers the for time syncronozation.
+// For the fastest time sync find NTP servers in your area: https://www.pool.ntp.org/zone/
+#define NTP_SERVER1  "pool.ntp.org"
+#define NTP_SERVER2  "time.nis.gov"
 #define WRITE_PRECISION WritePrecision::S
 #define MAX_BATCH_SIZE 10
 #define WRITE_BUFFER_SIZE 30
@@ -76,9 +80,8 @@ void setup() {
   sensorStatus.addTag("SSID", WiFi.SSID());
 
   // Accurate time is necessary for certificate validation and writing in batches
-  // For the fastest time sync find NTP servers in your area: https://www.pool.ntp.org/zone/
   // Syncing progress and the time will be printed to Serial.
-  timeSync(TZ_INFO, "pool.ntp.org", "time.nis.gov");
+  timeSync(TZ_INFO, NTP_SERVER1, NTP_SERVER2);
 
   // Check server connection
   if (client.validateConnection()) {
@@ -89,22 +92,22 @@ void setup() {
     Serial.println(client.getLastErrorMessage());
   }
 
-  //Enable messages batching and retry buffer
+  // Enable messages batching and retry buffer
   client.setWriteOptions(WRITE_PRECISION, MAX_BATCH_SIZE, WRITE_BUFFER_SIZE);
 }
 
 void loop() {
   // Sync time for batching once per hour
   if (iterations++ >= 360) {
-    timeSync();
+    timeSync(TZ_INFO, NTP_SERVER1, NTP_SERVER2);
     iterations = 0;
   }
 
-  //Report networks (low priority data) just in case we successfully wrote the previous batch
+  // Report networks (low priority data) just in case we successfully wrote the previous batch
   if (client.isBufferEmpty()) {
     // Report all the detected wifi networks
     int networks = WiFi.scanNetworks();
-    //Set identical time for the whole network scan
+    // Set identical time for the whole network scan
     time_t tnow = time(nullptr);
     for (int i = 0; i < networks; i++) {
       Point sensorNetworks("wifi_networks");
@@ -152,7 +155,7 @@ void loop() {
     Serial.println(client.isBufferFull() ? "Yes" : "No");
   }
 
-  //Wait 10s
+  // Wait 10s
   Serial.println("Wait 10s");
   delay(10000);
 }
diff --git a/src/InfluxDbClient.cpp b/src/InfluxDbClient.cpp
@@ -24,8 +24,8 @@
  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  * SOFTWARE.
 */
-#include <core_version.h>
 #include "InfluxDbClient.h"
+#include <core_version.h>
 
 #define STRHELPER(x) #x
 #define STR(x) STRHELPER(x) // stringifier
@@ -41,8 +41,7 @@
 static const char UserAgent[] PROGMEM = "influxdb-client-arduino/" INFLUXDB_CLIENT_VERSION " (" INFLUXDB_CLIENT_PLATFORM " " INFLUXDB_CLIENT_PLATFORM_VERSION ")";
 
 // Uncomment bellow in case of a problem and rebuild sketch
-//#define INFLUXDB_CLIENT_DEBUG
-
+//#define INFLUXDB_CLIENT_DEBUG_ENABLE
 #include "util/debug.h"
 
 static const char UnitialisedMessage[] PROGMEM = "Unconfigured instance"; 
@@ -194,12 +193,12 @@ void InfluxDBClient::setConnectionParamsV1(const char *serverUrl, const char *db
 }
 
 bool InfluxDBClient::init() {
-    INFLUXDB_CLIENT_DEBUG(F("Init\n"));
-    INFLUXDB_CLIENT_DEBUG(F("  Server url: %s\n"), _serverUrl.c_str());
-    INFLUXDB_CLIENT_DEBUG(F("  Org: %s\n"), _org.c_str());
-    INFLUXDB_CLIENT_DEBUG(F("  Bucket: %s\n"), _bucket.c_str());
-    INFLUXDB_CLIENT_DEBUG(F("  Token: %s\n"), _authToken.c_str());
-    INFLUXDB_CLIENT_DEBUG(F("  DB version: %d\n"), _dbVersion);
+    INFLUXDB_CLIENT_DEBUG("Init\n");
+    INFLUXDB_CLIENT_DEBUG("  Server url: %s\n", _serverUrl.c_str());
+    INFLUXDB_CLIENT_DEBUG("  Org: %s\n", _org.c_str());
+    INFLUXDB_CLIENT_DEBUG("  Bucket: %s\n", _bucket.c_str());
+    INFLUXDB_CLIENT_DEBUG("  Token: %s\n", _authToken.c_str());
+    INFLUXDB_CLIENT_DEBUG("  DB version: %d\n", _dbVersion);
     if(_serverUrl.length() == 0 || (_dbVersion == 2 && (_org.length() == 0 || _bucket.length() == 0 || _authToken.length() == 0))) {
          INFLUXDB_CLIENT_DEBUG("[E] Invalid parameters\n");
         return false;
@@ -220,8 +219,9 @@ bool InfluxDBClient::init() {
                 wifiClientSec->setFingerprint(_certInfo);
             }
         }
-        if (_insecure)
+        if (_insecure) {
             wifiClientSec->setInsecure();
+        }
 #elif defined(ESP32)
         WiFiClientSecure *wifiClientSec = new WiFiClientSecure;  
         if(_certInfo && strlen_P(_certInfo) > 0) { 
@@ -269,18 +269,18 @@ void InfluxDBClient::clean() {
 }
 
 void InfluxDBClient::setUrls() {
-    INFLUXDB_CLIENT_DEBUG(F("setUrls\n"));
+    INFLUXDB_CLIENT_DEBUG("setUrls\n");
     if(_dbVersion == 2) {
         _writeUrl = _serverUrl;
         _writeUrl += "/api/v2/write?org=";
         _writeUrl +=  _org ;
         _writeUrl += "&bucket=";
         _writeUrl += _bucket;
-        INFLUXDB_CLIENT_DEBUG(F("  writeUrl: %s\n"), _writeUrl.c_str());
+        INFLUXDB_CLIENT_DEBUG("  writeUrl: %s\n", _writeUrl.c_str());
         _queryUrl = _serverUrl;
         _queryUrl += "/api/v2/query?org=";
         _queryUrl +=  _org;
-        INFLUXDB_CLIENT_DEBUG(F("  queryUrl: %s\n"), _queryUrl.c_str());
+        INFLUXDB_CLIENT_DEBUG("  queryUrl: %s\n", _queryUrl.c_str());
     } else {
         _writeUrl = _serverUrl;
         _writeUrl += "/write?db=";
@@ -293,15 +293,16 @@ void InfluxDBClient::setUrls() {
             auth += "&p=";
             auth += _password;
             _writeUrl += auth;  
+            _queryUrl += "?";
             _queryUrl += auth;
         }
-        INFLUXDB_CLIENT_DEBUG(F("  writeUrl: %s\n"), _writeUrl.c_str());
-        INFLUXDB_CLIENT_DEBUG(F("  queryUrl: %s\n"), _queryUrl.c_str());
+        INFLUXDB_CLIENT_DEBUG("  writeUrl: %s\n", _writeUrl.c_str());
+        INFLUXDB_CLIENT_DEBUG("  queryUrl: %s\n", _queryUrl.c_str());
     }
     if(_writePrecision != WritePrecision::NoTime) {
         _writeUrl += "&precision=";
         _writeUrl += precisionToString(_writePrecision, _dbVersion);
-        INFLUXDB_CLIENT_DEBUG(F("  writeUrl: %s\n"), _writeUrl.c_str());
+        INFLUXDB_CLIENT_DEBUG("  writeUrl: %s\n", _writeUrl.c_str());
     }
     
 }
@@ -505,7 +506,7 @@ bool InfluxDBClient::validateConnection() {
         return false;
     }
     // on version 1.x /ping will by default return status code 204, without verbose
-    String url = _serverUrl + (_dbVersion==2?"/ready":"/ping?verbose=true");
+    String url = _serverUrl + (_dbVersion==2?"/health":"/ping?verbose=true");
     INFLUXDB_CLIENT_DEBUG("[D] Validating connection to %s\n", url.c_str());
 
     if(!_httpClient.begin(*_wifiClient, url)) {
diff --git a/src/InfluxDbClient.h b/src/InfluxDbClient.h
@@ -30,9 +30,6 @@
 #define INFLUXDB_CLIENT_VERSION "3.2.0"
 
 #include <Arduino.h>
-#include "query/FluxParser.h"
-#include "util/helpers.h"
-
 #if defined(ESP8266)
 # include <WiFiClientSecureBearSSL.h>
 # include <ESP8266HTTPClient.h>
@@ -42,6 +39,10 @@
 # error "This library currently supports only ESP8266 and ESP32."
 #endif
 
+#include "query/FluxParser.h"
+#include "util/helpers.h"
+
+
 #ifdef USING_AXTLS
 #error AxTLS does not work
 #endif
diff --git a/src/query/CsvReader.cpp b/src/query/CsvReader.cpp
@@ -25,9 +25,6 @@
  * SOFTWARE.
 */
 #include "CsvReader.h"
-// Uncomment bellow in case of a problem and rebuild sketch
-#define INFLUXDB_CLIENT_DEBUG
-#include "util/debug.h"
 
 CsvReader::CsvReader(HttpStreamScanner *scanner) {
     _scanner = scanner;
@@ -108,4 +105,4 @@ bool CsvReader::next() {
     }
     _row = fields;
     return true;
-}
+}
diff --git a/src/query/FluxParser.cpp b/src/query/FluxParser.cpp
@@ -27,7 +27,7 @@
 
 #include "FluxParser.h"
 // Uncomment bellow in case of a problem and rebuild sketch
-//#define INFLUXDB_CLIENT_DEBUG
+//#define INFLUXDB_CLIENT_DEBUG_ENABLE
 #include "util/debug.h"
 
 FluxQueryResult::FluxQueryResult(CsvReader *reader) {
@@ -123,12 +123,12 @@ bool FluxQueryResult::next() {
     if(!stat) {
         if(_data->_reader->getError()< 0) {
             _data->_error = HTTPClient::errorToString(_data->_reader->getError());
-            INFLUXDB_CLIENT_DEBUG(F("Error '%s'\n"), _data->_error.c_str());
+            INFLUXDB_CLIENT_DEBUG("Error '%s'\n", _data->_error.c_str());
         }
         return false;
     }
     std::vector<String> vals = _data->_reader->getRow();
-    INFLUXDB_CLIENT_DEBUG(F("[D] FluxQueryResult: vals.size %d\n"), vals.size());
+    INFLUXDB_CLIENT_DEBUG("[D] FluxQueryResult: vals.size %d\n", vals.size());
     if(vals.size() < 2) {
         goto readRow;
     }
@@ -145,15 +145,15 @@ bool FluxQueryResult::next() {
 				reference = "," + vals[2];
 			}
 			_data->_error =  message + reference;
-            INFLUXDB_CLIENT_DEBUG(F("Error '%s'\n"), _data->_error.c_str());
+            INFLUXDB_CLIENT_DEBUG("Error '%s'\n", _data->_error.c_str());
 			return false;
 		} else if (parsingState == ParsingStateNameRow) {
 			if (vals[1] == "error") {
 				parsingState = ParsingStateError;
 			} else {
                 if (vals.size()-1 != _data->_columnDatatypes.size()) {
                    _data->_error = String(F("Parsing error, header has different number of columns than table: ")) + String(vals.size()-1) + " vs " + String(_data->_columnDatatypes.size());
-                   INFLUXDB_CLIENT_DEBUG(F("Error '%s'\n"), _data->_error.c_str());
+                   INFLUXDB_CLIENT_DEBUG("Error '%s'\n", _data->_error.c_str());
 			       return false;
                 } else {
                     for(int i=1;i < vals.size(); i++) {
@@ -166,12 +166,12 @@ bool FluxQueryResult::next() {
 		}
 		if(_data->_columnDatatypes.size() == 0) {
 			_data->_error = F("Parsing error, datatype annotation not found");
-            INFLUXDB_CLIENT_DEBUG(F("Error '%s'\n"), _data->_error.c_str());
+            INFLUXDB_CLIENT_DEBUG("Error '%s'\n", _data->_error.c_str());
 			return false;
 		}
 		if (vals.size()-1 != _data->_columnNames.size()) {
 			_data->_error = String(F("Parsing error, row has different number of columns than table: ")) + String(vals.size()-1) + " vs " + String(_data->_columnNames.size());
-            INFLUXDB_CLIENT_DEBUG(F("Error '%s'\n"), _data->_error.c_str());
+            INFLUXDB_CLIENT_DEBUG("Error '%s'\n", _data->_error.c_str());
 			return false;
 		}
 		for(int i=1;i < vals.size(); i++) {
@@ -180,7 +180,7 @@ bool FluxQueryResult::next() {
                 v = convertValue(vals[i], _data->_columnDatatypes[i-1]);
                 if(!v) {
                     _data->_error = String(F("Unsupported datatype: ")) + _data->_columnDatatypes[i-1];
-                    INFLUXDB_CLIENT_DEBUG(F("Error '%s'\n"), _data->_error.c_str());
+                    INFLUXDB_CLIENT_DEBUG("Error '%s'\n", _data->_error.c_str());
                     return false;
                 }
             }  
diff --git a/src/query/HttpStreamScanner.cpp b/src/query/HttpStreamScanner.cpp
@@ -27,7 +27,7 @@
 #include "HttpStreamScanner.h"
 
 // Uncomment bellow in case of a problem and rebuild sketch
-//#define INFLUXDB_CLIENT_DEBUG
+//#define INFLUXDB_CLIENT_DEBUG_ENABLE
 #include "util/debug.h"
 
 HttpStreamScanner::HttpStreamScanner(HTTPClient *client, bool chunked)
@@ -37,13 +37,13 @@ HttpStreamScanner::HttpStreamScanner(HTTPClient *client, bool chunked)
     _chunked = chunked;
     _chunkHeader = chunked;
     _len = client->getSize();
-    INFLUXDB_CLIENT_DEBUG(F("[D] HttpStreamScanner: chunked: %s, size: %d\n"), _chunked?"true":"false", _len);
+    INFLUXDB_CLIENT_DEBUG("[D] HttpStreamScanner: chunked: %s, size: %d\n", _chunked?"true":"false", _len);
 }
 
 bool HttpStreamScanner::next() {
     while(_client->connected() && (_len > 0 || _len == -1)) {
         _line = _stream->readStringUntil('\n');
-        INFLUXDB_CLIENT_DEBUG(F("[D] HttpStreamScanner: line: %s\n"), _line.c_str());
+        INFLUXDB_CLIENT_DEBUG("[D] HttpStreamScanner: line: %s\n", _line.c_str());
         ++_linesNum;
         int lineLen = _line.length();
         if(lineLen == 0) {
@@ -68,7 +68,7 @@ bool HttpStreamScanner::next() {
         }
         if(_chunkHeader){
             _chunkLen = (int) strtol((const char *) _line.c_str(), NULL, 16);
-            INFLUXDB_CLIENT_DEBUG(F("[D] HttpStreamScanner chunk len: %d\n"), _chunkLen);
+            INFLUXDB_CLIENT_DEBUG("[D] HttpStreamScanner chunk len: %d\n", _chunkLen);
             _chunkHeader = false;
             _read = 0;
             if(_chunkLen == 0) { //last chunk
@@ -86,13 +86,13 @@ bool HttpStreamScanner::next() {
         
         if(_len > 0) {
             _len -= r;
-            INFLUXDB_CLIENT_DEBUG(F("[D] HttpStreamScanner new len: %d\n"), _len);
+            INFLUXDB_CLIENT_DEBUG("[D] HttpStreamScanner new len: %d\n", _len);
         }
         return true;
     }
     if(!_client->connected() && ( (_chunked && _chunkLen > 0) || (!_chunked && _len > 0))) { //report error only if we didn't went to 
         _error = HTTPC_ERROR_CONNECTION_LOST;
-        INFLUXDB_CLIENT_DEBUG(F("HttpStreamScanner connection lost\n"));
+        INFLUXDB_CLIENT_DEBUG("HttpStreamScanner connection lost\n");
     } 
     return false;
 }
diff --git a/src/util/debug.h b/src/util/debug.h
@@ -27,10 +27,9 @@
 #ifndef _INFLUXDB_CLIENT_DEBUG_H
 #define _INFLUXDB_CLIENT_DEBUG_H
 
-// captilised the A of Arduino - kdriver
 #include <Arduino.h>
 
-#ifdef INFLUXDB_CLIENT_DEBUG
+#ifdef INFLUXDB_CLIENT_DEBUG_ENABLE
 # define INFLUXDB_CLIENT_DEBUG(fmt, ...) Serial.printf_P( (PGM_P)PSTR(fmt), ## __VA_ARGS__ )
 #else
 # define INFLUXDB_CLIENT_DEBUG(fmt, ...)
diff --git a/test/server/server.js b/test/server/server.js
@@ -27,6 +27,10 @@ app.get('/ready', (req,res) => {
     lastUserAgent = req.get('User-Agent');
     res.status(200).send("<html><body><h1>OK</h1></body></html>");
 })
+app.get('/health', (req,res) => {
+    lastUserAgent = req.get('User-Agent');
+    res.status(200).send("<html><body><h1>OK</h1></body></html>");
+})
 
 app.get('/ping', (req,res) => {
     lastUserAgent = req.get('User-Agent');
@@ -338,7 +342,7 @@ function parsePoints(data) {
 const AuthToken = "Token 1234567890";
 function handleAuthentication(req, res) {
     var auth = req.get('Authorization');
-    if(auth != AuthToken) {
+    if(auth && auth != AuthToken) {
         res.status(401).send(`{"code":"unauthorized","message":"unauthorized access"}`);
         return false;
     } else {
@@ -382,7 +386,7 @@ function checkWriteParamsV1(req, res) {
 
 function checkQueryParams(req, res) {
     var org = req.query['org'];
-    if(org != 'my-org') {
+    if(org && org !== 'my-org') {
         res.status(404).send(`{"code":"not found","message":"organization name \"${org}\" not found"}`);
         return false;
     } else {
diff --git a/test/test.ino b/test/test.ino
