aws_sdk_s3/protocol_serde/
shape_list_objects.rs
1#[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 {:?}. This is likely a bug in the SDK.",
123 start_el
124 )));
125 }
126 while let Some(mut tag) = decoder.next_tag() {
127 match tag.start_el() {
128 s if s.matches("CommonPrefixes") => {
129 let var_8 =
130 Some(
131 Result::<::std::vec::Vec::<crate::types::CommonPrefix>, ::aws_smithy_xml::decode::XmlDecodeError>::Ok({
132 let mut list_9 = builder.common_prefixes.take().unwrap_or_default();
133 list_9.push(
134 crate::protocol_serde::shape_common_prefix::de_common_prefix(&mut tag)
135 ?
136 );
137 list_9
138 })
139 ?
140 )
141 ;
142 builder = builder.set_common_prefixes(var_8);
143 }
144 ,
145 s if s.matches("Contents") => {
146 let var_10 =
147 Some(
148 Result::<::std::vec::Vec::<crate::types::Object>, ::aws_smithy_xml::decode::XmlDecodeError>::Ok({
149 let mut list_11 = builder.contents.take().unwrap_or_default();
150 list_11.push(
151 crate::protocol_serde::shape_object::de_object(&mut tag)
152 ?
153 );
154 list_11
155 })
156 ?
157 )
158 ;
159 builder = builder.set_contents(var_10);
160 }
161 ,
162 s if s.matches("Delimiter") => {
163 let var_12 =
164 Some(
165 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
166 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
167 .into()
168 )
169 ?
170 )
171 ;
172 builder = builder.set_delimiter(var_12);
173 }
174 ,
175 s if s.matches("EncodingType") => {
176 let var_13 =
177 Some(
178 Result::<crate::types::EncodingType, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
179 crate::types::EncodingType::from(
180 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
181 )
182 )
183 ?
184 )
185 ;
186 builder = builder.set_encoding_type(var_13);
187 }
188 ,
189 s if s.matches("IsTruncated") => {
190 let var_14 =
191 Some(
192 {
193 <bool as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(
194 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
195 )
196 .map_err(|_|::aws_smithy_xml::decode::XmlDecodeError::custom("expected (boolean: `com.amazonaws.s3#IsTruncated`)"))
197 }
198 ?
199 )
200 ;
201 builder = builder.set_is_truncated(var_14);
202 }
203 ,
204 s if s.matches("Marker") => {
205 let var_15 =
206 Some(
207 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
208 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
209 .into()
210 )
211 ?
212 )
213 ;
214 builder = builder.set_marker(var_15);
215 }
216 ,
217 s if s.matches("Prefix") => {
218 let var_16 =
219 Some(
220 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
221 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
222 .into()
223 )
224 ?
225 )
226 ;
227 builder = builder.set_prefix(var_16);
228 }
229 ,
230 s if s.matches("NextMarker") => {
231 let var_17 =
232 Some(
233 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
234 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
235 .into()
236 )
237 ?
238 )
239 ;
240 builder = builder.set_next_marker(var_17);
241 }
242 ,
243 s if s.matches("MaxKeys") => {
244 let var_18 =
245 Some(
246 {
247 <i32 as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(
248 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
249 )
250 .map_err(|_|::aws_smithy_xml::decode::XmlDecodeError::custom("expected (integer: `com.amazonaws.s3#MaxKeys`)"))
251 }
252 ?
253 )
254 ;
255 builder = builder.set_max_keys(var_18);
256 }
257 ,
258 s if s.matches("Name") => {
259 let var_19 =
260 Some(
261 Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
262 ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
263 .into()
264 )
265 ?
266 )
267 ;
268 builder = builder.set_name(var_19);
269 }
270 ,
271 _ => {}
272 }
273 }
274 Ok(builder)
275}