Create a ClientTrait for RustSDK

databroker-cli/src/sdv_cli.rs

@@ -1,5 +1,5 @@
 /********************************************************************************
-* Copyright (c) 2023 Contributors to the Eclipse Foundation
+* Copyright (c) 2025 Contributors to the Eclipse Foundation
 *
 * See the NOTICE file(s) distributed with this work for additional
 * information regarding copyright ownership.
@@ -12,6 +12,7 @@
 ********************************************************************************/
 
 use databroker_proto::sdv::databroker as proto;
+use kuksa_common::SDVClientTraitV1;
 use kuksa_sdv::*;
 
 use prost_types::Timestamp;
@@ -451,7 +452,7 @@ pub async fn sdv_main(_cli: Cli) -> Result<(), Box<dyn std::error::Error>> {
                                 }
                                 let ts = Timestamp::from(SystemTime::now());
                                 let datapoints = HashMap::from([(
-                                    metadata.id,
+                                    metadata.name.clone(),
                                     proto::v1::Datapoint {
                                         timestamp: Some(ts),
                                         value: Some(data_value.unwrap()),

databroker/tests/read_write_values.rs

@@ -1,5 +1,5 @@
 /********************************************************************************
- * Copyright (c) 2023 Contributors to the Eclipse Foundation
+ * Copyright (c) 2025 Contributors to the Eclipse Foundation
  *
  * See the NOTICE file(s) distributed with this work for additional
  * information regarding copyright ownership.
@@ -17,6 +17,7 @@ use std::{collections::HashMap, future, time::SystemTime, vec};
 use cucumber::{cli, gherkin::Step, given, then, when, writer, World as _};
 use databroker::broker;
 use databroker_proto::kuksa::val::v1::{datapoint::Value, DataType, Datapoint};
+use kuksa_common::ClientTraitV1;
 use tracing::debug;
 use world::{DataBrokerWorld, ValueType};
 

lib/common/Cargo.toml

@@ -26,6 +26,12 @@ tokio = { workspace = true, features = [
 ] }
 tokio-stream = { workspace = true, features = ["sync"] }
 http = "0.2.8"
+log = "0.4"
+env_logger = "0.11"
+
+[dev-dependencies]
+prost = "0.12"
+prost-types = "0.12"
 
 [lib]
 name = "kuksa_common"