aws_sdk_datasync/protocol_serde/
shape_describe_task_execution.rs1#[allow(clippy::unnecessary_wraps)]
3pub fn de_describe_task_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::describe_task_execution::DescribeTaskExecutionOutput,
9 crate::operation::describe_task_execution::DescribeTaskExecutionError,
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::describe_task_execution::DescribeTaskExecutionError::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::describe_task_execution::DescribeTaskExecutionError::unhandled(generic)),
19 };
20
21 let _error_message = generic.message().map(|msg| msg.to_owned());
22 Err(match error_code {
23 "InternalException" => crate::operation::describe_task_execution::DescribeTaskExecutionError::InternalException({
24 #[allow(unused_mut)]
25 let mut tmp = {
26 #[allow(unused_mut)]
27 let mut output = crate::types::error::builders::InternalExceptionBuilder::default();
28 output = crate::protocol_serde::shape_internal_exception::de_internal_exception_json_err(_response_body, output)
29 .map_err(crate::operation::describe_task_execution::DescribeTaskExecutionError::unhandled)?;
30 let output = output.meta(generic);
31 output.build()
32 };
33 if tmp.message.is_none() {
34 tmp.message = _error_message;
35 }
36 tmp
37 }),
38 "InvalidRequestException" => crate::operation::describe_task_execution::DescribeTaskExecutionError::InvalidRequestException({
39 #[allow(unused_mut)]
40 let mut tmp = {
41 #[allow(unused_mut)]
42 let mut output = crate::types::error::builders::InvalidRequestExceptionBuilder::default();
43 output = crate::protocol_serde::shape_invalid_request_exception::de_invalid_request_exception_json_err(_response_body, output)
44 .map_err(crate::operation::describe_task_execution::DescribeTaskExecutionError::unhandled)?;
45 let output = output.meta(generic);
46 output.build()
47 };
48 if tmp.message.is_none() {
49 tmp.message = _error_message;
50 }
51 tmp
52 }),
53 _ => crate::operation::describe_task_execution::DescribeTaskExecutionError::generic(generic),
54 })
55}
56
57#[allow(clippy::unnecessary_wraps)]
58pub fn de_describe_task_execution_http_response(
59 _response_status: u16,
60 _response_headers: &::aws_smithy_runtime_api::http::Headers,
61 _response_body: &[u8],
62) -> std::result::Result<
63 crate::operation::describe_task_execution::DescribeTaskExecutionOutput,
64 crate::operation::describe_task_execution::DescribeTaskExecutionError,
65> {
66 Ok({
67 #[allow(unused_mut)]
68 let mut output = crate::operation::describe_task_execution::builders::DescribeTaskExecutionOutputBuilder::default();
69 output = crate::protocol_serde::shape_describe_task_execution::de_describe_task_execution(_response_body, output)
70 .map_err(crate::operation::describe_task_execution::DescribeTaskExecutionError::unhandled)?;
71 output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
72 output.build()
73 })
74}
75
76pub fn ser_describe_task_execution_input(
77 input: &crate::operation::describe_task_execution::DescribeTaskExecutionInput,
78) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
79 let mut out = String::new();
80 let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
81 crate::protocol_serde::shape_describe_task_execution_input::ser_describe_task_execution_input_input(&mut object, input)?;
82 object.finish();
83 Ok(::aws_smithy_types::body::SdkBody::from(out))
84}
85
86pub(crate) fn de_describe_task_execution(
87 value: &[u8],
88 mut builder: crate::operation::describe_task_execution::builders::DescribeTaskExecutionOutputBuilder,
89) -> ::std::result::Result<
90 crate::operation::describe_task_execution::builders::DescribeTaskExecutionOutputBuilder,
91 ::aws_smithy_json::deserialize::error::DeserializeError,
92> {
93 let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
94 let tokens = &mut tokens_owned;
95 ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
96 loop {
97 match tokens.next().transpose()? {
98 Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
99 Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
100 "TaskExecutionArn" => {
101 builder = builder.set_task_execution_arn(
102 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
103 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
104 .transpose()?,
105 );
106 }
107 "Status" => {
108 builder = builder.set_status(
109 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
110 .map(|s| s.to_unescaped().map(|u| crate::types::TaskExecutionStatus::from(u.as_ref())))
111 .transpose()?,
112 );
113 }
114 "Options" => {
115 builder = builder.set_options(crate::protocol_serde::shape_options::de_options(tokens)?);
116 }
117 "Excludes" => {
118 builder = builder.set_excludes(crate::protocol_serde::shape_filter_list::de_filter_list(tokens)?);
119 }
120 "Includes" => {
121 builder = builder.set_includes(crate::protocol_serde::shape_filter_list::de_filter_list(tokens)?);
122 }
123 "ManifestConfig" => {
124 builder = builder.set_manifest_config(crate::protocol_serde::shape_manifest_config::de_manifest_config(tokens)?);
125 }
126 "StartTime" => {
127 builder = builder.set_start_time(::aws_smithy_json::deserialize::token::expect_timestamp_or_null(
128 tokens.next(),
129 ::aws_smithy_types::date_time::Format::EpochSeconds,
130 )?);
131 }
132 "EstimatedFilesToTransfer" => {
133 builder = builder.set_estimated_files_to_transfer(
134 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
135 .map(i64::try_from)
136 .transpose()?,
137 );
138 }
139 "EstimatedBytesToTransfer" => {
140 builder = builder.set_estimated_bytes_to_transfer(
141 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
142 .map(i64::try_from)
143 .transpose()?,
144 );
145 }
146 "FilesTransferred" => {
147 builder = builder.set_files_transferred(
148 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
149 .map(i64::try_from)
150 .transpose()?,
151 );
152 }
153 "BytesWritten" => {
154 builder = builder.set_bytes_written(
155 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
156 .map(i64::try_from)
157 .transpose()?,
158 );
159 }
160 "BytesTransferred" => {
161 builder = builder.set_bytes_transferred(
162 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
163 .map(i64::try_from)
164 .transpose()?,
165 );
166 }
167 "BytesCompressed" => {
168 builder = builder.set_bytes_compressed(
169 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
170 .map(i64::try_from)
171 .transpose()?,
172 );
173 }
174 "Result" => {
175 builder = builder.set_result(crate::protocol_serde::shape_task_execution_result_detail::de_task_execution_result_detail(tokens)?);
176 }
177 "TaskReportConfig" => {
178 builder = builder.set_task_report_config(crate::protocol_serde::shape_task_report_config::de_task_report_config(tokens)?);
179 }
180 "FilesDeleted" => {
181 builder = builder.set_files_deleted(
182 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
183 .map(i64::try_from)
184 .transpose()?,
185 );
186 }
187 "FilesSkipped" => {
188 builder = builder.set_files_skipped(
189 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
190 .map(i64::try_from)
191 .transpose()?,
192 );
193 }
194 "FilesVerified" => {
195 builder = builder.set_files_verified(
196 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
197 .map(i64::try_from)
198 .transpose()?,
199 );
200 }
201 "ReportResult" => {
202 builder = builder.set_report_result(crate::protocol_serde::shape_report_result::de_report_result(tokens)?);
203 }
204 "EstimatedFilesToDelete" => {
205 builder = builder.set_estimated_files_to_delete(
206 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
207 .map(i64::try_from)
208 .transpose()?,
209 );
210 }
211 "TaskMode" => {
212 builder = builder.set_task_mode(
213 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
214 .map(|s| s.to_unescaped().map(|u| crate::types::TaskMode::from(u.as_ref())))
215 .transpose()?,
216 );
217 }
218 "FilesPrepared" => {
219 builder = builder.set_files_prepared(
220 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
221 .map(i64::try_from)
222 .transpose()?,
223 );
224 }
225 "FilesListed" => {
226 builder = builder.set_files_listed(
227 crate::protocol_serde::shape_task_execution_files_listed_detail::de_task_execution_files_listed_detail(tokens)?,
228 );
229 }
230 "FilesFailed" => {
231 builder = builder.set_files_failed(
232 crate::protocol_serde::shape_task_execution_files_failed_detail::de_task_execution_files_failed_detail(tokens)?,
233 );
234 }
235 "LaunchTime" => {
236 builder = builder.set_launch_time(::aws_smithy_json::deserialize::token::expect_timestamp_or_null(
237 tokens.next(),
238 ::aws_smithy_types::date_time::Format::EpochSeconds,
239 )?);
240 }
241 "EndTime" => {
242 builder = builder.set_end_time(::aws_smithy_json::deserialize::token::expect_timestamp_or_null(
243 tokens.next(),
244 ::aws_smithy_types::date_time::Format::EpochSeconds,
245 )?);
246 }
247 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
248 },
249 other => {
250 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
251 "expected object key or end object, found: {:?}",
252 other
253 )))
254 }
255 }
256 }
257 if tokens.next().is_some() {
258 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
259 "found more JSON tokens after completing parsing",
260 ));
261 }
262 Ok(builder)
263}