#[derive(Debug, Clone, Default, PartialEq, Eq)]
pub struct Subscription {
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 identifier: Vec<super::identifier::Identifier>,
pub name: Option<super::primitives::String>,
pub status: super::primitives::Code,
pub topic: super::primitives::Canonical,
pub contact: Vec<super::contact_point::ContactPoint>,
pub end: Option<super::primitives::Instant>,
pub managing_entity: Option<super::reference::Reference>,
pub reason: Option<super::primitives::String>,
pub filter_by: Vec<SubscriptionFilterBy>,
pub channel_type: super::coding::Coding,
pub endpoint: Option<super::primitives::Url>,
pub parameter: Vec<SubscriptionParameter>,
pub heartbeat_period: Option<super::primitives::UnsignedInt>,
pub timeout: Option<super::primitives::UnsignedInt>,
pub content_type: Option<super::primitives::Code>,
pub content: Option<super::primitives::Code>,
pub max_count: Option<super::primitives::PositiveInt>,
}
impl super::super::codec::Json for Subscription {
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("Subscription")),
);
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 !self.identifier.is_empty() {
let mut items = Vec::with_capacity(self.identifier.len());
for item in &self.identifier {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("identifier"),
super::super::codec::Value::Array(items),
);
}
if let Some(item) = &self.name {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("name"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_name"), e);
}
}
if let Some(v) = super::super::codec::Primitive::value_json(&self.status)? {
object.insert(std::string::String::from("status"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(&self.status)? {
object.insert(std::string::String::from("_status"), e);
}
if let Some(v) = super::super::codec::Primitive::value_json(&self.topic)? {
object.insert(std::string::String::from("topic"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(&self.topic)? {
object.insert(std::string::String::from("_topic"), e);
}
if !self.contact.is_empty() {
let mut items = Vec::with_capacity(self.contact.len());
for item in &self.contact {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("contact"),
super::super::codec::Value::Array(items),
);
}
if let Some(item) = &self.end {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("end"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_end"), e);
}
}
if let Some(item) = &self.managing_entity {
object.insert(
std::string::String::from("managingEntity"),
super::super::codec::Value::Object(super::super::codec::Json::to_json(item)?),
);
}
if let Some(item) = &self.reason {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("reason"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_reason"), e);
}
}
if !self.filter_by.is_empty() {
let mut items = Vec::with_capacity(self.filter_by.len());
for item in &self.filter_by {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("filterBy"),
super::super::codec::Value::Array(items),
);
}
object.insert(
std::string::String::from("channelType"),
super::super::codec::Value::Object(super::super::codec::Json::to_json(
&self.channel_type,
)?),
);
if let Some(item) = &self.endpoint {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("endpoint"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_endpoint"), e);
}
}
if !self.parameter.is_empty() {
let mut items = Vec::with_capacity(self.parameter.len());
for item in &self.parameter {
items.push(super::super::codec::Value::Object(
super::super::codec::Json::to_json(item)?,
));
}
object.insert(
std::string::String::from("parameter"),
super::super::codec::Value::Array(items),
);
}
if let Some(item) = &self.heartbeat_period {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("heartbeatPeriod"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_heartbeatPeriod"), e);
}
}
if let Some(item) = &self.timeout {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("timeout"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_timeout"), e);
}
}
if let Some(item) = &self.content_type {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("contentType"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_contentType"), e);
}
}
if let Some(item) = &self.content {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("content"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_content"), e);
}
}
if let Some(item) = &self.max_count {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("maxCount"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_maxCount"), e);
}
}
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_identifier: Option<&super::super::codec::Value> = None;
let mut raw_name: Option<&super::super::codec::Value> = None;
let mut raw_name_element: 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_topic: Option<&super::super::codec::Value> = None;
let mut raw_topic_element: Option<&super::super::codec::Value> = None;
let mut raw_contact: Option<&super::super::codec::Value> = None;
let mut raw_end: Option<&super::super::codec::Value> = None;
let mut raw_end_element: Option<&super::super::codec::Value> = None;
let mut raw_managing_entity: Option<&super::super::codec::Value> = None;
let mut raw_reason: Option<&super::super::codec::Value> = None;
let mut raw_reason_element: Option<&super::super::codec::Value> = None;
let mut raw_filter_by: Option<&super::super::codec::Value> = None;
let mut raw_channel_type: Option<&super::super::codec::Value> = None;
let mut raw_endpoint: Option<&super::super::codec::Value> = None;
let mut raw_endpoint_element: Option<&super::super::codec::Value> = None;
let mut raw_parameter: Option<&super::super::codec::Value> = None;
let mut raw_heartbeat_period: Option<&super::super::codec::Value> = None;
let mut raw_heartbeat_period_element: Option<&super::super::codec::Value> = None;
let mut raw_timeout: Option<&super::super::codec::Value> = None;
let mut raw_timeout_element: Option<&super::super::codec::Value> = None;
let mut raw_content_type: Option<&super::super::codec::Value> = None;
let mut raw_content_type_element: Option<&super::super::codec::Value> = None;
let mut raw_content: Option<&super::super::codec::Value> = None;
let mut raw_content_element: Option<&super::super::codec::Value> = None;
let mut raw_max_count: Option<&super::super::codec::Value> = None;
let mut raw_max_count_element: Option<&super::super::codec::Value> = None;
for (key, value) in object {
match key.as_str() {
"resourceType" => {
if value.as_str() != Some("Subscription") {
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);
}
"identifier" => {
raw_identifier = Some(value);
}
"name" => {
raw_name = Some(value);
}
"_name" => {
raw_name_element = Some(value);
}
"status" => {
raw_status = Some(value);
}
"_status" => {
raw_status_element = Some(value);
}
"topic" => {
raw_topic = Some(value);
}
"_topic" => {
raw_topic_element = Some(value);
}
"contact" => {
raw_contact = Some(value);
}
"end" => {
raw_end = Some(value);
}
"_end" => {
raw_end_element = Some(value);
}
"managingEntity" => {
raw_managing_entity = Some(value);
}
"reason" => {
raw_reason = Some(value);
}
"_reason" => {
raw_reason_element = Some(value);
}
"filterBy" => {
raw_filter_by = Some(value);
}
"channelType" => {
raw_channel_type = Some(value);
}
"endpoint" => {
raw_endpoint = Some(value);
}
"_endpoint" => {
raw_endpoint_element = Some(value);
}
"parameter" => {
raw_parameter = Some(value);
}
"heartbeatPeriod" => {
raw_heartbeat_period = Some(value);
}
"_heartbeatPeriod" => {
raw_heartbeat_period_element = Some(value);
}
"timeout" => {
raw_timeout = Some(value);
}
"_timeout" => {
raw_timeout_element = Some(value);
}
"contentType" => {
raw_content_type = Some(value);
}
"_contentType" => {
raw_content_type_element = Some(value);
}
"content" => {
raw_content = Some(value);
}
"_content" => {
raw_content_element = Some(value);
}
"maxCount" => {
raw_max_count = Some(value);
}
"_maxCount" => {
raw_max_count_element = 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 mut field_identifier = Vec::new();
if let Some(raw) = raw_identifier {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_identifier.push(path.with_index("identifier", index, |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
})?);
}
}
let field_name = match (raw_name, raw_name_element) {
(None, None) => None,
(value, element) => Some(path.with("name", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_status = path.with("status", |path| {
super::super::codec::Primitive::from_json_parts(raw_status, raw_status_element, path)
})?;
let field_topic = path.with("topic", |path| {
super::super::codec::Primitive::from_json_parts(raw_topic, raw_topic_element, path)
})?;
let mut field_contact = Vec::new();
if let Some(raw) = raw_contact {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_contact.push(path.with_index("contact", index, |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
})?);
}
}
let field_end = match (raw_end, raw_end_element) {
(None, None) => None,
(value, element) => Some(path.with("end", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_managing_entity = raw_managing_entity
.map(|value| {
path.with("managingEntity", |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(
super::super::codec::expect_single(value, path)?,
path,
)?,
path,
)
})
})
.transpose()?;
let field_reason = match (raw_reason, raw_reason_element) {
(None, None) => None,
(value, element) => Some(path.with("reason", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let mut field_filter_by = Vec::new();
if let Some(raw) = raw_filter_by {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_filter_by.push(path.with_index("filterBy", index, |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
})?);
}
}
let field_channel_type = path.with("channelType", |path| {
let value = raw_channel_type
.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_endpoint = match (raw_endpoint, raw_endpoint_element) {
(None, None) => None,
(value, element) => Some(path.with("endpoint", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let mut field_parameter = Vec::new();
if let Some(raw) = raw_parameter {
for (index, value) in super::super::codec::expect_array(raw, path)?
.iter()
.enumerate()
{
field_parameter.push(path.with_index("parameter", index, |path| {
super::super::codec::Json::from_json(
super::super::codec::expect_object(value, path)?,
path,
)
})?);
}
}
let field_heartbeat_period = match (raw_heartbeat_period, raw_heartbeat_period_element) {
(None, None) => None,
(value, element) => Some(path.with("heartbeatPeriod", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_timeout = match (raw_timeout, raw_timeout_element) {
(None, None) => None,
(value, element) => Some(path.with("timeout", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_content_type = match (raw_content_type, raw_content_type_element) {
(None, None) => None,
(value, element) => Some(path.with("contentType", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_content = match (raw_content, raw_content_element) {
(None, None) => None,
(value, element) => Some(path.with("content", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_max_count = match (raw_max_count, raw_max_count_element) {
(None, None) => None,
(value, element) => Some(path.with("maxCount", |path| {
super::super::codec::Primitive::from_json_parts(value, element, 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,
identifier: field_identifier,
name: field_name,
status: field_status,
topic: field_topic,
contact: field_contact,
end: field_end,
managing_entity: field_managing_entity,
reason: field_reason,
filter_by: field_filter_by,
channel_type: field_channel_type,
endpoint: field_endpoint,
parameter: field_parameter,
heartbeat_period: field_heartbeat_period,
timeout: field_timeout,
content_type: field_content_type,
content: field_content,
max_count: field_max_count,
})
}
}
impl serde::Serialize for Subscription {
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.content {
super::super::codec::element_entry(&mut map, "_content", item)?;
}
if let Some(item) = &self.content_type {
super::super::codec::element_entry(&mut map, "_contentType", item)?;
}
if let Some(item) = &self.end {
super::super::codec::element_entry(&mut map, "_end", item)?;
}
if let Some(item) = &self.endpoint {
super::super::codec::element_entry(&mut map, "_endpoint", item)?;
}
if let Some(item) = &self.heartbeat_period {
super::super::codec::element_entry(&mut map, "_heartbeatPeriod", 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.max_count {
super::super::codec::element_entry(&mut map, "_maxCount", item)?;
}
if let Some(item) = &self.name {
super::super::codec::element_entry(&mut map, "_name", item)?;
}
if let Some(item) = &self.reason {
super::super::codec::element_entry(&mut map, "_reason", item)?;
}
super::super::codec::element_entry(&mut map, "_status", &self.status)?;
if let Some(item) = &self.timeout {
super::super::codec::element_entry(&mut map, "_timeout", item)?;
}
super::super::codec::element_entry(&mut map, "_topic", &self.topic)?;
serde::ser::SerializeMap::serialize_entry(&mut map, "channelType", &self.channel_type)?;
if !self.contact.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "contact", &self.contact)?;
}
if !self.contained.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "contained", &self.contained)?;
}
if let Some(item) = &self.content {
super::super::codec::value_entry(&mut map, "content", item)?;
}
if let Some(item) = &self.content_type {
super::super::codec::value_entry(&mut map, "contentType", item)?;
}
if let Some(item) = &self.end {
super::super::codec::value_entry(&mut map, "end", item)?;
}
if let Some(item) = &self.endpoint {
super::super::codec::value_entry(&mut map, "endpoint", item)?;
}
if !self.extension.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "extension", &self.extension)?;
}
if !self.filter_by.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "filterBy", &self.filter_by)?;
}
if let Some(item) = &self.heartbeat_period {
super::super::codec::value_entry(&mut map, "heartbeatPeriod", item)?;
}
if let Some(v) = &self.id {
serde::ser::SerializeMap::serialize_entry(&mut map, "id", v)?;
}
if !self.identifier.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "identifier", &self.identifier)?;
}
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.managing_entity {
serde::ser::SerializeMap::serialize_entry(&mut map, "managingEntity", item)?;
}
if let Some(item) = &self.max_count {
super::super::codec::value_entry(&mut map, "maxCount", 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 let Some(item) = &self.name {
super::super::codec::value_entry(&mut map, "name", item)?;
}
if !self.parameter.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "parameter", &self.parameter)?;
}
if let Some(item) = &self.reason {
super::super::codec::value_entry(&mut map, "reason", item)?;
}
serde::ser::SerializeMap::serialize_entry(&mut map, "resourceType", "Subscription")?;
super::super::codec::value_entry(&mut map, "status", &self.status)?;
if let Some(item) = &self.text {
serde::ser::SerializeMap::serialize_entry(&mut map, "text", item)?;
}
if let Some(item) = &self.timeout {
super::super::codec::value_entry(&mut map, "timeout", item)?;
}
super::super::codec::value_entry(&mut map, "topic", &self.topic)?;
serde::ser::SerializeMap::end(map)
}
}
impl<'de> serde::Deserialize<'de> for Subscription {
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("Subscription");
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 SubscriptionFilterBy {
pub id: Option<std::string::String>,
pub extension: Vec<super::extension::Extension>,
pub modifier_extension: Vec<super::extension::Extension>,
pub resource_type: Option<super::primitives::Uri>,
pub filter_parameter: super::primitives::String,
pub comparator: Option<super::primitives::Code>,
pub modifier: Option<super::primitives::Code>,
pub value: super::primitives::String,
}
impl super::super::codec::Json for SubscriptionFilterBy {
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(item) = &self.resource_type {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("resourceType"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_resourceType"), e);
}
}
if let Some(v) = super::super::codec::Primitive::value_json(&self.filter_parameter)? {
object.insert(std::string::String::from("filterParameter"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(&self.filter_parameter)? {
object.insert(std::string::String::from("_filterParameter"), e);
}
if let Some(item) = &self.comparator {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("comparator"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_comparator"), e);
}
}
if let Some(item) = &self.modifier {
if let Some(v) = super::super::codec::Primitive::value_json(item)? {
object.insert(std::string::String::from("modifier"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(item)? {
object.insert(std::string::String::from("_modifier"), e);
}
}
if let Some(v) = super::super::codec::Primitive::value_json(&self.value)? {
object.insert(std::string::String::from("value"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(&self.value)? {
object.insert(std::string::String::from("_value"), e);
}
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_resource_type: Option<&super::super::codec::Value> = None;
let mut raw_resource_type_element: Option<&super::super::codec::Value> = None;
let mut raw_filter_parameter: Option<&super::super::codec::Value> = None;
let mut raw_filter_parameter_element: Option<&super::super::codec::Value> = None;
let mut raw_comparator: Option<&super::super::codec::Value> = None;
let mut raw_comparator_element: Option<&super::super::codec::Value> = None;
let mut raw_modifier: Option<&super::super::codec::Value> = None;
let mut raw_modifier_element: Option<&super::super::codec::Value> = None;
let mut raw_value: Option<&super::super::codec::Value> = None;
let mut raw_value_element: 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);
}
"resourceType" => {
raw_resource_type = Some(value);
}
"_resourceType" => {
raw_resource_type_element = Some(value);
}
"filterParameter" => {
raw_filter_parameter = Some(value);
}
"_filterParameter" => {
raw_filter_parameter_element = Some(value);
}
"comparator" => {
raw_comparator = Some(value);
}
"_comparator" => {
raw_comparator_element = Some(value);
}
"modifier" => {
raw_modifier = Some(value);
}
"_modifier" => {
raw_modifier_element = Some(value);
}
"value" => {
raw_value = Some(value);
}
"_value" => {
raw_value_element = 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_resource_type = match (raw_resource_type, raw_resource_type_element) {
(None, None) => None,
(value, element) => Some(path.with("resourceType", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_filter_parameter = path.with("filterParameter", |path| {
super::super::codec::Primitive::from_json_parts(
raw_filter_parameter,
raw_filter_parameter_element,
path,
)
})?;
let field_comparator = match (raw_comparator, raw_comparator_element) {
(None, None) => None,
(value, element) => Some(path.with("comparator", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_modifier = match (raw_modifier, raw_modifier_element) {
(None, None) => None,
(value, element) => Some(path.with("modifier", |path| {
super::super::codec::Primitive::from_json_parts(value, element, path)
})?),
};
let field_value = path.with("value", |path| {
super::super::codec::Primitive::from_json_parts(raw_value, raw_value_element, path)
})?;
Ok(Self {
id: field_id,
extension: field_extension,
modifier_extension: field_modifier_extension,
resource_type: field_resource_type,
filter_parameter: field_filter_parameter,
comparator: field_comparator,
modifier: field_modifier,
value: field_value,
})
}
}
impl serde::Serialize for SubscriptionFilterBy {
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.comparator {
super::super::codec::element_entry(&mut map, "_comparator", item)?;
}
super::super::codec::element_entry(&mut map, "_filterParameter", &self.filter_parameter)?;
if let Some(item) = &self.modifier {
super::super::codec::element_entry(&mut map, "_modifier", item)?;
}
if let Some(item) = &self.resource_type {
super::super::codec::element_entry(&mut map, "_resourceType", item)?;
}
super::super::codec::element_entry(&mut map, "_value", &self.value)?;
if let Some(item) = &self.comparator {
super::super::codec::value_entry(&mut map, "comparator", item)?;
}
if !self.extension.is_empty() {
serde::ser::SerializeMap::serialize_entry(&mut map, "extension", &self.extension)?;
}
super::super::codec::value_entry(&mut map, "filterParameter", &self.filter_parameter)?;
if let Some(v) = &self.id {
serde::ser::SerializeMap::serialize_entry(&mut map, "id", v)?;
}
if let Some(item) = &self.modifier {
super::super::codec::value_entry(&mut map, "modifier", item)?;
}
if !self.modifier_extension.is_empty() {
serde::ser::SerializeMap::serialize_entry(
&mut map,
"modifierExtension",
&self.modifier_extension,
)?;
}
if let Some(item) = &self.resource_type {
super::super::codec::value_entry(&mut map, "resourceType", item)?;
}
super::super::codec::value_entry(&mut map, "value", &self.value)?;
serde::ser::SerializeMap::end(map)
}
}
impl<'de> serde::Deserialize<'de> for SubscriptionFilterBy {
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("SubscriptionFilterBy");
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 SubscriptionParameter {
pub id: Option<std::string::String>,
pub extension: Vec<super::extension::Extension>,
pub modifier_extension: Vec<super::extension::Extension>,
pub name: super::primitives::String,
pub value: super::primitives::String,
}
impl super::super::codec::Json for SubscriptionParameter {
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.name)? {
object.insert(std::string::String::from("name"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(&self.name)? {
object.insert(std::string::String::from("_name"), e);
}
if let Some(v) = super::super::codec::Primitive::value_json(&self.value)? {
object.insert(std::string::String::from("value"), v);
}
if let Some(e) = super::super::codec::Primitive::element_json(&self.value)? {
object.insert(std::string::String::from("_value"), e);
}
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_name: Option<&super::super::codec::Value> = None;
let mut raw_name_element: Option<&super::super::codec::Value> = None;
let mut raw_value: Option<&super::super::codec::Value> = None;
let mut raw_value_element: 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);
}
"name" => {
raw_name = Some(value);
}
"_name" => {
raw_name_element = Some(value);
}
"value" => {
raw_value = Some(value);
}
"_value" => {
raw_value_element = 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_name = path.with("name", |path| {
super::super::codec::Primitive::from_json_parts(raw_name, raw_name_element, path)
})?;
let field_value = path.with("value", |path| {
super::super::codec::Primitive::from_json_parts(raw_value, raw_value_element, path)
})?;
Ok(Self {
id: field_id,
extension: field_extension,
modifier_extension: field_modifier_extension,
name: field_name,
value: field_value,
})
}
}
impl serde::Serialize for SubscriptionParameter {
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, "_name", &self.name)?;
super::super::codec::element_entry(&mut map, "_value", &self.value)?;
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 !self.modifier_extension.is_empty() {
serde::ser::SerializeMap::serialize_entry(
&mut map,
"modifierExtension",
&self.modifier_extension,
)?;
}
super::super::codec::value_entry(&mut map, "name", &self.name)?;
super::super::codec::value_entry(&mut map, "value", &self.value)?;
serde::ser::SerializeMap::end(map)
}
}
impl<'de> serde::Deserialize<'de> for SubscriptionParameter {
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("SubscriptionParameter");
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)
}
}