aws_sdk_s3/protocol_serde/
shape_list_objects_v2.rs1#[allow(clippy::unnecessary_wraps)]
3pub fn de_list_objects_v2_http_error(
4 _response_status: u16,
5 _response_headers: &::aws_smithy_runtime_api::http::Headers,
6 _response_body: &[u8],
7) -> std::result::Result<crate::operation::list_objects_v2::ListObjectsV2Output, crate::operation::list_objects_v2::ListObjectsV2Error> {
8 #[allow(unused_mut)]
9 let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
10 .map_err(crate::operation::list_objects_v2::ListObjectsV2Error::unhandled)?;
11 generic_builder = crate::s3_request_id::apply_extended_request_id(generic_builder, _response_headers);
12 generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
13 let generic = generic_builder.build();
14 let error_code = match generic.code() {
15 Some(code) => code,
16 None => return Err(crate::operation::list_objects_v2::ListObjectsV2Error::unhandled(generic)),
17 };
18
19 let _error_message = generic.message().map(|msg| msg.to_owned());
20 Err(match error_code {
21 "NoSuchBucket" => crate::operation::list_objects_v2::ListObjectsV2Error::NoSuchBucket({
22 #[allow(unused_mut)]
23 let mut tmp = {
24 #[allow(unused_mut)]
25 let mut output = crate::types::error::builders::NoSuchBucketBuilder::default();
26 output = crate::protocol_serde::shape_no_such_bucket::de_no_such_bucket_xml_err(_response_body, output)
27 .map_err(crate::operation::list_objects_v2::ListObjectsV2Error::unhandled)?;
28 let output = output.meta(generic);
29 output.build()
30 };
31 if tmp.message.is_none() {
32 tmp.message = _error_message;
33 }
34 tmp
35 }),
36 _ => crate::operation::list_objects_v2::ListObjectsV2Error::generic(generic),
37 })
38}
39
40#[allow(clippy::unnecessary_wraps)]
41pub fn de_list_objects_v2_http_response(
42 _response_status: u16,
43 _response_headers: &::aws_smithy_runtime_api::http::Headers,
44 _response_body: &[u8],
45) -> std::result::Result<crate::operation::list_objects_v2::ListObjectsV2Output, crate::operation::list_objects_v2::ListObjectsV2Error> {
46 Ok({
47 #[allow(unused_mut)]
48 let mut output = crate::operation::list_objects_v2::builders::ListObjectsV2OutputBuilder::default();
49 output = crate::protocol_serde::shape_list_objects_v2::de_list_objects_v2(_response_body, output)
50 .map_err(crate::operation::list_objects_v2::ListObjectsV2Error::unhandled)?;
51 output = output.set_request_charged(
52 crate::protocol_serde::shape_list_objects_v2_output::de_request_charged_header(_response_headers).map_err(|_| {
53 crate::operation::list_objects_v2::ListObjectsV2Error::unhandled("Failed to parse RequestCharged from header `x-amz-request-charged")
54 })?,
55 );
56 output._set_extended_request_id(crate::s3_request_id::RequestIdExt::extended_request_id(_response_headers).map(str::to_string));
57 output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
58 output.build()
59 })
60}
61
62pub fn ser_list_objects_v2_headers(
63 input: &crate::operation::list_objects_v2::ListObjectsV2Input,
64 mut builder: ::http::request::Builder,
65) -> std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
66 if let ::std::option::Option::Some(inner_1) = &input.request_payer {
67 let formatted_2 = inner_1.as_str();
68 let header_value = formatted_2;
69 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
70 ::aws_smithy_types::error::operation::BuildError::invalid_field(
71 "request_payer",
72 format!("`{}` cannot be used as a header value: {}", &header_value, err),
73 )
74 })?;
75 builder = builder.header("x-amz-request-payer", header_value);
76 }
77 if let ::std::option::Option::Some(inner_3) = &input.expected_bucket_owner {
78 let formatted_4 = inner_3.as_str();
79 let header_value = formatted_4;
80 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
81 ::aws_smithy_types::error::operation::BuildError::invalid_field(
82 "expected_bucket_owner",
83 format!("`{}` cannot be used as a header value: {}", &header_value, err),
84 )
85 })?;
86 builder = builder.header("x-amz-expected-bucket-owner", header_value);
87 }
88 if let ::std::option::Option::Some(inner_5) = &input.optional_object_attributes {
89 if inner_5.is_empty() {
91 builder = builder.header("x-amz-optional-object-attributes", "");
92 } else {
93 for inner_6 in inner_5 {
94 let formatted_7 = ::aws_smithy_http::header::quote_header_value(inner_6.as_str());
95 let header_value = formatted_7;
96 let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
97 ::aws_smithy_types::error::operation::BuildError::invalid_field(
98 "optional_object_attributes",
99 format!("`{}` cannot be used as a header value: {}", &header_value, err),
100 )
101 })?;
102 builder = builder.header("x-amz-optional-object-attributes", header_value);
103 }
104 }
105 }
106 Ok(builder)
107}
108
109#[allow(unused_mut)]
110pub fn de_list_objects_v2(
111 inp: &[u8],
112 mut builder: crate::operation::list_objects_v2::builders::ListObjectsV2OutputBuilder,
113) -> std::result::Result<crate::operation::list_objects_v2::builders::ListObjectsV2OutputBuilder, ::aws_smithy_xml::decode::XmlDecodeError> {
114 let mut doc = ::aws_smithy_xml::decode::Document::try_from(inp)?;
115
116 #[allow(unused_mut)]
117 let mut decoder = doc.root_element()?;
118 #[allow(unused_variables)]
119 let start_el = decoder.start_el();
120 if !start_el.matches("ListBucketResult") {
121 return Err(::aws_smithy_xml::decode::XmlDecodeError::custom(format!(
122 "encountered invalid XML root: expected ListBucketResult but got {start_el:?}. This is likely a bug in the SDK."
123 )));
124 }
125 while let Some(mut tag) = decoder.next_tag() {
126 match tag.start_el() {
127 s if s.matches("CommonPrefixes") => {
128 let var_8 =
129 Some(
130 Result::<::std::vec::Vec::<crate::types::CommonPrefix>, ::aws_smithy_xml::decode::XmlDecodeError>::Ok({
131 let mut list_9 = builder.common_prefixes.take().unwrap_or_default();
132 list_9.push(
133 crate::protocol_serde::shape_common_prefix::de_common_prefix(&mut tag)
134 ?
135 );
136 list_9
137 })
138 ?
139 )
140 ;
141 builder = builder.set_common_prefixes(var_8);
142 }
143 ,
144 s if s.matches("NextContinuationToken") => {
145 let var_10 =
146 Some(
147 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
148 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
149 .into()
150 )
151 ?
152 )
153 ;
154 builder = builder.set_next_continuation_token(var_10);
155 }
156 ,
157 s if s.matches("ContinuationToken") => {
158 let var_11 =
159 Some(
160 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
161 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
162 .into()
163 )
164 ?
165 )
166 ;
167 builder = builder.set_continuation_token(var_11);
168 }
169 ,
170 s if s.matches("Delimiter") => {
171 let var_12 =
172 Some(
173 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
174 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
175 .into()
176 )
177 ?
178 )
179 ;
180 builder = builder.set_delimiter(var_12);
181 }
182 ,
183 s if s.matches("EncodingType") => {
184 let var_13 =
185 Some(
186 Result::<crate::types::EncodingType, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
187 crate::types::EncodingType::from(
188 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
189 )
190 )
191 ?
192 )
193 ;
194 builder = builder.set_encoding_type(var_13);
195 }
196 ,
197 s if s.matches("IsTruncated") => {
198 let var_14 =
199 Some(
200 {
201 <bool as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(
202 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
203 )
204 .map_err(|_|::aws_smithy_xml::decode::XmlDecodeError::custom("expected (boolean: `com.amazonaws.s3#IsTruncated`)"))
205 }
206 ?
207 )
208 ;
209 builder = builder.set_is_truncated(var_14);
210 }
211 ,
212 s if s.matches("Prefix") => {
213 let var_15 =
214 Some(
215 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
216 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
217 .into()
218 )
219 ?
220 )
221 ;
222 builder = builder.set_prefix(var_15);
223 }
224 ,
225 s if s.matches("Name") => {
226 let var_16 =
227 Some(
228 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
229 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
230 .into()
231 )
232 ?
233 )
234 ;
235 builder = builder.set_name(var_16);
236 }
237 ,
238 s if s.matches("Contents") => {
239 let var_17 =
240 Some(
241 Result::<::std::vec::Vec::<crate::types::Object>, ::aws_smithy_xml::decode::XmlDecodeError>::Ok({
242 let mut list_18 = builder.contents.take().unwrap_or_default();
243 list_18.push(
244 crate::protocol_serde::shape_object::de_object(&mut tag)
245 ?
246 );
247 list_18
248 })
249 ?
250 )
251 ;
252 builder = builder.set_contents(var_17);
253 }
254 ,
255 s if s.matches("StartAfter") => {
256 let var_19 =
257 Some(
258 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
259 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
260 .into()
261 )
262 ?
263 )
264 ;
265 builder = builder.set_start_after(var_19);
266 }
267 ,
268 s if s.matches("MaxKeys") => {
269 let var_20 =
270 Some(
271 {
272 <i32 as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(
273 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
274 )
275 .map_err(|_|::aws_smithy_xml::decode::XmlDecodeError::custom("expected (integer: `com.amazonaws.s3#MaxKeys`)"))
276 }
277 ?
278 )
279 ;
280 builder = builder.set_max_keys(var_20);
281 }
282 ,
283 s if s.matches("KeyCount") => {
284 let var_21 =
285 Some(
286 {
287 <i32 as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(
288 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
289 )
290 .map_err(|_|::aws_smithy_xml::decode::XmlDecodeError::custom("expected (integer: `com.amazonaws.s3#KeyCount`)"))
291 }
292 ?
293 )
294 ;
295 builder = builder.set_key_count(var_21);
296 }
297 ,
298 _ => {}
299 }
300 }
301 Ok(builder)
302}