aws_sdk_imagebuilder/protocol_serde/
shape_get_workflow_execution.rs1#[allow(clippy::unnecessary_wraps)]
3pub fn de_get_workflow_execution_http_error(
4 _response_status: u16,
5 _response_headers: &::aws_smithy_runtime_api::http::Headers,
6 _response_body: &[u8],
7) -> std::result::Result<
8 crate::operation::get_workflow_execution::GetWorkflowExecutionOutput,
9 crate::operation::get_workflow_execution::GetWorkflowExecutionError,
10> {
11 #[allow(unused_mut)]
12 let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
13 .map_err(crate::operation::get_workflow_execution::GetWorkflowExecutionError::unhandled)?;
14 generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
15 let generic = generic_builder.build();
16 let error_code = match generic.code() {
17 Some(code) => code,
18 None => return Err(crate::operation::get_workflow_execution::GetWorkflowExecutionError::unhandled(generic)),
19 };
20
21 let _error_message = generic.message().map(|msg| msg.to_owned());
22 Err(match error_code {
23 "CallRateLimitExceededException" => crate::operation::get_workflow_execution::GetWorkflowExecutionError::CallRateLimitExceededException({
24 #[allow(unused_mut)]
25 let mut tmp = {
26 #[allow(unused_mut)]
27 let mut output = crate::types::error::builders::CallRateLimitExceededExceptionBuilder::default();
28 output = crate::protocol_serde::shape_call_rate_limit_exceeded_exception::de_call_rate_limit_exceeded_exception_json_err(
29 _response_body,
30 output,
31 )
32 .map_err(crate::operation::get_workflow_execution::GetWorkflowExecutionError::unhandled)?;
33 let output = output.meta(generic);
34 output.build()
35 };
36 if tmp.message.is_none() {
37 tmp.message = _error_message;
38 }
39 tmp
40 }),
41 "ClientException" => crate::operation::get_workflow_execution::GetWorkflowExecutionError::ClientException({
42 #[allow(unused_mut)]
43 let mut tmp = {
44 #[allow(unused_mut)]
45 let mut output = crate::types::error::builders::ClientExceptionBuilder::default();
46 output = crate::protocol_serde::shape_client_exception::de_client_exception_json_err(_response_body, output)
47 .map_err(crate::operation::get_workflow_execution::GetWorkflowExecutionError::unhandled)?;
48 let output = output.meta(generic);
49 output.build()
50 };
51 if tmp.message.is_none() {
52 tmp.message = _error_message;
53 }
54 tmp
55 }),
56 "ForbiddenException" => crate::operation::get_workflow_execution::GetWorkflowExecutionError::ForbiddenException({
57 #[allow(unused_mut)]
58 let mut tmp = {
59 #[allow(unused_mut)]
60 let mut output = crate::types::error::builders::ForbiddenExceptionBuilder::default();
61 output = crate::protocol_serde::shape_forbidden_exception::de_forbidden_exception_json_err(_response_body, output)
62 .map_err(crate::operation::get_workflow_execution::GetWorkflowExecutionError::unhandled)?;
63 let output = output.meta(generic);
64 output.build()
65 };
66 if tmp.message.is_none() {
67 tmp.message = _error_message;
68 }
69 tmp
70 }),
71 "InvalidRequestException" => crate::operation::get_workflow_execution::GetWorkflowExecutionError::InvalidRequestException({
72 #[allow(unused_mut)]
73 let mut tmp = {
74 #[allow(unused_mut)]
75 let mut output = crate::types::error::builders::InvalidRequestExceptionBuilder::default();
76 output = crate::protocol_serde::shape_invalid_request_exception::de_invalid_request_exception_json_err(_response_body, output)
77 .map_err(crate::operation::get_workflow_execution::GetWorkflowExecutionError::unhandled)?;
78 let output = output.meta(generic);
79 output.build()
80 };
81 if tmp.message.is_none() {
82 tmp.message = _error_message;
83 }
84 tmp
85 }),
86 "ServiceException" => crate::operation::get_workflow_execution::GetWorkflowExecutionError::ServiceException({
87 #[allow(unused_mut)]
88 let mut tmp = {
89 #[allow(unused_mut)]
90 let mut output = crate::types::error::builders::ServiceExceptionBuilder::default();
91 output = crate::protocol_serde::shape_service_exception::de_service_exception_json_err(_response_body, output)
92 .map_err(crate::operation::get_workflow_execution::GetWorkflowExecutionError::unhandled)?;
93 let output = output.meta(generic);
94 output.build()
95 };
96 if tmp.message.is_none() {
97 tmp.message = _error_message;
98 }
99 tmp
100 }),
101 "ServiceUnavailableException" => crate::operation::get_workflow_execution::GetWorkflowExecutionError::ServiceUnavailableException({
102 #[allow(unused_mut)]
103 let mut tmp = {
104 #[allow(unused_mut)]
105 let mut output = crate::types::error::builders::ServiceUnavailableExceptionBuilder::default();
106 output =
107 crate::protocol_serde::shape_service_unavailable_exception::de_service_unavailable_exception_json_err(_response_body, output)
108 .map_err(crate::operation::get_workflow_execution::GetWorkflowExecutionError::unhandled)?;
109 let output = output.meta(generic);
110 output.build()
111 };
112 if tmp.message.is_none() {
113 tmp.message = _error_message;
114 }
115 tmp
116 }),
117 _ => crate::operation::get_workflow_execution::GetWorkflowExecutionError::generic(generic),
118 })
119}
120
121#[allow(clippy::unnecessary_wraps)]
122pub fn de_get_workflow_execution_http_response(
123 _response_status: u16,
124 _response_headers: &::aws_smithy_runtime_api::http::Headers,
125 _response_body: &[u8],
126) -> std::result::Result<
127 crate::operation::get_workflow_execution::GetWorkflowExecutionOutput,
128 crate::operation::get_workflow_execution::GetWorkflowExecutionError,
129> {
130 Ok({
131 #[allow(unused_mut)]
132 let mut output = crate::operation::get_workflow_execution::builders::GetWorkflowExecutionOutputBuilder::default();
133 output = crate::protocol_serde::shape_get_workflow_execution::de_get_workflow_execution(_response_body, output)
134 .map_err(crate::operation::get_workflow_execution::GetWorkflowExecutionError::unhandled)?;
135 output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
136 output.build()
137 })
138}
139
140pub(crate) fn de_get_workflow_execution(
141 value: &[u8],
142 mut builder: crate::operation::get_workflow_execution::builders::GetWorkflowExecutionOutputBuilder,
143) -> ::std::result::Result<
144 crate::operation::get_workflow_execution::builders::GetWorkflowExecutionOutputBuilder,
145 ::aws_smithy_json::deserialize::error::DeserializeError,
146> {
147 let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
148 let tokens = &mut tokens_owned;
149 ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
150 loop {
151 match tokens.next().transpose()? {
152 Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
153 Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
154 "endTime" => {
155 builder = builder.set_end_time(
156 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
157 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
158 .transpose()?,
159 );
160 }
161 "imageBuildVersionArn" => {
162 builder = builder.set_image_build_version_arn(
163 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
164 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
165 .transpose()?,
166 );
167 }
168 "message" => {
169 builder = builder.set_message(
170 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
171 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
172 .transpose()?,
173 );
174 }
175 "parallelGroup" => {
176 builder = builder.set_parallel_group(
177 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
178 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
179 .transpose()?,
180 );
181 }
182 "requestId" => {
183 builder = builder.set_request_id(
184 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
185 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
186 .transpose()?,
187 );
188 }
189 "startTime" => {
190 builder = builder.set_start_time(
191 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
192 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
193 .transpose()?,
194 );
195 }
196 "status" => {
197 builder = builder.set_status(
198 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
199 .map(|s| s.to_unescaped().map(|u| crate::types::WorkflowExecutionStatus::from(u.as_ref())))
200 .transpose()?,
201 );
202 }
203 "totalStepCount" => {
204 builder = builder.set_total_step_count(
205 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
206 .map(i32::try_from)
207 .transpose()?,
208 );
209 }
210 "totalStepsFailed" => {
211 builder = builder.set_total_steps_failed(
212 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
213 .map(i32::try_from)
214 .transpose()?,
215 );
216 }
217 "totalStepsSkipped" => {
218 builder = builder.set_total_steps_skipped(
219 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
220 .map(i32::try_from)
221 .transpose()?,
222 );
223 }
224 "totalStepsSucceeded" => {
225 builder = builder.set_total_steps_succeeded(
226 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
227 .map(i32::try_from)
228 .transpose()?,
229 );
230 }
231 "type" => {
232 builder = builder.set_type(
233 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
234 .map(|s| s.to_unescaped().map(|u| crate::types::WorkflowType::from(u.as_ref())))
235 .transpose()?,
236 );
237 }
238 "workflowBuildVersionArn" => {
239 builder = builder.set_workflow_build_version_arn(
240 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
241 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
242 .transpose()?,
243 );
244 }
245 "workflowExecutionId" => {
246 builder = builder.set_workflow_execution_id(
247 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
248 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
249 .transpose()?,
250 );
251 }
252 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
253 },
254 other => {
255 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
256 "expected object key or end object, found: {:?}",
257 other
258 )))
259 }
260 }
261 }
262 if tokens.next().is_some() {
263 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
264 "found more JSON tokens after completing parsing",
265 ));
266 }
267 Ok(builder)
268}