1 1 | // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
|
2 2 | ::pin_project_lite::pin_project! {
|
3 3 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
4 4 | /// [`ContentTypeParametersInput`](crate::input::ContentTypeParametersInput) using modelled bindings.
|
5 5 | pub struct ContentTypeParametersInputFuture {
|
6 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ContentTypeParametersInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
6 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ContentTypeParametersInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
7 7 | }
|
8 8 | }
|
9 9 |
|
10 10 | impl std::future::Future for ContentTypeParametersInputFuture {
|
11 11 | type Output = Result<
|
12 12 | crate::input::ContentTypeParametersInput,
|
13 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
13 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
14 14 | >;
|
15 15 |
|
16 16 | fn poll(
|
17 17 | self: std::pin::Pin<&mut Self>,
|
18 18 | cx: &mut std::task::Context<'_>,
|
19 19 | ) -> std::task::Poll<Self::Output> {
|
20 20 | let this = self.project();
|
21 21 | this.inner.as_mut().poll(cx)
|
22 22 | }
|
23 23 | }
|
24 24 |
|
25 25 | impl<B>
|
26 - | ::aws_smithy_http_server::request::FromRequest<
|
27 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
26 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
27 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
28 28 | B,
|
29 29 | > for crate::input::ContentTypeParametersInput
|
30 30 | where
|
31 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
31 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
32 32 | B: 'static,
|
33 33 |
|
34 34 | B::Data: Send,
|
35 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
36 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
35 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
36 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
37 37 | {
|
38 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
38 + | type Rejection =
|
39 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
39 40 | type Future = ContentTypeParametersInputFuture;
|
40 41 |
|
41 42 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
42 43 | let fut = async move {
|
43 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
44 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
44 45 | request.headers(),
|
45 46 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
46 47 | ) {
|
47 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
48 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
48 49 | }
|
49 50 | crate::protocol_serde::shape_content_type_parameters::de_content_type_parameters_http_request(request)
|
50 51 | .await
|
51 52 | };
|
52 53 | use ::futures_util::future::TryFutureExt;
|
53 - | let fut = fut.map_err(
|
54 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
54 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
55 55 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
56 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
57 - | },
|
58 - | );
|
56 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
57 + | });
|
59 58 | ContentTypeParametersInputFuture {
|
60 59 | inner: Box::pin(fut),
|
61 60 | }
|
62 61 | }
|
63 62 | }
|
64 63 | impl
|
65 - | ::aws_smithy_http_server::response::IntoResponse<
|
66 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
64 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
65 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
67 66 | > for crate::output::ContentTypeParametersOutput
|
68 67 | {
|
69 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
68 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
70 69 | match crate::protocol_serde::shape_content_type_parameters::ser_content_type_parameters_http_response(self) {
|
71 70 | Ok(response) => response,
|
72 71 | Err(e) => {
|
73 72 | ::tracing::error!(error = %e, "failed to serialize response");
|
74 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
73 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
75 74 | }
|
76 75 | }
|
77 76 | }
|
78 77 | }
|
79 78 | impl
|
80 - | ::aws_smithy_http_server::response::IntoResponse<
|
81 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
79 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
80 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
82 81 | > for crate::error::ContentTypeParametersError
|
83 82 | {
|
84 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
83 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
85 84 | match crate::protocol_serde::shape_content_type_parameters::ser_content_type_parameters_http_error(&self) {
|
86 85 | Ok(mut response) => {
|
87 - | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
86 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
88 87 | response
|
89 88 | },
|
90 89 | Err(e) => {
|
91 90 | ::tracing::error!(error = %e, "failed to serialize response");
|
92 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
91 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
93 92 | }
|
94 93 | }
|
95 94 | }
|
96 95 | }
|
97 96 |
|
98 97 | ::pin_project_lite::pin_project! {
|
99 98 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
100 99 | /// [`PutWithContentEncodingInput`](crate::input::PutWithContentEncodingInput) using modelled bindings.
|
101 100 | pub struct PutWithContentEncodingInputFuture {
|
102 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::PutWithContentEncodingInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
101 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::PutWithContentEncodingInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
103 102 | }
|
104 103 | }
|
105 104 |
|
106 105 | impl std::future::Future for PutWithContentEncodingInputFuture {
|
107 106 | type Output = Result<
|
108 107 | crate::input::PutWithContentEncodingInput,
|
109 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
108 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
110 109 | >;
|
111 110 |
|
112 111 | fn poll(
|
113 112 | self: std::pin::Pin<&mut Self>,
|
114 113 | cx: &mut std::task::Context<'_>,
|
115 114 | ) -> std::task::Poll<Self::Output> {
|
116 115 | let this = self.project();
|
117 116 | this.inner.as_mut().poll(cx)
|
118 117 | }
|
119 118 | }
|
120 119 |
|
121 120 | impl<B>
|
122 - | ::aws_smithy_http_server::request::FromRequest<
|
123 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
121 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
122 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
124 123 | B,
|
125 124 | > for crate::input::PutWithContentEncodingInput
|
126 125 | where
|
127 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
126 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
128 127 | B: 'static,
|
129 128 |
|
130 129 | B::Data: Send,
|
131 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
132 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
130 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
131 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
133 132 | {
|
134 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
133 + | type Rejection =
|
134 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
135 135 | type Future = PutWithContentEncodingInputFuture;
|
136 136 |
|
137 137 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
138 138 | let fut = async move {
|
139 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
139 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
140 140 | request.headers(),
|
141 141 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
142 142 | ) {
|
143 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
143 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
144 144 | }
|
145 145 | crate::protocol_serde::shape_put_with_content_encoding::de_put_with_content_encoding_http_request(request)
|
146 146 | .await
|
147 147 | };
|
148 148 | use ::futures_util::future::TryFutureExt;
|
149 - | let fut = fut.map_err(
|
150 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
149 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
151 150 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
152 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
153 - | },
|
154 - | );
|
151 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
152 + | });
|
155 153 | PutWithContentEncodingInputFuture {
|
156 154 | inner: Box::pin(fut),
|
157 155 | }
|
158 156 | }
|
159 157 | }
|
160 158 | impl
|
161 - | ::aws_smithy_http_server::response::IntoResponse<
|
162 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
159 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
160 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
163 161 | > for crate::output::PutWithContentEncodingOutput
|
164 162 | {
|
165 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
163 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
166 164 | match crate::protocol_serde::shape_put_with_content_encoding::ser_put_with_content_encoding_http_response(self) {
|
167 165 | Ok(response) => response,
|
168 166 | Err(e) => {
|
169 167 | ::tracing::error!(error = %e, "failed to serialize response");
|
170 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
168 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
171 169 | }
|
172 170 | }
|
173 171 | }
|
174 172 | }
|
175 173 | impl
|
176 - | ::aws_smithy_http_server::response::IntoResponse<
|
177 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
174 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
175 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
178 176 | > for crate::error::PutWithContentEncodingError
|
179 177 | {
|
180 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
178 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
181 179 | match crate::protocol_serde::shape_put_with_content_encoding::ser_put_with_content_encoding_http_error(&self) {
|
182 180 | Ok(mut response) => {
|
183 - | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
181 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
184 182 | response
|
185 183 | },
|
186 184 | Err(e) => {
|
187 185 | ::tracing::error!(error = %e, "failed to serialize response");
|
188 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
186 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
189 187 | }
|
190 188 | }
|
191 189 | }
|
192 190 | }
|
193 191 |
|
194 192 | ::pin_project_lite::pin_project! {
|
195 193 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
196 194 | /// [`FractionalSecondsInput`](crate::input::FractionalSecondsInput) using modelled bindings.
|
197 195 | pub struct FractionalSecondsInputFuture {
|
198 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::FractionalSecondsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
196 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::FractionalSecondsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
199 197 | }
|
200 198 | }
|
201 199 |
|
202 200 | impl std::future::Future for FractionalSecondsInputFuture {
|
203 201 | type Output = Result<
|
204 202 | crate::input::FractionalSecondsInput,
|
205 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
203 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
206 204 | >;
|
207 205 |
|
208 206 | fn poll(
|
209 207 | self: std::pin::Pin<&mut Self>,
|
210 208 | cx: &mut std::task::Context<'_>,
|
211 209 | ) -> std::task::Poll<Self::Output> {
|
212 210 | let this = self.project();
|
213 211 | this.inner.as_mut().poll(cx)
|
214 212 | }
|
215 213 | }
|
216 214 |
|
217 215 | impl<B>
|
218 - | ::aws_smithy_http_server::request::FromRequest<
|
219 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
216 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
217 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
220 218 | B,
|
221 219 | > for crate::input::FractionalSecondsInput
|
222 220 | where
|
223 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
221 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
224 222 | B: 'static,
|
225 223 |
|
226 224 | B::Data: Send,
|
227 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
228 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
225 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
226 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
229 227 | {
|
230 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
228 + | type Rejection =
|
229 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
231 230 | type Future = FractionalSecondsInputFuture;
|
232 231 |
|
233 232 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
234 233 | let fut = async move {
|
235 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
234 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
236 235 | request.headers(),
|
237 236 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
238 237 | ) {
|
239 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
238 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
240 239 | }
|
241 240 | crate::protocol_serde::shape_fractional_seconds::de_fractional_seconds_http_request(
|
242 241 | request,
|
243 242 | )
|
244 243 | .await
|
245 244 | };
|
246 245 | use ::futures_util::future::TryFutureExt;
|
247 - | let fut = fut.map_err(
|
248 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
246 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
249 247 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
250 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
251 - | },
|
252 - | );
|
248 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
249 + | });
|
253 250 | FractionalSecondsInputFuture {
|
254 251 | inner: Box::pin(fut),
|
255 252 | }
|
256 253 | }
|
257 254 | }
|
258 255 | impl
|
259 - | ::aws_smithy_http_server::response::IntoResponse<
|
260 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
256 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
257 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
261 258 | > for crate::output::FractionalSecondsOutput
|
262 259 | {
|
263 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
260 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
264 261 | match crate::protocol_serde::shape_fractional_seconds::ser_fractional_seconds_http_response(
|
265 262 | self,
|
266 263 | ) {
|
267 264 | Ok(response) => response,
|
268 265 | Err(e) => {
|
269 266 | ::tracing::error!(error = %e, "failed to serialize response");
|
270 - | ::aws_smithy_http_server::response::IntoResponse::<
|
271 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
272 - | >::into_response(
|
273 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
274 - | e,
|
275 - | ),
|
276 - | )
|
267 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
277 268 | }
|
278 269 | }
|
279 270 | }
|
280 271 | }
|
281 272 | impl
|
282 - | ::aws_smithy_http_server::response::IntoResponse<
|
283 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
273 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
274 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
284 275 | > for crate::error::FractionalSecondsError
|
285 276 | {
|
286 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
277 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
287 278 | match crate::protocol_serde::shape_fractional_seconds::ser_fractional_seconds_http_error(
|
288 279 | &self,
|
289 280 | ) {
|
290 281 | Ok(mut response) => {
|
291 282 | response.extensions_mut().insert(
|
292 - | ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
|
283 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
284 + | self.name(),
|
285 + | ),
|
293 286 | );
|
294 287 | response
|
295 288 | }
|
296 289 | Err(e) => {
|
297 290 | ::tracing::error!(error = %e, "failed to serialize response");
|
298 - | ::aws_smithy_http_server::response::IntoResponse::<
|
299 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
300 - | >::into_response(
|
301 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
302 - | e,
|
303 - | ),
|
304 - | )
|
291 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
305 292 | }
|
306 293 | }
|
307 294 | }
|
308 295 | }
|
309 296 |
|
310 297 | ::pin_project_lite::pin_project! {
|
311 298 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
312 299 | /// [`DatetimeOffsetsInput`](crate::input::DatetimeOffsetsInput) using modelled bindings.
|
313 300 | pub struct DatetimeOffsetsInputFuture {
|
314 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::DatetimeOffsetsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
301 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::DatetimeOffsetsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
315 302 | }
|
316 303 | }
|
317 304 |
|
318 305 | impl std::future::Future for DatetimeOffsetsInputFuture {
|
319 306 | type Output = Result<
|
320 307 | crate::input::DatetimeOffsetsInput,
|
321 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
308 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
322 309 | >;
|
323 310 |
|
324 311 | fn poll(
|
325 312 | self: std::pin::Pin<&mut Self>,
|
326 313 | cx: &mut std::task::Context<'_>,
|
327 314 | ) -> std::task::Poll<Self::Output> {
|
328 315 | let this = self.project();
|
329 316 | this.inner.as_mut().poll(cx)
|
330 317 | }
|
331 318 | }
|
332 319 |
|
333 320 | impl<B>
|
334 - | ::aws_smithy_http_server::request::FromRequest<
|
335 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
321 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
322 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
336 323 | B,
|
337 324 | > for crate::input::DatetimeOffsetsInput
|
338 325 | where
|
339 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
326 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
340 327 | B: 'static,
|
341 328 |
|
342 329 | B::Data: Send,
|
343 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
344 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
330 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
331 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
345 332 | {
|
346 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
333 + | type Rejection =
|
334 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
347 335 | type Future = DatetimeOffsetsInputFuture;
|
348 336 |
|
349 337 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
350 338 | let fut = async move {
|
351 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
339 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
352 340 | request.headers(),
|
353 341 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
354 342 | ) {
|
355 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
343 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
356 344 | }
|
357 345 | crate::protocol_serde::shape_datetime_offsets::de_datetime_offsets_http_request(request)
|
358 346 | .await
|
359 347 | };
|
360 348 | use ::futures_util::future::TryFutureExt;
|
361 - | let fut = fut.map_err(
|
362 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
349 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
363 350 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
364 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
365 - | },
|
366 - | );
|
351 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
352 + | });
|
367 353 | DatetimeOffsetsInputFuture {
|
368 354 | inner: Box::pin(fut),
|
369 355 | }
|
370 356 | }
|
371 357 | }
|
372 358 | impl
|
373 - | ::aws_smithy_http_server::response::IntoResponse<
|
374 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
359 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
360 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
375 361 | > for crate::output::DatetimeOffsetsOutput
|
376 362 | {
|
377 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
363 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
378 364 | match crate::protocol_serde::shape_datetime_offsets::ser_datetime_offsets_http_response(
|
379 365 | self,
|
380 366 | ) {
|
381 367 | Ok(response) => response,
|
382 368 | Err(e) => {
|
383 369 | ::tracing::error!(error = %e, "failed to serialize response");
|
384 - | ::aws_smithy_http_server::response::IntoResponse::<
|
385 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
386 - | >::into_response(
|
387 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
388 - | e,
|
389 - | ),
|
390 - | )
|
370 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
391 371 | }
|
392 372 | }
|
393 373 | }
|
394 374 | }
|
395 375 | impl
|
396 - | ::aws_smithy_http_server::response::IntoResponse<
|
397 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
376 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
377 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
398 378 | > for crate::error::DatetimeOffsetsError
|
399 379 | {
|
400 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
380 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
401 381 | match crate::protocol_serde::shape_datetime_offsets::ser_datetime_offsets_http_error(&self)
|
402 382 | {
|
403 383 | Ok(mut response) => {
|
404 384 | response.extensions_mut().insert(
|
405 - | ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
|
385 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
386 + | self.name(),
|
387 + | ),
|
406 388 | );
|
407 389 | response
|
408 390 | }
|
409 391 | Err(e) => {
|
410 392 | ::tracing::error!(error = %e, "failed to serialize response");
|
411 - | ::aws_smithy_http_server::response::IntoResponse::<
|
412 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
413 - | >::into_response(
|
414 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
415 - | e,
|
416 - | ),
|
417 - | )
|
393 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
418 394 | }
|
419 395 | }
|
420 396 | }
|
421 397 | }
|
422 398 |
|
423 399 | ::pin_project_lite::pin_project! {
|
424 400 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
425 401 | /// [`HostWithPathOperationInput`](crate::input::HostWithPathOperationInput) using modelled bindings.
|
426 402 | pub struct HostWithPathOperationInputFuture {
|
427 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::HostWithPathOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
403 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::HostWithPathOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
428 404 | }
|
429 405 | }
|
430 406 |
|
431 407 | impl std::future::Future for HostWithPathOperationInputFuture {
|
432 408 | type Output = Result<
|
433 409 | crate::input::HostWithPathOperationInput,
|
434 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
410 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
435 411 | >;
|
436 412 |
|
437 413 | fn poll(
|
438 414 | self: std::pin::Pin<&mut Self>,
|
439 415 | cx: &mut std::task::Context<'_>,
|
440 416 | ) -> std::task::Poll<Self::Output> {
|
441 417 | let this = self.project();
|
442 418 | this.inner.as_mut().poll(cx)
|
443 419 | }
|
444 420 | }
|
445 421 |
|
446 422 | impl<B>
|
447 - | ::aws_smithy_http_server::request::FromRequest<
|
448 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
423 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
424 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
449 425 | B,
|
450 426 | > for crate::input::HostWithPathOperationInput
|
451 427 | where
|
452 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
428 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
453 429 | B: 'static,
|
454 430 |
|
455 431 | B::Data: Send,
|
456 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
457 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
432 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
433 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
458 434 | {
|
459 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
435 + | type Rejection =
|
436 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
460 437 | type Future = HostWithPathOperationInputFuture;
|
461 438 |
|
462 439 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
463 440 | let fut = async move {
|
464 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
441 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
465 442 | request.headers(),
|
466 443 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
467 444 | ) {
|
468 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
445 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
469 446 | }
|
470 447 | crate::protocol_serde::shape_host_with_path_operation::de_host_with_path_operation_http_request(request)
|
471 448 | .await
|
472 449 | };
|
473 450 | use ::futures_util::future::TryFutureExt;
|
474 - | let fut = fut.map_err(
|
475 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
451 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
476 452 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
477 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
478 - | },
|
479 - | );
|
453 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
454 + | });
|
480 455 | HostWithPathOperationInputFuture {
|
481 456 | inner: Box::pin(fut),
|
482 457 | }
|
483 458 | }
|
484 459 | }
|
485 460 | impl
|
486 - | ::aws_smithy_http_server::response::IntoResponse<
|
487 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
461 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
462 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
488 463 | > for crate::output::HostWithPathOperationOutput
|
489 464 | {
|
490 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
465 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
491 466 | match crate::protocol_serde::shape_host_with_path_operation::ser_host_with_path_operation_http_response(self) {
|
492 467 | Ok(response) => response,
|
493 468 | Err(e) => {
|
494 469 | ::tracing::error!(error = %e, "failed to serialize response");
|
495 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
470 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
496 471 | }
|
497 472 | }
|
498 473 | }
|
499 474 | }
|
500 475 | impl
|
501 - | ::aws_smithy_http_server::response::IntoResponse<
|
502 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
476 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
477 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
503 478 | > for crate::error::HostWithPathOperationError
|
504 479 | {
|
505 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
480 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
506 481 | match crate::protocol_serde::shape_host_with_path_operation::ser_host_with_path_operation_http_error(&self) {
|
507 482 | Ok(mut response) => {
|
508 - | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
483 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
509 484 | response
|
510 485 | },
|
511 486 | Err(e) => {
|
512 487 | ::tracing::error!(error = %e, "failed to serialize response");
|
513 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
488 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
514 489 | }
|
515 490 | }
|
516 491 | }
|
517 492 | }
|
518 493 |
|
519 494 | ::pin_project_lite::pin_project! {
|
520 495 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
521 496 | /// [`EndpointWithHostLabelOperationInput`](crate::input::EndpointWithHostLabelOperationInput) using modelled bindings.
|
522 497 | pub struct EndpointWithHostLabelOperationInputFuture {
|
523 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointWithHostLabelOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
498 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointWithHostLabelOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
524 499 | }
|
525 500 | }
|
526 501 |
|
527 502 | impl std::future::Future for EndpointWithHostLabelOperationInputFuture {
|
528 503 | type Output = Result<
|
529 504 | crate::input::EndpointWithHostLabelOperationInput,
|
530 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
505 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
531 506 | >;
|
532 507 |
|
533 508 | fn poll(
|
534 509 | self: std::pin::Pin<&mut Self>,
|
535 510 | cx: &mut std::task::Context<'_>,
|
536 511 | ) -> std::task::Poll<Self::Output> {
|
537 512 | let this = self.project();
|
538 513 | this.inner.as_mut().poll(cx)
|
539 514 | }
|
540 515 | }
|
541 516 |
|
542 517 | impl<B>
|
543 - | ::aws_smithy_http_server::request::FromRequest<
|
544 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
518 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
519 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
545 520 | B,
|
546 521 | > for crate::input::EndpointWithHostLabelOperationInput
|
547 522 | where
|
548 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
523 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
549 524 | B: 'static,
|
550 525 |
|
551 526 | B::Data: Send,
|
552 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
553 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
527 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
528 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
554 529 | {
|
555 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
530 + | type Rejection =
|
531 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
556 532 | type Future = EndpointWithHostLabelOperationInputFuture;
|
557 533 |
|
558 534 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
559 535 | let fut = async move {
|
560 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
536 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
561 537 | request.headers(),
|
562 538 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
563 539 | ) {
|
564 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
540 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
565 541 | }
|
566 542 | crate::protocol_serde::shape_endpoint_with_host_label_operation::de_endpoint_with_host_label_operation_http_request(request)
|
567 543 | .await
|
568 544 | };
|
569 545 | use ::futures_util::future::TryFutureExt;
|
570 - | let fut = fut.map_err(
|
571 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
546 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
572 547 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
573 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
574 - | },
|
575 - | );
|
548 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
549 + | });
|
576 550 | EndpointWithHostLabelOperationInputFuture {
|
577 551 | inner: Box::pin(fut),
|
578 552 | }
|
579 553 | }
|
580 554 | }
|
581 555 | impl
|
582 - | ::aws_smithy_http_server::response::IntoResponse<
|
583 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
556 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
557 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
584 558 | > for crate::output::EndpointWithHostLabelOperationOutput
|
585 559 | {
|
586 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
560 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
587 561 | match crate::protocol_serde::shape_endpoint_with_host_label_operation::ser_endpoint_with_host_label_operation_http_response(self) {
|
588 562 | Ok(response) => response,
|
589 563 | Err(e) => {
|
590 564 | ::tracing::error!(error = %e, "failed to serialize response");
|
591 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
565 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
592 566 | }
|
593 567 | }
|
594 568 | }
|
595 569 | }
|
596 570 | impl
|
597 - | ::aws_smithy_http_server::response::IntoResponse<
|
598 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
571 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
572 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
599 573 | > for crate::error::EndpointWithHostLabelOperationError
|
600 574 | {
|
601 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
575 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
602 576 | match crate::protocol_serde::shape_endpoint_with_host_label_operation::ser_endpoint_with_host_label_operation_http_error(&self) {
|
603 577 | Ok(mut response) => {
|
604 - | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
578 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
605 579 | response
|
606 580 | },
|
607 581 | Err(e) => {
|
608 582 | ::tracing::error!(error = %e, "failed to serialize response");
|
609 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
583 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
610 584 | }
|
611 585 | }
|
612 586 | }
|
613 587 | }
|
614 588 |
|
615 589 | ::pin_project_lite::pin_project! {
|
616 590 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
617 591 | /// [`EndpointOperationInput`](crate::input::EndpointOperationInput) using modelled bindings.
|
618 592 | pub struct EndpointOperationInputFuture {
|
619 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
593 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EndpointOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
620 594 | }
|
621 595 | }
|
622 596 |
|
623 597 | impl std::future::Future for EndpointOperationInputFuture {
|
624 598 | type Output = Result<
|
625 599 | crate::input::EndpointOperationInput,
|
626 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
600 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
627 601 | >;
|
628 602 |
|
629 603 | fn poll(
|
630 604 | self: std::pin::Pin<&mut Self>,
|
631 605 | cx: &mut std::task::Context<'_>,
|
632 606 | ) -> std::task::Poll<Self::Output> {
|
633 607 | let this = self.project();
|
634 608 | this.inner.as_mut().poll(cx)
|
635 609 | }
|
636 610 | }
|
637 611 |
|
638 612 | impl<B>
|
639 - | ::aws_smithy_http_server::request::FromRequest<
|
640 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
613 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
614 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
641 615 | B,
|
642 616 | > for crate::input::EndpointOperationInput
|
643 617 | where
|
644 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
618 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
645 619 | B: 'static,
|
646 620 |
|
647 621 | B::Data: Send,
|
648 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
649 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
622 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
623 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
650 624 | {
|
651 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
625 + | type Rejection =
|
626 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
652 627 | type Future = EndpointOperationInputFuture;
|
653 628 |
|
654 629 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
655 630 | let fut = async move {
|
656 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
631 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
657 632 | request.headers(),
|
658 633 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
659 634 | ) {
|
660 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
635 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
661 636 | }
|
662 637 | crate::protocol_serde::shape_endpoint_operation::de_endpoint_operation_http_request(
|
663 638 | request,
|
664 639 | )
|
665 640 | .await
|
666 641 | };
|
667 642 | use ::futures_util::future::TryFutureExt;
|
668 - | let fut = fut.map_err(
|
669 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
643 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
670 644 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
671 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
672 - | },
|
673 - | );
|
645 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
646 + | });
|
674 647 | EndpointOperationInputFuture {
|
675 648 | inner: Box::pin(fut),
|
676 649 | }
|
677 650 | }
|
678 651 | }
|
679 652 | impl
|
680 - | ::aws_smithy_http_server::response::IntoResponse<
|
681 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
653 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
654 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
682 655 | > for crate::output::EndpointOperationOutput
|
683 656 | {
|
684 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
657 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
685 658 | match crate::protocol_serde::shape_endpoint_operation::ser_endpoint_operation_http_response(
|
686 659 | self,
|
687 660 | ) {
|
688 661 | Ok(response) => response,
|
689 662 | Err(e) => {
|
690 663 | ::tracing::error!(error = %e, "failed to serialize response");
|
691 - | ::aws_smithy_http_server::response::IntoResponse::<
|
692 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
693 - | >::into_response(
|
694 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
695 - | e,
|
696 - | ),
|
697 - | )
|
664 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
698 665 | }
|
699 666 | }
|
700 667 | }
|
701 668 | }
|
702 669 | impl
|
703 - | ::aws_smithy_http_server::response::IntoResponse<
|
704 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
670 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
671 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
705 672 | > for crate::error::EndpointOperationError
|
706 673 | {
|
707 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
674 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
708 675 | match crate::protocol_serde::shape_endpoint_operation::ser_endpoint_operation_http_error(
|
709 676 | &self,
|
710 677 | ) {
|
711 678 | Ok(mut response) => {
|
712 679 | response.extensions_mut().insert(
|
713 - | ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
|
680 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
681 + | self.name(),
|
682 + | ),
|
714 683 | );
|
715 684 | response
|
716 685 | }
|
717 686 | Err(e) => {
|
718 687 | ::tracing::error!(error = %e, "failed to serialize response");
|
719 - | ::aws_smithy_http_server::response::IntoResponse::<
|
720 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
721 - | >::into_response(
|
722 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
723 - | e,
|
724 - | ),
|
725 - | )
|
688 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
726 689 | }
|
727 690 | }
|
728 691 | }
|
729 692 | }
|
730 693 |
|
731 694 | ::pin_project_lite::pin_project! {
|
732 695 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
733 696 | /// [`JsonUnionsInput`](crate::input::JsonUnionsInput) using modelled bindings.
|
734 697 | pub struct JsonUnionsInputFuture {
|
735 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::JsonUnionsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
698 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::JsonUnionsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
736 699 | }
|
737 700 | }
|
738 701 |
|
739 702 | impl std::future::Future for JsonUnionsInputFuture {
|
740 703 | type Output = Result<
|
741 704 | crate::input::JsonUnionsInput,
|
742 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
705 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
743 706 | >;
|
744 707 |
|
745 708 | fn poll(
|
746 709 | self: std::pin::Pin<&mut Self>,
|
747 710 | cx: &mut std::task::Context<'_>,
|
748 711 | ) -> std::task::Poll<Self::Output> {
|
749 712 | let this = self.project();
|
750 713 | this.inner.as_mut().poll(cx)
|
751 714 | }
|
752 715 | }
|
753 716 |
|
754 717 | impl<B>
|
755 - | ::aws_smithy_http_server::request::FromRequest<
|
756 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
718 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
719 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
757 720 | B,
|
758 721 | > for crate::input::JsonUnionsInput
|
759 722 | where
|
760 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
723 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
761 724 | B: 'static,
|
762 725 |
|
763 726 | B::Data: Send,
|
764 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
765 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
727 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
728 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
766 729 | {
|
767 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
730 + | type Rejection =
|
731 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
768 732 | type Future = JsonUnionsInputFuture;
|
769 733 |
|
770 734 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
771 735 | let fut = async move {
|
772 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
736 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
773 737 | request.headers(),
|
774 738 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
775 739 | ) {
|
776 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
740 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
777 741 | }
|
778 742 | crate::protocol_serde::shape_json_unions::de_json_unions_http_request(request).await
|
779 743 | };
|
780 744 | use ::futures_util::future::TryFutureExt;
|
781 - | let fut = fut.map_err(
|
782 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
745 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
783 746 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
784 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
785 - | },
|
786 - | );
|
747 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
748 + | });
|
787 749 | JsonUnionsInputFuture {
|
788 750 | inner: Box::pin(fut),
|
789 751 | }
|
790 752 | }
|
791 753 | }
|
792 754 | impl
|
793 - | ::aws_smithy_http_server::response::IntoResponse<
|
794 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
755 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
756 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
795 757 | > for crate::output::JsonUnionsOutput
|
796 758 | {
|
797 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
759 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
798 760 | match crate::protocol_serde::shape_json_unions::ser_json_unions_http_response(self) {
|
799 761 | Ok(response) => response,
|
800 762 | Err(e) => {
|
801 763 | ::tracing::error!(error = %e, "failed to serialize response");
|
802 - | ::aws_smithy_http_server::response::IntoResponse::<
|
803 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
804 - | >::into_response(
|
805 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
806 - | e,
|
807 - | ),
|
808 - | )
|
764 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
809 765 | }
|
810 766 | }
|
811 767 | }
|
812 768 | }
|
813 769 | impl
|
814 - | ::aws_smithy_http_server::response::IntoResponse<
|
815 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
770 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
771 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
816 772 | > for crate::error::JsonUnionsError
|
817 773 | {
|
818 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
774 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
819 775 | match crate::protocol_serde::shape_json_unions::ser_json_unions_http_error(&self) {
|
820 776 | Ok(mut response) => {
|
821 777 | response.extensions_mut().insert(
|
822 - | ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
|
778 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
779 + | self.name(),
|
780 + | ),
|
823 781 | );
|
824 782 | response
|
825 783 | }
|
826 784 | Err(e) => {
|
827 785 | ::tracing::error!(error = %e, "failed to serialize response");
|
828 - | ::aws_smithy_http_server::response::IntoResponse::<
|
829 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
830 - | >::into_response(
|
831 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
832 - | e,
|
833 - | ),
|
834 - | )
|
786 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
835 787 | }
|
836 788 | }
|
837 789 | }
|
838 790 | }
|
839 791 |
|
840 792 | ::pin_project_lite::pin_project! {
|
841 793 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
842 794 | /// [`GreetingWithErrorsInput`](crate::input::GreetingWithErrorsInput) using modelled bindings.
|
843 795 | pub struct GreetingWithErrorsInputFuture {
|
844 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GreetingWithErrorsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
796 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GreetingWithErrorsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
845 797 | }
|
846 798 | }
|
847 799 |
|
848 800 | impl std::future::Future for GreetingWithErrorsInputFuture {
|
849 801 | type Output = Result<
|
850 802 | crate::input::GreetingWithErrorsInput,
|
851 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
803 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
852 804 | >;
|
853 805 |
|
854 806 | fn poll(
|
855 807 | self: std::pin::Pin<&mut Self>,
|
856 808 | cx: &mut std::task::Context<'_>,
|
857 809 | ) -> std::task::Poll<Self::Output> {
|
858 810 | let this = self.project();
|
859 811 | this.inner.as_mut().poll(cx)
|
860 812 | }
|
861 813 | }
|
862 814 |
|
863 815 | impl<B>
|
864 - | ::aws_smithy_http_server::request::FromRequest<
|
865 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
816 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
817 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
866 818 | B,
|
867 819 | > for crate::input::GreetingWithErrorsInput
|
868 820 | where
|
869 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
821 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
870 822 | B: 'static,
|
871 823 |
|
872 824 | B::Data: Send,
|
873 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
874 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
825 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
826 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
875 827 | {
|
876 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
828 + | type Rejection =
|
829 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
877 830 | type Future = GreetingWithErrorsInputFuture;
|
878 831 |
|
879 832 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
880 833 | let fut = async move {
|
881 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
834 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
882 835 | request.headers(),
|
883 836 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
884 837 | ) {
|
885 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
838 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
886 839 | }
|
887 840 | crate::protocol_serde::shape_greeting_with_errors::de_greeting_with_errors_http_request(
|
888 841 | request,
|
889 842 | )
|
890 843 | .await
|
891 844 | };
|
892 845 | use ::futures_util::future::TryFutureExt;
|
893 - | let fut = fut.map_err(
|
894 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
846 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
895 847 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
896 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
897 - | },
|
898 - | );
|
848 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
849 + | });
|
899 850 | GreetingWithErrorsInputFuture {
|
900 851 | inner: Box::pin(fut),
|
901 852 | }
|
902 853 | }
|
903 854 | }
|
904 855 | impl
|
905 - | ::aws_smithy_http_server::response::IntoResponse<
|
906 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
856 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
857 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
907 858 | > for crate::output::GreetingWithErrorsOutput
|
908 859 | {
|
909 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
860 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
910 861 | match crate::protocol_serde::shape_greeting_with_errors::ser_greeting_with_errors_http_response(self) {
|
911 862 | Ok(response) => response,
|
912 863 | Err(e) => {
|
913 864 | ::tracing::error!(error = %e, "failed to serialize response");
|
914 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
865 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
915 866 | }
|
916 867 | }
|
917 868 | }
|
918 869 | }
|
919 870 | impl
|
920 - | ::aws_smithy_http_server::response::IntoResponse<
|
921 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
871 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
872 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
922 873 | > for crate::error::GreetingWithErrorsError
|
923 874 | {
|
924 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
875 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
925 876 | match crate::protocol_serde::shape_greeting_with_errors::ser_greeting_with_errors_http_error(
|
926 877 | &self,
|
927 878 | ) {
|
928 879 | Ok(mut response) => {
|
929 880 | response.extensions_mut().insert(
|
930 - | ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
|
881 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
882 + | self.name(),
|
883 + | ),
|
931 884 | );
|
932 885 | response
|
933 886 | }
|
934 887 | Err(e) => {
|
935 888 | ::tracing::error!(error = %e, "failed to serialize response");
|
936 - | ::aws_smithy_http_server::response::IntoResponse::<
|
937 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
938 - | >::into_response(
|
939 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
940 - | e,
|
941 - | ),
|
942 - | )
|
889 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
943 890 | }
|
944 891 | }
|
945 892 | }
|
946 893 | }
|
947 894 |
|
948 895 | ::pin_project_lite::pin_project! {
|
949 896 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
950 897 | /// [`SparseNullsOperationInput`](crate::input::SparseNullsOperationInput) using modelled bindings.
|
951 898 | pub struct SparseNullsOperationInputFuture {
|
952 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::SparseNullsOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
899 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::SparseNullsOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
953 900 | }
|
954 901 | }
|
955 902 |
|
956 903 | impl std::future::Future for SparseNullsOperationInputFuture {
|
957 904 | type Output = Result<
|
958 905 | crate::input::SparseNullsOperationInput,
|
959 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
906 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
960 907 | >;
|
961 908 |
|
962 909 | fn poll(
|
963 910 | self: std::pin::Pin<&mut Self>,
|
964 911 | cx: &mut std::task::Context<'_>,
|
965 912 | ) -> std::task::Poll<Self::Output> {
|
966 913 | let this = self.project();
|
967 914 | this.inner.as_mut().poll(cx)
|
968 915 | }
|
969 916 | }
|
970 917 |
|
971 918 | impl<B>
|
972 - | ::aws_smithy_http_server::request::FromRequest<
|
973 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
919 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
920 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
974 921 | B,
|
975 922 | > for crate::input::SparseNullsOperationInput
|
976 923 | where
|
977 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
924 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
978 925 | B: 'static,
|
979 926 |
|
980 927 | B::Data: Send,
|
981 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
982 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
928 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
929 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
983 930 | {
|
984 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
931 + | type Rejection =
|
932 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
985 933 | type Future = SparseNullsOperationInputFuture;
|
986 934 |
|
987 935 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
988 936 | let fut = async move {
|
989 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
937 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
990 938 | request.headers(),
|
991 939 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
992 940 | ) {
|
993 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
941 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
994 942 | }
|
995 943 | crate::protocol_serde::shape_sparse_nulls_operation::de_sparse_nulls_operation_http_request(request)
|
996 944 | .await
|
997 945 | };
|
998 946 | use ::futures_util::future::TryFutureExt;
|
999 - | let fut = fut.map_err(
|
1000 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
947 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1001 948 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1002 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1003 - | },
|
1004 - | );
|
949 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
950 + | });
|
1005 951 | SparseNullsOperationInputFuture {
|
1006 952 | inner: Box::pin(fut),
|
1007 953 | }
|
1008 954 | }
|
1009 955 | }
|
1010 956 | impl
|
1011 - | ::aws_smithy_http_server::response::IntoResponse<
|
1012 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
957 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
958 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1013 959 | > for crate::output::SparseNullsOperationOutput
|
1014 960 | {
|
1015 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
961 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1016 962 | match crate::protocol_serde::shape_sparse_nulls_operation::ser_sparse_nulls_operation_http_response(self) {
|
1017 963 | Ok(response) => response,
|
1018 964 | Err(e) => {
|
1019 965 | ::tracing::error!(error = %e, "failed to serialize response");
|
1020 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
966 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1021 967 | }
|
1022 968 | }
|
1023 969 | }
|
1024 970 | }
|
1025 971 | impl
|
1026 - | ::aws_smithy_http_server::response::IntoResponse<
|
1027 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
972 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
973 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1028 974 | > for crate::error::SparseNullsOperationError
|
1029 975 | {
|
1030 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
976 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1031 977 | match crate::protocol_serde::shape_sparse_nulls_operation::ser_sparse_nulls_operation_http_error(&self) {
|
1032 978 | Ok(mut response) => {
|
1033 - | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
979 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1034 980 | response
|
1035 981 | },
|
1036 982 | Err(e) => {
|
1037 983 | ::tracing::error!(error = %e, "failed to serialize response");
|
1038 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
984 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1039 985 | }
|
1040 986 | }
|
1041 987 | }
|
1042 988 | }
|
1043 989 |
|
1044 990 | ::pin_project_lite::pin_project! {
|
1045 991 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1046 992 | /// [`NullOperationInput`](crate::input::NullOperationInput) using modelled bindings.
|
1047 993 | pub struct NullOperationInputFuture {
|
1048 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NullOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
994 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::NullOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1049 995 | }
|
1050 996 | }
|
1051 997 |
|
1052 998 | impl std::future::Future for NullOperationInputFuture {
|
1053 999 | type Output = Result<
|
1054 1000 | crate::input::NullOperationInput,
|
1055 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1001 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1056 1002 | >;
|
1057 1003 |
|
1058 1004 | fn poll(
|
1059 1005 | self: std::pin::Pin<&mut Self>,
|
1060 1006 | cx: &mut std::task::Context<'_>,
|
1061 1007 | ) -> std::task::Poll<Self::Output> {
|
1062 1008 | let this = self.project();
|
1063 1009 | this.inner.as_mut().poll(cx)
|
1064 1010 | }
|
1065 1011 | }
|
1066 1012 |
|
1067 1013 | impl<B>
|
1068 - | ::aws_smithy_http_server::request::FromRequest<
|
1069 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1014 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1015 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1070 1016 | B,
|
1071 1017 | > for crate::input::NullOperationInput
|
1072 1018 | where
|
1073 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1019 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1074 1020 | B: 'static,
|
1075 1021 |
|
1076 1022 | B::Data: Send,
|
1077 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1078 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1023 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1024 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1079 1025 | {
|
1080 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1026 + | type Rejection =
|
1027 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1081 1028 | type Future = NullOperationInputFuture;
|
1082 1029 |
|
1083 1030 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1084 1031 | let fut = async move {
|
1085 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1032 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1086 1033 | request.headers(),
|
1087 1034 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
1088 1035 | ) {
|
1089 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1036 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1090 1037 | }
|
1091 1038 | crate::protocol_serde::shape_null_operation::de_null_operation_http_request(request)
|
1092 1039 | .await
|
1093 1040 | };
|
1094 1041 | use ::futures_util::future::TryFutureExt;
|
1095 - | let fut = fut.map_err(
|
1096 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1042 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1097 1043 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1098 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1099 - | },
|
1100 - | );
|
1044 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1045 + | });
|
1101 1046 | NullOperationInputFuture {
|
1102 1047 | inner: Box::pin(fut),
|
1103 1048 | }
|
1104 1049 | }
|
1105 1050 | }
|
1106 1051 | impl
|
1107 - | ::aws_smithy_http_server::response::IntoResponse<
|
1108 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1052 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1053 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1109 1054 | > for crate::output::NullOperationOutput
|
1110 1055 | {
|
1111 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1056 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1112 1057 | match crate::protocol_serde::shape_null_operation::ser_null_operation_http_response(self) {
|
1113 1058 | Ok(response) => response,
|
1114 1059 | Err(e) => {
|
1115 1060 | ::tracing::error!(error = %e, "failed to serialize response");
|
1116 - | ::aws_smithy_http_server::response::IntoResponse::<
|
1117 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1118 - | >::into_response(
|
1119 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
1120 - | e,
|
1121 - | ),
|
1122 - | )
|
1061 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1123 1062 | }
|
1124 1063 | }
|
1125 1064 | }
|
1126 1065 | }
|
1127 1066 | impl
|
1128 - | ::aws_smithy_http_server::response::IntoResponse<
|
1129 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1067 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1068 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1130 1069 | > for crate::error::NullOperationError
|
1131 1070 | {
|
1132 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1071 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1133 1072 | match crate::protocol_serde::shape_null_operation::ser_null_operation_http_error(&self) {
|
1134 1073 | Ok(mut response) => {
|
1135 1074 | response.extensions_mut().insert(
|
1136 - | ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
|
1075 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
1076 + | self.name(),
|
1077 + | ),
|
1137 1078 | );
|
1138 1079 | response
|
1139 1080 | }
|
1140 1081 | Err(e) => {
|
1141 1082 | ::tracing::error!(error = %e, "failed to serialize response");
|
1142 - | ::aws_smithy_http_server::response::IntoResponse::<
|
1143 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1144 - | >::into_response(
|
1145 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
1146 - | e,
|
1147 - | ),
|
1148 - | )
|
1083 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1149 1084 | }
|
1150 1085 | }
|
1151 1086 | }
|
1152 1087 | }
|
1153 1088 |
|
1154 1089 | ::pin_project_lite::pin_project! {
|
1155 1090 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1156 1091 | /// [`JsonIntEnumsInput`](crate::input::JsonIntEnumsInput) using modelled bindings.
|
1157 1092 | pub struct JsonIntEnumsInputFuture {
|
1158 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::JsonIntEnumsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1093 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::JsonIntEnumsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1159 1094 | }
|
1160 1095 | }
|
1161 1096 |
|
1162 1097 | impl std::future::Future for JsonIntEnumsInputFuture {
|
1163 1098 | type Output = Result<
|
1164 1099 | crate::input::JsonIntEnumsInput,
|
1165 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1100 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1166 1101 | >;
|
1167 1102 |
|
1168 1103 | fn poll(
|
1169 1104 | self: std::pin::Pin<&mut Self>,
|
1170 1105 | cx: &mut std::task::Context<'_>,
|
1171 1106 | ) -> std::task::Poll<Self::Output> {
|
1172 1107 | let this = self.project();
|
1173 1108 | this.inner.as_mut().poll(cx)
|
1174 1109 | }
|
1175 1110 | }
|
1176 1111 |
|
1177 1112 | impl<B>
|
1178 - | ::aws_smithy_http_server::request::FromRequest<
|
1179 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1113 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1114 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1180 1115 | B,
|
1181 1116 | > for crate::input::JsonIntEnumsInput
|
1182 1117 | where
|
1183 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1118 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1184 1119 | B: 'static,
|
1185 1120 |
|
1186 1121 | B::Data: Send,
|
1187 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1188 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1122 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1123 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1189 1124 | {
|
1190 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1125 + | type Rejection =
|
1126 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1191 1127 | type Future = JsonIntEnumsInputFuture;
|
1192 1128 |
|
1193 1129 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1194 1130 | let fut = async move {
|
1195 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1131 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1196 1132 | request.headers(),
|
1197 1133 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
1198 1134 | ) {
|
1199 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1135 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1200 1136 | }
|
1201 1137 | crate::protocol_serde::shape_json_int_enums::de_json_int_enums_http_request(request)
|
1202 1138 | .await
|
1203 1139 | };
|
1204 1140 | use ::futures_util::future::TryFutureExt;
|
1205 - | let fut = fut.map_err(
|
1206 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1141 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1207 1142 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1208 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1209 - | },
|
1210 - | );
|
1143 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1144 + | });
|
1211 1145 | JsonIntEnumsInputFuture {
|
1212 1146 | inner: Box::pin(fut),
|
1213 1147 | }
|
1214 1148 | }
|
1215 1149 | }
|
1216 1150 | impl
|
1217 - | ::aws_smithy_http_server::response::IntoResponse<
|
1218 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1151 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1152 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1219 1153 | > for crate::output::JsonIntEnumsOutput
|
1220 1154 | {
|
1221 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1155 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1222 1156 | match crate::protocol_serde::shape_json_int_enums::ser_json_int_enums_http_response(self) {
|
1223 1157 | Ok(response) => response,
|
1224 1158 | Err(e) => {
|
1225 1159 | ::tracing::error!(error = %e, "failed to serialize response");
|
1226 - | ::aws_smithy_http_server::response::IntoResponse::<
|
1227 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1228 - | >::into_response(
|
1229 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
1230 - | e,
|
1231 - | ),
|
1232 - | )
|
1160 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1233 1161 | }
|
1234 1162 | }
|
1235 1163 | }
|
1236 1164 | }
|
1237 1165 | impl
|
1238 - | ::aws_smithy_http_server::response::IntoResponse<
|
1239 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1166 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1167 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1240 1168 | > for crate::error::JsonIntEnumsError
|
1241 1169 | {
|
1242 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1170 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1243 1171 | match crate::protocol_serde::shape_json_int_enums::ser_json_int_enums_http_error(&self) {
|
1244 1172 | Ok(mut response) => {
|
1245 1173 | response.extensions_mut().insert(
|
1246 - | ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
|
1174 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
1175 + | self.name(),
|
1176 + | ),
|
1247 1177 | );
|
1248 1178 | response
|
1249 1179 | }
|
1250 1180 | Err(e) => {
|
1251 1181 | ::tracing::error!(error = %e, "failed to serialize response");
|
1252 - | ::aws_smithy_http_server::response::IntoResponse::<
|
1253 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1254 - | >::into_response(
|
1255 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
1256 - | e,
|
1257 - | ),
|
1258 - | )
|
1182 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1259 1183 | }
|
1260 1184 | }
|
1261 1185 | }
|
1262 1186 | }
|
1263 1187 |
|
1264 1188 | ::pin_project_lite::pin_project! {
|
1265 1189 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1266 1190 | /// [`JsonEnumsInput`](crate::input::JsonEnumsInput) using modelled bindings.
|
1267 1191 | pub struct JsonEnumsInputFuture {
|
1268 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::JsonEnumsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1192 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::JsonEnumsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1269 1193 | }
|
1270 1194 | }
|
1271 1195 |
|
1272 1196 | impl std::future::Future for JsonEnumsInputFuture {
|
1273 1197 | type Output = Result<
|
1274 1198 | crate::input::JsonEnumsInput,
|
1275 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1199 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1276 1200 | >;
|
1277 1201 |
|
1278 1202 | fn poll(
|
1279 1203 | self: std::pin::Pin<&mut Self>,
|
1280 1204 | cx: &mut std::task::Context<'_>,
|
1281 1205 | ) -> std::task::Poll<Self::Output> {
|
1282 1206 | let this = self.project();
|
1283 1207 | this.inner.as_mut().poll(cx)
|
1284 1208 | }
|
1285 1209 | }
|
1286 1210 |
|
1287 1211 | impl<B>
|
1288 - | ::aws_smithy_http_server::request::FromRequest<
|
1289 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1212 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1213 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1290 1214 | B,
|
1291 1215 | > for crate::input::JsonEnumsInput
|
1292 1216 | where
|
1293 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1217 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1294 1218 | B: 'static,
|
1295 1219 |
|
1296 1220 | B::Data: Send,
|
1297 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1298 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1221 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1222 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1299 1223 | {
|
1300 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1224 + | type Rejection =
|
1225 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1301 1226 | type Future = JsonEnumsInputFuture;
|
1302 1227 |
|
1303 1228 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1304 1229 | let fut = async move {
|
1305 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1230 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1306 1231 | request.headers(),
|
1307 1232 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
1308 1233 | ) {
|
1309 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1234 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1310 1235 | }
|
1311 1236 | crate::protocol_serde::shape_json_enums::de_json_enums_http_request(request).await
|
1312 1237 | };
|
1313 1238 | use ::futures_util::future::TryFutureExt;
|
1314 - | let fut = fut.map_err(
|
1315 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1239 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1316 1240 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1317 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1318 - | },
|
1319 - | );
|
1241 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1242 + | });
|
1320 1243 | JsonEnumsInputFuture {
|
1321 1244 | inner: Box::pin(fut),
|
1322 1245 | }
|
1323 1246 | }
|
1324 1247 | }
|
1325 1248 | impl
|
1326 - | ::aws_smithy_http_server::response::IntoResponse<
|
1327 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1249 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1250 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1328 1251 | > for crate::output::JsonEnumsOutput
|
1329 1252 | {
|
1330 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1253 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1331 1254 | match crate::protocol_serde::shape_json_enums::ser_json_enums_http_response(self) {
|
1332 1255 | Ok(response) => response,
|
1333 1256 | Err(e) => {
|
1334 1257 | ::tracing::error!(error = %e, "failed to serialize response");
|
1335 - | ::aws_smithy_http_server::response::IntoResponse::<
|
1336 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1337 - | >::into_response(
|
1338 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
1339 - | e,
|
1340 - | ),
|
1341 - | )
|
1258 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1342 1259 | }
|
1343 1260 | }
|
1344 1261 | }
|
1345 1262 | }
|
1346 1263 | impl
|
1347 - | ::aws_smithy_http_server::response::IntoResponse<
|
1348 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1264 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1265 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1349 1266 | > for crate::error::JsonEnumsError
|
1350 1267 | {
|
1351 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1268 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1352 1269 | match crate::protocol_serde::shape_json_enums::ser_json_enums_http_error(&self) {
|
1353 1270 | Ok(mut response) => {
|
1354 1271 | response.extensions_mut().insert(
|
1355 - | ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
|
1272 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
1273 + | self.name(),
|
1274 + | ),
|
1356 1275 | );
|
1357 1276 | response
|
1358 1277 | }
|
1359 1278 | Err(e) => {
|
1360 1279 | ::tracing::error!(error = %e, "failed to serialize response");
|
1361 - | ::aws_smithy_http_server::response::IntoResponse::<
|
1362 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1363 - | >::into_response(
|
1364 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
1365 - | e,
|
1366 - | ),
|
1367 - | )
|
1280 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1368 1281 | }
|
1369 1282 | }
|
1370 1283 | }
|
1371 1284 | }
|
1372 1285 |
|
1373 1286 | ::pin_project_lite::pin_project! {
|
1374 1287 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1375 1288 | /// [`PutAndGetInlineDocumentsInput`](crate::input::PutAndGetInlineDocumentsInput) using modelled bindings.
|
1376 1289 | pub struct PutAndGetInlineDocumentsInputFuture {
|
1377 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::PutAndGetInlineDocumentsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1290 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::PutAndGetInlineDocumentsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1378 1291 | }
|
1379 1292 | }
|
1380 1293 |
|
1381 1294 | impl std::future::Future for PutAndGetInlineDocumentsInputFuture {
|
1382 1295 | type Output = Result<
|
1383 1296 | crate::input::PutAndGetInlineDocumentsInput,
|
1384 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1297 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1385 1298 | >;
|
1386 1299 |
|
1387 1300 | fn poll(
|
1388 1301 | self: std::pin::Pin<&mut Self>,
|
1389 1302 | cx: &mut std::task::Context<'_>,
|
1390 1303 | ) -> std::task::Poll<Self::Output> {
|
1391 1304 | let this = self.project();
|
1392 1305 | this.inner.as_mut().poll(cx)
|
1393 1306 | }
|
1394 1307 | }
|
1395 1308 |
|
1396 1309 | impl<B>
|
1397 - | ::aws_smithy_http_server::request::FromRequest<
|
1398 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1310 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1311 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1399 1312 | B,
|
1400 1313 | > for crate::input::PutAndGetInlineDocumentsInput
|
1401 1314 | where
|
1402 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1315 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1403 1316 | B: 'static,
|
1404 1317 |
|
1405 1318 | B::Data: Send,
|
1406 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1407 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1319 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1320 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1408 1321 | {
|
1409 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1322 + | type Rejection =
|
1323 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1410 1324 | type Future = PutAndGetInlineDocumentsInputFuture;
|
1411 1325 |
|
1412 1326 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1413 1327 | let fut = async move {
|
1414 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1328 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1415 1329 | request.headers(),
|
1416 1330 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
1417 1331 | ) {
|
1418 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1332 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1419 1333 | }
|
1420 1334 | crate::protocol_serde::shape_put_and_get_inline_documents::de_put_and_get_inline_documents_http_request(request)
|
1421 1335 | .await
|
1422 1336 | };
|
1423 1337 | use ::futures_util::future::TryFutureExt;
|
1424 - | let fut = fut.map_err(
|
1425 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1338 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1426 1339 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1427 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1428 - | },
|
1429 - | );
|
1340 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1341 + | });
|
1430 1342 | PutAndGetInlineDocumentsInputFuture {
|
1431 1343 | inner: Box::pin(fut),
|
1432 1344 | }
|
1433 1345 | }
|
1434 1346 | }
|
1435 1347 | impl
|
1436 - | ::aws_smithy_http_server::response::IntoResponse<
|
1437 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1348 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1349 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1438 1350 | > for crate::output::PutAndGetInlineDocumentsOutput
|
1439 1351 | {
|
1440 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1352 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1441 1353 | match crate::protocol_serde::shape_put_and_get_inline_documents::ser_put_and_get_inline_documents_http_response(self) {
|
1442 1354 | Ok(response) => response,
|
1443 1355 | Err(e) => {
|
1444 1356 | ::tracing::error!(error = %e, "failed to serialize response");
|
1445 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1357 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1446 1358 | }
|
1447 1359 | }
|
1448 1360 | }
|
1449 1361 | }
|
1450 1362 | impl
|
1451 - | ::aws_smithy_http_server::response::IntoResponse<
|
1452 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1363 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1364 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1453 1365 | > for crate::error::PutAndGetInlineDocumentsError
|
1454 1366 | {
|
1455 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1367 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1456 1368 | match crate::protocol_serde::shape_put_and_get_inline_documents::ser_put_and_get_inline_documents_http_error(&self) {
|
1457 1369 | Ok(mut response) => {
|
1458 - | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1370 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1459 1371 | response
|
1460 1372 | },
|
1461 1373 | Err(e) => {
|
1462 1374 | ::tracing::error!(error = %e, "failed to serialize response");
|
1463 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1375 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1464 1376 | }
|
1465 1377 | }
|
1466 1378 | }
|
1467 1379 | }
|
1468 1380 |
|
1469 1381 | ::pin_project_lite::pin_project! {
|
1470 1382 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1471 1383 | /// [`OperationWithOptionalInputOutputInput`](crate::input::OperationWithOptionalInputOutputInput) using modelled bindings.
|
1472 1384 | pub struct OperationWithOptionalInputOutputInputFuture {
|
1473 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithOptionalInputOutputInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1385 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationWithOptionalInputOutputInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1474 1386 | }
|
1475 1387 | }
|
1476 1388 |
|
1477 1389 | impl std::future::Future for OperationWithOptionalInputOutputInputFuture {
|
1478 1390 | type Output = Result<
|
1479 1391 | crate::input::OperationWithOptionalInputOutputInput,
|
1480 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1392 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1481 1393 | >;
|
1482 1394 |
|
1483 1395 | fn poll(
|
1484 1396 | self: std::pin::Pin<&mut Self>,
|
1485 1397 | cx: &mut std::task::Context<'_>,
|
1486 1398 | ) -> std::task::Poll<Self::Output> {
|
1487 1399 | let this = self.project();
|
1488 1400 | this.inner.as_mut().poll(cx)
|
1489 1401 | }
|
1490 1402 | }
|
1491 1403 |
|
1492 1404 | impl<B>
|
1493 - | ::aws_smithy_http_server::request::FromRequest<
|
1494 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1405 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1406 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1495 1407 | B,
|
1496 1408 | > for crate::input::OperationWithOptionalInputOutputInput
|
1497 1409 | where
|
1498 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1410 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1499 1411 | B: 'static,
|
1500 1412 |
|
1501 1413 | B::Data: Send,
|
1502 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1503 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1414 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1415 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1504 1416 | {
|
1505 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1417 + | type Rejection =
|
1418 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1506 1419 | type Future = OperationWithOptionalInputOutputInputFuture;
|
1507 1420 |
|
1508 1421 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1509 1422 | let fut = async move {
|
1510 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1423 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1511 1424 | request.headers(),
|
1512 1425 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
1513 1426 | ) {
|
1514 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1427 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1515 1428 | }
|
1516 1429 | crate::protocol_serde::shape_operation_with_optional_input_output::de_operation_with_optional_input_output_http_request(request)
|
1517 1430 | .await
|
1518 1431 | };
|
1519 1432 | use ::futures_util::future::TryFutureExt;
|
1520 - | let fut = fut.map_err(
|
1521 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1433 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1522 1434 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1523 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1524 - | },
|
1525 - | );
|
1435 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1436 + | });
|
1526 1437 | OperationWithOptionalInputOutputInputFuture {
|
1527 1438 | inner: Box::pin(fut),
|
1528 1439 | }
|
1529 1440 | }
|
1530 1441 | }
|
1531 1442 | impl
|
1532 - | ::aws_smithy_http_server::response::IntoResponse<
|
1533 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1443 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1444 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1534 1445 | > for crate::output::OperationWithOptionalInputOutputOutput
|
1535 1446 | {
|
1536 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1447 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1537 1448 | match crate::protocol_serde::shape_operation_with_optional_input_output::ser_operation_with_optional_input_output_http_response(self) {
|
1538 1449 | Ok(response) => response,
|
1539 1450 | Err(e) => {
|
1540 1451 | ::tracing::error!(error = %e, "failed to serialize response");
|
1541 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1452 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1542 1453 | }
|
1543 1454 | }
|
1544 1455 | }
|
1545 1456 | }
|
1546 1457 | impl
|
1547 - | ::aws_smithy_http_server::response::IntoResponse<
|
1548 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1458 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1459 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1549 1460 | > for crate::error::OperationWithOptionalInputOutputError
|
1550 1461 | {
|
1551 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1462 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1552 1463 | match crate::protocol_serde::shape_operation_with_optional_input_output::ser_operation_with_optional_input_output_http_error(&self) {
|
1553 1464 | Ok(mut response) => {
|
1554 - | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1465 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1555 1466 | response
|
1556 1467 | },
|
1557 1468 | Err(e) => {
|
1558 1469 | ::tracing::error!(error = %e, "failed to serialize response");
|
1559 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1470 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1560 1471 | }
|
1561 1472 | }
|
1562 1473 | }
|
1563 1474 | }
|
1564 1475 |
|
1565 1476 | ::pin_project_lite::pin_project! {
|
1566 1477 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1567 1478 | /// [`SimpleScalarPropertiesInput`](crate::input::SimpleScalarPropertiesInput) using modelled bindings.
|
1568 1479 | pub struct SimpleScalarPropertiesInputFuture {
|
1569 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::SimpleScalarPropertiesInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1480 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::SimpleScalarPropertiesInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1570 1481 | }
|
1571 1482 | }
|
1572 1483 |
|
1573 1484 | impl std::future::Future for SimpleScalarPropertiesInputFuture {
|
1574 1485 | type Output = Result<
|
1575 1486 | crate::input::SimpleScalarPropertiesInput,
|
1576 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1487 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1577 1488 | >;
|
1578 1489 |
|
1579 1490 | fn poll(
|
1580 1491 | self: std::pin::Pin<&mut Self>,
|
1581 1492 | cx: &mut std::task::Context<'_>,
|
1582 1493 | ) -> std::task::Poll<Self::Output> {
|
1583 1494 | let this = self.project();
|
1584 1495 | this.inner.as_mut().poll(cx)
|
1585 1496 | }
|
1586 1497 | }
|
1587 1498 |
|
1588 1499 | impl<B>
|
1589 - | ::aws_smithy_http_server::request::FromRequest<
|
1590 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1500 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1501 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1591 1502 | B,
|
1592 1503 | > for crate::input::SimpleScalarPropertiesInput
|
1593 1504 | where
|
1594 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1505 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1595 1506 | B: 'static,
|
1596 1507 |
|
1597 1508 | B::Data: Send,
|
1598 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1599 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1509 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1510 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1600 1511 | {
|
1601 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1512 + | type Rejection =
|
1513 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1602 1514 | type Future = SimpleScalarPropertiesInputFuture;
|
1603 1515 |
|
1604 1516 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1605 1517 | let fut = async move {
|
1606 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1518 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1607 1519 | request.headers(),
|
1608 1520 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
1609 1521 | ) {
|
1610 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1522 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1611 1523 | }
|
1612 1524 | crate::protocol_serde::shape_simple_scalar_properties::de_simple_scalar_properties_http_request(request)
|
1613 1525 | .await
|
1614 1526 | };
|
1615 1527 | use ::futures_util::future::TryFutureExt;
|
1616 - | let fut = fut.map_err(
|
1617 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1528 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1618 1529 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1619 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1620 - | },
|
1621 - | );
|
1530 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1531 + | });
|
1622 1532 | SimpleScalarPropertiesInputFuture {
|
1623 1533 | inner: Box::pin(fut),
|
1624 1534 | }
|
1625 1535 | }
|
1626 1536 | }
|
1627 1537 | impl
|
1628 - | ::aws_smithy_http_server::response::IntoResponse<
|
1629 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1538 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1539 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1630 1540 | > for crate::output::SimpleScalarPropertiesOutput
|
1631 1541 | {
|
1632 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1542 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1633 1543 | match crate::protocol_serde::shape_simple_scalar_properties::ser_simple_scalar_properties_http_response(self) {
|
1634 1544 | Ok(response) => response,
|
1635 1545 | Err(e) => {
|
1636 1546 | ::tracing::error!(error = %e, "failed to serialize response");
|
1637 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1547 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1638 1548 | }
|
1639 1549 | }
|
1640 1550 | }
|
1641 1551 | }
|
1642 1552 | impl
|
1643 - | ::aws_smithy_http_server::response::IntoResponse<
|
1644 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1553 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1554 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1645 1555 | > for crate::error::SimpleScalarPropertiesError
|
1646 1556 | {
|
1647 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1557 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1648 1558 | match crate::protocol_serde::shape_simple_scalar_properties::ser_simple_scalar_properties_http_error(&self) {
|
1649 1559 | Ok(mut response) => {
|
1650 - | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1560 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1651 1561 | response
|
1652 1562 | },
|
1653 1563 | Err(e) => {
|
1654 1564 | ::tracing::error!(error = %e, "failed to serialize response");
|
1655 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1565 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1656 1566 | }
|
1657 1567 | }
|
1658 1568 | }
|
1659 1569 | }
|
1660 1570 |
|
1661 1571 | ::pin_project_lite::pin_project! {
|
1662 1572 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1663 1573 | /// [`KitchenSinkOperationInput`](crate::input::KitchenSinkOperationInput) using modelled bindings.
|
1664 1574 | pub struct KitchenSinkOperationInputFuture {
|
1665 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::KitchenSinkOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1575 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::KitchenSinkOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1666 1576 | }
|
1667 1577 | }
|
1668 1578 |
|
1669 1579 | impl std::future::Future for KitchenSinkOperationInputFuture {
|
1670 1580 | type Output = Result<
|
1671 1581 | crate::input::KitchenSinkOperationInput,
|
1672 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1582 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1673 1583 | >;
|
1674 1584 |
|
1675 1585 | fn poll(
|
1676 1586 | self: std::pin::Pin<&mut Self>,
|
1677 1587 | cx: &mut std::task::Context<'_>,
|
1678 1588 | ) -> std::task::Poll<Self::Output> {
|
1679 1589 | let this = self.project();
|
1680 1590 | this.inner.as_mut().poll(cx)
|
1681 1591 | }
|
1682 1592 | }
|
1683 1593 |
|
1684 1594 | impl<B>
|
1685 - | ::aws_smithy_http_server::request::FromRequest<
|
1686 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1595 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1596 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1687 1597 | B,
|
1688 1598 | > for crate::input::KitchenSinkOperationInput
|
1689 1599 | where
|
1690 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1600 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1691 1601 | B: 'static,
|
1692 1602 |
|
1693 1603 | B::Data: Send,
|
1694 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1695 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1604 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1605 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1696 1606 | {
|
1697 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1607 + | type Rejection =
|
1608 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1698 1609 | type Future = KitchenSinkOperationInputFuture;
|
1699 1610 |
|
1700 1611 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1701 1612 | let fut = async move {
|
1702 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1613 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1703 1614 | request.headers(),
|
1704 1615 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
1705 1616 | ) {
|
1706 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1617 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1707 1618 | }
|
1708 1619 | crate::protocol_serde::shape_kitchen_sink_operation::de_kitchen_sink_operation_http_request(request)
|
1709 1620 | .await
|
1710 1621 | };
|
1711 1622 | use ::futures_util::future::TryFutureExt;
|
1712 - | let fut = fut.map_err(
|
1713 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1623 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1714 1624 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1715 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1716 - | },
|
1717 - | );
|
1625 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1626 + | });
|
1718 1627 | KitchenSinkOperationInputFuture {
|
1719 1628 | inner: Box::pin(fut),
|
1720 1629 | }
|
1721 1630 | }
|
1722 1631 | }
|
1723 1632 | impl
|
1724 - | ::aws_smithy_http_server::response::IntoResponse<
|
1725 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1633 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1634 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1726 1635 | > for crate::output::KitchenSinkOperationOutput
|
1727 1636 | {
|
1728 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1637 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1729 1638 | match crate::protocol_serde::shape_kitchen_sink_operation::ser_kitchen_sink_operation_http_response(self) {
|
1730 1639 | Ok(response) => response,
|
1731 1640 | Err(e) => {
|
1732 1641 | ::tracing::error!(error = %e, "failed to serialize response");
|
1733 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1642 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1734 1643 | }
|
1735 1644 | }
|
1736 1645 | }
|
1737 1646 | }
|
1738 1647 | impl
|
1739 - | ::aws_smithy_http_server::response::IntoResponse<
|
1740 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1648 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1649 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1741 1650 | > for crate::error::KitchenSinkOperationError
|
1742 1651 | {
|
1743 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1652 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1744 1653 | match crate::protocol_serde::shape_kitchen_sink_operation::ser_kitchen_sink_operation_http_error(&self) {
|
1745 1654 | Ok(mut response) => {
|
1746 - | response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1655 + | response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
|
1747 1656 | response
|
1748 1657 | },
|
1749 1658 | Err(e) => {
|
1750 1659 | ::tracing::error!(error = %e, "failed to serialize response");
|
1751 - | ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1660 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1752 1661 | }
|
1753 1662 | }
|
1754 1663 | }
|
1755 1664 | }
|
1756 1665 |
|
1757 1666 | ::pin_project_lite::pin_project! {
|
1758 1667 | /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
|
1759 1668 | /// [`EmptyOperationInput`](crate::input::EmptyOperationInput) using modelled bindings.
|
1760 1669 | pub struct EmptyOperationInputFuture {
|
1761 - | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EmptyOperationInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1670 + | inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::EmptyOperationInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
|
1762 1671 | }
|
1763 1672 | }
|
1764 1673 |
|
1765 1674 | impl std::future::Future for EmptyOperationInputFuture {
|
1766 1675 | type Output = Result<
|
1767 1676 | crate::input::EmptyOperationInput,
|
1768 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1677 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
|
1769 1678 | >;
|
1770 1679 |
|
1771 1680 | fn poll(
|
1772 1681 | self: std::pin::Pin<&mut Self>,
|
1773 1682 | cx: &mut std::task::Context<'_>,
|
1774 1683 | ) -> std::task::Poll<Self::Output> {
|
1775 1684 | let this = self.project();
|
1776 1685 | this.inner.as_mut().poll(cx)
|
1777 1686 | }
|
1778 1687 | }
|
1779 1688 |
|
1780 1689 | impl<B>
|
1781 - | ::aws_smithy_http_server::request::FromRequest<
|
1782 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1690 + | ::aws_smithy_legacy_http_server::request::FromRequest<
|
1691 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1783 1692 | B,
|
1784 1693 | > for crate::input::EmptyOperationInput
|
1785 1694 | where
|
1786 - | B: ::aws_smithy_http_server::body::HttpBody + Send,
|
1695 + | B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
|
1787 1696 | B: 'static,
|
1788 1697 |
|
1789 1698 | B::Data: Send,
|
1790 - | ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1791 - | From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
|
1699 + | ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
|
1700 + | From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
|
1792 1701 | {
|
1793 - | type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1702 + | type Rejection =
|
1703 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
|
1794 1704 | type Future = EmptyOperationInputFuture;
|
1795 1705 |
|
1796 1706 | fn from_request(request: ::http::Request<B>) -> Self::Future {
|
1797 1707 | let fut = async move {
|
1798 - | if !::aws_smithy_http_server::protocol::accept_header_classifier(
|
1708 + | if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
|
1799 1709 | request.headers(),
|
1800 1710 | &crate::mimes::CONTENT_TYPE_APPLICATION_X_AMZ_JSON_1_1,
|
1801 1711 | ) {
|
1802 - | return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1712 + | return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
|
1803 1713 | }
|
1804 1714 | crate::protocol_serde::shape_empty_operation::de_empty_operation_http_request(request)
|
1805 1715 | .await
|
1806 1716 | };
|
1807 1717 | use ::futures_util::future::TryFutureExt;
|
1808 - | let fut = fut.map_err(
|
1809 - | |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1718 + | let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
|
1810 1719 | ::tracing::debug!(error = %e, "failed to deserialize request");
|
1811 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1812 - | },
|
1813 - | );
|
1720 + | ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
|
1721 + | });
|
1814 1722 | EmptyOperationInputFuture {
|
1815 1723 | inner: Box::pin(fut),
|
1816 1724 | }
|
1817 1725 | }
|
1818 1726 | }
|
1819 1727 | impl
|
1820 - | ::aws_smithy_http_server::response::IntoResponse<
|
1821 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1728 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1729 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1822 1730 | > for crate::output::EmptyOperationOutput
|
1823 1731 | {
|
1824 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1732 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1825 1733 | match crate::protocol_serde::shape_empty_operation::ser_empty_operation_http_response(self)
|
1826 1734 | {
|
1827 1735 | Ok(response) => response,
|
1828 1736 | Err(e) => {
|
1829 1737 | ::tracing::error!(error = %e, "failed to serialize response");
|
1830 - | ::aws_smithy_http_server::response::IntoResponse::<
|
1831 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1832 - | >::into_response(
|
1833 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
1834 - | e,
|
1835 - | ),
|
1836 - | )
|
1738 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1837 1739 | }
|
1838 1740 | }
|
1839 1741 | }
|
1840 1742 | }
|
1841 1743 | impl
|
1842 - | ::aws_smithy_http_server::response::IntoResponse<
|
1843 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1744 + | ::aws_smithy_legacy_http_server::response::IntoResponse<
|
1745 + | ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1844 1746 | > for crate::error::EmptyOperationError
|
1845 1747 | {
|
1846 - | fn into_response(self) -> ::aws_smithy_http_server::response::Response {
|
1748 + | fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
|
1847 1749 | match crate::protocol_serde::shape_empty_operation::ser_empty_operation_http_error(&self) {
|
1848 1750 | Ok(mut response) => {
|
1849 1751 | response.extensions_mut().insert(
|
1850 - | ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
|
1752 + | ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
|
1753 + | self.name(),
|
1754 + | ),
|
1851 1755 | );
|
1852 1756 | response
|
1853 1757 | }
|
1854 1758 | Err(e) => {
|
1855 1759 | ::tracing::error!(error = %e, "failed to serialize response");
|
1856 - | ::aws_smithy_http_server::response::IntoResponse::<
|
1857 - | ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
|
1858 - | >::into_response(
|
1859 - | ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
|
1860 - | e,
|
1861 - | ),
|
1862 - | )
|
1760 + | ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
|
1863 1761 | }
|
1864 1762 | }
|
1865 1763 | }
|
1866 1764 | }
|