Server Test Python

rev. d06a46cae0f385cdae37a9f8264db3469a090ab5 (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-server-test-python/naming_test_structs/rust-server-codegen-python/src/operation_shape.rs

@@ -1,1 +29,31 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(missing_docs)] // documentation missing in model
 pub struct Structs;
-4
 impl ::aws_smithy_http_server::operation::OperationShape for Structs {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for Structs {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "naming_obs_structs#Structs",
             "naming_obs_structs",
             "Structs",
         );
-12
     type Input = crate::input::StructsInput;
     type Output = crate::output::StructsOutput;
     type Error = crate::error::StructsError;
-16
+}
-17
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for Structs {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::DefaultRequestFmt;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::DefaultResponseFmt;
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity for Structs {
     type RequestFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultRequestFmt;
     type ResponseFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultResponseFmt;
-23
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-26
+    }
-27
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-30
+    }
-31
+}

tmp-codegen-diff/codegen-server-test-python/naming_test_structs/rust-server-codegen-python/src/protocol_serde/shape_structs.rs

@@ -1,1 +120,120 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_structs_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::StructsInput,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::structs_input_internal::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         let bytes = ::hyper::body::to_bytes(body).await?;
         if !bytes.is_empty() {
             ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(
             ::aws_smithy_legacy_http_server::protocol::content_type_header_classifier_smithy(
                 &headers,
                 Some("application/x-amz-json-1.1"),
             )?;
             input = crate::protocol_serde::shape_structs::de_structs(bytes.as_ref(), input)?;
-29
+        }
         input.build()
     })
-32
+}
-33
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_structs_http_response(
     #[allow(unused_variables)] output: crate::output::StructsOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/x-amz-json-1.1",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_structs_output::ser_structs_output_output_output(&output)?;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         let body = ::aws_smithy_legacy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-62
+}
-63
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_structs_http_error(
     error: &crate::error::StructsError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::aws_json::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::StructsError::InternalServerError(output) => {
                 let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/x-amz-json-1.1",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-91
+            }
-92
+        }
     })
-94
+}
-95
 pub(crate) fn de_structs(
     value: &[u8],
     mut builder: crate::input::structs_input_internal::Builder,
 ) -> ::std::result::Result<
     crate::input::structs_input_internal::Builder,

