aws_sdk_apigatewayv2/protocol_serde/
shape_get_integration.rs1#[allow(clippy::unnecessary_wraps)]
3pub fn de_get_integration_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::get_integration::GetIntegrationOutput, crate::operation::get_integration::GetIntegrationError> {
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::get_integration::GetIntegrationError::unhandled)?;
11 generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
12 let generic = generic_builder.build();
13 let error_code = match generic.code() {
14 Some(code) => code,
15 None => return Err(crate::operation::get_integration::GetIntegrationError::unhandled(generic)),
16 };
17
18 let _error_message = generic.message().map(|msg| msg.to_owned());
19 Err(match error_code {
20 "NotFoundException" => crate::operation::get_integration::GetIntegrationError::NotFoundException({
21 #[allow(unused_mut)]
22 let mut tmp = {
23 #[allow(unused_mut)]
24 let mut output = crate::types::error::builders::NotFoundExceptionBuilder::default();
25 output = crate::protocol_serde::shape_not_found_exception::de_not_found_exception_json_err(_response_body, output)
26 .map_err(crate::operation::get_integration::GetIntegrationError::unhandled)?;
27 let output = output.meta(generic);
28 output.build()
29 };
30 if tmp.message.is_none() {
31 tmp.message = _error_message;
32 }
33 tmp
34 }),
35 "TooManyRequestsException" => crate::operation::get_integration::GetIntegrationError::TooManyRequestsException({
36 #[allow(unused_mut)]
37 let mut tmp = {
38 #[allow(unused_mut)]
39 let mut output = crate::types::error::builders::TooManyRequestsExceptionBuilder::default();
40 output = crate::protocol_serde::shape_too_many_requests_exception::de_too_many_requests_exception_json_err(_response_body, output)
41 .map_err(crate::operation::get_integration::GetIntegrationError::unhandled)?;
42 let output = output.meta(generic);
43 output.build()
44 };
45 if tmp.message.is_none() {
46 tmp.message = _error_message;
47 }
48 tmp
49 }),
50 _ => crate::operation::get_integration::GetIntegrationError::generic(generic),
51 })
52}
53
54#[allow(clippy::unnecessary_wraps)]
55pub fn de_get_integration_http_response(
56 _response_status: u16,
57 _response_headers: &::aws_smithy_runtime_api::http::Headers,
58 _response_body: &[u8],
59) -> std::result::Result<crate::operation::get_integration::GetIntegrationOutput, crate::operation::get_integration::GetIntegrationError> {
60 Ok({
61 #[allow(unused_mut)]
62 let mut output = crate::operation::get_integration::builders::GetIntegrationOutputBuilder::default();
63 output = crate::protocol_serde::shape_get_integration::de_get_integration(_response_body, output)
64 .map_err(crate::operation::get_integration::GetIntegrationError::unhandled)?;
65 output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
66 output.build()
67 })
68}
69
70pub(crate) fn de_get_integration(
71 value: &[u8],
72 mut builder: crate::operation::get_integration::builders::GetIntegrationOutputBuilder,
73) -> ::std::result::Result<
74 crate::operation::get_integration::builders::GetIntegrationOutputBuilder,
75 ::aws_smithy_json::deserialize::error::DeserializeError,
76> {
77 let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
78 let tokens = &mut tokens_owned;
79 ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
80 loop {
81 match tokens.next().transpose()? {
82 Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
83 Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
84 "apiGatewayManaged" => {
85 builder = builder.set_api_gateway_managed(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
86 }
87 "connectionId" => {
88 builder = builder.set_connection_id(
89 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
90 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
91 .transpose()?,
92 );
93 }
94 "connectionType" => {
95 builder = builder.set_connection_type(
96 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
97 .map(|s| s.to_unescaped().map(|u| crate::types::ConnectionType::from(u.as_ref())))
98 .transpose()?,
99 );
100 }
101 "contentHandlingStrategy" => {
102 builder = builder.set_content_handling_strategy(
103 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
104 .map(|s| s.to_unescaped().map(|u| crate::types::ContentHandlingStrategy::from(u.as_ref())))
105 .transpose()?,
106 );
107 }
108 "credentialsArn" => {
109 builder = builder.set_credentials_arn(
110 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
111 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
112 .transpose()?,
113 );
114 }
115 "description" => {
116 builder = builder.set_description(
117 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
118 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
119 .transpose()?,
120 );
121 }
122 "integrationId" => {
123 builder = builder.set_integration_id(
124 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
125 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
126 .transpose()?,
127 );
128 }
129 "integrationMethod" => {
130 builder = builder.set_integration_method(
131 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
132 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
133 .transpose()?,
134 );
135 }
136 "integrationResponseSelectionExpression" => {
137 builder = builder.set_integration_response_selection_expression(
138 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
139 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
140 .transpose()?,
141 );
142 }
143 "integrationSubtype" => {
144 builder = builder.set_integration_subtype(
145 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
146 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
147 .transpose()?,
148 );
149 }
150 "integrationType" => {
151 builder = builder.set_integration_type(
152 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
153 .map(|s| s.to_unescaped().map(|u| crate::types::IntegrationType::from(u.as_ref())))
154 .transpose()?,
155 );
156 }
157 "integrationUri" => {
158 builder = builder.set_integration_uri(
159 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
160 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
161 .transpose()?,
162 );
163 }
164 "passthroughBehavior" => {
165 builder = builder.set_passthrough_behavior(
166 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
167 .map(|s| s.to_unescaped().map(|u| crate::types::PassthroughBehavior::from(u.as_ref())))
168 .transpose()?,
169 );
170 }
171 "payloadFormatVersion" => {
172 builder = builder.set_payload_format_version(
173 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
174 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
175 .transpose()?,
176 );
177 }
178 "requestParameters" => {
179 builder = builder.set_request_parameters(crate::protocol_serde::shape_integration_parameters::de_integration_parameters(tokens)?);
180 }
181 "requestTemplates" => {
182 builder = builder.set_request_templates(crate::protocol_serde::shape_template_map::de_template_map(tokens)?);
183 }
184 "responseParameters" => {
185 builder = builder.set_response_parameters(crate::protocol_serde::shape_response_parameters::de_response_parameters(tokens)?);
186 }
187 "templateSelectionExpression" => {
188 builder = builder.set_template_selection_expression(
189 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
190 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
191 .transpose()?,
192 );
193 }
194 "timeoutInMillis" => {
195 builder = builder.set_timeout_in_millis(
196 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
197 .map(i32::try_from)
198 .transpose()?,
199 );
200 }
201 "tlsConfig" => {
202 builder = builder.set_tls_config(crate::protocol_serde::shape_tls_config::de_tls_config(tokens)?);
203 }
204 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
205 },
206 other => {
207 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
208 "expected object key or end object, found: {:?}",
209 other
210 )))
211 }
212 }
213 }
214 if tokens.next().is_some() {
215 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
216 "found more JSON tokens after completing parsing",
217 ));
218 }
219 Ok(builder)
220}