Initial publish request values implementation for OpenProviderStream

SoftwareDefinedVehicle · Jul 25, 2024 · 5116fe6 · 5116fe6
1 parent fbd5fb5
commit 5116fe6
Show file tree

Hide file tree

Showing 9 changed files with 449 additions and 372 deletions.
diff --git a/databroker/src/broker.rs b/databroker/src/broker.rs
@@ -15,7 +15,7 @@ use crate::permissions::{PermissionError, Permissions};
 pub use crate::types;
 
 use crate::query;
-pub use crate::types::{ChangeType, DataType, DataValue, EntryType};
+pub use crate::types::{ChangeType, DataType, DataValue, EntryType, ValueFailure};
 
 use tokio::sync::{broadcast, mpsc, RwLock};
 use tokio_stream::wrappers::ReceiverStream;

diff --git a/databroker/src/grpc/kuksa_val_v1/conversions.rs b/databroker/src/grpc/kuksa_val_v1/conversions.rs
@@ -143,6 +143,7 @@ impl From<broker::Datapoint> for Option<proto::Datapoint> {
                 })),
                 timestamp: Some(from.ts.into()),
             }),
+            broker::DataValue::ValueFailure(_) => None,
         }
     }
 }
@@ -231,6 +232,7 @@ impl From<broker::DataValue> for Option<proto::Datapoint> {
                 })),
                 timestamp: None,
             }),
+            broker::DataValue::ValueFailure(_) => None,
         }
     }
 }

diff --git a/databroker/src/grpc/kuksa_val_v2/conversions.rs b/databroker/src/grpc/kuksa_val_v2/conversions.rs
diff --git a/databroker/src/grpc/kuksa_val_v2/mod.rs b/databroker/src/grpc/kuksa_val_v2/mod.rs
@@ -1,5 +1,5 @@
 /********************************************************************************
-* Copyright (c) 2022 Contributors to the Eclipse Foundation
+* Copyright (c) 2024 Contributors to the Eclipse Foundation
 *
 * See the NOTICE file(s) distributed with this work for additional
 * information regarding copyright ownership.