↧ Expand context

     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     let mut tokens_owned =
         ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value))
             .peekable();
     let tokens = &mut tokens_owned;
     ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
     loop {
         match tokens.next().transpose()? {
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 match key.to_unescaped()?.as_ref() {
                     "result" => {
                         builder = builder
                             .set_result(crate::protocol_serde::shape_result::de_result(tokens)?);
-116
+                    }
                     "resultList" => {
                         builder = builder.set_result_list(
                             crate::protocol_serde::shape_result_list::de_result_list(tokens)?,
                         );

tmp-codegen-diff/codegen-server-test-python/naming_test_structs/rust-server-codegen-python/src/python_operation_adaptor.rs

@@ -1,1 +35,37 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// Python handler for operation `Structs`.
 pub(crate) async fn structs(
     input: crate::input::StructsInput,
     state: ::aws_smithy_http_server::Extension<::aws_smithy_http_server_python::context::PyContext>,
     state: ::aws_smithy_legacy_http_server::Extension<
         ::aws_smithy_http_server_python::context::PyContext,
     >,
     handler: ::aws_smithy_http_server_python::PyHandler,
 ) -> std::result::Result<crate::output::StructsOutput, crate::error::StructsError> {
     // Async block used to run the handler and catch any Python error.
     let result = if handler.is_coroutine {
         ::tracing::trace!(name = "structs", "executing python handler coroutine");
         let result = ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let coroutine = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {

↧ Expand context

                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             ::pyo3_asyncio::tokio::into_future(coroutine)
         })?;
         result.await.and_then(|r| {
             ::pyo3::Python::with_gil(|py| r.extract::<crate::output::StructsOutput>(py))
         })
     } else {
         ::tracing::trace!(name = "structs", "executing python handler function");
         ::pyo3::Python::with_gil(|py| {
             let pyhandler: &::pyo3::types::PyFunction = handler.extract(py)?;
             let output = if handler.args == 1 {
                 pyhandler.call1((input,))?
             } else {
                 pyhandler.call1((input, ::pyo3::ToPyObject::to_object(&state.0, py)))?
             };
             output.extract::<crate::output::StructsOutput>()
         })
     };
     // Catch and record a Python traceback.

tmp-codegen-diff/codegen-server-test-python/naming_test_structs/rust-server-codegen-python/src/python_server_application.rs

@@ -56,56 +146,146 @@

↥ Expand context

-56
+        }
-57
+    }
-58
+}
 impl Clone for App {
     fn clone(&self) -> Self {
         Self {
             handlers: self.handlers.clone(),
             middlewares: self.middlewares.clone(),
             context: self.context.clone(),
             workers: ::parking_lot::Mutex::new(vec![]),
-66
+        }
-67
+    }
-68
+}
 impl ::aws_smithy_http_server_python::PyApp for App {
     fn workers(&self) -> &::parking_lot::Mutex<Vec<::pyo3::PyObject>> {
         &self.workers
-72
+    }
     fn context(&self) -> &Option<::pyo3::PyObject> {
         &self.context
-75
+    }

     fn handlers(
         &mut self,
     ) -> &mut ::std::collections::HashMap<String, ::aws_smithy_http_server_python::PyHandler> {
         &mut self.handlers
-80
+    }
     fn build_service(
         &mut self,
         event_loop: &::pyo3::PyAny,
     ) -> ::pyo3::PyResult<
         ::tower::util::BoxCloneService<
             ::http::Request<::aws_smithy_http_server::body::Body>,
             ::http::Response<::aws_smithy_http_server::body::BoxBody>,
             ::http::Request<::aws_smithy_legacy_http_server::body::Body>,
             ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
             std::convert::Infallible,
         >,
     > {
         let builder = crate::service::NamingObstacleCourseStructs::builder_without_plugins();
         let structs_locals = ::pyo3_asyncio::TaskLocals::new(event_loop);
         let handler = self
             .handlers
             .get("structs")
             .expect("Python handler for operation `structs` not found")
             .clone();
         let builder = builder.structs(move |input, state| {
             ::pyo3_asyncio::tokio::scope(
                 structs_locals.clone(),
                 crate::python_operation_adaptor::structs(input, state, handler.clone()),
-102
+            )
         });
         let mut service = ::tower::util::BoxCloneService::new(builder.build().expect("one or more operations do not have a registered handler; this is a bug in the Python code generator, please file a bug report under https://github.com/smithy-lang/smithy-rs/issues"));
-105
-106
+        {
             use ::tower::Layer;
             ::tracing::trace!("adding middlewares to rust python router");
             let mut middlewares = self.middlewares.clone();
             // Reverse the middlewares, so they run with same order as they defined
             middlewares.reverse();
             for handler in middlewares {
                 ::tracing::trace!(name = &handler.name, "adding python middleware");
                 let locals = ::pyo3_asyncio::TaskLocals::new(event_loop);
                 let layer = ::aws_smithy_http_server_python::PyMiddlewareLayer::<
                     ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
                     ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
                 >::new(handler, locals);
                 service = ::tower::util::BoxCloneService::new(layer.layer(service));
-119
+            }
-120
+        }
         Ok(service)
-122
+    }
-123
+}
 #[::pyo3::pymethods]
 impl App {
     /// Create a new [App].

↧ Expand context

     #[new]
     pub fn new() -> Self {
         Self::default()
-130
+    }
-131
     /// Register a context object that will be shared between handlers.
     ///
     /// :param context Ctx:
     /// :rtype None:
     #[pyo3(text_signature = "($self, context)")]
     pub fn context(&mut self, context: ::pyo3::PyObject) {
         self.context = Some(context);
-139
+    }
-140
     /// Register a Python function to be executed inside a Tower middleware layer.
     ///
     /// :param func typing.Callable\[\[naming_test_structs.middleware.Request, typing.Callable\[\[naming_test_structs.middleware.Request\], typing.Awaitable\[naming_test_structs.middleware.Response\]\]\], typing.Awaitable\[naming_test_structs.middleware.Response\]\]:
     /// :rtype None:
     #[pyo3(text_signature = "($self, func)")]
     pub fn middleware(

tmp-codegen-diff/codegen-server-test-python/naming_test_structs/rust-server-codegen-python/src/service.rs

@@ -1,1 +631,641 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// The service builder for [`NamingObstacleCourseStructs`].
 ///
 /// Constructed via [`NamingObstacleCourseStructs::builder`].
 pub struct NamingObstacleCourseStructsBuilder<Body, L, HttpPl, ModelPl> {
     structs: Option<::aws_smithy_http_server::routing::Route<Body>>,
     structs: Option<::aws_smithy_legacy_http_server::routing::Route<Body>>,
     layer: L,
     http_plugin: HttpPl,
     model_plugin: ModelPl,
-10
+}
-11
 impl<Body, L, HttpPl, ModelPl> NamingObstacleCourseStructsBuilder<Body, L, HttpPl, ModelPl> {
     /// Sets the [`Structs`](crate::operation_shape::Structs) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use naming_test_structs::{NamingObstacleCourseStructs, NamingObstacleCourseStructsConfig};
     ///
     /// use naming_test_structs::{input, output, error};
     ///
     /// async fn handler(input: input::StructsInput) -> Result<output::StructsOutput, error::StructsError> {
     ///     todo!()
     /// }
     ///
     /// let config = NamingObstacleCourseStructsConfig::builder().build();
     /// let app = NamingObstacleCourseStructs::builder(config)
     ///     .structs(handler)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: NamingObstacleCourseStructs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// # let app: NamingObstacleCourseStructs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn structs<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::Structs, HandlerExtractors>,
                         HandlerType: ::aws_smithy_legacy_http_server::operation::Handler<crate::operation_shape::Structs, HandlerExtractors>,
-41
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             NamingObstacleCourseStructs<L>,
                             crate::operation_shape::Structs,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::Structs, HandlerType>
                             ::aws_smithy_legacy_http_server::operation::IntoService<crate::operation_shape::Structs, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             NamingObstacleCourseStructs<L>,
                             crate::operation_shape::Structs,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             NamingObstacleCourseStructs<L>,
                             crate::operation_shape::Structs,
-55
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     NamingObstacleCourseStructs<L>,
                                     crate::operation_shape::Structs,
                                     ModelPl::Output
-61
+                                >
                             >::Output
                         >,
-64
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-67
-68
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::Structs::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.structs_custom(svc)
-78
+    }
-79
     /// Sets the [`Structs`](crate::operation_shape::Structs) operation.
     ///
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_http_server::operation) for more information.
     /// This should be an async function satisfying the [`Handler`](::aws_smithy_legacy_http_server::operation::Handler) trait.
     /// See the [operation module documentation](::aws_smithy_legacy_http_server::operation) for more information.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use naming_test_structs::{NamingObstacleCourseStructs, NamingObstacleCourseStructsConfig};
     ///
     /// use naming_test_structs::{input, output, error};
     ///
     /// async fn handler(input: input::StructsInput) -> Result<output::StructsOutput, error::StructsError> {
     ///     todo!()
     /// }
     ///
     /// let config = NamingObstacleCourseStructsConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);
     /// let app = NamingObstacleCourseStructs::builder(config)
     ///     .structs_service(svc)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: NamingObstacleCourseStructs<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// # let app: NamingObstacleCourseStructs<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::aws_json::router::AwsJsonRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>> = app;
     /// ```
     ///
                     pub fn structs_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::Structs, ServiceExtractors>,
                         S: ::aws_smithy_legacy_http_server::operation::OperationService<crate::operation_shape::Structs, ServiceExtractors>,
-109
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             NamingObstacleCourseStructs<L>,
                             crate::operation_shape::Structs,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::Structs, S>
                             ::aws_smithy_legacy_http_server::operation::Normalize<crate::operation_shape::Structs, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                         ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             NamingObstacleCourseStructs<L>,
                             crate::operation_shape::Structs,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             NamingObstacleCourseStructs<L>,
                             crate::operation_shape::Structs,
-123
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                 ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_legacy_http_server::plugin::Plugin<
                                     NamingObstacleCourseStructs<L>,
                                     crate::operation_shape::Structs,
                                     ModelPl::Output
-129
+                                >
                             >::Output
                         >,
-132
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         HttpPl::Output: ::tower::Service<::http::Request<Body>, Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
-135
-136
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         use ::aws_smithy_legacy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_legacy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::Structs::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
         let svc =
             ::aws_smithy_legacy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
                 .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.structs_custom(svc)
-146
+    }
-147
     /// Sets the [`Structs`](crate::operation_shape::Structs) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn structs_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-160
+    {
         self.structs = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self.structs = Some(::aws_smithy_legacy_http_server::routing::Route::new(svc));
         self
-163
+    }
-164
+}
-165
 impl<Body, L, HttpPl, ModelPl> NamingObstacleCourseStructsBuilder<Body, L, HttpPl, ModelPl> {
     /// Constructs a [`NamingObstacleCourseStructs`] from the arguments provided to the builder.
     ///
     /// Forgetting to register a handler for one or more operations will result in an error.
     ///
     /// Check out [`NamingObstacleCourseStructsBuilder::build_unchecked`] if you'd prefer the service to return status code 500 when an
     /// unspecified route is requested.
     pub fn build(
         self,
     ) -> ::std::result::Result<
         NamingObstacleCourseStructs<
             ::aws_smithy_http_server::routing::RoutingService<
                 ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<L::Service>,
                 ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
             ::aws_smithy_legacy_http_server::routing::RoutingService<
                 ::aws_smithy_legacy_http_server::protocol::aws_json::router::AwsJsonRouter<
                     L::Service,
                 >,
                 ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
             >,
         >,
         MissingOperationsError,
-185
+    >
     where
         L: ::tower::Layer<::aws_smithy_http_server::routing::Route<Body>>,
         L: ::tower::Layer<::aws_smithy_legacy_http_server::routing::Route<Body>>,
-188
+    {
         let router = {
             use ::aws_smithy_http_server::operation::OperationShape;
             use ::aws_smithy_legacy_http_server::operation::OperationShape;
             let mut missing_operation_names = std::collections::HashMap::new();
             if self.structs.is_none() {
                 missing_operation_names.insert(crate::operation_shape::Structs::ID, ".structs()");
-194
+            }
             if !missing_operation_names.is_empty() {
                 return Err(MissingOperationsError {
                     operation_names2setter_methods: missing_operation_names,
                 });
-199
+            }
             let unexpected_error_msg = "this should never panic since we are supposed to check beforehand that a handler has been registered for this operation; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues";
-201
             ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter::from_iter([(
             ::aws_smithy_legacy_http_server::protocol::aws_json::router::AwsJsonRouter::from_iter([
-+
+                (
                     request_specs::structs(),
                     self.structs.expect(unexpected_error_msg),
             )])
                 ),
             ])
         };
         let svc = ::aws_smithy_http_server::routing::RoutingService::new(router);
         let svc = ::aws_smithy_legacy_http_server::routing::RoutingService::new(router);
         let svc = svc.map(|s| s.layer(self.layer));
         Ok(NamingObstacleCourseStructs { svc })
-212
+    }
-213
     /// Constructs a [`NamingObstacleCourseStructs`] from the arguments provided to the builder.
     /// Operations without a handler default to returning 500 Internal Server Error to the caller.
     ///
     /// Check out [`NamingObstacleCourseStructsBuilder::build`] if you'd prefer the builder to fail if one or more operations do
     /// not have a registered handler.
     pub fn build_unchecked(self) -> NamingObstacleCourseStructs<L::Service>
     where
         Body: Send + 'static,
         L: ::tower::Layer<
             ::aws_smithy_http_server::routing::RoutingService<
                 ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<
                     ::aws_smithy_http_server::routing::Route<Body>,
             ::aws_smithy_legacy_http_server::routing::RoutingService<
                 ::aws_smithy_legacy_http_server::protocol::aws_json::router::AwsJsonRouter<
                     ::aws_smithy_legacy_http_server::routing::Route<Body>,
                 >,
                 ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
                 ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
             >,
         >,
-230
+    {
         let router =
             ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter::from_iter([(
             ::aws_smithy_legacy_http_server::protocol::aws_json::router::AwsJsonRouter::from_iter(
                 [(
                     request_specs::structs(),
                     self.structs.unwrap_or_else(|| {
                     let svc = ::aws_smithy_http_server::operation::MissingFailure::<
                         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
                         let svc = ::aws_smithy_legacy_http_server::operation::MissingFailure::<
                             ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
                         >::default();
                     ::aws_smithy_http_server::routing::Route::new(svc)
                         ::aws_smithy_legacy_http_server::routing::Route::new(svc)
                     }),
             )]);
                 )],
             );
         let svc = self
             .layer
             .layer(::aws_smithy_http_server::routing::RoutingService::new(
                 router,
             ));
             .layer(::aws_smithy_legacy_http_server::routing::RoutingService::new(router));
         NamingObstacleCourseStructs { svc }
-247
+    }
-248
+}
-249
 /// The error encountered when calling the [`NamingObstacleCourseStructsBuilder::build`] method if one or more operation handlers are not
 /// specified.
 #[derive(Debug)]
 pub struct MissingOperationsError {
     operation_names2setter_methods:
         std::collections::HashMap<::aws_smithy_http_server::shape_id::ShapeId, &'static str>,
         std::collections::HashMap<::aws_smithy_legacy_http_server::shape_id::ShapeId, &'static str>,
-256
+}
-257
 impl std::fmt::Display for MissingOperationsError {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         write!(
                             f,
                             "You must specify a handler for all operations attached to `NamingObstacleCourseStructs`.\n\
                             We are missing handlers for the following operations:\n",
                         )?;
         for operation_name in self.operation_names2setter_methods.keys() {
             writeln!(f, "- {}", operation_name.absolute())?;
-267
+        }
-268
         writeln!(f, "\nUse the dedicated methods on `NamingObstacleCourseStructsBuilder` to register the missing handlers:")?;
         for setter_name in self.operation_names2setter_methods.values() {
             writeln!(f, "- {}", setter_name)?;
-272
+        }
         Ok(())
-274
+    }
-275
+}
-276
 impl std::error::Error for MissingOperationsError {}
