Fix/createdb

Cargo.toml

@@ -44,7 +44,6 @@ serde = { version = "1.0.203", features = ["derive"] }
 serde_json = "1.0.94"
 tracing = "0.1"
 uuid = { version = "1.3.0", features = ["v4"] }
-
 zenoh = { version = "0.11.0-dev", git = "https://github.com/eclipse-zenoh/zenoh.git", branch = "dev/1.0.0", features = [
     "unstable",
     "internal",

v1/src/lib.rs

@@ -419,8 +419,8 @@ impl Storage for InfluxDbStorage {
         // Note: tags are stored as strings in InfluxDB, while fileds are typed.
         // For simpler/faster deserialization, we store encoding, timestamp and base64 as fields.
         // while the kind is stored as a tag to be indexed by InfluxDB and have faster queries on it.
-        let encoding_string_rep = value.encoding().clone().to_string(); // add_field only supports Strings and not Vec<u8>
-        let encoding: Encoding = (value.encoding().clone()).into();
+        let encoding_string_rep = value.encoding().to_string(); // add_field only supports Strings and not Vec<u8>
+        let encoding: &Encoding = value.encoding();
 
         let query = InfluxWQuery::new(
             InfluxTimestamp::Nanoseconds(influx_time),
@@ -501,7 +501,7 @@ impl Storage for InfluxDbStorage {
         key: Option<OwnedKeyExpr>,
         parameters: &str,
     ) -> ZResult<Vec<StoredData>> {
-        let measurement = match key.clone() {
+        let measurement = match key {
             Some(k) => k,
             None => OwnedKeyExpr::from_str(NONE_KEY).unwrap(),
         };
@@ -527,7 +527,7 @@ impl Storage for InfluxDbStorage {
             base64: bool,
             value: String,
         }
-        debug!("Get {:?} with Influx query: {}", key, influx_query_str);
+        // debug!("Get {:?} with Influx query: {}", &key, influx_query_str);
         let mut result = Vec::new();
         match self.client.json_query(influx_query).await {
             Ok(mut query_result) => {

v2/Cargo.toml

@@ -27,7 +27,8 @@ base64 = { workspace = true }
 chrono = { version = "0.4.31", features = ["serde"] }
 futures = "0.3.28"
 git-version = { workspace = true }
-influxdb2 = { version = "0.4.5", features = [
+
+influxdb2 = { version = "0.5.2", features = [
     "rustls",
 ], default-features = false }
 influxdb2-derive = "0.1.1"