Skip to content

Commit c34e84c

Browse files
committed
feat: add user and password to validation ping (caching removed)
1 parent 681ece9 commit c34e84c

File tree

2 files changed

+10
-12
lines changed

2 files changed

+10
-12
lines changed

src/InfluxDbClient.cpp

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -252,18 +252,12 @@ void InfluxDBClient::setUrls() {
252252
_queryUrl += "/api/v2/query?org=";
253253
_queryUrl += urlEncode(_org.c_str());
254254
INFLUXDB_CLIENT_DEBUG("[D] queryUrl: %s\n", _queryUrl.c_str());
255-
_validateUrl = _serverUrl;
256-
_validateUrl += "/health";
257-
INFLUXDB_CLIENT_DEBUG("[D] validateUrl: %s\n", _validateUrl.c_str());
258255
} else {
259256
_writeUrl = _serverUrl;
260257
_writeUrl += "/write?db=";
261258
_writeUrl += urlEncode(_bucket.c_str());
262259
_queryUrl = _serverUrl;
263260
_queryUrl += "/api/v2/query";
264-
// on version 1.x /ping will by default return status code 204, without verbose
265-
_validateUrl = _serverUrl;
266-
_validateUrl += "/ping?verbose=true";
267261
if(_user.length() > 0 && _password.length() > 0) {
268262
String auth = "&u=";
269263
auth += urlEncode(_user.c_str());
@@ -272,11 +266,9 @@ void InfluxDBClient::setUrls() {
272266
_writeUrl += auth;
273267
_queryUrl += "?";
274268
_queryUrl += auth;
275-
_validateUrl += auth;
276269
}
277270
INFLUXDB_CLIENT_DEBUG("[D] writeUrl: %s\n", _writeUrl.c_str());
278271
INFLUXDB_CLIENT_DEBUG("[D] queryUrl: %s\n", _queryUrl.c_str());
279-
INFLUXDB_CLIENT_DEBUG("[D] validateUrl: %s\n", _validateUrl.c_str());
280272
}
281273
if(_writeOptions._writePrecision != WritePrecision::NoTime) {
282274
_writeUrl += "&precision=";
@@ -551,9 +543,17 @@ bool InfluxDBClient::validateConnection() {
551543
_lastErrorResponse = FPSTR(UninitializedMessage);
552544
return false;
553545
}
554-
INFLUXDB_CLIENT_DEBUG("[D] Validating connection to %s\n", _serverUrl.c_str());
546+
// on version 1.x /ping will by default return status code 204, without verbose
547+
String url = _serverUrl + (_dbVersion==2?"/health":"/ping?verbose=true");
548+
if(_dbVersion==1 && _user.length() > 0 && _password.length() > 0) {
549+
url += "&u=";
550+
url += urlEncode(_user.c_str());
551+
url += "&p=";
552+
url += urlEncode(_password.c_str());
553+
}
554+
INFLUXDB_CLIENT_DEBUG("[D] Validating connection to %s\n", url.c_str());
555555

556-
if(!_httpClient->begin(*_wifiClient, _validateUrl)) {
556+
if(!_httpClient->begin(*_wifiClient, url)) {
557557
INFLUXDB_CLIENT_DEBUG("[E] begin failed\n");
558558
return false;
559559
}

src/InfluxDbClient.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -195,8 +195,6 @@ class InfluxDBClient {
195195
String _writeUrl;
196196
// Cached full query url
197197
String _queryUrl;
198-
// Cached full validation url
199-
String _validateUrl;
200198
// Points buffer
201199
Batch **_writeBuffer = nullptr;
202200
// Batch buffer size

0 commit comments

Comments
 (0)