-278
 mod request_specs {
     pub(super) fn structs() -> &'static str {
         "NamingObstacleCourseStructs.Structs"
-282
+    }
-283
+}
-284
 /// Confounds model generation machinery with lots of problematic names
 ///
 /// See the [root](crate) documentation for more information.
 #[derive(Clone)]
 pub struct NamingObstacleCourseStructs<
     S = ::aws_smithy_http_server::routing::RoutingService<
         ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<
             ::aws_smithy_http_server::routing::Route<::aws_smithy_http_server::body::BoxBody>,
     S = ::aws_smithy_legacy_http_server::routing::RoutingService<
         ::aws_smithy_legacy_http_server::protocol::aws_json::router::AwsJsonRouter<
             ::aws_smithy_legacy_http_server::routing::Route<
                 ::aws_smithy_legacy_http_server::body::BoxBody,
             >,
         >,
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     >,
 > {
     // This is the router wrapped by layers.
     svc: S,
-301
+}
-302
 impl NamingObstacleCourseStructs<()> {
     /// Constructs a builder for [`NamingObstacleCourseStructs`].
     /// You must specify a configuration object holding any plugins and layers that should be applied
     /// to the operations in this service.
     pub fn builder<
         Body,
         L,
         HttpPl: ::aws_smithy_http_server::plugin::HttpMarker,
         ModelPl: ::aws_smithy_http_server::plugin::ModelMarker,
         HttpPl: ::aws_smithy_legacy_http_server::plugin::HttpMarker,
         ModelPl: ::aws_smithy_legacy_http_server::plugin::ModelMarker,
     >(
         config: NamingObstacleCourseStructsConfig<L, HttpPl, ModelPl>,
     ) -> NamingObstacleCourseStructsBuilder<Body, L, HttpPl, ModelPl> {
         NamingObstacleCourseStructsBuilder {
             structs: None,
             layer: config.layers,
             http_plugin: config.http_plugins,
             model_plugin: config.model_plugins,
-320
+        }
-321
+    }
-322
     /// Constructs a builder for [`NamingObstacleCourseStructs`].
     /// You must specify what plugins should be applied to the operations in this service.
     ///
     /// Use [`NamingObstacleCourseStructs::builder_without_plugins`] if you don't need to apply plugins.
     ///
     /// Check out [`HttpPlugins`](::aws_smithy_http_server::plugin::HttpPlugins) and
     /// [`ModelPlugins`](::aws_smithy_http_server::plugin::ModelPlugins) if you need to apply
     /// Check out [`HttpPlugins`](::aws_smithy_legacy_http_server::plugin::HttpPlugins) and
     /// [`ModelPlugins`](::aws_smithy_legacy_http_server::plugin::ModelPlugins) if you need to apply
     /// multiple plugins.
     #[deprecated(
         since = "0.57.0",
         note = "please use the `builder` constructor and register plugins on the `NamingObstacleCourseStructsConfig` object instead; see https://github.com/smithy-lang/smithy-rs/discussions/3096"
     )]
     pub fn builder_with_plugins<
         Body,
         HttpPl: ::aws_smithy_http_server::plugin::HttpMarker,
         ModelPl: ::aws_smithy_http_server::plugin::ModelMarker,
         HttpPl: ::aws_smithy_legacy_http_server::plugin::HttpMarker,
         ModelPl: ::aws_smithy_legacy_http_server::plugin::ModelMarker,
     >(
         http_plugin: HttpPl,
         model_plugin: ModelPl,
     ) -> NamingObstacleCourseStructsBuilder<Body, ::tower::layer::util::Identity, HttpPl, ModelPl>
-343
+    {
         NamingObstacleCourseStructsBuilder {
             structs: None,
             layer: ::tower::layer::util::Identity::new(),
             http_plugin,
             model_plugin,
-349
+        }
-350
+    }
-351
     /// Constructs a builder for [`NamingObstacleCourseStructs`].
     ///
     /// Use [`NamingObstacleCourseStructs::builder_with_plugins`] if you need to specify plugins.
     #[deprecated(
         since = "0.57.0",
         note = "please use the `builder` constructor instead; see https://github.com/smithy-lang/smithy-rs/discussions/3096"
     )]
     pub fn builder_without_plugins<Body>() -> NamingObstacleCourseStructsBuilder<
         Body,
         ::tower::layer::util::Identity,
         ::aws_smithy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
     > {
         Self::builder_with_plugins(
             ::aws_smithy_http_server::plugin::IdentityPlugin,
             ::aws_smithy_http_server::plugin::IdentityPlugin,
             ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
             ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
-368
+        )
-369
+    }
-370
+}
-371
 impl<S> NamingObstacleCourseStructs<S> {
     /// Converts [`NamingObstacleCourseStructs`] into a [`MakeService`](tower::make::MakeService).
     pub fn into_make_service(self) -> ::aws_smithy_http_server::routing::IntoMakeService<Self> {
         ::aws_smithy_http_server::routing::IntoMakeService::new(self)
     pub fn into_make_service(
         self,
     ) -> ::aws_smithy_legacy_http_server::routing::IntoMakeService<Self> {
         ::aws_smithy_legacy_http_server::routing::IntoMakeService::new(self)
-378
+    }
-379
     /// Converts [`NamingObstacleCourseStructs`] into a [`MakeService`](tower::make::MakeService) with [`ConnectInfo`](::aws_smithy_http_server::request::connect_info::ConnectInfo).
     /// Converts [`NamingObstacleCourseStructs`] into a [`MakeService`](tower::make::MakeService) with [`ConnectInfo`](::aws_smithy_legacy_http_server::request::connect_info::ConnectInfo).
     pub fn into_make_service_with_connect_info<C>(
         self,
     ) -> ::aws_smithy_http_server::routing::IntoMakeServiceWithConnectInfo<Self, C> {
         ::aws_smithy_http_server::routing::IntoMakeServiceWithConnectInfo::new(self)
     ) -> ::aws_smithy_legacy_http_server::routing::IntoMakeServiceWithConnectInfo<Self, C> {
         ::aws_smithy_legacy_http_server::routing::IntoMakeServiceWithConnectInfo::new(self)
-385
+    }
-386
+}
-387
 impl<S>
     NamingObstacleCourseStructs<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<S>,
             ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         ::aws_smithy_legacy_http_server::routing::RoutingService<
             ::aws_smithy_legacy_http_server::protocol::aws_json::router::AwsJsonRouter<S>,
             ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         >,
-394
+    >
-395
+{
     /// Applies a [`Layer`](::tower::Layer) uniformly to all routes.
     #[deprecated(
         since = "0.57.0",
         note = "please add layers to the `NamingObstacleCourseStructsConfig` object instead; see https://github.com/smithy-lang/smithy-rs/discussions/3096"
     )]
     pub fn layer<L>(
         self,
         layer: &L,
     ) -> NamingObstacleCourseStructs<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<L::Service>,
             ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
         ::aws_smithy_legacy_http_server::routing::RoutingService<
             ::aws_smithy_legacy_http_server::protocol::aws_json::router::AwsJsonRouter<L::Service>,
             ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         >,
-409
+    >
     where
         L: ::tower::Layer<S>,
-412
+    {
         NamingObstacleCourseStructs {
             svc: self.svc.map(|s| s.layer(layer)),
-415
+        }
-416
+    }
-417
     /// Applies [`Route::new`](::aws_smithy_http_server::routing::Route::new) to all routes.
     /// Applies [`Route::new`](::aws_smithy_legacy_http_server::routing::Route::new) to all routes.
     ///
     /// This has the effect of erasing all types accumulated via layers.
     pub fn boxed<B>(
         self,
     ) -> NamingObstacleCourseStructs<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::aws_json::router::AwsJsonRouter<
                 ::aws_smithy_http_server::routing::Route<B>,
         ::aws_smithy_legacy_http_server::routing::RoutingService<
             ::aws_smithy_legacy_http_server::protocol::aws_json::router::AwsJsonRouter<
                 ::aws_smithy_legacy_http_server::routing::Route<B>,
             >,
             ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
             ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         >,
-430
+    >
     where
         S: ::tower::Service<
             ::http::Request<B>,
             Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
             Response = ::http::Response<::aws_smithy_legacy_http_server::body::BoxBody>,
             Error = std::convert::Infallible,
         >,
         S: Clone + Send + 'static,
         S::Future: Send + 'static,
-439
+    {
         self.layer(&::tower::layer::layer_fn(
             ::aws_smithy_http_server::routing::Route::new,
             ::aws_smithy_legacy_http_server::routing::Route::new,
         ))
-443
+    }
-444
+}
-445
 impl<S, R> ::tower::Service<R> for NamingObstacleCourseStructs<S>
 where
     S: ::tower::Service<R>,
