aws_sdk_s3/protocol_serde/
shape_list_objects.rs1#[allow(clippy::unnecessary_wraps)]
3pub fn de_list_objects_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::ListObjectsOutput, crate::operation::list_objects::ListObjectsError> {
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::ListObjectsError::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::ListObjectsError::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::ListObjectsError::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::ListObjectsError::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::ListObjectsError::generic(generic),
37 })
38}
39
40#[allow(clippy::unnecessary_wraps)]
41pub fn de_list_objects_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::ListObjectsOutput, crate::operation::list_objects::ListObjectsError> {
46 Ok({
47 #[allow(unused_mut)]
48 let mut output = crate::operation::list_objects::builders::ListObjectsOutputBuilder::default();
49 output = crate::protocol_serde::shape_list_objects::de_list_objects(_response_body, output)
50 .map_err(crate::operation::list_objects::ListObjectsError::unhandled)?;
51 output = output.set_request_charged(
52 crate::protocol_serde::shape_list_objects_output::de_request_charged_header(_response_headers).map_err(|_| {
53 crate::operation::list_objects::ListObjectsError::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_headers(
63 input: &crate::operation::list_objects::ListObjectsInput,
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(
111 inp: &[u8],
112 mut builder: crate::operation::list_objects::builders::ListObjectsOutputBuilder,
113) -> std::result::Result<crate::operation::list_objects::builders::ListObjectsOutputBuilder, ::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("Contents") => {
145 let var_10 =
146 Some(
147 Result::<::std::vec::Vec::<crate::types::Object>, ::aws_smithy_xml::decode::XmlDecodeError>::Ok({
148 let mut list_11 = builder.contents.take().unwrap_or_default();
149 list_11.push(
150 crate::protocol_serde::shape_object::de_object(&mut tag)
151 ?
152 );
153 list_11
154 })
155 ?
156 )
157 ;
158 builder = builder.set_contents(var_10);
159 }
160 ,
161 s if s.matches("Delimiter") => {
162 let var_12 =
163 Some(
164 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
165 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
166 .into()
167 )
168 ?
169 )
170 ;
171 builder = builder.set_delimiter(var_12);
172 }
173 ,
174 s if s.matches("EncodingType") => {
175 let var_13 =
176 Some(
177 Result::<crate::types::EncodingType, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
178 crate::types::EncodingType::from(
179 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
180 )
181 )
182 ?
183 )
184 ;
185 builder = builder.set_encoding_type(var_13);
186 }
187 ,
188 s if s.matches("IsTruncated") => {
189 let var_14 =
190 Some(
191 {
192 <bool as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(
193 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
194 )
195 .map_err(|_|::aws_smithy_xml::decode::XmlDecodeError::custom("expected (boolean: `com.amazonaws.s3#IsTruncated`)"))
196 }
197 ?
198 )
199 ;
200 builder = builder.set_is_truncated(var_14);
201 }
202 ,
203 s if s.matches("Marker") => {
204 let var_15 =
205 Some(
206 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
207 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
208 .into()
209 )
210 ?
211 )
212 ;
213 builder = builder.set_marker(var_15);
214 }
215 ,
216 s if s.matches("Prefix") => {
217 let var_16 =
218 Some(
219 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
220 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
221 .into()
222 )
223 ?
224 )
225 ;
226 builder = builder.set_prefix(var_16);
227 }
228 ,
229 s if s.matches("NextMarker") => {
230 let var_17 =
231 Some(
232 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
233 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
234 .into()
235 )
236 ?
237 )
238 ;
239 builder = builder.set_next_marker(var_17);
240 }
241 ,
242 s if s.matches("MaxKeys") => {
243 let var_18 =
244 Some(
245 {
246 <i32 as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(
247 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
248 )
249 .map_err(|_|::aws_smithy_xml::decode::XmlDecodeError::custom("expected (integer: `com.amazonaws.s3#MaxKeys`)"))
250 }
251 ?
252 )
253 ;
254 builder = builder.set_max_keys(var_18);
255 }
256 ,
257 s if s.matches("Name") => {
258 let var_19 =
259 Some(
260 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
261 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
262 .into()
263 )
264 ?
265 )
266 ;
267 builder = builder.set_name(var_19);
268 }
269 ,
270 _ => {}
271 }
272 }
273 Ok(builder)
274}