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,16 +419,16 @@ 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),
             measurement.clone(),
         )
         .add_tag("kind", "PUT")
         .add_field("timestamp", timestamp.to_string())
-        .add_field("encoding_prefix", u16::from(encoding.id()))
+        .add_field("encoding_prefix", encoding.id())
         .add_field("encoding_suffix", encoding_string_rep) // TODO: Rename To Encoding and only keep String rep
         .add_field("base64", base64)
         .add_field("value", strvalue);
@@ -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);
+
         let mut result = Vec::new();
         match self.client.json_query(influx_query).await {
             Ok(mut query_result) => {
@@ -551,13 +551,9 @@ impl Storage for InfluxDbStorage {
                                 // for each point
                                 for zpoint in serie.values {
                                     // get the encoding
-                                    let encoding_prefix: u16 =
-                                        zpoint.encoding_prefix.try_into().map_err(|_| {
-                                            zerror!("Unknown encoding {}", zpoint.encoding_prefix)
-                                        })?;
 
                                     let encoding = if zpoint.encoding_suffix.is_empty() {
-                                        Encoding::new(encoding_prefix, None)
+                                        Encoding::new(zpoint.encoding_prefix.into(), None)
                                     } else {
                                         Encoding::from(zpoint.encoding_suffix)
                                     };

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"