-449
+{
     type Response = S::Response;
     type Error = S::Error;
     type Future = S::Future;
-453
     fn poll_ready(
         &mut self,
         cx: &mut std::task::Context,
     ) -> std::task::Poll<::std::result::Result<(), Self::Error>> {
         self.svc.poll_ready(cx)
-459
+    }
-460
     fn call(&mut self, request: R) -> Self::Future {
         self.svc.call(request)
-463
+    }
-464
+}
-465
 /// An enumeration of all [operations](https://smithy.io/2.0/spec/service-types.html#operation) in NamingObstacleCourseStructs.
 #[allow(clippy::enum_variant_names)]
 #[derive(Debug, PartialEq, Eq, Clone, Copy)]
 pub enum Operation {
     Structs,
-471
+}
-472
 impl Operation {
     /// Returns the [operations](https://smithy.io/2.0/spec/service-types.html#operation) [`ShapeId`](::aws_smithy_http_server::shape_id::ShapeId).
     pub fn shape_id(&self) -> ::aws_smithy_http_server::shape_id::ShapeId {
     /// Returns the [operations](https://smithy.io/2.0/spec/service-types.html#operation) [`ShapeId`](::aws_smithy_legacy_http_server::shape_id::ShapeId).
     pub fn shape_id(&self) -> ::aws_smithy_legacy_http_server::shape_id::ShapeId {
         match self {
             Operation::Structs => ::aws_smithy_http_server::shape_id::ShapeId::new(
             Operation::Structs => ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
                 "naming_obs_structs#Structs",
                 "naming_obs_structs",
                 "Structs",
             ),
-482
+        }
-483
+    }
-484
+}
 impl<L> ::aws_smithy_http_server::service::ContainsOperation<crate::operation_shape::Structs>
 impl<L> ::aws_smithy_legacy_http_server::service::ContainsOperation<crate::operation_shape::Structs>
     for NamingObstacleCourseStructs<L>
-487
+{
     const VALUE: Operation = Operation::Structs;
-489
+}
-490
 impl<S> ::aws_smithy_http_server::service::ServiceShape for NamingObstacleCourseStructs<S> {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
 impl<S> ::aws_smithy_legacy_http_server::service::ServiceShape for NamingObstacleCourseStructs<S> {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "naming_obs_structs#NamingObstacleCourseStructs",
             "naming_obs_structs",
             "NamingObstacleCourseStructs",
         );
-498
     const VERSION: Option<&'static str> = Some("2006-03-01");
-500
     type Protocol = ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1;
     type Protocol = ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1;
-502
     type Operations = Operation;
-504
+}
 /// Configuration for the [`NamingObstacleCourseStructs`]. This is the central place where to register and
 /// configure [`::tower::Layer`]s, HTTP plugins, and model plugins.
 ///
 /// ```rust,no_run
 /// # use naming_test_structs::NamingObstacleCourseStructsConfig;
 /// # use ::aws_smithy_http_server::plugin::IdentityPlugin;
 /// # use ::aws_smithy_legacy_http_server::plugin::IdentityPlugin;
 /// # use ::tower::layer::util::Identity;
 /// # let authentication_plugin = IdentityPlugin;
 /// # let authorization_plugin = IdentityPlugin;
 /// # let server_request_id_provider_layer = Identity::new();
 /// let config = NamingObstacleCourseStructsConfig::builder()
 ///     // Layers get executed first...
 ///     .layer(server_request_id_provider_layer)
 ///     // ...then HTTP plugins...
 ///     .http_plugin(authentication_plugin)
 ///     // ...and right after deserialization, model plugins.
 ///     .model_plugin(authorization_plugin)
 ///     .build();
 /// ```
 ///
 /// See the [`plugin`] system for details.
 ///
 /// [`plugin`]: ::aws_smithy_http_server::plugin
 /// [`plugin`]: ::aws_smithy_legacy_http_server::plugin
 #[derive(::std::fmt::Debug)]
 pub struct NamingObstacleCourseStructsConfig<L, H, M> {
     layers: L,
     http_plugins: H,
     model_plugins: M,
-533
+}
-534
 impl NamingObstacleCourseStructsConfig<(), (), ()> {
     /// Returns a builder to construct the configuration.
     pub fn builder() -> NamingObstacleCourseStructsConfigBuilder<
         ::tower::layer::util::Identity,
         ::aws_smithy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
         ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
     > {
         NamingObstacleCourseStructsConfigBuilder {
             layers: ::tower::layer::util::Identity::new(),
             http_plugins: ::aws_smithy_http_server::plugin::IdentityPlugin,
             model_plugins: ::aws_smithy_http_server::plugin::IdentityPlugin,
             http_plugins: ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
             model_plugins: ::aws_smithy_legacy_http_server::plugin::IdentityPlugin,
-546
+        }
-547
+    }
-548
+}
-549
 /// Builder returned by [`NamingObstacleCourseStructsConfig::builder()`].
 #[derive(::std::fmt::Debug)]
 pub struct NamingObstacleCourseStructsConfigBuilder<L, H, M> {
     pub(crate) layers: L,
     pub(crate) http_plugins: H,
     pub(crate) model_plugins: M,
-556
+}
-557
 impl<L, H, M> NamingObstacleCourseStructsConfigBuilder<L, H, M> {
     /// Add a [`::tower::Layer`] to the service.
     pub fn layer<NewLayer>(
         self,
         layer: NewLayer,
     ) -> NamingObstacleCourseStructsConfigBuilder<::tower::layer::util::Stack<NewLayer, L>, H, M>
-564
+    {
         NamingObstacleCourseStructsConfigBuilder {
             layers: ::tower::layer::util::Stack::new(layer, self.layers),
             http_plugins: self.http_plugins,
             model_plugins: self.model_plugins,
-569
+        }
-570
+    }
-571
     /// Add a HTTP [plugin] to the service.
     ///
     /// [plugin]: ::aws_smithy_http_server::plugin
     /// [plugin]: ::aws_smithy_legacy_http_server::plugin
     // We eagerly require `NewPlugin: HttpMarker`, despite not really needing it, because compiler
     // errors get _substantially_ better if the user makes a mistake.
     pub fn http_plugin<NewPlugin: ::aws_smithy_http_server::plugin::HttpMarker>(
     pub fn http_plugin<NewPlugin: ::aws_smithy_legacy_http_server::plugin::HttpMarker>(
         self,
         http_plugin: NewPlugin,
     ) -> NamingObstacleCourseStructsConfigBuilder<
         L,
         ::aws_smithy_http_server::plugin::PluginStack<NewPlugin, H>,
         ::aws_smithy_legacy_http_server::plugin::PluginStack<NewPlugin, H>,
         M,
     > {
         NamingObstacleCourseStructsConfigBuilder {
             layers: self.layers,
             http_plugins: ::aws_smithy_http_server::plugin::PluginStack::new(
             http_plugins: ::aws_smithy_legacy_http_server::plugin::PluginStack::new(
                 http_plugin,
                 self.http_plugins,
             ),
             model_plugins: self.model_plugins,
-592
+        }
-593
+    }
-594
     /// Add a model [plugin] to the service.
     ///
     /// [plugin]: ::aws_smithy_http_server::plugin
     /// [plugin]: ::aws_smithy_legacy_http_server::plugin
     // We eagerly require `NewPlugin: ModelMarker`, despite not really needing it, because compiler
     // errors get _substantially_ better if the user makes a mistake.
     pub fn model_plugin<NewPlugin: ::aws_smithy_http_server::plugin::ModelMarker>(
     pub fn model_plugin<NewPlugin: ::aws_smithy_legacy_http_server::plugin::ModelMarker>(
         self,
         model_plugin: NewPlugin,
     ) -> NamingObstacleCourseStructsConfigBuilder<
         L,
         H,
         ::aws_smithy_http_server::plugin::PluginStack<NewPlugin, M>,
         ::aws_smithy_legacy_http_server::plugin::PluginStack<NewPlugin, M>,
     > {
         NamingObstacleCourseStructsConfigBuilder {
             layers: self.layers,
             http_plugins: self.http_plugins,
             model_plugins: ::aws_smithy_http_server::plugin::PluginStack::new(
             model_plugins: ::aws_smithy_legacy_http_server::plugin::PluginStack::new(
                 model_plugin,
                 self.model_plugins,
             ),
-615
+        }
-616
+    }
-617
     /// Build the configuration.
     pub fn build(self) -> super::NamingObstacleCourseStructsConfig<L, H, M> {
         super::NamingObstacleCourseStructsConfig {
             layers: self.layers,

↧ Expand context

             http_plugins: self.http_plugins,
             model_plugins: self.model_plugins,
-624
+        }
-625
+    }
-626
+}
 /// A macro to help with scoping [plugins](crate::server::plugin) to a subset of all operations.
 ///
 /// In contrast to [`crate::server::scope`](crate::server::scope), this macro has knowledge
 /// of the service and any operations _not_ specified will be placed in the opposing group.
 ///
 /// # Example
 ///
 /// ```rust
 /// scope! {
 ///     /// Includes [`Structs`], excluding all other operations.
 ///     struct ScopeA {
 ///         includes: [Structs]
 ///     }
 /// }
 ///

tmp-codegen-diff/codegen-server-test-python/pokemon-service-server-sdk/rust-server-codegen-python/Cargo.toml

@@ -1,1 +70,71 @@

↥ Expand context

 version = "0.0.1"
 authors = ["protocoltest@example.com"]
 description = "test"
 edition = "2021"
-8
 [package.metadata.smithy]
 codegen-version = "ci"
 protocol = "aws.protocols#restJson1"
 [dependencies.aws-smithy-eventstream]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-eventstream"
 [dependencies.aws-smithy-http]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-http"
 features = ["event-stream"]
 [dependencies.aws-smithy-http-server]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-http-server"
 [dependencies.aws-smithy-http-server-python]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-http-server-python"
 [dependencies.aws-smithy-json]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-json"
 [dependencies.aws-smithy-legacy-http]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-legacy-http"
 features = ["event-stream"]
 [dependencies.aws-smithy-legacy-http-server]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-legacy-http-server"
 [dependencies.aws-smithy-runtime-api]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-runtime-api"
 features = ["client", "http-02x"]
 features = ["http-02x", "client", "http-1x"]
 [dependencies.aws-smithy-types]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-types"
 features = ["http-body-0-4-x"]
 [dependencies.futures-util]
 version = "0.3"
 [dependencies.http]
 version = "0.2.9"
 [dependencies.mime]
 version = "0.3"
 [dependencies.nom]
 version = "7"
 [dependencies.parking_lot]
 version = "0.12"
 [dependencies.percent-encoding]
 version = "2.0.0"
 [dependencies.pin-project-lite]
 version = "0.2"
 [dependencies.pyo3]
 version = "0.20"
 [dependencies.pyo3-asyncio]
 version = "0.20"
 features = ["attributes", "tokio-runtime", "unstable-streams"]
 [dependencies.tokio]
 version = "1.20.1"
 features = ["full"]
 [dependencies.tokio-stream]
 version = "0.1.12"
 [dependencies.tower]
 version = "0.4"
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.hyper]
 version = "0.14.12"
 version = "0.14.26"
 [dev-dependencies.tokio]
 version = "1.23.1"
 [features]
 aws-lambda = ["aws-smithy-http-server/aws-lambda"]
 request-id = ["aws-smithy-http-server/request-id"]
 rt-tokio = ["aws-smithy-types/rt-tokio"]
 aws-lambda = ["aws-smithy-legacy-http-server/aws-lambda"]
 request-id = ["aws-smithy-legacy-http-server/request-id"]
 rt-tokio = ["aws-smithy-types/http-body-1-x", "aws-smithy-types/rt-tokio"]
 extension-module = ["pyo3/extension-module"]
 default = ["request-id", "rt-tokio", "extension-module"]
 [lib]
 name = "pokemon_service_server_sdk"
 crate-type = ["cdylib"]
-70
-71

tmp-codegen-diff/codegen-server-test-python/pokemon-service-server-sdk/rust-server-codegen-python/python/pokemon_service_server_sdk/middleware/init.pyi

@@ -1,1 +38,38 @@

 import typing
-2
 class MiddlewareException(Exception):
     """
     Exception that can be thrown from a Python middleware.
-6
     It allows to specify a message and HTTP status code and implementing protocol specific capabilities
     to build a [aws_smithy_http_server::response::Response] from it.
     to build a [aws_smithy_legacy_http_server::response::Response] from it.
     """
-10
     message: str
-12
     status_code: int
-14
     def __init__(self, message: str, status_code: typing.Optional[int] = ...) -> None:
         ...
-17
-18

↧ Expand context

 class Request:
     """
     Python-compatible [Request] object.
     """
-23
     body: typing.Awaitable[bytes]
     """
     Return the HTTP body of this request.
     Note that this is a costly operation because the whole request body is cloned.
     """
-29
     headers: typing.MutableMapping[str, str]
     """
     Return the HTTP headers of this request.
     """
-34
     method: str
     """
     Return the HTTP method of this request.
     """

tmp-codegen-diff/codegen-server-test-python/pokemon-service-server-sdk/rust-server-codegen-python/src/input.rs

@@ -377,377 +437,437 @@

↥ Expand context

         /// `passcode` was not provided but it is required when building `GetStorageInput`.
         MissingPasscode,
-379
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::MissingUser => write!(f, "`user` was not provided but it is required when building `GetStorageInput`"),
                 ConstraintViolation::MissingPasscode => write!(f, "`passcode` was not provided but it is required when building `GetStorageInput`"),
-385
+            }
-386
+        }
-387
+    }
     impl ::std::error::Error for ConstraintViolation {}
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             match self {
             ConstraintViolation::MissingUser => crate::model::ValidationExceptionField {
                                                 message: format!("Value at '{}/user' failed to satisfy constraint: Member must not be null", path),

                                                 path: path + "/user",
                                             },
             ConstraintViolation::MissingPasscode => crate::model::ValidationExceptionField {
                                                 message: format!("Value at '{}/passcode' failed to satisfy constraint: Member must not be null", path),
                                                 path: path + "/passcode",
                                             },
-403
+        }
-404
+        }
-405
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection
-408
+    {
         fn from(constraint_violation: ConstraintViolation) -> Self {
             let first_validation_exception_field =
                 constraint_violation.as_validation_exception_field("".to_owned());
             let validation_exception = crate::error::ValidationException {
                 message: format!(
                     "1 validation error detected. {}",
                     &first_validation_exception_field.message
                 ),
                 field_list: Some(vec![first_validation_exception_field]),

↧ Expand context

             };
             Self::ConstraintViolation(
                                 crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(&validation_exception)
                                     .expect("validation exceptions should never fail to serialize; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues")
-422
+                            )
-423
+        }
-424
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::GetStorageInput>
-427
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-430
+        }
-431
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::GetStorageInput {
         type Error = ConstraintViolation;
-434
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-437
+        }

