#[jacquard_derive::lexicon]
#[derive(
serde::Serialize,
serde::Deserialize,
Debug,
Clone,
PartialEq,
Eq,
jacquard_derive::IntoStatic
)]
#[serde(rename_all = "camelCase")]
pub struct MultiObservation<'a> {
#[serde(skip_serializing_if = "std::option::Option::is_none")]
#[serde(borrow)]
pub derived_from: std::option::Option<
Vec<jacquard_common::types::string::AtUri<'a>>,
>,
#[serde(borrow)]
pub entries: Vec<
crate::dev_sensorthings::multi_observation::MultiObservationEntry<'a>,
>,
pub phenomenon_time: jacquard_common::types::string::Datetime,
#[serde(skip_serializing_if = "std::option::Option::is_none")]
pub phenomenon_time_end: std::option::Option<
jacquard_common::types::string::Datetime,
>,
#[serde(skip_serializing_if = "std::option::Option::is_none")]
#[serde(borrow)]
pub result_quality: std::option::Option<MultiObservationResultQuality<'a>>,
#[serde(skip_serializing_if = "std::option::Option::is_none")]
pub result_time: std::option::Option<jacquard_common::types::string::Datetime>,
#[serde(borrow)]
pub sensor: jacquard_common::types::string::AtUri<'a>,
#[serde(borrow)]
pub thing: jacquard_common::types::string::AtUri<'a>,
}
pub mod multi_observation_state {
pub use crate::builder_types::{Set, Unset, IsSet, IsUnset};
#[allow(unused)]
use ::core::marker::PhantomData;
mod sealed {
pub trait Sealed {}
}
pub trait State: sealed::Sealed {
type PhenomenonTime;
type Thing;
type Sensor;
type Entries;
}
pub struct Empty(());
impl sealed::Sealed for Empty {}
impl State for Empty {
type PhenomenonTime = Unset;
type Thing = Unset;
type Sensor = Unset;
type Entries = Unset;
}
pub struct SetPhenomenonTime<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetPhenomenonTime<S> {}
impl<S: State> State for SetPhenomenonTime<S> {
type PhenomenonTime = Set<members::phenomenon_time>;
type Thing = S::Thing;
type Sensor = S::Sensor;
type Entries = S::Entries;
}
pub struct SetThing<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetThing<S> {}
impl<S: State> State for SetThing<S> {
type PhenomenonTime = S::PhenomenonTime;
type Thing = Set<members::thing>;
type Sensor = S::Sensor;
type Entries = S::Entries;
}
pub struct SetSensor<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetSensor<S> {}
impl<S: State> State for SetSensor<S> {
type PhenomenonTime = S::PhenomenonTime;
type Thing = S::Thing;
type Sensor = Set<members::sensor>;
type Entries = S::Entries;
}
pub struct SetEntries<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetEntries<S> {}
impl<S: State> State for SetEntries<S> {
type PhenomenonTime = S::PhenomenonTime;
type Thing = S::Thing;
type Sensor = S::Sensor;
type Entries = Set<members::entries>;
}
#[allow(non_camel_case_types)]
pub mod members {
pub struct phenomenon_time(());
pub struct thing(());
pub struct sensor(());
pub struct entries(());
}
}
pub struct MultiObservationBuilder<'a, S: multi_observation_state::State> {
_phantom_state: ::core::marker::PhantomData<fn() -> S>,
__unsafe_private_named: (
::core::option::Option<Vec<jacquard_common::types::string::AtUri<'a>>>,
::core::option::Option<
Vec<crate::dev_sensorthings::multi_observation::MultiObservationEntry<'a>>,
>,
::core::option::Option<jacquard_common::types::string::Datetime>,
::core::option::Option<jacquard_common::types::string::Datetime>,
::core::option::Option<MultiObservationResultQuality<'a>>,
::core::option::Option<jacquard_common::types::string::Datetime>,
::core::option::Option<jacquard_common::types::string::AtUri<'a>>,
::core::option::Option<jacquard_common::types::string::AtUri<'a>>,
),
_phantom: ::core::marker::PhantomData<&'a ()>,
}
impl<'a> MultiObservation<'a> {
pub fn new() -> MultiObservationBuilder<'a, multi_observation_state::Empty> {
MultiObservationBuilder::new()
}
}
impl<'a> MultiObservationBuilder<'a, multi_observation_state::Empty> {
pub fn new() -> Self {
MultiObservationBuilder {
_phantom_state: ::core::marker::PhantomData,
__unsafe_private_named: (None, None, None, None, None, None, None, None),
_phantom: ::core::marker::PhantomData,
}
}
}
impl<'a, S: multi_observation_state::State> MultiObservationBuilder<'a, S> {
pub fn derived_from(
mut self,
value: impl Into<Option<Vec<jacquard_common::types::string::AtUri<'a>>>>,
) -> Self {
self.__unsafe_private_named.0 = value.into();
self
}
pub fn maybe_derived_from(
mut self,
value: Option<Vec<jacquard_common::types::string::AtUri<'a>>>,
) -> Self {
self.__unsafe_private_named.0 = value;
self
}
}
impl<'a, S> MultiObservationBuilder<'a, S>
where
S: multi_observation_state::State,
S::Entries: multi_observation_state::IsUnset,
{
pub fn entries(
mut self,
value: impl Into<
Vec<crate::dev_sensorthings::multi_observation::MultiObservationEntry<'a>>,
>,
) -> MultiObservationBuilder<'a, multi_observation_state::SetEntries<S>> {
self.__unsafe_private_named.1 = ::core::option::Option::Some(value.into());
MultiObservationBuilder {
_phantom_state: ::core::marker::PhantomData,
__unsafe_private_named: self.__unsafe_private_named,
_phantom: ::core::marker::PhantomData,
}
}
}
impl<'a, S> MultiObservationBuilder<'a, S>
where
S: multi_observation_state::State,
S::PhenomenonTime: multi_observation_state::IsUnset,
{
pub fn phenomenon_time(
mut self,
value: impl Into<jacquard_common::types::string::Datetime>,
) -> MultiObservationBuilder<'a, multi_observation_state::SetPhenomenonTime<S>> {
self.__unsafe_private_named.2 = ::core::option::Option::Some(value.into());
MultiObservationBuilder {
_phantom_state: ::core::marker::PhantomData,
__unsafe_private_named: self.__unsafe_private_named,
_phantom: ::core::marker::PhantomData,
}
}
}
impl<'a, S: multi_observation_state::State> MultiObservationBuilder<'a, S> {
pub fn phenomenon_time_end(
mut self,
value: impl Into<Option<jacquard_common::types::string::Datetime>>,
) -> Self {
self.__unsafe_private_named.3 = value.into();
self
}
pub fn maybe_phenomenon_time_end(
mut self,
value: Option<jacquard_common::types::string::Datetime>,
) -> Self {
self.__unsafe_private_named.3 = value;
self
}
}
impl<'a, S: multi_observation_state::State> MultiObservationBuilder<'a, S> {
pub fn result_quality(
mut self,
value: impl Into<Option<MultiObservationResultQuality<'a>>>,
) -> Self {
self.__unsafe_private_named.4 = value.into();
self
}
pub fn maybe_result_quality(
mut self,
value: Option<MultiObservationResultQuality<'a>>,
) -> Self {
self.__unsafe_private_named.4 = value;
self
}
}
impl<'a, S: multi_observation_state::State> MultiObservationBuilder<'a, S> {
pub fn result_time(
mut self,
value: impl Into<Option<jacquard_common::types::string::Datetime>>,
) -> Self {
self.__unsafe_private_named.5 = value.into();
self
}
pub fn maybe_result_time(
mut self,
value: Option<jacquard_common::types::string::Datetime>,
) -> Self {
self.__unsafe_private_named.5 = value;
self
}
}
impl<'a, S> MultiObservationBuilder<'a, S>
where
S: multi_observation_state::State,
S::Sensor: multi_observation_state::IsUnset,
{
pub fn sensor(
mut self,
value: impl Into<jacquard_common::types::string::AtUri<'a>>,
) -> MultiObservationBuilder<'a, multi_observation_state::SetSensor<S>> {
self.__unsafe_private_named.6 = ::core::option::Option::Some(value.into());
MultiObservationBuilder {
_phantom_state: ::core::marker::PhantomData,
__unsafe_private_named: self.__unsafe_private_named,
_phantom: ::core::marker::PhantomData,
}
}
}
impl<'a, S> MultiObservationBuilder<'a, S>
where
S: multi_observation_state::State,
S::Thing: multi_observation_state::IsUnset,
{
pub fn thing(
mut self,
value: impl Into<jacquard_common::types::string::AtUri<'a>>,
) -> MultiObservationBuilder<'a, multi_observation_state::SetThing<S>> {
self.__unsafe_private_named.7 = ::core::option::Option::Some(value.into());
MultiObservationBuilder {
_phantom_state: ::core::marker::PhantomData,
__unsafe_private_named: self.__unsafe_private_named,
_phantom: ::core::marker::PhantomData,
}
}
}
impl<'a, S> MultiObservationBuilder<'a, S>
where
S: multi_observation_state::State,
S::PhenomenonTime: multi_observation_state::IsSet,
S::Thing: multi_observation_state::IsSet,
S::Sensor: multi_observation_state::IsSet,
S::Entries: multi_observation_state::IsSet,
{
pub fn build(self) -> MultiObservation<'a> {
MultiObservation {
derived_from: self.__unsafe_private_named.0,
entries: self.__unsafe_private_named.1.unwrap(),
phenomenon_time: self.__unsafe_private_named.2.unwrap(),
phenomenon_time_end: self.__unsafe_private_named.3,
result_quality: self.__unsafe_private_named.4,
result_time: self.__unsafe_private_named.5,
sensor: self.__unsafe_private_named.6.unwrap(),
thing: self.__unsafe_private_named.7.unwrap(),
extra_data: Default::default(),
}
}
pub fn build_with_data(
self,
extra_data: std::collections::BTreeMap<
jacquard_common::deps::smol_str::SmolStr,
jacquard_common::types::value::Data<'a>,
>,
) -> MultiObservation<'a> {
MultiObservation {
derived_from: self.__unsafe_private_named.0,
entries: self.__unsafe_private_named.1.unwrap(),
phenomenon_time: self.__unsafe_private_named.2.unwrap(),
phenomenon_time_end: self.__unsafe_private_named.3,
result_quality: self.__unsafe_private_named.4,
result_time: self.__unsafe_private_named.5,
sensor: self.__unsafe_private_named.6.unwrap(),
thing: self.__unsafe_private_named.7.unwrap(),
extra_data: Some(extra_data),
}
}
}
impl<'a> MultiObservation<'a> {
pub fn uri(
uri: impl Into<jacquard_common::CowStr<'a>>,
) -> Result<
jacquard_common::types::uri::RecordUri<'a, MultiObservationRecord>,
jacquard_common::types::uri::UriError,
> {
jacquard_common::types::uri::RecordUri::try_from_uri(
jacquard_common::types::string::AtUri::new_cow(uri.into())?,
)
}
}
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub enum MultiObservationResultQuality<'a> {
Good,
Suspect,
Missing,
Other(jacquard_common::CowStr<'a>),
}
impl<'a> MultiObservationResultQuality<'a> {
pub fn as_str(&self) -> &str {
match self {
Self::Good => "dev.sensorthings.quality#good",
Self::Suspect => "dev.sensorthings.quality#suspect",
Self::Missing => "dev.sensorthings.quality#missing",
Self::Other(s) => s.as_ref(),
}
}
}
impl<'a> From<&'a str> for MultiObservationResultQuality<'a> {
fn from(s: &'a str) -> Self {
match s {
"dev.sensorthings.quality#good" => Self::Good,
"dev.sensorthings.quality#suspect" => Self::Suspect,
"dev.sensorthings.quality#missing" => Self::Missing,
_ => Self::Other(jacquard_common::CowStr::from(s)),
}
}
}
impl<'a> From<String> for MultiObservationResultQuality<'a> {
fn from(s: String) -> Self {
match s.as_str() {
"dev.sensorthings.quality#good" => Self::Good,
"dev.sensorthings.quality#suspect" => Self::Suspect,
"dev.sensorthings.quality#missing" => Self::Missing,
_ => Self::Other(jacquard_common::CowStr::from(s)),
}
}
}
impl<'a> core::fmt::Display for MultiObservationResultQuality<'a> {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
write!(f, "{}", self.as_str())
}
}
impl<'a> AsRef<str> for MultiObservationResultQuality<'a> {
fn as_ref(&self) -> &str {
self.as_str()
}
}
impl<'a> serde::Serialize for MultiObservationResultQuality<'a> {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
serializer.serialize_str(self.as_str())
}
}
impl<'de, 'a> serde::Deserialize<'de> for MultiObservationResultQuality<'a>
where
'de: 'a,
{
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
let s = <&'de str>::deserialize(deserializer)?;
Ok(Self::from(s))
}
}
impl<'a> Default for MultiObservationResultQuality<'a> {
fn default() -> Self {
Self::Other(Default::default())
}
}
impl jacquard_common::IntoStatic for MultiObservationResultQuality<'_> {
type Output = MultiObservationResultQuality<'static>;
fn into_static(self) -> Self::Output {
match self {
MultiObservationResultQuality::Good => MultiObservationResultQuality::Good,
MultiObservationResultQuality::Suspect => {
MultiObservationResultQuality::Suspect
}
MultiObservationResultQuality::Missing => {
MultiObservationResultQuality::Missing
}
MultiObservationResultQuality::Other(v) => {
MultiObservationResultQuality::Other(v.into_static())
}
}
}
}
#[derive(
serde::Serialize,
serde::Deserialize,
Debug,
Clone,
PartialEq,
Eq,
jacquard_derive::IntoStatic
)]
#[serde(rename_all = "camelCase")]
pub struct MultiObservationGetRecordOutput<'a> {
#[serde(skip_serializing_if = "std::option::Option::is_none")]
#[serde(borrow)]
pub cid: std::option::Option<jacquard_common::types::string::Cid<'a>>,
#[serde(borrow)]
pub uri: jacquard_common::types::string::AtUri<'a>,
#[serde(borrow)]
pub value: MultiObservation<'a>,
}
impl From<MultiObservationGetRecordOutput<'_>> for MultiObservation<'_> {
fn from(output: MultiObservationGetRecordOutput<'_>) -> Self {
use jacquard_common::IntoStatic;
output.value.into_static()
}
}
impl jacquard_common::types::collection::Collection for MultiObservation<'_> {
const NSID: &'static str = "dev.sensorthings.multiObservation";
type Record = MultiObservationRecord;
}
#[derive(Debug, serde::Serialize, serde::Deserialize)]
pub struct MultiObservationRecord;
impl jacquard_common::xrpc::XrpcResp for MultiObservationRecord {
const NSID: &'static str = "dev.sensorthings.multiObservation";
const ENCODING: &'static str = "application/json";
type Output<'de> = MultiObservationGetRecordOutput<'de>;
type Err<'de> = jacquard_common::types::collection::RecordError<'de>;
}
impl jacquard_common::types::collection::Collection for MultiObservationRecord {
const NSID: &'static str = "dev.sensorthings.multiObservation";
type Record = MultiObservationRecord;
}
impl<'a> ::jacquard_lexicon::schema::LexiconSchema for MultiObservation<'a> {
fn nsid() -> &'static str {
"dev.sensorthings.multiObservation"
}
fn def_name() -> &'static str {
"main"
}
fn lexicon_doc() -> ::jacquard_lexicon::lexicon::LexiconDoc<'static> {
lexicon_doc_dev_sensorthings_multiObservation()
}
fn validate(
&self,
) -> ::core::result::Result<(), ::jacquard_lexicon::validation::ConstraintError> {
if let Some(ref value) = self.derived_from {
#[allow(unused_comparisons)]
if value.len() > 16usize {
return Err(::jacquard_lexicon::validation::ConstraintError::MaxLength {
path: ::jacquard_lexicon::validation::ValidationPath::from_field(
"derived_from",
),
max: 16usize,
actual: value.len(),
});
}
}
{
let value = &self.entries;
#[allow(unused_comparisons)]
if value.len() > 32usize {
return Err(::jacquard_lexicon::validation::ConstraintError::MaxLength {
path: ::jacquard_lexicon::validation::ValidationPath::from_field(
"entries",
),
max: 32usize,
actual: value.len(),
});
}
}
if let Some(ref value) = self.result_quality {
#[allow(unused_comparisons)]
if <str>::len(value.as_ref()) > 64usize {
return Err(::jacquard_lexicon::validation::ConstraintError::MaxLength {
path: ::jacquard_lexicon::validation::ValidationPath::from_field(
"result_quality",
),
max: 64usize,
actual: <str>::len(value.as_ref()),
});
}
}
Ok(())
}
}
fn lexicon_doc_dev_sensorthings_multiObservation() -> ::jacquard_lexicon::lexicon::LexiconDoc<
'static,
> {
::jacquard_lexicon::lexicon::LexiconDoc {
lexicon: ::jacquard_lexicon::lexicon::Lexicon::Lexicon1,
id: ::jacquard_common::CowStr::new_static("dev.sensorthings.multiObservation"),
revision: None,
description: None,
defs: {
let mut map = ::alloc::collections::BTreeMap::new();
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static("main"),
::jacquard_lexicon::lexicon::LexUserType::Record(::jacquard_lexicon::lexicon::LexRecord {
description: Some(
::jacquard_common::CowStr::new_static(
"A composite observation bundling multiple co-produced results from a single act of sensing. Each entry carries its own ObservedProperty, unit, and scale metadata. Use this instead of separate Observations when the results are genuinely co-produced (e.g. wave statistics from spectral processing) and have no independent existence.",
),
),
key: Some(::jacquard_common::CowStr::new_static("any")),
record: ::jacquard_lexicon::lexicon::LexRecordRecord::Object(::jacquard_lexicon::lexicon::LexObject {
description: None,
required: Some(
vec![
::jacquard_common::deps::smol_str::SmolStr::new_static("thing"),
::jacquard_common::deps::smol_str::SmolStr::new_static("sensor"),
::jacquard_common::deps::smol_str::SmolStr::new_static("phenomenonTime"),
::jacquard_common::deps::smol_str::SmolStr::new_static("entries")
],
),
nullable: None,
properties: {
#[allow(unused_mut)]
let mut map = ::alloc::collections::BTreeMap::new();
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"derivedFrom",
),
::jacquard_lexicon::lexicon::LexObjectProperty::Array(::jacquard_lexicon::lexicon::LexArray {
description: Some(
::jacquard_common::CowStr::new_static(
"AT-URIs of source observations or datastreams",
),
),
items: ::jacquard_lexicon::lexicon::LexArrayItem::String(::jacquard_lexicon::lexicon::LexString {
description: None,
format: Some(
::jacquard_lexicon::lexicon::LexStringFormat::AtUri,
),
default: None,
min_length: None,
max_length: None,
min_graphemes: None,
max_graphemes: None,
r#enum: None,
r#const: None,
known_values: None,
}),
min_length: None,
max_length: Some(16usize),
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"entries",
),
::jacquard_lexicon::lexicon::LexObjectProperty::Array(::jacquard_lexicon::lexicon::LexArray {
description: Some(
::jacquard_common::CowStr::new_static(
"Array of co-produced result entries",
),
),
items: ::jacquard_lexicon::lexicon::LexArrayItem::Ref(::jacquard_lexicon::lexicon::LexRef {
description: None,
r#ref: ::jacquard_common::CowStr::new_static(
"#multiObservationEntry",
),
}),
min_length: None,
max_length: Some(32usize),
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"phenomenonTime",
),
::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString {
description: Some(
::jacquard_common::CowStr::new_static(
"Time the phenomenon was observed. Start of interval if phenomenonTimeEnd is present.",
),
),
format: Some(
::jacquard_lexicon::lexicon::LexStringFormat::Datetime,
),
default: None,
min_length: None,
max_length: None,
min_graphemes: None,
max_graphemes: None,
r#enum: None,
r#const: None,
known_values: None,
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"phenomenonTimeEnd",
),
::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString {
description: Some(
::jacquard_common::CowStr::new_static(
"End of observation interval. For wave statistics, this is the end of the burst window.",
),
),
format: Some(
::jacquard_lexicon::lexicon::LexStringFormat::Datetime,
),
default: None,
min_length: None,
max_length: None,
min_graphemes: None,
max_graphemes: None,
r#enum: None,
r#const: None,
known_values: None,
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"resultQuality",
),
::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString {
description: Some(
::jacquard_common::CowStr::new_static(
"Quality flag applying to the composite observation as a whole",
),
),
format: None,
default: None,
min_length: None,
max_length: Some(64usize),
min_graphemes: None,
max_graphemes: None,
r#enum: None,
r#const: None,
known_values: None,
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"resultTime",
),
::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString {
description: Some(
::jacquard_common::CowStr::new_static(
"Time the results became available",
),
),
format: Some(
::jacquard_lexicon::lexicon::LexStringFormat::Datetime,
),
default: None,
min_length: None,
max_length: None,
min_graphemes: None,
max_graphemes: None,
r#enum: None,
r#const: None,
known_values: None,
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"sensor",
),
::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString {
description: Some(
::jacquard_common::CowStr::new_static(
"AT-URI of the dev.sensorthings.sensor record (the instrument or process that co-produced these results)",
),
),
format: Some(
::jacquard_lexicon::lexicon::LexStringFormat::AtUri,
),
default: None,
min_length: None,
max_length: None,
min_graphemes: None,
max_graphemes: None,
r#enum: None,
r#const: None,
known_values: None,
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"thing",
),
::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString {
description: Some(
::jacquard_common::CowStr::new_static(
"AT-URI of the dev.sensorthings.thing record",
),
),
format: Some(
::jacquard_lexicon::lexicon::LexStringFormat::AtUri,
),
default: None,
min_length: None,
max_length: None,
min_graphemes: None,
max_graphemes: None,
r#enum: None,
r#const: None,
known_values: None,
}),
);
map
},
}),
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"multiObservationEntry",
),
::jacquard_lexicon::lexicon::LexUserType::Object(::jacquard_lexicon::lexicon::LexObject {
description: Some(
::jacquard_common::CowStr::new_static(
"A single result within a composite observation, fully self-describing.",
),
),
required: Some(
vec![
::jacquard_common::deps::smol_str::SmolStr::new_static("observedProperty"),
::jacquard_common::deps::smol_str::SmolStr::new_static("unitOfMeasurement"),
::jacquard_common::deps::smol_str::SmolStr::new_static("result")
],
),
nullable: None,
properties: {
#[allow(unused_mut)]
let mut map = ::alloc::collections::BTreeMap::new();
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"observedProperty",
),
::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString {
description: Some(
::jacquard_common::CowStr::new_static(
"AT-URI of the dev.sensorthings.observedProperty record",
),
),
format: Some(
::jacquard_lexicon::lexicon::LexStringFormat::AtUri,
),
default: None,
min_length: None,
max_length: None,
min_graphemes: None,
max_graphemes: None,
r#enum: None,
r#const: None,
known_values: None,
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"result",
),
::jacquard_lexicon::lexicon::LexObjectProperty::Union(::jacquard_lexicon::lexicon::LexRefUnion {
description: None,
refs: vec![
::jacquard_common::CowStr::new_static("dev.sensorthings.observation#numericResult"),
::jacquard_common::CowStr::new_static("dev.sensorthings.observation#categoryResult"),
::jacquard_common::CowStr::new_static("dev.sensorthings.observation#booleanResult"),
::jacquard_common::CowStr::new_static("dev.sensorthings.observation#arrayResult"),
::jacquard_common::CowStr::new_static("dev.sensorthings.observation#geoPointResult")
],
closed: None,
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"resultQuality",
),
::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString {
description: Some(
::jacquard_common::CowStr::new_static(
"Quality flag for this specific entry, if different from the composite quality",
),
),
format: None,
default: None,
min_length: None,
max_length: Some(64usize),
min_graphemes: None,
max_graphemes: None,
r#enum: None,
r#const: None,
known_values: None,
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"resultScaleFactor",
),
::jacquard_lexicon::lexicon::LexObjectProperty::Integer(::jacquard_lexicon::lexicon::LexInteger {
description: None,
default: None,
minimum: None,
maximum: None,
r#enum: None,
r#const: None,
}),
);
map.insert(
::jacquard_common::deps::smol_str::SmolStr::new_static(
"unitOfMeasurement",
),
::jacquard_lexicon::lexicon::LexObjectProperty::Ref(::jacquard_lexicon::lexicon::LexRef {
description: None,
r#ref: ::jacquard_common::CowStr::new_static(
"dev.sensorthings.datastream#unitOfMeasurement",
),
}),
);
map
},
}),
);
map
},
}
}
#[jacquard_derive::lexicon]
#[derive(
serde::Serialize,
serde::Deserialize,
Debug,
Clone,
PartialEq,
Eq,
jacquard_derive::IntoStatic
)]
#[serde(rename_all = "camelCase")]
pub struct MultiObservationEntry<'a> {
#[serde(borrow)]
pub observed_property: jacquard_common::types::string::AtUri<'a>,
#[serde(borrow)]
pub result: MultiObservationEntryResult<'a>,
#[serde(skip_serializing_if = "std::option::Option::is_none")]
#[serde(borrow)]
pub result_quality: std::option::Option<MultiObservationEntryResultQuality<'a>>,
#[serde(skip_serializing_if = "std::option::Option::is_none")]
pub result_scale_factor: std::option::Option<i64>,
#[serde(borrow)]
pub unit_of_measurement: crate::dev_sensorthings::datastream::UnitOfMeasurement<'a>,
}
pub mod multi_observation_entry_state {
pub use crate::builder_types::{Set, Unset, IsSet, IsUnset};
#[allow(unused)]
use ::core::marker::PhantomData;
mod sealed {
pub trait Sealed {}
}
pub trait State: sealed::Sealed {
type UnitOfMeasurement;
type ObservedProperty;
type Result;
}
pub struct Empty(());
impl sealed::Sealed for Empty {}
impl State for Empty {
type UnitOfMeasurement = Unset;
type ObservedProperty = Unset;
type Result = Unset;
}
pub struct SetUnitOfMeasurement<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetUnitOfMeasurement<S> {}
impl<S: State> State for SetUnitOfMeasurement<S> {
type UnitOfMeasurement = Set<members::unit_of_measurement>;
type ObservedProperty = S::ObservedProperty;
type Result = S::Result;
}
pub struct SetObservedProperty<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetObservedProperty<S> {}
impl<S: State> State for SetObservedProperty<S> {
type UnitOfMeasurement = S::UnitOfMeasurement;
type ObservedProperty = Set<members::observed_property>;
type Result = S::Result;
}
pub struct SetResult<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetResult<S> {}
impl<S: State> State for SetResult<S> {
type UnitOfMeasurement = S::UnitOfMeasurement;
type ObservedProperty = S::ObservedProperty;
type Result = Set<members::result>;
}
#[allow(non_camel_case_types)]
pub mod members {
pub struct unit_of_measurement(());
pub struct observed_property(());
pub struct result(());
}
}
pub struct MultiObservationEntryBuilder<'a, S: multi_observation_entry_state::State> {
_phantom_state: ::core::marker::PhantomData<fn() -> S>,
__unsafe_private_named: (
::core::option::Option<jacquard_common::types::string::AtUri<'a>>,
::core::option::Option<MultiObservationEntryResult<'a>>,
::core::option::Option<MultiObservationEntryResultQuality<'a>>,
::core::option::Option<i64>,
::core::option::Option<
crate::dev_sensorthings::datastream::UnitOfMeasurement<'a>,
>,
),
_phantom: ::core::marker::PhantomData<&'a ()>,
}
impl<'a> MultiObservationEntry<'a> {
pub fn new() -> MultiObservationEntryBuilder<
'a,
multi_observation_entry_state::Empty,
> {
MultiObservationEntryBuilder::new()
}
}
impl<'a> MultiObservationEntryBuilder<'a, multi_observation_entry_state::Empty> {
pub fn new() -> Self {
MultiObservationEntryBuilder {
_phantom_state: ::core::marker::PhantomData,
__unsafe_private_named: (None, None, None, None, None),
_phantom: ::core::marker::PhantomData,
}
}
}
impl<'a, S> MultiObservationEntryBuilder<'a, S>
where
S: multi_observation_entry_state::State,
S::ObservedProperty: multi_observation_entry_state::IsUnset,
{
pub fn observed_property(
mut self,
value: impl Into<jacquard_common::types::string::AtUri<'a>>,
) -> MultiObservationEntryBuilder<
'a,
multi_observation_entry_state::SetObservedProperty<S>,
> {
self.__unsafe_private_named.0 = ::core::option::Option::Some(value.into());
MultiObservationEntryBuilder {
_phantom_state: ::core::marker::PhantomData,
__unsafe_private_named: self.__unsafe_private_named,
_phantom: ::core::marker::PhantomData,
}
}
}
impl<'a, S> MultiObservationEntryBuilder<'a, S>
where
S: multi_observation_entry_state::State,
S::Result: multi_observation_entry_state::IsUnset,
{
pub fn result(
mut self,
value: impl Into<MultiObservationEntryResult<'a>>,
) -> MultiObservationEntryBuilder<'a, multi_observation_entry_state::SetResult<S>> {
self.__unsafe_private_named.1 = ::core::option::Option::Some(value.into());
MultiObservationEntryBuilder {
_phantom_state: ::core::marker::PhantomData,
__unsafe_private_named: self.__unsafe_private_named,
_phantom: ::core::marker::PhantomData,
}
}
}
impl<'a, S: multi_observation_entry_state::State> MultiObservationEntryBuilder<'a, S> {
pub fn result_quality(
mut self,
value: impl Into<Option<MultiObservationEntryResultQuality<'a>>>,
) -> Self {
self.__unsafe_private_named.2 = value.into();
self
}
pub fn maybe_result_quality(
mut self,
value: Option<MultiObservationEntryResultQuality<'a>>,
) -> Self {
self.__unsafe_private_named.2 = value;
self
}
}
impl<'a, S: multi_observation_entry_state::State> MultiObservationEntryBuilder<'a, S> {
pub fn result_scale_factor(mut self, value: impl Into<Option<i64>>) -> Self {
self.__unsafe_private_named.3 = value.into();
self
}
pub fn maybe_result_scale_factor(mut self, value: Option<i64>) -> Self {
self.__unsafe_private_named.3 = value;
self
}
}
impl<'a, S> MultiObservationEntryBuilder<'a, S>
where
S: multi_observation_entry_state::State,
S::UnitOfMeasurement: multi_observation_entry_state::IsUnset,
{
pub fn unit_of_measurement(
mut self,
value: impl Into<crate::dev_sensorthings::datastream::UnitOfMeasurement<'a>>,
) -> MultiObservationEntryBuilder<
'a,
multi_observation_entry_state::SetUnitOfMeasurement<S>,
> {
self.__unsafe_private_named.4 = ::core::option::Option::Some(value.into());
MultiObservationEntryBuilder {
_phantom_state: ::core::marker::PhantomData,
__unsafe_private_named: self.__unsafe_private_named,
_phantom: ::core::marker::PhantomData,
}
}
}
impl<'a, S> MultiObservationEntryBuilder<'a, S>
where
S: multi_observation_entry_state::State,
S::UnitOfMeasurement: multi_observation_entry_state::IsSet,
S::ObservedProperty: multi_observation_entry_state::IsSet,
S::Result: multi_observation_entry_state::IsSet,
{
pub fn build(self) -> MultiObservationEntry<'a> {
MultiObservationEntry {
observed_property: self.__unsafe_private_named.0.unwrap(),
result: self.__unsafe_private_named.1.unwrap(),
result_quality: self.__unsafe_private_named.2,
result_scale_factor: self.__unsafe_private_named.3,
unit_of_measurement: self.__unsafe_private_named.4.unwrap(),
extra_data: Default::default(),
}
}
pub fn build_with_data(
self,
extra_data: std::collections::BTreeMap<
jacquard_common::deps::smol_str::SmolStr,
jacquard_common::types::value::Data<'a>,
>,
) -> MultiObservationEntry<'a> {
MultiObservationEntry {
observed_property: self.__unsafe_private_named.0.unwrap(),
result: self.__unsafe_private_named.1.unwrap(),
result_quality: self.__unsafe_private_named.2,
result_scale_factor: self.__unsafe_private_named.3,
unit_of_measurement: self.__unsafe_private_named.4.unwrap(),
extra_data: Some(extra_data),
}
}
}
#[jacquard_derive::open_union]
#[derive(
serde::Serialize,
serde::Deserialize,
Debug,
Clone,
PartialEq,
Eq,
jacquard_derive::IntoStatic
)]
#[serde(tag = "$type")]
#[serde(bound(deserialize = "'de: 'a"))]
pub enum MultiObservationEntryResult<'a> {}
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub enum MultiObservationEntryResultQuality<'a> {
Good,
Suspect,
Missing,
Other(jacquard_common::CowStr<'a>),
}
impl<'a> MultiObservationEntryResultQuality<'a> {
pub fn as_str(&self) -> &str {
match self {
Self::Good => "dev.sensorthings.quality#good",
Self::Suspect => "dev.sensorthings.quality#suspect",
Self::Missing => "dev.sensorthings.quality#missing",
Self::Other(s) => s.as_ref(),
}
}
}
impl<'a> From<&'a str> for MultiObservationEntryResultQuality<'a> {
fn from(s: &'a str) -> Self {
match s {
"dev.sensorthings.quality#good" => Self::Good,
"dev.sensorthings.quality#suspect" => Self::Suspect,
"dev.sensorthings.quality#missing" => Self::Missing,
_ => Self::Other(jacquard_common::CowStr::from(s)),
}
}
}
impl<'a> From<String> for MultiObservationEntryResultQuality<'a> {
fn from(s: String) -> Self {
match s.as_str() {
"dev.sensorthings.quality#good" => Self::Good,
"dev.sensorthings.quality#suspect" => Self::Suspect,
"dev.sensorthings.quality#missing" => Self::Missing,
_ => Self::Other(jacquard_common::CowStr::from(s)),
}
}
}
impl<'a> core::fmt::Display for MultiObservationEntryResultQuality<'a> {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
write!(f, "{}", self.as_str())
}
}
impl<'a> AsRef<str> for MultiObservationEntryResultQuality<'a> {
fn as_ref(&self) -> &str {
self.as_str()
}
}
impl<'a> serde::Serialize for MultiObservationEntryResultQuality<'a> {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: serde::Serializer,
{
serializer.serialize_str(self.as_str())
}
}
impl<'de, 'a> serde::Deserialize<'de> for MultiObservationEntryResultQuality<'a>
where
'de: 'a,
{
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: serde::Deserializer<'de>,
{
let s = <&'de str>::deserialize(deserializer)?;
Ok(Self::from(s))
}
}
impl<'a> Default for MultiObservationEntryResultQuality<'a> {
fn default() -> Self {
Self::Other(Default::default())
}
}
impl jacquard_common::IntoStatic for MultiObservationEntryResultQuality<'_> {
type Output = MultiObservationEntryResultQuality<'static>;
fn into_static(self) -> Self::Output {
match self {
MultiObservationEntryResultQuality::Good => {
MultiObservationEntryResultQuality::Good
}
MultiObservationEntryResultQuality::Suspect => {
MultiObservationEntryResultQuality::Suspect
}
MultiObservationEntryResultQuality::Missing => {
MultiObservationEntryResultQuality::Missing
}
MultiObservationEntryResultQuality::Other(v) => {
MultiObservationEntryResultQuality::Other(v.into_static())
}
}
}
}
impl<'a> ::jacquard_lexicon::schema::LexiconSchema for MultiObservationEntry<'a> {
fn nsid() -> &'static str {
"dev.sensorthings.multiObservation"
}
fn def_name() -> &'static str {
"multiObservationEntry"
}
fn lexicon_doc() -> ::jacquard_lexicon::lexicon::LexiconDoc<'static> {
lexicon_doc_dev_sensorthings_multiObservation()
}
fn validate(
&self,
) -> ::core::result::Result<(), ::jacquard_lexicon::validation::ConstraintError> {
if let Some(ref value) = self.result_quality {
#[allow(unused_comparisons)]
if <str>::len(value.as_ref()) > 64usize {
return Err(::jacquard_lexicon::validation::ConstraintError::MaxLength {
path: ::jacquard_lexicon::validation::ValidationPath::from_field(
"result_quality",
),
max: 64usize,
actual: <str>::len(value.as_ref()),
});
}
}
Ok(())
}
}