#[derive(Debug, Clone, Default, PartialEq, Eq)]
pub struct SubscriptionStatus {
pub id: Option<std::string::String>,
pub meta: Option<super::meta::Meta>,
pub implicit_rules: Option<super::primitives::Uri>,
pub language: Option<super::primitives::Code>,
pub text: Option<super::narrative::Narrative>,
pub contained: Vec<super::resource::Resource>,
pub extension: Vec<super::extension::Extension>,
pub modifier_extension: Vec<super::extension::Extension>,
pub status: Option<super::primitives::Code>,
pub r#type: super::primitives::Code,
pub events_since_subscription_start: Option<super::primitives::String>,
pub notification_event: Vec<SubscriptionStatusNotificationEvent>,
pub subscription: super::reference::Reference,
pub topic: Option<super::primitives::Canonical>,
pub error: Vec<super::codeable_concept::CodeableConcept>,
}
impl super::super::codec::Json for SubscriptionStatus {
fn to_json(&self) -> Result<super::super::codec::Object, super::super::codec::EncodeError> {
let mut object = super::super::codec::Object::new();
object.insert(
std::string::String::from("resourceType"),
super::super::codec::Value::String(std::string::String::from("SubscriptionStatus")),
);
if let Some(v) = &self.id {
object.insert(
std::string::String::from("id"),
super::super::codec::Value::String(v.clone()),
);
}
if let Some(item) = &self.meta {
object.insert(
std::string::String::from("meta"),
super::super::codec::Value::Object(super::super::codec::Json::to_json(item)?),
);
}
if let Some(item) = &self.implicit_rules {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("implicitRules"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_implicitRules"), e);
}
}
if let Some(item) = &self.language {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("language"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_language"), e);
}
}
if let Some(item) = &self.text {
object.insert(
std::string::String::from("text"),
super::super::codec::Value::Object(super::super::codec::Json::to_json(item)?),
);
}
if !self.contained.is_empty() {
let mut items = Vec::with_capacity(self.contained.len());
for item in &self.contained {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("contained"),
super::super::codec::Value::Array(items),
);
}
if !self.extension.is_empty() {
let mut items = Vec::with_capacity(self.extension.len());
for item in &self.extension {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("extension"),
super::super::codec::Value::Array(items),
);
}
if !self.modifier_extension.is_empty() {
let mut items = Vec::with_capacity(self.modifier_extension.len());
for item in &self.modifier_extension {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("modifierExtension"),
super::super::codec::Value::Array(items),
);
}
if let Some(item) = &self.status {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("status"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_status"), e);
}
}
if let Some(v) = super::super::codec::Primitive::value_json(&self.r#type)? {
object.insert(std::string::String::from("type"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(&self.r#type)? {
object.insert(std::string::String::from("_type"), e);
}
if let Some(item) = &self.events_since_subscription_start {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("eventsSinceSubscriptionStart"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(
std::string::String::from("_eventsSinceSubscriptionStart"),
e,
);
}
}
if !self.notification_event.is_empty() {
let mut items = Vec::with_capacity(self.notification_event.len());
for item in &self.notification_event {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("notificationEvent"),
super::super::codec::Value::Array(items),
);
}
object.insert(
std::string::String::from("subscription"),
super::super::codec::Value::Object(super::super::codec::Json::to_json(
&self.subscription,
)?),
);
if let Some(item) = &self.topic {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("topic"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_topic"), e);
}
}
if !self.error.is_empty() {
let mut items = Vec::with_capacity(self.error.len());
for item in &self.error {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("error"),
super::super::codec::Value::Array(items),
);
}
Ok(object)
}
fn from_json(
object: &super::super::codec::Object,
path: &mut super::super::codec::Path,
) -> Result<Self, super::super::codec::DecodeError> {
let mut raw_id: Option<&super::super::codec::Value> = None;
let mut raw_meta: Option<&super::super::codec::Value> = None;
let mut raw_implicit_rules: Option<&super::super::codec::Value> = None;
let mut raw_implicit_rules_element: Option<&super::super::codec::Value> = None;
let mut raw_language: Option<&super::super::codec::Value> = None;
let mut raw_language_element: Option<&super::super::codec::Value> = None;
let mut raw_text: Option<&super::super::codec::Value> = None;
let mut raw_contained: Option<&super::super::codec::Value> = None;
let mut raw_extension: Option<&super::super::codec::Value> = None;
let mut raw_modifier_extension: Option<&super::super::codec::Value> = None;
let mut raw_status: Option<&super::super::codec::Value> = None;
let mut raw_status_element: Option<&super::super::codec::Value> = None;
let mut raw_type: Option<&super::super::codec::Value> = None;
let mut raw_type_element: Option<&super::super::codec::Value> = None;
let mut raw_events_since_subscription_start: Option<&super::super::codec::Value> = None;
let mut raw_events_since_subscription_start_element: Option<&super::super::codec::Value> =
None;
let mut raw_notification_event: Option<&super::super::codec::Value> = None;
let mut raw_subscription: Option<&super::super::codec::Value> = None;
let mut raw_topic: Option<&super::super::codec::Value> = None;
let mut raw_topic_element: Option<&super::super::codec::Value> = None;
let mut raw_error: Option<&super::super::codec::Value> = None;
for (key, value) in object {
match key.as_str() {
"resourceType" => {
if value.as_str() != Some("SubscriptionStatus") {
return Err(path.error(super::super::codec::DecodeErrorKind::ResourceType));
}
}
"id" => {
raw_id = Some(value);
}
"meta" => {
raw_meta = Some(value);
}
"implicitRules" => {
raw_implicit_rules = Some(value);
}
"_implicitRules" => {
raw_implicit_rules_element = Some(value);
}
"language" => {
raw_language = Some(value);
}
"_language" => {
raw_language_element = Some(value);
}
"text" => {
raw_text = Some(value);
}
"contained" => {
raw_contained = Some(value);
}
"extension" => {
raw_extension = Some(value);
}
"modifierExtension" => {
raw_modifier_extension = Some(value);
}
"status" => {
raw_status = Some(value);
}
"_status" => {
raw_status_element = Some(value);
}
"type" => {
raw_type = Some(value);
}
"_type" => {
raw_type_element = Some(value);
}
"eventsSinceSubscriptionStart" => {
raw_events_since_subscription_start = Some(value);
}
"_eventsSinceSubscriptionStart" => {
raw_events_since_subscription_start_element = Some(value);
}
"notificationEvent" => {
raw_notification_event = Some(value);
}
"subscription" => {
raw_subscription = Some(value);
}
"topic" => {
raw_topic = Some(value);
}
"_topic" => {
raw_topic_element = Some(value);
}
"error" => {
raw_error = Some(value);
}
other => {
return path.with(other, |path| {
Err(path.error(super::super::codec::DecodeErrorKind::UnknownProperty))
});
}
}
}
let field_id = raw_id
.map(|value| {
path.with("id", |path| {
let value = super::super::codec::expect_single(value, path)?;
super::primitives::checked_id(
super::super::codec::expect_string(value, path)?,
path,
)
})
})
.transpose()?;
let field_meta = raw_meta
.map(|value| {
path.with("meta", |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(
super::super::codec::expect_single(value, path)?,
path,
)?,
path,
)
})
})
.transpose()?;
let field_implicit_rules = match (raw_implicit_rules, raw_implicit_rules_element) {
(None, None) => None,
(value, element) => Some(path.with("implicitRules", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_language = match (raw_language, raw_language_element) {
(None, None) => None,
(value, element) => Some(path.with("language", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_text = raw_text
.map(|value| {
path.with("text", |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(
super::super::codec::expect_single(value, path)?,
path,
)?,
path,
)
})
})
.transpose()?;
let mut field_contained = Vec::new();
if let Some(raw) = raw_contained {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_contained.push(path.with_index("contained", index, |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
})?);
}
}
let mut field_extension = Vec::new();
if let Some(raw) = raw_extension {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_extension.push(path.with_index("extension", index, |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
})?);
}
}
let mut field_modifier_extension = Vec::new();
if let Some(raw) = raw_modifier_extension {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_modifier_extension.push(path.with_index(
"modifierExtension",
index,
|path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
},
)?);
}
}
let field_status = match (raw_status, raw_status_element) {
(None, None) => None,
(value, element) => Some(path.with("status", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_type = path.with("type", |path| {
super::super::codec::Primitive::from_json_parts(raw_type, raw_type_element, path)
})?;
let field_events_since_subscription_start = match (
raw_events_since_subscription_start,
raw_events_since_subscription_start_element,
) {
(None, None) => None,
(value, element) => Some(path.with("eventsSinceSubscriptionStart", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let mut field_notification_event = Vec::new();
if let Some(raw) = raw_notification_event {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_notification_event.push(path.with_index(
"notificationEvent",
index,
|path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
},
)?);
}
}
let field_subscription = path.with("subscription", |path| {
let value = raw_subscription
.ok_or_else(|| path.error(super::super::codec::DecodeErrorKind::MissingProperty))?;
super::super::codec::Json::from_json(
super::super::codec::expect_object(
super::super::codec::expect_single(value, path)?,
path,
)?,
path,
)
})?;
let field_topic = match (raw_topic, raw_topic_element) {
(None, None) => None,
(value, element) => Some(path.with("topic", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let mut field_error = Vec::new();
if let Some(raw) = raw_error {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_error.push(path.with_index("error", index, |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
})?);
}
}
Ok(Self {
id: field_id,
meta: field_meta,
implicit_rules: field_implicit_rules,
language: field_language,
text: field_text,
contained: field_contained,
extension: field_extension,
modifier_extension: field_modifier_extension,
status: field_status,
r#type: field_type,
events_since_subscription_start: field_events_since_subscription_start,
notification_event: field_notification_event,
subscription: field_subscription,
topic: field_topic,
error: field_error,
})
}
}
impl serde::Serialize for SubscriptionStatus {
fn serialize<S: serde::Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error> {
let mut map = serde::Serializer::serialize_map(serializer, None)?;
if let Some(item) = &self.events_since_subscription_start {
super::super::codec::element_entry(&mut map, "_eventsSinceSubscriptionStart", item)?;
}
if let Some(item) = &self.implicit_rules {
super::super::codec::element_entry(&mut map, "_implicitRules", item)?;
}
if let Some(item) = &self.language {
super::super::codec::element_entry(&mut map, "_language", item)?;
}
if let Some(item) = &self.status {
super::super::codec::element_entry(&mut map, "_status", item)?;
}
if let Some(item) = &self.topic {
super::super::codec::element_entry(&mut map, "_topic", item)?;
}
super::super::codec::element_entry(&mut map, "_type", &self.r#type)?;
if !self.contained.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "contained", &self.contained)?;
}
if !self.error.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "error", &self.error)?;
}
if let Some(item) = &self.events_since_subscription_start {
super::super::codec::value_entry(&mut map, "eventsSinceSubscriptionStart", item)?;
}
if !self.extension.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "extension", &self.extension)?;
}
if let Some(v) = &self.id {
serde::ser::SerializeMap::serialize_entry(&mut map, "id", v)?;
}
if let Some(item) = &self.implicit_rules {
super::super::codec::value_entry(&mut map, "implicitRules", item)?;
}
if let Some(item) = &self.language {
super::super::codec::value_entry(&mut map, "language", item)?;
}
if let Some(item) = &self.meta {
serde::ser::SerializeMap::serialize_entry(&mut map, "meta", item)?;
}
if !self.modifier_extension.is_empty() {
serde::ser::SerializeMap::serialize_entry(
&mut map,
"modifierExtension",
&self.modifier_extension,
)?;
}
if !self.notification_event.is_empty() {
serde::ser::SerializeMap::serialize_entry(
&mut map,
"notificationEvent",
&self.notification_event,
)?;
}
serde::ser::SerializeMap::serialize_entry(&mut map, "resourceType", "SubscriptionStatus")?;
if let Some(item) = &self.status {
super::super::codec::value_entry(&mut map, "status", item)?;
}
serde::ser::SerializeMap::serialize_entry(&mut map, "subscription", &self.subscription)?;
if let Some(item) = &self.text {
serde::ser::SerializeMap::serialize_entry(&mut map, "text", item)?;
}
if let Some(item) = &self.topic {
super::super::codec::value_entry(&mut map, "topic", item)?;
}
super::super::codec::value_entry(&mut map, "type", &self.r#type)?;
serde::ser::SerializeMap::end(map)
}
}
impl<'de> serde::Deserialize<'de> for SubscriptionStatus {
fn deserialize<D: serde::Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error> {
let value = <super::super::codec::Value as serde::Deserialize>::deserialize(deserializer)?;
let mut path = super::super::codec::Path::root("SubscriptionStatus");
let object =
super::super::codec::expect_object(&value, &path).map_err(serde::de::Error::custom)?;
super::super::codec::Json::from_json(object, &mut path).map_err(serde::de::Error::custom)
}
}
#[derive(Debug, Clone, Default, PartialEq, Eq)]
pub struct SubscriptionStatusNotificationEvent {
pub id: Option<std::string::String>,
pub extension: Vec<super::extension::Extension>,
pub modifier_extension: Vec<super::extension::Extension>,
pub event_number: super::primitives::String,
pub timestamp: Option<super::primitives::Instant>,
pub focus: Option<super::reference::Reference>,
pub additional_context: Vec<super::reference::Reference>,
}
impl super::super::codec::Json for SubscriptionStatusNotificationEvent {
fn to_json(&self) -> Result<super::super::codec::Object, super::super::codec::EncodeError> {
let mut object = super::super::codec::Object::new();
if let Some(v) = &self.id {
object.insert(
std::string::String::from("id"),
super::super::codec::Value::String(v.clone()),
);
}
if !self.extension.is_empty() {
let mut items = Vec::with_capacity(self.extension.len());
for item in &self.extension {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("extension"),
super::super::codec::Value::Array(items),
);
}
if !self.modifier_extension.is_empty() {
let mut items = Vec::with_capacity(self.modifier_extension.len());
for item in &self.modifier_extension {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("modifierExtension"),
super::super::codec::Value::Array(items),
);
}
if let Some(v) = super::super::codec::Primitive::value_json(&self.event_number)? {
object.insert(std::string::String::from("eventNumber"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(&self.event_number)? {
object.insert(std::string::String::from("_eventNumber"), e);
}
if let Some(item) = &self.timestamp {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("timestamp"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_timestamp"), e);
}
}
if let Some(item) = &self.focus {
object.insert(
std::string::String::from("focus"),
super::super::codec::Value::Object(super::super::codec::Json::to_json(item)?),
);
}
if !self.additional_context.is_empty() {
let mut items = Vec::with_capacity(self.additional_context.len());
for item in &self.additional_context {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("additionalContext"),
super::super::codec::Value::Array(items),
);
}
Ok(object)
}
fn from_json(
object: &super::super::codec::Object,
path: &mut super::super::codec::Path,
) -> Result<Self, super::super::codec::DecodeError> {
let mut raw_id: Option<&super::super::codec::Value> = None;
let mut raw_extension: Option<&super::super::codec::Value> = None;
let mut raw_modifier_extension: Option<&super::super::codec::Value> = None;
let mut raw_event_number: Option<&super::super::codec::Value> = None;
let mut raw_event_number_element: Option<&super::super::codec::Value> = None;
let mut raw_timestamp: Option<&super::super::codec::Value> = None;
let mut raw_timestamp_element: Option<&super::super::codec::Value> = None;
let mut raw_focus: Option<&super::super::codec::Value> = None;
let mut raw_additional_context: Option<&super::super::codec::Value> = None;
for (key, value) in object {
match key.as_str() {
"id" => {
raw_id = Some(value);
}
"extension" => {
raw_extension = Some(value);
}
"modifierExtension" => {
raw_modifier_extension = Some(value);
}
"eventNumber" => {
raw_event_number = Some(value);
}
"_eventNumber" => {
raw_event_number_element = Some(value);
}
"timestamp" => {
raw_timestamp = Some(value);
}
"_timestamp" => {
raw_timestamp_element = Some(value);
}
"focus" => {
raw_focus = Some(value);
}
"additionalContext" => {
raw_additional_context = Some(value);
}
other => {
return path.with(other, |path| {
Err(path.error(super::super::codec::DecodeErrorKind::UnknownProperty))
});
}
}
}
let field_id = raw_id
.map(|value| {
path.with("id", |path| {
let value = super::super::codec::expect_single(value, path)?;
super::primitives::checked_string(
super::super::codec::expect_string(value, path)?,
path,
)
})
})
.transpose()?;
let mut field_extension = Vec::new();
if let Some(raw) = raw_extension {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_extension.push(path.with_index("extension", index, |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
})?);
}
}
let mut field_modifier_extension = Vec::new();
if let Some(raw) = raw_modifier_extension {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_modifier_extension.push(path.with_index(
"modifierExtension",
index,
|path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
},
)?);
}
}
let field_event_number = path.with("eventNumber", |path| {
super::super::codec::Primitive::from_json_parts(
raw_event_number,
raw_event_number_element,
path,
)
})?;
let field_timestamp = match (raw_timestamp, raw_timestamp_element) {
(None, None) => None,
(value, element) => Some(path.with("timestamp", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_focus = raw_focus
.map(|value| {
path.with("focus", |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(
super::super::codec::expect_single(value, path)?,
path,
)?,
path,
)
})
})
.transpose()?;
let mut field_additional_context = Vec::new();
if let Some(raw) = raw_additional_context {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_additional_context.push(path.with_index(
"additionalContext",
index,
|path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
},
)?);
}
}
Ok(Self {
id: field_id,
extension: field_extension,
modifier_extension: field_modifier_extension,
event_number: field_event_number,
timestamp: field_timestamp,
focus: field_focus,
additional_context: field_additional_context,
})
}
}
impl serde::Serialize for SubscriptionStatusNotificationEvent {
fn serialize<S: serde::Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error> {
let mut map = serde::Serializer::serialize_map(serializer, None)?;
super::super::codec::element_entry(&mut map, "_eventNumber", &self.event_number)?;
if let Some(item) = &self.timestamp {
super::super::codec::element_entry(&mut map, "_timestamp", item)?;
}
if !self.additional_context.is_empty() {
serde::ser::SerializeMap::serialize_entry(
&mut map,
"additionalContext",
&self.additional_context,
)?;
}
super::super::codec::value_entry(&mut map, "eventNumber", &self.event_number)?;
if !self.extension.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "extension", &self.extension)?;
}
if let Some(item) = &self.focus {
serde::ser::SerializeMap::serialize_entry(&mut map, "focus", item)?;
}
if let Some(v) = &self.id {
serde::ser::SerializeMap::serialize_entry(&mut map, "id", v)?;
}
if !self.modifier_extension.is_empty() {
serde::ser::SerializeMap::serialize_entry(
&mut map,
"modifierExtension",
&self.modifier_extension,
)?;
}
if let Some(item) = &self.timestamp {
super::super::codec::value_entry(&mut map, "timestamp", item)?;
}
serde::ser::SerializeMap::end(map)
}
}
impl<'de> serde::Deserialize<'de> for SubscriptionStatusNotificationEvent {
fn deserialize<D: serde::Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error> {
let value = <super::super::codec::Value as serde::Deserialize>::deserialize(deserializer)?;
let mut path = super::super::codec::Path::root("SubscriptionStatusNotificationEvent");
let object =
super::super::codec::expect_object(&value, &path).map_err(serde::de::Error::custom)?;
super::super::codec::Json::from_json(object, &mut path).map_err(serde::de::Error::custom)
}
}