@@ -556,556 +616,616 @@

↥ Expand context

     #[allow(clippy::enum_variant_names)]
     pub(crate) enum ConstraintViolation {
         /// `name` was not provided but it is required when building `GetPokemonSpeciesInput`.
         MissingName,
-560
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::MissingName => write!(f, "`name` was not provided but it is required when building `GetPokemonSpeciesInput`"),
-565
+            }
-566
+        }
-567
+    }
     impl ::std::error::Error for ConstraintViolation {}
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             match self {
                 ConstraintViolation::MissingName => crate::model::ValidationExceptionField {

                     message: format!(
                         "Value at '{}/name' failed to satisfy constraint: Member must not be null",
                         path
                     ),
                     path: path + "/name",
                 },
-582
+            }
-583
+        }
-584
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection
-587
+    {
         fn from(constraint_violation: ConstraintViolation) -> Self {
             let first_validation_exception_field =
                 constraint_violation.as_validation_exception_field("".to_owned());
             let validation_exception = crate::error::ValidationException {
                 message: format!(
                     "1 validation error detected. {}",
                     &first_validation_exception_field.message
                 ),
                 field_list: Some(vec![first_validation_exception_field]),

↧ Expand context

             };
             Self::ConstraintViolation(
                                 crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(&validation_exception)
                                     .expect("validation exceptions should never fail to serialize; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues")
-601
+                            )
-602
+        }
-603
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::GetPokemonSpeciesInput>
-606
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-609
+        }
-610
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::GetPokemonSpeciesInput {
         type Error = ConstraintViolation;
-613
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-616
+        }

@@ -794,794 +854,854 @@

↥ Expand context

         /// `region` was not provided but it is required when building `CapturePokemonInput`.
         MissingRegion,
-796
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::MissingEvents => write!(f, "`events` was not provided but it is required when building `CapturePokemonInput`"),
                 ConstraintViolation::MissingRegion => write!(f, "`region` was not provided but it is required when building `CapturePokemonInput`"),
