diff --git a/code/components/jomjol_flowcontroll/ClassFlowInfluxDBv2.cpp b/code/components/jomjol_flowcontroll/ClassFlowInfluxDBv2.cpp index 67d917e3..bd423305 100644 --- a/code/components/jomjol_flowcontroll/ClassFlowInfluxDBv2.cpp +++ b/code/components/jomjol_flowcontroll/ClassFlowInfluxDBv2.cpp @@ -20,7 +20,7 @@ static const char* TAG = "INFLUXDBV2"; void ClassFlowInfluxDBv2::SetInitialParameter(void) { uri = ""; - database = ""; + bucket = ""; dborg = ""; dbtoken = ""; // dbfield = ""; @@ -109,9 +109,9 @@ bool ClassFlowInfluxDBv2::ReadParameter(FILE* pfile, string& aktparamgraph) { handleMeasurement(splitted[0], splitted[1]); } - if (((toUpper(splitted[0]) == "DATABASE")) && (splitted.size() > 1)) + if (((toUpper(splitted[0]) == "BUCKET")) && (splitted.size() > 1)) { - this->database = splitted[1]; + this->bucket = splitted[1]; } } @@ -119,11 +119,11 @@ bool ClassFlowInfluxDBv2::ReadParameter(FILE* pfile, string& aktparamgraph) printf("org: %s\n", dborg.c_str()); printf("token: %s\n", dbtoken.c_str()); - if ((uri.length() > 0) && (database.length() > 0) && (dbtoken.length() > 0) && (dborg.length() > 0)) + if ((uri.length() > 0) && (bucket.length() > 0) && (dbtoken.length() > 0) && (dborg.length() > 0)) { LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "Init InfluxDB with uri: " + uri + ", org: " + dborg + ", token: *****"); // printf("vor V2 Init\n"); - InfluxDB_V2_Init(uri, database, dborg, dbtoken); + InfluxDB_V2_Init(uri, bucket, dborg, dbtoken); // printf("nach V2 Init\n"); InfluxDBenable = true; } else { diff --git a/code/components/jomjol_flowcontroll/ClassFlowInfluxDBv2.h b/code/components/jomjol_flowcontroll/ClassFlowInfluxDBv2.h index 1c73d0c1..01ced8fa 100644 --- a/code/components/jomjol_flowcontroll/ClassFlowInfluxDBv2.h +++ b/code/components/jomjol_flowcontroll/ClassFlowInfluxDBv2.h @@ -15,7 +15,7 @@ class ClassFlowInfluxDBv2 : public ClassFlow { protected: - std::string uri, database; + std::string uri, bucket; std::string dborg, dbtoken, dbfield; std::string OldValue; ClassFlowPostProcessing* flowpostprocessing; diff --git a/code/components/jomjol_influxdb/interface_influxdb.cpp b/code/components/jomjol_influxdb/interface_influxdb.cpp index e1b22146..dfad9320 100644 --- a/code/components/jomjol_influxdb/interface_influxdb.cpp +++ b/code/components/jomjol_influxdb/interface_influxdb.cpp @@ -16,16 +16,16 @@ std::string _influxDBUser; std::string _influxDBPassword; std::string _influxDB_V2_URI; -std::string _influxDB_V2_Database; +std::string _influxDB_V2_Bucket; std::string _influxDB_V2_Token; std::string _influxDB_V2_Org; static esp_err_t http_event_handler(esp_http_client_event_t *evt); -void InfluxDB_V2_Init(std::string _uri, std::string _database, std::string _org, std::string _token) +void InfluxDB_V2_Init(std::string _uri, std::string _bucket, std::string _org, std::string _token) { _influxDB_V2_URI = _uri; - _influxDB_V2_Database = _database; + _influxDB_V2_Bucket = _bucket; _influxDB_V2_Org = _org; _influxDB_V2_Token = _token; } @@ -70,7 +70,7 @@ void InfluxDB_V2_Publish(std::string _measurement, std::string _key, std::string LogFile.WriteToFile(ESP_LOG_INFO, TAG, "sending line to influxdb:" + payload); - std::string apiURI = _influxDB_V2_URI + "/api/v2/write?org=" + _influxDB_V2_Org + "&bucket=" + _influxDB_V2_Database; + std::string apiURI = _influxDB_V2_URI + "/api/v2/write?org=" + _influxDB_V2_Org + "&bucket=" + _influxDB_V2_Bucket; apiURI.shrink_to_fit(); http_config.url = apiURI.c_str(); ESP_LOGI(TAG, "http_config: %s", http_config.url); // Add mark on log to see when it restarted @@ -183,7 +183,7 @@ void InfluxDBPublish(std::string _measurement, std::string _key, std::string _co LogFile.WriteToFile(ESP_LOG_INFO, TAG, "sending line to influxdb:" + payload); - // use the default retention policy of the database + // use the default retention policy of the bucket std::string apiURI = _influxDBURI + "/write?db=" + _influxDBDatabase; // std::string apiURI = _influxDBURI + "/api/v2/write?bucket=" + _influxDBDatabase + "/"; diff --git a/code/components/jomjol_influxdb/interface_influxdb.h b/code/components/jomjol_influxdb/interface_influxdb.h index bc29bf21..0d969800 100644 --- a/code/components/jomjol_influxdb/interface_influxdb.h +++ b/code/components/jomjol_influxdb/interface_influxdb.h @@ -13,7 +13,7 @@ void InfluxDBInit(std::string _influxDBURI, std::string _database, std::string _ void InfluxDBPublish(std::string _measurement, std::string _key, std::string _content, std::string _timestamp); // Interface to InfluxDB v2.x -void InfluxDB_V2_Init(std::string _uri, std::string _database, std::string _org, std::string _token); +void InfluxDB_V2_Init(std::string _uri, std::string _bucket, std::string _org, std::string _token); void InfluxDB_V2_Publish(std::string _measurement, std::string _key, std::string _content, std::string _timestamp); diff --git a/code/main/main.cpp b/code/main/main.cpp index a6774eab..7a508bba 100644 --- a/code/main/main.cpp +++ b/code/main/main.cpp @@ -642,7 +642,6 @@ void migrateConfiguration(void) { /* Fieldname has a as prefix! */ if (isInString(configLines[i], "Fieldname")) { // It is the parameter "Fieldname" migrated = migrated | replaceString(configLines[i], "Fieldname", "Field"); // Rename it to Field - migrated = migrated | replaceString(configLines[i], ";", ""); // Enable it } } @@ -650,7 +649,10 @@ void migrateConfiguration(void) { /* Fieldname has a as prefix! */ if (isInString(configLines[i], "Fieldname")) { // It is the parameter "Fieldname" migrated = migrated | replaceString(configLines[i], "Fieldname", "Field"); // Rename it to Field - migrated = migrated | replaceString(configLines[i], ";", ""); // Enable it + } + /* Database got renamed to Bucket! */ + if (isInString(configLines[i], "Database")) { // It is the parameter "Database" + migrated = migrated | replaceString(configLines[i], "Database", "Bucket"); // Rename it to Bucket } } @@ -814,4 +816,4 @@ bool setCpuFrequency(void) { } return true; -} \ No newline at end of file +} diff --git a/sd-card/config/config.ini b/sd-card/config/config.ini index 49a6718c..7179e354 100644 --- a/sd-card/config/config.ini +++ b/sd-card/config/config.ini @@ -75,7 +75,7 @@ HomeassistantDiscovery = false ;[InfluxDBv2] ;Uri = undefined -;Database = undefined +;Bucket = undefined ;Measurement = undefined ;Org = undefined ;Token = undefined diff --git a/sd-card/html/edit_config_param.html b/sd-card/html/edit_config_param.html index a3b4bcc2..ce3b8335 100644 --- a/sd-card/html/edit_config_param.html +++ b/sd-card/html/edit_config_param.html @@ -952,13 +952,13 @@ - - + + - + - $TOOLTIP_InfluxDBv2_Database + $TOOLTIP_InfluxDBv2_Bucket @@ -2134,7 +2134,7 @@ function UpdateInput() { // WriteParameter(param, category, "InfluxDB", "Field", true); WriteParameter(param, category, "InfluxDBv2", "Uri", true); - WriteParameter(param, category, "InfluxDBv2", "Database", true); + WriteParameter(param, category, "InfluxDBv2", "Bucket", true); // WriteParameter(param, category, "InfluxDBv2", "Measurement", true); WriteParameter(param, category, "InfluxDBv2", "Org", true); WriteParameter(param, category, "InfluxDBv2", "Token", true); @@ -2272,7 +2272,7 @@ function ReadParameterAll() ReadParameter(param, "InfluxDB", "password", true); ReadParameter(param, "InfluxDBv2", "Uri", true); - ReadParameter(param, "InfluxDBv2", "Database", true); + ReadParameter(param, "InfluxDBv2", "Bucket", true); ReadParameter(param, "InfluxDBv2", "Measurement", true); ReadParameter(param, "InfluxDBv2", "Org", true); ReadParameter(param, "InfluxDBv2", "Token", true); diff --git a/sd-card/html/readconfigparam.js b/sd-card/html/readconfigparam.js index 0c24add5..2de8a601 100644 --- a/sd-card/html/readconfigparam.js +++ b/sd-card/html/readconfigparam.js @@ -206,7 +206,7 @@ function ParseConfig() { category[catname]["found"] = false; param[catname] = new Object(); ParamAddValue(param, catname, "Uri"); - ParamAddValue(param, catname, "Database"); + ParamAddValue(param, catname, "Bucket"); // ParamAddValue(param, catname, "Measurement"); ParamAddValue(param, catname, "Org"); ParamAddValue(param, catname, "Token");