aws_sdk_codepipeline/protocol_serde/
shape_pipeline_declaration.rs1pub(crate) fn de_pipeline_declaration<'a, I>(
3 tokens: &mut ::std::iter::Peekable<I>,
4) -> ::std::result::Result<Option<crate::types::PipelineDeclaration>, ::aws_smithy_json::deserialize::error::DeserializeError>
5where
6 I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
7{
8 match tokens.next().transpose()? {
9 Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
10 Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
11 #[allow(unused_mut)]
12 let mut builder = crate::types::builders::PipelineDeclarationBuilder::default();
13 loop {
14 match tokens.next().transpose()? {
15 Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
16 Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
17 "name" => {
18 builder = builder.set_name(
19 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
20 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
21 .transpose()?,
22 );
23 }
24 "roleArn" => {
25 builder = builder.set_role_arn(
26 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
27 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
28 .transpose()?,
29 );
30 }
31 "artifactStore" => {
32 builder = builder.set_artifact_store(crate::protocol_serde::shape_artifact_store::de_artifact_store(tokens)?);
33 }
34 "artifactStores" => {
35 builder = builder.set_artifact_stores(crate::protocol_serde::shape_artifact_store_map::de_artifact_store_map(tokens)?);
36 }
37 "stages" => {
38 builder = builder.set_stages(
39 crate::protocol_serde::shape_pipeline_stage_declaration_list::de_pipeline_stage_declaration_list(tokens)?,
40 );
41 }
42 "version" => {
43 builder = builder.set_version(
44 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
45 .map(i32::try_from)
46 .transpose()?,
47 );
48 }
49 "executionMode" => {
50 builder = builder.set_execution_mode(
51 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
52 .map(|s| s.to_unescaped().map(|u| crate::types::ExecutionMode::from(u.as_ref())))
53 .transpose()?,
54 );
55 }
56 "pipelineType" => {
57 builder = builder.set_pipeline_type(
58 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
59 .map(|s| s.to_unescaped().map(|u| crate::types::PipelineType::from(u.as_ref())))
60 .transpose()?,
61 );
62 }
63 "variables" => {
64 builder = builder.set_variables(
65 crate::protocol_serde::shape_pipeline_variable_declaration_list::de_pipeline_variable_declaration_list(tokens)?,
66 );
67 }
68 "triggers" => {
69 builder = builder.set_triggers(
70 crate::protocol_serde::shape_pipeline_trigger_declaration_list::de_pipeline_trigger_declaration_list(tokens)?,
71 );
72 }
73 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
74 },
75 other => {
76 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
77 "expected object key or end object, found: {:?}",
78 other
79 )))
80 }
81 }
82 }
83 Ok(Some(crate::serde_util::pipeline_declaration_correct_errors(builder).build().map_err(
84 |err| ::aws_smithy_json::deserialize::error::DeserializeError::custom_source("Response was invalid", err),
85 )?))
86 }
87 _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
88 "expected start object or null",
89 )),
90 }
91}
92
93pub fn ser_pipeline_declaration(
94 object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
95 input: &crate::types::PipelineDeclaration,
96) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
97 {
98 object.key("name").string(input.name.as_str());
99 }
100 {
101 object.key("roleArn").string(input.role_arn.as_str());
102 }
103 if let Some(var_1) = &input.artifact_store {
104 #[allow(unused_mut)]
105 let mut object_2 = object.key("artifactStore").start_object();
106 crate::protocol_serde::shape_artifact_store::ser_artifact_store(&mut object_2, var_1)?;
107 object_2.finish();
108 }
109 if let Some(var_3) = &input.artifact_stores {
110 #[allow(unused_mut)]
111 let mut object_4 = object.key("artifactStores").start_object();
112 for (key_5, value_6) in var_3 {
113 {
114 #[allow(unused_mut)]
115 let mut object_7 = object_4.key(key_5.as_str()).start_object();
116 crate::protocol_serde::shape_artifact_store::ser_artifact_store(&mut object_7, value_6)?;
117 object_7.finish();
118 }
119 }
120 object_4.finish();
121 }
122 {
123 let mut array_8 = object.key("stages").start_array();
124 for item_9 in &input.stages {
125 {
126 #[allow(unused_mut)]
127 let mut object_10 = array_8.value().start_object();
128 crate::protocol_serde::shape_stage_declaration::ser_stage_declaration(&mut object_10, item_9)?;
129 object_10.finish();
130 }
131 }
132 array_8.finish();
133 }
134 if let Some(var_11) = &input.version {
135 object.key("version").number(
136 #[allow(clippy::useless_conversion)]
137 ::aws_smithy_types::Number::NegInt((*var_11).into()),
138 );
139 }
140 if let Some(var_12) = &input.execution_mode {
141 object.key("executionMode").string(var_12.as_str());
142 }
143 if let Some(var_13) = &input.pipeline_type {
144 object.key("pipelineType").string(var_13.as_str());
145 }
146 if let Some(var_14) = &input.variables {
147 let mut array_15 = object.key("variables").start_array();
148 for item_16 in var_14 {
149 {
150 #[allow(unused_mut)]
151 let mut object_17 = array_15.value().start_object();
152 crate::protocol_serde::shape_pipeline_variable_declaration::ser_pipeline_variable_declaration(&mut object_17, item_16)?;
153 object_17.finish();
154 }
155 }
156 array_15.finish();
157 }
158 if let Some(var_18) = &input.triggers {
159 let mut array_19 = object.key("triggers").start_array();
160 for item_20 in var_18 {
161 {
162 #[allow(unused_mut)]
163 let mut object_21 = array_19.value().start_object();
164 crate::protocol_serde::shape_pipeline_trigger_declaration::ser_pipeline_trigger_declaration(&mut object_21, item_20)?;
165 object_21.finish();
166 }
167 }
168 array_19.finish();
169 }
170 Ok(())
171}