-802
+            }
-803
+        }
-804
+    }
     impl ::std::error::Error for ConstraintViolation {}
     impl ConstraintViolation {
         pub(crate) fn as_validation_exception_field(
             self,
             path: ::std::string::String,
         ) -> crate::model::ValidationExceptionField {
             match self {
             ConstraintViolation::MissingEvents => crate::model::ValidationExceptionField {
                                                 message: format!("Value at '{}/events' failed to satisfy constraint: Member must not be null", path),

                                                 path: path + "/events",
                                             },
             ConstraintViolation::MissingRegion => crate::model::ValidationExceptionField {
                                                 message: format!("Value at '{}/region' failed to satisfy constraint: Member must not be null", path),
                                                 path: path + "/region",
                                             },
-820
+        }
-821
+        }
-822
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection
-825
+    {
         fn from(constraint_violation: ConstraintViolation) -> Self {
             let first_validation_exception_field =
                 constraint_violation.as_validation_exception_field("".to_owned());
             let validation_exception = crate::error::ValidationException {
                 message: format!(
                     "1 validation error detected. {}",
                     &first_validation_exception_field.message
                 ),
                 field_list: Some(vec![first_validation_exception_field]),

↧ Expand context

             };
             Self::ConstraintViolation(
                                 crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(&validation_exception)
                                     .expect("validation exceptions should never fail to serialize; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues")
-839
+                            )
-840
+        }
-841
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::CapturePokemonInput>
-844
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-847
+        }
-848
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::CapturePokemonInput {
         type Error = ConstraintViolation;
-851
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-854
+        }

tmp-codegen-diff/codegen-server-test-python/pokemon-service-server-sdk/rust-server-codegen-python/src/lib.rs

@@ -29,29 +128,129 @@

↥ Expand context

 //! The primary entrypoint is [`PokemonService`]: it satisfies the [`Service<http::Request, Response = http::Response>`](::tower::Service)
 //! trait and therefore can be handed to a [`hyper` server](https://github.com/hyperium/hyper) via [`PokemonService::into_make_service`]
 //! or used in AWS Lambda
 #![cfg_attr(
     feature = "aws-lambda",
     doc = " via [`LambdaHandler`](crate::server::routing::LambdaHandler)."
 )]
 #![cfg_attr(
     not(feature = "aws-lambda"),
     doc = " by enabling the `aws-lambda` feature flag and utilizing the `LambdaHandler`."
 )]
 //! The [`crate::input`], [`crate::output`], and [`crate::error`]
 //! modules provide the types used in each operation.
 //!
 //! ### Running on Hyper
 //!
 //! ```rust,no_run
 //! # use std::net::SocketAddr;
 //! # async fn dummy() {
 //! use pokemon_service_server_sdk::{PokemonService, PokemonServiceConfig};

 //!
 //! # let app = PokemonService::builder(
 //! #     PokemonServiceConfig::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let server = app.into_make_service();
 //! let bind: SocketAddr = "127.0.0.1:6969".parse()
 //!     .expect("unable to parse the server bind address and port");
 //! ::hyper::Server::bind(&bind).serve(server).await.unwrap();
 //! # }
 //!
 //! ```
 //!
 //! ### Running on Lambda
 //!
 //! ```rust,ignore
 //! use pokemon_service_server_sdk::server::routing::LambdaHandler;
 //! use pokemon_service_server_sdk::PokemonService;
 //!
 //! # async fn dummy() {
 //! # let app = PokemonService::builder(
 //! #     PokemonServiceConfig::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let handler = LambdaHandler::new(app);
 //! lambda_http::run(handler).await.unwrap();
 //! # }
 //! ```
 //!
 //! # Building the PokemonService
 //!
 //! To construct [`PokemonService`] we use [`PokemonServiceBuilder`] returned by [`PokemonService::builder`].
 //!
 //! ## Plugins
 //!
 //! The [`PokemonService::builder`] method, returning [`PokemonServiceBuilder`],
 //! accepts a config object on which plugins can be registered.
 //! Plugins allow you to build middleware which is aware of the operation it is being applied to.
 //!
 //! ```rust,no_run
 //! # use pokemon_service_server_sdk::server::plugin::IdentityPlugin as LoggingPlugin;
 //! # use pokemon_service_server_sdk::server::plugin::IdentityPlugin as MetricsPlugin;
 //! # use ::hyper::Body;
 //! use pokemon_service_server_sdk::server::plugin::HttpPlugins;
 //! use pokemon_service_server_sdk::{PokemonService, PokemonServiceConfig, PokemonServiceBuilder};
 //!
 //! let http_plugins = HttpPlugins::new()
 //!         .push(LoggingPlugin)
 //!         .push(MetricsPlugin);
 //! let config = PokemonServiceConfig::builder().build();
 //! let builder: PokemonServiceBuilder<Body, _, _, _> = PokemonService::builder(config);
 //! let builder: PokemonServiceBuilder<::hyper::Body, _, _, _> = PokemonService::builder(config);
 //! ```
 //!
 //! Check out [`crate::server::plugin`] to learn more about plugins.
 //!
 //! ## Handlers
 //!
 //! [`PokemonServiceBuilder`] provides a setter method for each operation in your Smithy model. The setter methods expect an async function as input, matching the signature for the corresponding operation in your Smithy model.
 //! We call these async functions **handlers**. This is where your application business logic lives.
 //!
 //! Every handler must take an `Input`, and optional [`extractor arguments`](crate::server::request), while returning:

↧ Expand context

 //!
 //! * A `Result<Output, Error>` if your operation has modeled errors, or
 //! * An `Output` otherwise.
 //!
 //! ```rust,no_run
 //! # struct Input;
 //! # struct Output;
 //! # struct Error;
 //! async fn infallible_handler(input: Input) -> Output { todo!() }
 //!
 //! async fn fallible_handler(input: Input) -> Result<Output, Error> { todo!() }
 //! ```
 //!
 //! Handlers can accept up to 8 extractors:
 //!
 //! ```rust,no_run
 //! # struct Input;
 //! # struct Output;
 //! # struct Error;
 //! # struct State;

@@ -194,195 +290,291 @@

↥ Expand context

 //!     todo!()
 //! }
 //!
 //! async fn check_health(input: input::CheckHealthInput) -> Result<output::CheckHealthOutput, error::CheckHealthError> {
 //!     todo!()
 //! }
 //!
 //! async fn do_nothing(input: input::DoNothingInput) -> Result<output::DoNothingOutput, error::DoNothingError> {
 //!     todo!()
 //! }
 //!
 //! async fn get_pokemon_species(input: input::GetPokemonSpeciesInput) -> Result<output::GetPokemonSpeciesOutput, error::GetPokemonSpeciesError> {
 //!     todo!()
 //! }
 //!
 //! async fn get_server_statistics(input: input::GetServerStatisticsInput) -> Result<output::GetServerStatisticsOutput, error::GetServerStatisticsError> {
 //!     todo!()
 //! }
 //!
 //! async fn get_storage(input: input::GetStorageInput) -> Result<output::GetStorageOutput, error::GetStorageError> {

 //!     todo!()
 //! }
 //!
 //! async fn stream_pokemon_radio(input: input::StreamPokemonRadioInput) -> Result<output::StreamPokemonRadioOutput, error::StreamPokemonRadioError> {
 //!     todo!()
 //! }
 //!
 //! ```
 //!
 //! [`serve`]: https://docs.rs/hyper/0.14.16/hyper/server/struct.Builder.html#method.serve
 //! [hyper server]: https://docs.rs/hyper/0.14.26/hyper/server/index.html
 //! [`tower::make::MakeService`]: https://docs.rs/tower/latest/tower/make/trait.MakeService.html
 //! [HTTP binding traits]: https://smithy.io/2.0/spec/http-bindings.html
 //! [operations]: https://smithy.io/2.0/spec/service-types.html#operation
 //! [hyper server]: https://docs.rs/hyper/latest/hyper/server/index.html
 //! [Service]: https://docs.rs/tower-service/latest/tower_service/trait.Service.html
 pub use crate::service::{
     MissingOperationsError, PokemonService, PokemonServiceBuilder, PokemonServiceConfig,
     PokemonServiceConfigBuilder,
 };
-234
 /// Contains the types that are re-exported from the `aws-smithy-http-server` crate.
 pub mod server {
     // Re-export all types from the `aws-smithy-http-server` crate.
     pub use ::aws_smithy_http_server::*;
     pub use ::aws_smithy_legacy_http_server::*;
-239
+}
-240
 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-243
 /// All error types that operations can return. Documentation on these types is copied from the model.
 pub mod error;
-246
 /// Input structures for operations. Documentation on these types is copied from the model.
 pub mod input;
-249
 /// Data structures used by operation inputs/outputs. Documentation on these types is copied from the model.
 pub mod model;
-252
 /// All operations that this crate can perform.
 pub mod operation;
-255
 /// A collection of types representing each operation defined in the service closure.
 ///
 /// The [plugin system](::aws_smithy_http_server::plugin) makes use of these
 /// The [plugin system](::aws_smithy_legacy_http_server::plugin) makes use of these
 /// [zero-sized types](https://doc.rust-lang.org/nomicon/exotic-sizes.html#zero-sized-types-zsts) (ZSTs) to
 /// parameterize [`Plugin`](::aws_smithy_http_server::plugin::Plugin) implementations. Their traits, such as
 /// [`OperationShape`](::aws_smithy_http_server::operation::OperationShape), can be used to provide
 /// parameterize [`Plugin`](::aws_smithy_legacy_http_server::plugin::Plugin) implementations. Their traits, such as
 /// [`OperationShape`](::aws_smithy_legacy_http_server::operation::OperationShape), can be used to provide
 /// operation specific information to the [`Layer`](::tower::Layer) being applied.
 pub mod operation_shape;
-264
 /// Output structures for operations. Documentation on these types is copied from the model.
 pub mod output;
-267
 /// Python wrapper types for event streams.
 pub mod python_event_stream;
-270
 /// Export PyO3 symbols in the shared library

↧ Expand context

 pub mod python_module_export;
-273
 /// Operation adapters that delegate to Python handlers.
 pub mod python_operation_adaptor;
-276
 /// Python server and application implementation.
 pub mod python_server_application;
-279
 mod service;
-281
 /// Data primitives referenced by other data types.
 pub mod types;
-284
 /// Constrained types for constrained shapes.
 mod constrained;
-287
 mod mimes;
-289
 mod event_stream_serde;
-291

tmp-codegen-diff/codegen-server-test-python/pokemon-service-server-sdk/rust-server-codegen-python/src/operation.rs

@@ -1,1 +705,696 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`GetStorageInput`](crate::input::GetStorageInput) using modelled bindings.
     pub struct GetStorageInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GetStorageInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GetStorageInput, ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-7
+    }
-8
+}
-9
 impl std::future::Future for GetStorageInputFuture {
     type Output = Result<
         crate::input::GetStorageInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-15
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-22
+    }
-23
+}
-24
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::GetStorageInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-33
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-37
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = GetStorageInputFuture;
-41
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-49
+            }
             crate::protocol_serde::shape_get_storage::de_get_storage_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
--
+                )
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e)
                     });
         GetStorageInputFuture {
             inner: Box::pin(fut),
-59
+        }
-60
+    }
-61
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::GetStorageOutput
-66
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_get_storage::ser_get_storage_http_response(self) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-73
+            }
-74
+        }
-75
+    }
-76
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::GetStorageError
-81
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_get_storage::ser_get_storage_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-91
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-95
+            }
-96
+        }
-97
+    }
-98
+}
-99
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`GetPokemonSpeciesInput`](crate::input::GetPokemonSpeciesInput) using modelled bindings.
     pub struct GetPokemonSpeciesInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GetPokemonSpeciesInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GetPokemonSpeciesInput, ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-105
+    }
-106
+}
-107
 impl std::future::Future for GetPokemonSpeciesInputFuture {
     type Output = Result<
         crate::input::GetPokemonSpeciesInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-113
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-120
+    }
-121
+}
-122
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::GetPokemonSpeciesInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-131
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-135
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = GetPokemonSpeciesInputFuture;
-139
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-147
+            }
             crate::protocol_serde::shape_get_pokemon_species::de_get_pokemon_species_http_request(
                 request,
-150
+            )
             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
--
+                )
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e)
                     });
         GetPokemonSpeciesInputFuture {
             inner: Box::pin(fut),
-160
+        }
-161
+    }
-162
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::GetPokemonSpeciesOutput
-167
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_get_pokemon_species::ser_get_pokemon_species_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-174
+                        }
-175
+                    }
-176
+    }
-177
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::GetPokemonSpeciesError
-182
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_get_pokemon_species::ser_get_pokemon_species_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-194
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-198
+            }
-199
+        }
-200
+    }
-201
+}
-202
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`StreamPokemonRadioInput`](crate::input::StreamPokemonRadioInput) using modelled bindings.
     pub struct StreamPokemonRadioInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::StreamPokemonRadioInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::StreamPokemonRadioInput, ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-208
+    }
-209
+}
-210
 impl std::future::Future for StreamPokemonRadioInputFuture {
     type Output = Result<
         crate::input::StreamPokemonRadioInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-216
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-223
+    }
-224
+}
-225
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::StreamPokemonRadioInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-234
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-238
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = StreamPokemonRadioInputFuture;
-242
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_OCTET_STREAM,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-250
+            }
             crate::protocol_serde::shape_stream_pokemon_radio::de_stream_pokemon_radio_http_request(
                 request,
-253
+            )
             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
--
+                )
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e)
                     });
         StreamPokemonRadioInputFuture {
             inner: Box::pin(fut),
-263
+        }
-264
+    }
-265
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::StreamPokemonRadioOutput
-270
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_stream_pokemon_radio::ser_stream_pokemon_radio_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-277
+                        }
-278
+                    }
-279
+    }
-280
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::StreamPokemonRadioError
-285
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_stream_pokemon_radio::ser_stream_pokemon_radio_http_error(
             &self,
         ) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-297
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-301
+            }
-302
+        }
-303
+    }
-304
+}
-305
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`CheckHealthInput`](crate::input::CheckHealthInput) using modelled bindings.
     pub struct CheckHealthInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::CheckHealthInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::CheckHealthInput, ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-311
+    }
-312
+}
-313
 impl std::future::Future for CheckHealthInputFuture {
     type Output = Result<
         crate::input::CheckHealthInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-319
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-326
+    }
-327
+}
-328
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::CheckHealthInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-337
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-341
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = CheckHealthInputFuture;
-345
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-353
+            }
             crate::protocol_serde::shape_check_health::de_check_health_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
--
+                )
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e)
                     });
         CheckHealthInputFuture {
             inner: Box::pin(fut),
-363
+        }
-364
+    }
-365
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::CheckHealthOutput
-370
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_check_health::ser_check_health_http_response(self) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-377
+            }
-378
+        }
-379
+    }
-380
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::CheckHealthError
-385
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_check_health::ser_check_health_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-395
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-399
+            }
-400
+        }
-401
+    }
-402
+}
-403
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`CapturePokemonInput`](crate::input::CapturePokemonInput) using modelled bindings.
     pub struct CapturePokemonInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::CapturePokemonInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::CapturePokemonInput, ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-409
+    }
-410
+}
-411
 impl std::future::Future for CapturePokemonInputFuture {
     type Output = Result<
         crate::input::CapturePokemonInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-417
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-424
+    }
-425
+}
-426
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::CapturePokemonInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-435
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-440
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = CapturePokemonInputFuture;
-444
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_VND_AMAZON_EVENTSTREAM,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-452
+            }
             crate::protocol_serde::shape_capture_pokemon::de_capture_pokemon_http_request(request)
                 .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
--
+                )
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e)
                     });
         CapturePokemonInputFuture {
             inner: Box::pin(fut),
-463
+        }
-464
+    }
-465
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::CapturePokemonOutput
-470
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_capture_pokemon::ser_capture_pokemon_http_response(self)
-473
+        {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-478
+            }
-479
+        }
-480
+    }
-481
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::CapturePokemonError
-486
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_capture_pokemon::ser_capture_pokemon_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-496
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-500
+            }
-501
+        }
-502
+    }
-503
+}
-504
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`DoNothingInput`](crate::input::DoNothingInput) using modelled bindings.
     pub struct DoNothingInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::DoNothingInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::DoNothingInput, ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-510
+    }
-511
+}
-512
 impl std::future::Future for DoNothingInputFuture {
     type Output = Result<
         crate::input::DoNothingInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-518
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-525
+    }
-526
+}
-527
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::DoNothingInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-536
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-540
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = DoNothingInputFuture;
-544
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-552
+            }
             crate::protocol_serde::shape_do_nothing::de_do_nothing_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
--
+                )
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e)
                     });
         DoNothingInputFuture {
             inner: Box::pin(fut),
-562
+        }
-563
+    }
-564
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::DoNothingOutput
-569
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_do_nothing::ser_do_nothing_http_response(self) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-576
+            }
-577
+        }
-578
+    }
-579
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::DoNothingError
-584
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_do_nothing::ser_do_nothing_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-594
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-598
+            }
-599
+        }
-600
+    }
-601
+}
-602
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`GetServerStatisticsInput`](crate::input::GetServerStatisticsInput) using modelled bindings.
     pub struct GetServerStatisticsInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GetServerStatisticsInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::GetServerStatisticsInput, ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-608
+    }
-609
+}
-610
 impl std::future::Future for GetServerStatisticsInputFuture {
     type Output = Result<
         crate::input::GetServerStatisticsInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-616
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-623
+    }
-624
+}
-625
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::GetServerStatisticsInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-634
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-638
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = GetServerStatisticsInputFuture;
-642
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-650
+            }
             crate::protocol_serde::shape_get_server_statistics::de_get_server_statistics_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
--
+                )
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e)
                     });
         GetServerStatisticsInputFuture {
             inner: Box::pin(fut),
-661
+        }
-662
+    }
-663
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::GetServerStatisticsOutput
-668
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_get_server_statistics::ser_get_server_statistics_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-675
+                        }
-676
+                    }
-677
+    }
-678
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::GetServerStatisticsError
-683
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
     fn into_response(self) -> ::aws_smithy_legacy_http_server::response::Response {
         match crate::protocol_serde::shape_get_server_statistics::ser_get_server_statistics_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-693
+            }
-694
+        }
-695
+    }
-696
+}

tmp-codegen-diff/codegen-server-test-python/pokemon-service-server-sdk/rust-server-codegen-python/src/operation_shape.rs

@@ -1,1 +289,284 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
-2
 /// Retrieve information about your Pokédex.
 pub struct GetStorage;
-5
 impl ::aws_smithy_http_server::operation::OperationShape for GetStorage {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for GetStorage {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.aws.example#GetStorage",
             "com.aws.example",
             "GetStorage",
         );
-13
     type Input = crate::input::GetStorageInput;
     type Output = crate::output::GetStorageOutput;
     type Error = crate::error::GetStorageError;
-17
+}
-18
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for GetStorage {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::sensitivity::headers::MakeHeaders<
             fn(
                 &::http::header::HeaderName,
--
+            )
                 -> ::aws_smithy_http_server::instrumentation::sensitivity::headers::HeaderMarker,
         >,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeLabel<
                 fn(usize) -> bool,
             >,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
         >,
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity for GetStorage {
     type RequestFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt<
                         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::headers::MakeHeaders<fn(&::http::header::HeaderName) -> ::aws_smithy_legacy_http_server::instrumentation::sensitivity::headers::HeaderMarker>,
                         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::uri::MakeUri<
                             ::aws_smithy_legacy_http_server::instrumentation::sensitivity::uri::MakeLabel<fn(usize) -> bool>,
                             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity
-+
+                        >
                     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     type ResponseFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
     >;
-31
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
             .header({
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
 .header({
                     |name: &::http::header::HeaderName| {
                         let name_match = matches!(name.as_str(), "passcode");
                         let key_suffix = None;
                     let value = name_match;
                     ::aws_smithy_http_server::instrumentation::sensitivity::headers::HeaderMarker {
                         key_suffix,
                         value,
--
+                    }
 let value = name_match;
                         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::headers::HeaderMarker { key_suffix, value }
-40
+                    }
                 } as fn(&_) -> _)
             .label(
                 { |index: usize| matches!(index, 1) } as fn(usize) -> bool,
                 None,
--
+            )
 .label({
                         |index: usize| matches!(index, 1)
                     } as fn(usize) -> bool, None)
-45
+    }
-46
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-49
+    }
-50
+}
-51
 /// Retrieve information about a Pokémon species.
 pub struct GetPokemonSpecies;
-54
 impl ::aws_smithy_http_server::operation::OperationShape for GetPokemonSpecies {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for GetPokemonSpecies {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.aws.example#GetPokemonSpecies",
             "com.aws.example",
             "GetPokemonSpecies",
         );
-62
     type Input = crate::input::GetPokemonSpeciesInput;
     type Output = crate::output::GetPokemonSpeciesOutput;
     type Error = crate::error::GetPokemonSpeciesError;
-66
+}
-67
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for GetPokemonSpecies {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity
     for GetPokemonSpecies
-+
+{
     type RequestFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     type ResponseFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
     >;
-82
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-85
+    }
-86
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-89
+    }
-90
+}
-91
 /// Fetch a radio song from the database and stream it back as a playable audio.
 pub struct StreamPokemonRadio;
-94
 impl ::aws_smithy_http_server::operation::OperationShape for StreamPokemonRadio {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for StreamPokemonRadio {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.aws.example#StreamPokemonRadio",
             "com.aws.example",
             "StreamPokemonRadio",
         );
-102
     type Input = crate::input::StreamPokemonRadioInput;
     type Output = crate::output::StreamPokemonRadioOutput;
     type Error = crate::error::StreamPokemonRadioError;
-106
+}
-107
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for StreamPokemonRadio {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity
     for StreamPokemonRadio
-+
+{
     type RequestFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     type ResponseFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
     >;
-122
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-125
+    }
-126
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-129
+    }
-130
+}
-131
 /// Health check operation, to check the service is up Not yet a deep check
 pub struct CheckHealth;
-134
 impl ::aws_smithy_http_server::operation::OperationShape for CheckHealth {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for CheckHealth {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.aws.example#CheckHealth",
             "com.aws.example",
             "CheckHealth",
         );
-142
     type Input = crate::input::CheckHealthInput;
     type Output = crate::output::CheckHealthOutput;
     type Error = crate::error::CheckHealthError;
-146
+}
-147
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for CheckHealth {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity for CheckHealth {
     type RequestFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     type ResponseFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
     >;
-160
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-163
+    }
-164
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-167
+    }
-168
+}
-169
 /// Capture Pokémons via event streams.
 pub struct CapturePokemon;
-172
 impl ::aws_smithy_http_server::operation::OperationShape for CapturePokemon {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for CapturePokemon {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.aws.example#CapturePokemon",
             "com.aws.example",
             "CapturePokemon",
         );
-180
     type Input = crate::input::CapturePokemonInput;
     type Output = crate::output::CapturePokemonOutput;
     type Error = crate::error::CapturePokemonError;
-184
+}
-185
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for CapturePokemon {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity for CapturePokemon {
     type RequestFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     type ResponseFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
     >;
-198
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-201
+    }
-202
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-205
+    }
-206
+}
-207
 /// DoNothing operation, used to stress test the framework.
 pub struct DoNothing;
-210
 impl ::aws_smithy_http_server::operation::OperationShape for DoNothing {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for DoNothing {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.aws.example#DoNothing",
             "com.aws.example",
             "DoNothing",
         );
-218
     type Input = crate::input::DoNothingInput;
     type Output = crate::output::DoNothingOutput;
     type Error = crate::error::DoNothingError;
-222
+}
-223
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for DoNothing {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity for DoNothing {
     type RequestFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     type ResponseFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
     >;
-236
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-239
+    }
-240
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-243
+    }
-244
+}
-245
 /// Retrieve HTTP server statistiscs, such as calls count.
 pub struct GetServerStatistics;
-248
 impl ::aws_smithy_http_server::operation::OperationShape for GetServerStatistics {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new(
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for GetServerStatistics {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.aws.example#GetServerStatistics",
             "com.aws.example",
             "GetServerStatistics",
         );
-256
     type Input = crate::input::GetServerStatisticsInput;
     type Output = crate::output::GetServerStatisticsOutput;
     type Error = crate::error::GetServerStatisticsError;
-260
+}
-261
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for GetServerStatistics {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity
     for GetServerStatistics
-+
+{
     type RequestFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     type ResponseFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
     >;
-276
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-279
+    }
-280
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-283
+    }
-284
+}

tmp-codegen-diff/codegen-server-test-python/pokemon-service-server-sdk/rust-server-codegen-python/src/protocol_serde/shape_capture_pokemon.rs

@@ -1,1 +257,257 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_capture_pokemon_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::CapturePokemonInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::capture_pokemon_input_internal::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
                 crate::protocol_serde::shape_capture_pokemon_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .try_recv_initial(::aws_smithy_legacy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                     |ev_error| ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
-35
+                                                    )
                                                 )? {
-37
-38
+                                            }
             Some(receiver)
         } {
             input = input.set_events(value)
-42
+        }
         let input_string = uri.path();
         let (input_string, (_, m1)) =
             ::nom::sequence::tuple::<_, _, ::nom::error::Error<&str>, _>((
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::bytes::complete::tag::<_, _, ::nom::error::Error<&str>>(
                         "capture-pokemon-event",
                     ),
                 ),
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::branch::alt::<_, _, ::nom::error::Error<&str>, _>((
                         ::nom::bytes::complete::take_until("/"),
                         ::nom::combinator::rest,
                     )),
                 ),
             ))(input_string)?;
         debug_assert_eq!("", input_string);
         input =
             input.set_region(crate::protocol_serde::shape_capture_pokemon_input::de_region(m1)?);
         input.build()?
     })
-65
+}
-66
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_capture_pokemon_http_response(
     #[allow(unused_variables)] output: crate::output::CapturePokemonOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let body = ::aws_smithy_http_server::body::boxed(
             ::aws_smithy_http_server::body::Body::wrap_stream({
         let body = ::aws_smithy_legacy_http_server::body::boxed(
             ::aws_smithy_legacy_http_server::body::Body::wrap_stream({
                 let error_marshaller =
                     crate::event_stream_serde::CapturePokemonEventsErrorMarshaller::new();
                 let marshaller = crate::event_stream_serde::CapturePokemonEventsMarshaller::new();
                 let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};
                 output
                     .events
                     .into_body_stream(marshaller, error_marshaller, signer)
             }),
         );
         builder.body(body)?
     })
-97
+}
-98
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_capture_pokemon_http_error(
     error: &crate::error::CapturePokemonError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::CapturePokemonError::UnsupportedRegionError(output) => {
                 let payload = crate::protocol_serde::shape_unsupported_region_error::ser_unsupported_region_error_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "UnsupportedRegionError",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-131
+            }
             crate::error::CapturePokemonError::ThrottlingError(output) => {
                 let payload =
                     crate::protocol_serde::shape_throttling_error::ser_throttling_error_error(
                         output,
                     )?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ThrottlingError",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-158
+            }
             crate::error::CapturePokemonError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-182
+            }
             crate::error::CapturePokemonError::MasterBallUnsuccessful(output) => {
                 let payload = crate::protocol_serde::shape_master_ball_unsuccessful::ser_master_ball_unsuccessful_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "MasterBallUnsuccessful",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-206
+            }
             crate::error::CapturePokemonError::InvalidPokeballError(output) => {
                 let payload = crate::protocol_serde::shape_invalid_pokeball_error::ser_invalid_pokeball_error_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "InvalidPokeballError",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-230
+            }
             crate::error::CapturePokemonError::InternalServerError(output) => {
                 let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/vnd.amazon.eventstream",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "InternalServerError",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-254
+            }
-255
+        }
     })
-257
+}

tmp-codegen-diff/codegen-server-test-python/pokemon-service-server-sdk/rust-server-codegen-python/src/protocol_serde/shape_capture_pokemon_input.rs

@@ -1,1 +25,25 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub fn de_events_payload(
     body: &mut ::aws_smithy_types::body::SdkBody,
 ) -> std::result::Result<
     crate::python_event_stream::CapturePokemonInputEventsReceiver,
     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     let unmarshaller = crate::event_stream_serde::AttemptCapturingPokemonEventUnmarshaller::new();

     let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
     let receiver =
         crate::python_event_stream::CapturePokemonInputEventsReceiver::new(unmarshaller, body);
     Ok(receiver)
-13
+}
-14
 pub fn de_region(
     value: &str,
 ) -> std::result::Result<
     ::std::string::String,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection,
 > {
     let value = ::percent_encoding::percent_decode_str(value)
         .decode_utf8()?
         .into_owned();
     Ok(value)
-25
+}

tmp-codegen-diff/codegen-server-test-python/pokemon-service-server-sdk/rust-server-codegen-python/src/protocol_serde/shape_check_health.rs

@@ -1,1 +91,93 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_check_health_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::CheckHealthInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::check_health_input_internal::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(&headers, None)?;
         ::aws_smithy_legacy_http_server::protocol::content_type_header_classifier_smithy(
             &headers, None,
         )?;
         input.build()
     })
-27
+}
-28
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_check_health_http_response(
     #[allow(unused_variables)] output: crate::output::CheckHealthOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload = "";
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         let body = ::aws_smithy_legacy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-56
+}
-57
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_check_health_http_error(
     error: &crate::error::CheckHealthError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::CheckHealthError::InternalServerError(output) => {
                 let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "InternalServerError",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-90
+            }
-91
+        }
     })
-93
+}

Pages: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35

1 1	`# Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.`
2 2	`[package]`
3 3	`name = "pokemon-service-server-sdk"`