Server Test Python

rev. d06a46cae0f385cdae37a9f8264db3469a090ab5 (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-server-test-python/naming_test_casing/rust-server-codegen-python/Cargo.toml

@@ -1,1 +57,59 @@

 [package]
 name = "naming_test_casing"
 version = "0.0.1"
 authors = ["protocoltest@example.com"]
 description = "test"
 edition = "2021"
-8
 [package.metadata.smithy]
 codegen-version = "ci"
 protocol = "aws.protocols#awsJson1_1"
 [dependencies.aws-smithy-http]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-http"
 [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"
 [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 = ["http-02x"]
 [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.parking_lot]
 version = "0.12"
 [dependencies.pin-project-lite]
 version = "0.2"
 [dependencies.pyo3]
 version = "0.20"
 [dependencies.pyo3-asyncio]
 version = "0.20"
 features = ["attributes", "tokio-runtime"]
 [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]
 rt-tokio = ["aws-smithy-types/rt-tokio"]
 aws-lambda = ["aws-smithy-http-server/aws-lambda"]
 request-id = ["aws-smithy-http-server/request-id"]
 aws-lambda = ["aws-smithy-legacy-http-server/aws-lambda"]
 request-id = ["aws-smithy-legacy-http-server/request-id"]
 extension-module = ["pyo3/extension-module"]
 default = ["rt-tokio", "request-id", "extension-module"]
 [lib]
 name = "naming_test_casing"
 crate-type = ["cdylib"]
-58
-59

tmp-codegen-diff/codegen-server-test-python/naming_test_casing/rust-server-codegen-python/python/naming_test_casing/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/naming_test_casing/rust-server-codegen-python/src/lib.rs

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

↥ Expand context

 //! The primary entrypoint is [`AcronymInsideService`]: 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 [`AcronymInsideService::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 naming_test_casing::{AcronymInsideService, AcronymInsideServiceConfig};

 //!
 //! # let app = AcronymInsideService::builder(
 //! #     AcronymInsideServiceConfig::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 naming_test_casing::server::routing::LambdaHandler;
 //! use naming_test_casing::AcronymInsideService;
 //!
 //! # async fn dummy() {
 //! # let app = AcronymInsideService::builder(
 //! #     AcronymInsideServiceConfig::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let handler = LambdaHandler::new(app);
 //! lambda_http::run(handler).await.unwrap();
 //! # }
 //! ```
 //!
 //! # Building the AcronymInsideService
 //!
 //! To construct [`AcronymInsideService`] we use [`AcronymInsideServiceBuilder`] returned by [`AcronymInsideService::builder`].
 //!
 //! ## Plugins
 //!
 //! The [`AcronymInsideService::builder`] method, returning [`AcronymInsideServiceBuilder`],
 //! 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 naming_test_casing::server::plugin::IdentityPlugin as LoggingPlugin;
 //! # use naming_test_casing::server::plugin::IdentityPlugin as MetricsPlugin;
 //! # use ::hyper::Body;
 //! use naming_test_casing::server::plugin::HttpPlugins;
 //! use naming_test_casing::{AcronymInsideService, AcronymInsideServiceConfig, AcronymInsideServiceBuilder};
 //!
 //! let http_plugins = HttpPlugins::new()
 //!         .push(LoggingPlugin)
 //!         .push(MetricsPlugin);
 //! let config = AcronymInsideServiceConfig::builder().build();
 //! let builder: AcronymInsideServiceBuilder<Body, _, _, _> = AcronymInsideService::builder(config);
 //! let builder: AcronymInsideServiceBuilder<::hyper::Body, _, _, _> = AcronymInsideService::builder(config);
 //! ```
 //!
 //! Check out [`crate::server::plugin`] to learn more about plugins.
 //!
 //! ## Handlers
 //!
 //! [`AcronymInsideServiceBuilder`] 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;

@@ -164,165 +257,258 @@

↥ Expand context

 //! use naming_test_casing::{AcronymInsideService, AcronymInsideServiceConfig};
 //!
 //! #[::tokio::main]
 //! pub async fn main() {
 //!    let config = AcronymInsideServiceConfig::builder().build();
 //!    let app = AcronymInsideService::builder(config)
 //!        .do_nothing(do_nothing)
 //!        .build()
 //!        .expect("failed to build an instance of AcronymInsideService");
 //!
 //!    let bind: SocketAddr = "127.0.0.1:6969".parse()
 //!        .expect("unable to parse the server bind address and port");
 //!    let server = ::hyper::Server::bind(&bind).serve(app.into_make_service());
 //!    # let server = async { Ok::<_, ()>(()) };
 //!
 //!    // Run your service!
 //!    if let Err(err) = server.await {
 //!        eprintln!("server error: {:?}", err);
 //!    }
 //! }

 //!
 //! use naming_test_casing::{input, output, error};
 //!
 //! async fn do_nothing(input: input::DoNothingInput) -> Result<output::DoNothingOutput, error::DoNothingError> {
 //!     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::{
     AcronymInsideService, AcronymInsideServiceBuilder, AcronymInsideServiceConfig,
     AcronymInsideServiceConfigBuilder, MissingOperationsError,
 };
-204
 /// 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::*;
-209
+}
-210
 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-213
 /// All error types that operations can return. Documentation on these types is copied from the model.
 pub mod error;
-216
 /// Input structures for operations. Documentation on these types is copied from the model.
 pub mod input;
-219
 /// All operations that this crate can perform.
 pub mod operation;
-222
 /// 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;
-231
 /// Output structures for operations. Documentation on these types is copied from the model.
 pub mod output;
-234
 /// Export PyO3 symbols in the shared library
 pub mod python_module_export;
-237
 /// Operation adapters that delegate to Python handlers.

↧ Expand context

 pub mod python_operation_adaptor;
-240
 /// Python server and application implementation.
 pub mod python_server_application;
-243
 mod service;
-245
 /// Data primitives referenced by other data types.
 pub mod types;
-248
 /// Constrained types for constrained shapes.
 mod constrained;
-251
 mod mimes;
-253
 pub(crate) mod protocol_serde;
-255
 /// Re-exported Python types from supporting crates.
 pub mod python_types {
     pub use ::aws_smithy_http_server_python::types::Blob;

tmp-codegen-diff/codegen-server-test-python/naming_test_casing/rust-server-codegen-python/src/operation.rs

@@ -1,1 +109,98 @@

 // 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
     /// [`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::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::DoNothingInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-7
+    }
-8
+}
-9
 impl std::future::Future for DoNothingInputFuture {
     type Output = Result<
         crate::input::DoNothingInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::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::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         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,
-33
     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>,
-37
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = DoNothingInputFuture;
-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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-49
+            }
             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::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         DoNothingInputFuture {
             inner: Box::pin(fut),
-59
+        }
-60
+    }
-61
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::DoNothingOutput
-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_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::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-73
+            }
-74
+        }
-75
+    }
-76
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::error::DoNothingError
-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_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
-91
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-95
+            }
-96
+        }
-97
+    }
-98
+}

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(missing_docs)] // documentation missing in model
 pub struct DoNothing;
-4
 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("casing#DoNothing", "casing", "DoNothing");
 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(
             "casing#DoNothing",
             "casing",
             "DoNothing",
         );
-12
     type Input = crate::input::DoNothingInput;
     type Output = crate::output::DoNothingOutput;
     type Error = crate::error::DoNothingError;
-16
+}
-17
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for DoNothing {
     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 DoNothing {
     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_casing/rust-server-codegen-python/src/protocol_serde/shape_do_nothing.rs

@@ -1,1 +85,85 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_do_nothing_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::DoNothingInput,
     ::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::do_nothing_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();
         input.build()
     })
-24
+}
-25
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_do_nothing_http_response(
     #[allow(unused_variables)] output: crate::output::DoNothingOutput,
 ) -> 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 = "";
         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)?
     })
-53
+}
-54
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_do_nothing_http_error(
     error: &crate::error::DoNothingError,
 ) -> 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::DoNothingError::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))?
-82
+            }
-83
+        }
     })
-85
+}

tmp-codegen-diff/codegen-server-test-python/naming_test_casing/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 `DoNothing`.
 pub(crate) async fn do_nothing(
     input: crate::input::DoNothingInput,
     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::DoNothingOutput, crate::error::DoNothingError> {
     // Async block used to run the handler and catch any Python error.
     let result = if handler.is_coroutine {
         ::tracing::trace!(name = "do_nothing", "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::DoNothingOutput>(py))
         })
     } else {
         ::tracing::trace!(name = "do_nothing", "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::DoNothingOutput>()
         })
     };
     // Catch and record a Python traceback.

tmp-codegen-diff/codegen-server-test-python/naming_test_casing/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::AcronymInsideService::builder_without_plugins();
         let do_nothing_locals = ::pyo3_asyncio::TaskLocals::new(event_loop);
         let handler = self
             .handlers
             .get("do_nothing")
             .expect("Python handler for operation `do_nothing` not found")
             .clone();
         let builder = builder.do_nothing(move |input, state| {
             ::pyo3_asyncio::tokio::scope(
                 do_nothing_locals.clone(),
                 crate::python_operation_adaptor::do_nothing(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_casing.middleware.Request, typing.Callable\[\[naming_test_casing.middleware.Request\], typing.Awaitable\[naming_test_casing.middleware.Response\]\]\], typing.Awaitable\[naming_test_casing.middleware.Response\]\]:
     /// :rtype None:
     #[pyo3(text_signature = "($self, func)")]
     pub fn middleware(

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

@@ -1,1 +630,641 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// The service builder for [`AcronymInsideService`].
 ///
 /// Constructed via [`AcronymInsideService::builder`].
 pub struct AcronymInsideServiceBuilder<Body, L, HttpPl, ModelPl> {
     do_nothing: Option<::aws_smithy_http_server::routing::Route<Body>>,
     do_nothing: Option<::aws_smithy_legacy_http_server::routing::Route<Body>>,
     layer: L,
     http_plugin: HttpPl,
     model_plugin: ModelPl,
-10
+}
-11
 impl<Body, L, HttpPl, ModelPl> AcronymInsideServiceBuilder<Body, L, HttpPl, ModelPl> {
     /// Sets the [`DoNothing`](crate::operation_shape::DoNothing) 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_casing::{AcronymInsideService, AcronymInsideServiceConfig};
     ///
     /// use naming_test_casing::{input, output, error};
     ///
     /// async fn handler(input: input::DoNothingInput) -> Result<output::DoNothingOutput, error::DoNothingError> {
     ///     todo!()
     /// }
     ///
     /// let config = AcronymInsideServiceConfig::builder().build();
     /// let app = AcronymInsideService::builder(config)
     ///     .do_nothing(handler)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: AcronymInsideService<::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: AcronymInsideService<::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 do_nothing<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::DoNothing, HandlerExtractors>,
                         HandlerType: ::aws_smithy_legacy_http_server::operation::Handler<crate::operation_shape::DoNothing, HandlerExtractors>,
-41
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             AcronymInsideService<L>,
                             crate::operation_shape::DoNothing,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::DoNothing, HandlerType>
                             ::aws_smithy_legacy_http_server::operation::IntoService<crate::operation_shape::DoNothing, 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<
                             AcronymInsideService<L>,
                             crate::operation_shape::DoNothing,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             AcronymInsideService<L>,
                             crate::operation_shape::DoNothing,
-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<
                                     AcronymInsideService<L>,
                                     crate::operation_shape::DoNothing,
                                     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::DoNothing::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.do_nothing_custom(svc)
-78
+    }
-79
     /// Sets the [`DoNothing`](crate::operation_shape::DoNothing) 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_casing::{AcronymInsideService, AcronymInsideServiceConfig};
     ///
     /// use naming_test_casing::{input, output, error};
     ///
     /// async fn handler(input: input::DoNothingInput) -> Result<output::DoNothingOutput, error::DoNothingError> {
     ///     todo!()
     /// }
     ///
     /// let config = AcronymInsideServiceConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);
     /// let app = AcronymInsideService::builder(config)
     ///     .do_nothing_service(svc)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: AcronymInsideService<::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: AcronymInsideService<::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 do_nothing_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::DoNothing, ServiceExtractors>,
                         S: ::aws_smithy_legacy_http_server::operation::OperationService<crate::operation_shape::DoNothing, ServiceExtractors>,
-109
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             AcronymInsideService<L>,
                             crate::operation_shape::DoNothing,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::DoNothing, S>
                             ::aws_smithy_legacy_http_server::operation::Normalize<crate::operation_shape::DoNothing, 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<
                             AcronymInsideService<L>,
                             crate::operation_shape::DoNothing,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             AcronymInsideService<L>,
                             crate::operation_shape::DoNothing,
-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<
                                     AcronymInsideService<L>,
                                     crate::operation_shape::DoNothing,
                                     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::DoNothing::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.do_nothing_custom(svc)
-146
+    }
-147
     /// Sets the [`DoNothing`](crate::operation_shape::DoNothing) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn do_nothing_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.do_nothing = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self.do_nothing = Some(::aws_smithy_legacy_http_server::routing::Route::new(svc));
         self
-163
+    }
-164
+}
-165
 impl<Body, L, HttpPl, ModelPl> AcronymInsideServiceBuilder<Body, L, HttpPl, ModelPl> {
     /// Constructs a [`AcronymInsideService`] from the arguments provided to the builder.
     ///
     /// Forgetting to register a handler for one or more operations will result in an error.
     ///
     /// Check out [`AcronymInsideServiceBuilder::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<
         AcronymInsideService<
             ::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.do_nothing.is_none() {
                 missing_operation_names
                     .insert(crate::operation_shape::DoNothing::ID, ".do_nothing()");
-195
+            }
             if !missing_operation_names.is_empty() {
                 return Err(MissingOperationsError {
                     operation_names2setter_methods: missing_operation_names,
                 });
-200
+            }
             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";
-202
             ::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::do_nothing(),
                     self.do_nothing.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(AcronymInsideService { svc })
-213
+    }
-214
     /// Constructs a [`AcronymInsideService`] from the arguments provided to the builder.
     /// Operations without a handler default to returning 500 Internal Server Error to the caller.
     ///
     /// Check out [`AcronymInsideServiceBuilder::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) -> AcronymInsideService<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,
             >,
         >,
-231
+    {
         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::do_nothing(),
                     self.do_nothing.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));
         AcronymInsideService { svc }
-248
+    }
-249
+}
-250
 /// The error encountered when calling the [`AcronymInsideServiceBuilder::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>,
-257
+}
-258
 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 `AcronymInsideService`.\n\
                             We are missing handlers for the following operations:\n",
         )?;
         for operation_name in self.operation_names2setter_methods.keys() {
             writeln!(f, "- {}", operation_name.absolute())?;
-268
+        }
-269
         writeln!(f, "\nUse the dedicated methods on `AcronymInsideServiceBuilder` to register the missing handlers:")?;
         for setter_name in self.operation_names2setter_methods.values() {
             writeln!(f, "- {}", setter_name)?;
-273
+        }
         Ok(())
-275
+    }
-276
+}
-277
 impl std::error::Error for MissingOperationsError {}
-279
 mod request_specs {
     pub(super) fn do_nothing() -> &'static str {
         "ACRONYMInside_Service.DoNothing"
-283
+    }
-284
+}
-285
 /// Confounds model generation machinery with lots of problematic casing
 ///
 /// See the [root](crate) documentation for more information.
 #[derive(Clone)]
 pub struct AcronymInsideService<
     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,
-302
+}
-303
 impl AcronymInsideService<()> {
     /// Constructs a builder for [`AcronymInsideService`].
     /// 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: AcronymInsideServiceConfig<L, HttpPl, ModelPl>,
     ) -> AcronymInsideServiceBuilder<Body, L, HttpPl, ModelPl> {
         AcronymInsideServiceBuilder {
             do_nothing: None,
             layer: config.layers,
             http_plugin: config.http_plugins,
             model_plugin: config.model_plugins,
-321
+        }
-322
+    }
-323
     /// Constructs a builder for [`AcronymInsideService`].
     /// You must specify what plugins should be applied to the operations in this service.
     ///
     /// Use [`AcronymInsideService::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 `AcronymInsideServiceConfig` 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,
     ) -> AcronymInsideServiceBuilder<Body, ::tower::layer::util::Identity, HttpPl, ModelPl> {
         AcronymInsideServiceBuilder {
             do_nothing: None,
             layer: ::tower::layer::util::Identity::new(),
             http_plugin,
             model_plugin,
-349
+        }
-350
+    }
-351
     /// Constructs a builder for [`AcronymInsideService`].
     ///
     /// Use [`AcronymInsideService::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>() -> AcronymInsideServiceBuilder<
         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> AcronymInsideService<S> {
     /// Converts [`AcronymInsideService`] 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 [`AcronymInsideService`] into a [`MakeService`](tower::make::MakeService) with [`ConnectInfo`](::aws_smithy_http_server::request::connect_info::ConnectInfo).
     /// Converts [`AcronymInsideService`] 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>
     AcronymInsideService<
         ::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 `AcronymInsideServiceConfig` object instead; see https://github.com/smithy-lang/smithy-rs/discussions/3096"
     )]
     pub fn layer<L>(
         self,
         layer: &L,
     ) -> AcronymInsideService<
         ::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
+    {
         AcronymInsideService {
             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,
     ) -> AcronymInsideService<
         ::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 AcronymInsideService<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 AcronymInsideService.
 #[allow(clippy::enum_variant_names)]
 #[derive(Debug, PartialEq, Eq, Clone, Copy)]
 pub enum Operation {
     DoNothing,
-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::DoNothing => ::aws_smithy_http_server::shape_id::ShapeId::new(
             Operation::DoNothing => ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
                 "casing#DoNothing",
                 "casing",
                 "DoNothing",
             ),
-482
+        }
-483
+    }
-484
+}
 impl<L> ::aws_smithy_http_server::service::ContainsOperation<crate::operation_shape::DoNothing>
 impl<L>
     ::aws_smithy_legacy_http_server::service::ContainsOperation<crate::operation_shape::DoNothing>
     for AcronymInsideService<L>
-488
+{
     const VALUE: Operation = Operation::DoNothing;
-490
+}
-491
 impl<S> ::aws_smithy_http_server::service::ServiceShape for AcronymInsideService<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 AcronymInsideService<S> {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "casing#ACRONYMInside_Service",
             "casing",
             "ACRONYMInside_Service",
         );
-499
     const VERSION: Option<&'static str> = Some("");
-501
     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;
-503
     type Operations = Operation;
-505
+}
 /// Configuration for the [`AcronymInsideService`]. This is the central place where to register and
 /// configure [`::tower::Layer`]s, HTTP plugins, and model plugins.
 ///
 /// ```rust,no_run
 /// # use naming_test_casing::AcronymInsideServiceConfig;
 /// # 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 = AcronymInsideServiceConfig::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 AcronymInsideServiceConfig<L, H, M> {
     layers: L,
     http_plugins: H,
     model_plugins: M,
-534
+}
-535
 impl AcronymInsideServiceConfig<(), (), ()> {
     /// Returns a builder to construct the configuration.
     pub fn builder() -> AcronymInsideServiceConfigBuilder<
         ::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,
     > {
         AcronymInsideServiceConfigBuilder {
             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,
-547
+        }
-548
+    }
-549
+}
-550
 /// Builder returned by [`AcronymInsideServiceConfig::builder()`].
 #[derive(::std::fmt::Debug)]
 pub struct AcronymInsideServiceConfigBuilder<L, H, M> {
     pub(crate) layers: L,
     pub(crate) http_plugins: H,
     pub(crate) model_plugins: M,
-557
+}
-558
 impl<L, H, M> AcronymInsideServiceConfigBuilder<L, H, M> {
     /// Add a [`::tower::Layer`] to the service.
     pub fn layer<NewLayer>(
         self,
         layer: NewLayer,
     ) -> AcronymInsideServiceConfigBuilder<::tower::layer::util::Stack<NewLayer, L>, H, M> {
         AcronymInsideServiceConfigBuilder {
             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,
     ) -> AcronymInsideServiceConfigBuilder<
         L,
         ::aws_smithy_http_server::plugin::PluginStack<NewPlugin, H>,
         ::aws_smithy_legacy_http_server::plugin::PluginStack<NewPlugin, H>,
         M,
     > {
         AcronymInsideServiceConfigBuilder {
             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,
     ) -> AcronymInsideServiceConfigBuilder<
         L,
         H,
         ::aws_smithy_http_server::plugin::PluginStack<NewPlugin, M>,
         ::aws_smithy_legacy_http_server::plugin::PluginStack<NewPlugin, M>,
     > {
         AcronymInsideServiceConfigBuilder {
             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::AcronymInsideServiceConfig<L, H, M> {
         super::AcronymInsideServiceConfig {
             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 [`DoNothing`], excluding all other operations.
 ///     struct ScopeA {
 ///         includes: [DoNothing]
 ///     }
 /// }
 ///

tmp-codegen-diff/codegen-server-test-python/naming_test_ops/rust-server-codegen-python/Cargo.toml

@@ -1,1 +59,59 @@

↥ Expand context

 [package]
 name = "naming_test_ops"
 version = "0.0.1"
 authors = ["protocoltest@example.com"]
 description = "test"
 edition = "2021"
-8
 [package.metadata.smithy]
 codegen-version = "ci"
 protocol = "aws.protocols#awsJson1_1"
 [dependencies.aws-smithy-http]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-http"
 [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"
 [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 = ["http-02x"]
 [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.hyper]
 version = "0.14.26"
 [dependencies.mime]
 version = "0.3"
 [dependencies.parking_lot]
 version = "0.12"
 [dependencies.pin-project-lite]
 version = "0.2"
 [dependencies.pyo3]
 version = "0.20"
 [dependencies.pyo3-asyncio]
 version = "0.20"
 features = ["attributes", "tokio-runtime"]
 [dependencies.tower]
 version = "0.4"
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.hyper]
 version = "0.14.12"
 [dev-dependencies.tokio]
 version = "1.23.1"
 [features]
 rt-tokio = ["aws-smithy-types/rt-tokio"]
 aws-lambda = ["aws-smithy-http-server/aws-lambda"]
 request-id = ["aws-smithy-http-server/request-id"]
 aws-lambda = ["aws-smithy-legacy-http-server/aws-lambda"]
 request-id = ["aws-smithy-legacy-http-server/request-id"]
 extension-module = ["pyo3/extension-module"]
 default = ["rt-tokio", "request-id", "extension-module"]
 [lib]
 name = "naming_test_ops"
 crate-type = ["cdylib"]
-58
-59

tmp-codegen-diff/codegen-server-test-python/naming_test_ops/rust-server-codegen-python/python/naming_test_ops/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/naming_test_ops/rust-server-codegen-python/src/input.rs

@@ -668,668 +728,728 @@

↥ Expand context

     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     #[non_exhaustive]
     #[allow(clippy::enum_variant_names)]
     pub(crate) enum ConstraintViolation {
         /// Constraint violation occurred building member `r#enum` when building `RpcEchoInput`.
         #[doc(hidden)]
         Enum(crate::model::unknown_variant_colliding_enum_internal::ConstraintViolation),
-676
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::Enum(_) => write!(f, "constraint violation occurred building member `r#enum` when building `RpcEchoInput`"),
-681
+            }
-682
+        }
-683
+    }
     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::Enum(inner) => {
                     inner.as_validation_exception_field(path + "/enum")
-693
+                }
-694
+            }
-695
+        }
-696
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection
-699
+    {
         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")
-713
+                            )
-714
+        }
-715
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::RpcEchoInput>
-718
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-721
+        }
-722
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::RpcEchoInput {
         type Error = ConstraintViolation;
-725
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-728
+        }

@@ -933,933 +993,993 @@

↥ Expand context

     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     #[non_exhaustive]
     #[allow(clippy::enum_variant_names)]
     pub(crate) enum ConstraintViolation {
         /// Constraint violation occurred building member `r#enum` when building `MatchInput`.
         #[doc(hidden)]
         Enum(crate::model::unknown_variant_colliding_enum_internal::ConstraintViolation),
-941
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::Enum(_) => write!(f, "constraint violation occurred building member `r#enum` when building `MatchInput`"),
-946
+            }
-947
+        }
-948
+    }
     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::Enum(inner) => {
                     inner.as_validation_exception_field(path + "/enum")
-958
+                }
-959
+            }
-960
+        }
-961
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection
-964
+    {
         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")
-978
+                            )
-979
+        }
-980
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::MatchInput>
-983
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-986
+        }
-987
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::MatchInput {
         type Error = ConstraintViolation;
-990
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-993
+        }

@@ -1451,1451 +1511,1511 @@

↥ Expand context

     #[derive(::std::cmp::PartialEq, ::std::fmt::Debug)]
     /// Holds one variant for each of the ways the builder can fail.
     #[non_exhaustive]
     #[allow(clippy::enum_variant_names)]
     pub(crate) enum ConstraintViolation {
         /// Constraint violation occurred building member `r#enum` when building `ReservedWordsAsMembersInput`.
         #[doc(hidden)]
         Enum(crate::model::unknown_variant_colliding_enum_internal::ConstraintViolation),
-1459
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::Enum(_) => write!(f, "constraint violation occurred building member `r#enum` when building `ReservedWordsAsMembersInput`"),
-1464
+            }
-1465
+        }
-1466
+    }
     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::Enum(inner) => {
                     inner.as_validation_exception_field(path + "/enum")
-1476
+                }
-1477
+            }
-1478
+        }
-1479
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection
-1482
+    {
         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")
-1496
+                            )
-1497
+        }
-1498
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::ReservedWordsAsMembersInput>
-1501
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-1504
+        }
-1505
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::ReservedWordsAsMembersInput {
         type Error = ConstraintViolation;
-1508
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-1511
+        }

tmp-codegen-diff/codegen-server-test-python/naming_test_ops/rust-server-codegen-python/src/lib.rs

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

↥ Expand context

 //! The primary entrypoint is [`Config`]: 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 [`Config::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 naming_test_ops::{Config, ConfigConfig};

 //!
 //! # let app = Config::builder(
 //! #     ConfigConfig::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 naming_test_ops::server::routing::LambdaHandler;
 //! use naming_test_ops::Config;
 //!
 //! # async fn dummy() {
 //! # let app = Config::builder(
 //! #     ConfigConfig::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let handler = LambdaHandler::new(app);
 //! lambda_http::run(handler).await.unwrap();
 //! # }
 //! ```
 //!
 //! # Building the Config
 //!
 //! To construct [`Config`] we use [`ConfigBuilder`] returned by [`Config::builder`].
 //!
 //! ## Plugins
 //!
 //! The [`Config::builder`] method, returning [`ConfigBuilder`],
 //! 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 naming_test_ops::server::plugin::IdentityPlugin as LoggingPlugin;
 //! # use naming_test_ops::server::plugin::IdentityPlugin as MetricsPlugin;
 //! # use ::hyper::Body;
 //! use naming_test_ops::server::plugin::HttpPlugins;
 //! use naming_test_ops::{Config, ConfigConfig, ConfigBuilder};
 //!
 //! let http_plugins = HttpPlugins::new()
 //!         .push(LoggingPlugin)
 //!         .push(MetricsPlugin);
 //! let config = ConfigConfig::builder().build();
 //! let builder: ConfigBuilder<Body, _, _, _> = Config::builder(config);
 //! let builder: ConfigBuilder<::hyper::Body, _, _, _> = Config::builder(config);
 //! ```
 //!
 //! Check out [`crate::server::plugin`] to learn more about plugins.
 //!
 //! ## Handlers
 //!
 //! [`ConfigBuilder`] 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 +289,290 @@

↥ Expand context

 //!     todo!()
 //! }
 //!
 //! async fn r#match(input: input::MatchInput) -> Result<output::MatchOutput, error::MatchError> {
 //!     todo!()
 //! }
 //!
 //! async fn option(input: input::OptionInput) -> Result<output::OptionOutput, error::OptionError> {
 //!     todo!()
 //! }
 //!
 //! async fn reserved_words_as_members(input: input::ReservedWordsAsMembersInput) -> Result<output::ReservedWordsAsMembersOutput, error::ReservedWordsAsMembersError> {
 //!     todo!()
 //! }
 //!
 //! async fn result(input: input::ResultInput) -> Result<output::ResultOutput, error::ResultError> {
 //!     todo!()
 //! }
 //!
 //! async fn rpc_echo(input: input::RpcEchoInput) -> Result<output::RpcEchoOutput, error::RPCEchoError> {

 //!     todo!()
 //! }
 //!
 //! async fn structure_name_punning(input: input::StructureNamePunningInput) -> Result<output::StructureNamePunningOutput, error::StructureNamePunningError> {
 //!     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::{
     Config, ConfigBuilder, ConfigConfig, ConfigConfigBuilder, MissingOperationsError,
 };
-233
 /// 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::*;
-238
+}
-239
 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-242
 /// All error types that operations can return. Documentation on these types is copied from the model.
 pub mod error;
-245
 /// Input structures for operations. Documentation on these types is copied from the model.
 pub mod input;
-248
 /// Data structures used by operation inputs/outputs. Documentation on these types is copied from the model.
 pub mod model;
-251
 /// All operations that this crate can perform.
 pub mod operation;
-254
 /// 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;
-263
 /// Output structures for operations. Documentation on these types is copied from the model.
 pub mod output;
-266
 /// Export PyO3 symbols in the shared library
 pub mod python_module_export;
-269
 /// Operation adapters that delegate to Python handlers.

↧ Expand context

 pub mod python_operation_adaptor;
-272
 /// Python server and application implementation.
 pub mod python_server_application;
-275
 mod service;
-277
 /// Data primitives referenced by other data types.
 pub mod types;
-280
 /// Constrained types for constrained shapes.
 mod constrained;
-283
 mod mimes;
-285
 pub(crate) mod protocol_serde;
-287
 /// Re-exported Python types from supporting crates.
 pub mod python_types {
     pub use ::aws_smithy_http_server_python::types::Blob;

tmp-codegen-diff/codegen-server-test-python/naming_test_ops/rust-server-codegen-python/src/operation.rs

@@ -1,1 +738,681 @@

 // 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
     /// [`RpcEchoInput`](crate::input::RpcEchoInput) using modelled bindings.
     pub struct RpcEchoInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::RpcEchoInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::RpcEchoInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-7
+    }
-8
+}
-9
 impl std::future::Future for RpcEchoInputFuture {
     type Output = Result<
         crate::input::RpcEchoInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::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::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::RpcEchoInput
 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::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>,
-37
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = RpcEchoInputFuture;
-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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-49
+            }
             crate::protocol_serde::shape_rpc_echo::de_rpc_echo_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         RpcEchoInputFuture {
             inner: Box::pin(fut),
-59
+        }
-60
+    }
-61
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::RpcEchoOutput
-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_rpc_echo::ser_rpc_echo_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::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-73
+            }
-74
+        }
-75
+    }
-76
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::error::RPCEchoError
-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_rpc_echo::ser_rpc_echo_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::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-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
     /// [`MatchInput`](crate::input::MatchInput) using modelled bindings.
     pub struct MatchInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MatchInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MatchInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-105
+    }
-106
+}
-107
 impl std::future::Future for MatchInputFuture {
     type Output = Result<
         crate::input::MatchInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::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::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::MatchInput
 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::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>,
-135
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = MatchInputFuture;
-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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-147
+            }
             crate::protocol_serde::shape_match::de_match_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         MatchInputFuture {
             inner: Box::pin(fut),
-157
+        }
-158
+    }
-159
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::MatchOutput
-164
+{
     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_match::ser_match_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::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-171
+            }
-172
+        }
-173
+    }
-174
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::error::MatchError
-179
+{
     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_match::ser_match_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
-189
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-193
+            }
-194
+        }
-195
+    }
-196
+}
-197
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`OptionInput`](crate::input::OptionInput) using modelled bindings.
     pub struct OptionInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OptionInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OptionInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-203
+    }
-204
+}
-205
 impl std::future::Future for OptionInputFuture {
     type Output = Result<
         crate::input::OptionInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-211
     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)
-218
+    }
-219
+}
-220
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::OptionInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-229
     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>,
-233
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = OptionInputFuture;
-237
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-245
+            }
             crate::protocol_serde::shape_option::de_option_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         OptionInputFuture {
             inner: Box::pin(fut),
-255
+        }
-256
+    }
-257
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::OptionOutput
-262
+{
     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_option::ser_option_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::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-269
+            }
-270
+        }
-271
+    }
-272
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::error::OptionError
-277
+{
     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_option::ser_option_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
-287
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-291
+            }
-292
+        }
-293
+    }
-294
+}
-295
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`ResultInput`](crate::input::ResultInput) using modelled bindings.
     pub struct ResultInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ResultInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ResultInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-301
+    }
-302
+}
-303
 impl std::future::Future for ResultInputFuture {
     type Output = Result<
         crate::input::ResultInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-309
     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)
-316
+    }
-317
+}
-318
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::ResultInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-327
     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>,
-331
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = ResultInputFuture;
-335
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-343
+            }
             crate::protocol_serde::shape_result::de_result_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         ResultInputFuture {
             inner: Box::pin(fut),
-353
+        }
-354
+    }
-355
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::ResultOutput
-360
+{
     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_result::ser_result_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::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-367
+            }
-368
+        }
-369
+    }
-370
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::error::ResultError
-375
+{
     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_result::ser_result_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
-385
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-389
+            }
-390
+        }
-391
+    }
-392
+}
-393
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`ErrCollisionsInput`](crate::input::ErrCollisionsInput) using modelled bindings.
     pub struct ErrCollisionsInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ErrCollisionsInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ErrCollisionsInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-399
+    }
-400
+}
-401
 impl std::future::Future for ErrCollisionsInputFuture {
     type Output = Result<
         crate::input::ErrCollisionsInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-407
     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)
-414
+    }
-415
+}
-416
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::ErrCollisionsInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-425
     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>,
-429
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = ErrCollisionsInputFuture;
-433
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-441
+            }
             crate::protocol_serde::shape_err_collisions::de_err_collisions_http_request(request)
                 .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         ErrCollisionsInputFuture {
             inner: Box::pin(fut),
-452
+        }
-453
+    }
-454
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::ErrCollisionsOutput
-459
+{
     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_err_collisions::ser_err_collisions_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::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-466
+            }
-467
+        }
-468
+    }
-469
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::error::ErrCollisionsError
-474
+{
     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_err_collisions::ser_err_collisions_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
-484
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(
                         e,
                     ),
--
+                )
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-488
+            }
-489
+        }
-490
+    }
-491
+}
-492
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`StructureNamePunningInput`](crate::input::StructureNamePunningInput) using modelled bindings.
     pub struct StructureNamePunningInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::StructureNamePunningInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::StructureNamePunningInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-498
+    }
-499
+}
-500
 impl std::future::Future for StructureNamePunningInputFuture {
     type Output = Result<
         crate::input::StructureNamePunningInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-506
     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)
-513
+    }
-514
+}
-515
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::StructureNamePunningInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-524
     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>,
-528
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = StructureNamePunningInputFuture;
-532
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-540
+            }
             crate::protocol_serde::shape_structure_name_punning::de_structure_name_punning_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         StructureNamePunningInputFuture {
             inner: Box::pin(fut),
-551
+        }
-552
+    }
-553
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::StructureNamePunningOutput
-558
+{
     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_structure_name_punning::ser_structure_name_punning_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::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-565
+                        }
-566
+                    }
-567
+    }
-568
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::error::StructureNamePunningError
-573
+{
     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_structure_name_punning::ser_structure_name_punning_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::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-583
+            }
-584
+        }
-585
+    }
-586
+}
-587
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`ReservedWordsAsMembersInput`](crate::input::ReservedWordsAsMembersInput) using modelled bindings.
     pub struct ReservedWordsAsMembersInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ReservedWordsAsMembersInput, ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ReservedWordsAsMembersInput, ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError>> + Send>>
-593
+    }
-594
+}
-595
 impl std::future::Future for ReservedWordsAsMembersInputFuture {
     type Output = Result<
         crate::input::ReservedWordsAsMembersInput,
         ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError,
     >;
-601
     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)
-608
+    }
-609
+}
-610
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
         B,
     > for crate::input::ReservedWordsAsMembersInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-619
     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>,
-623
+{
     type Rejection = ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError;
     type Future = ReservedWordsAsMembersInputFuture;
-627
     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_X_AMZ_JSON_1_1,
             ) {
                 return Err(::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection::NotAcceptable);
-635
+            }
             crate::protocol_serde::shape_reserved_words_as_members::de_reserved_words_as_members_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::aws_json::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::aws_json::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e)
                     });
         ReservedWordsAsMembersInputFuture {
             inner: Box::pin(fut),
-646
+        }
-647
+    }
-648
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::output::ReservedWordsAsMembersOutput
-653
+{
     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_reserved_words_as_members::ser_reserved_words_as_members_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::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-660
+                        }
-661
+                    }
-662
+    }
-663
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::aws_json_11::AwsJson1_1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1,
     > for crate::error::ReservedWordsAsMembersError
-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_reserved_words_as_members::ser_reserved_words_as_members_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::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::aws_json_11::AwsJson1_1>::into_response(::aws_smithy_legacy_http_server::protocol::aws_json::runtime_error::RuntimeError::from(e))
-678
+            }
-679
+        }
-680
+    }
-681
+}

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

@@ -1,1 +189,209 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(missing_docs)] // documentation missing in model
 pub struct RpcEcho;
-4
 impl ::aws_smithy_http_server::operation::OperationShape for RpcEcho {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new("crate#RPCEcho", "crate", "RPCEcho");
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for RpcEcho {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "crate#RPCEcho",
             "crate",
             "RPCEcho",
         );
-12
     type Input = crate::input::RpcEchoInput;
     type Output = crate::output::RpcEchoOutput;
     type Error = crate::error::RPCEchoError;
-16
+}
-17
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for RpcEcho {
     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 RpcEcho {
     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
+}
-32
 #[allow(missing_docs)] // documentation missing in model
 pub struct Match;
-35
 impl ::aws_smithy_http_server::operation::OperationShape for Match {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new("crate#Match", "crate", "Match");
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for Match {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new("crate#Match", "crate", "Match");
-39
     type Input = crate::input::MatchInput;
     type Output = crate::output::MatchOutput;
     type Error = crate::error::MatchError;
-43
+}
-44
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for Match {
     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 Match {
     type RequestFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultRequestFmt;
     type ResponseFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultResponseFmt;
-50
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-53
+    }
-54
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-57
+    }
-58
+}
-59
 #[allow(missing_docs)] // documentation missing in model
 pub struct Option;
-62
 impl ::aws_smithy_http_server::operation::OperationShape for Option {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new("crate#Option", "crate", "Option");
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for Option {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new("crate#Option", "crate", "Option");
-66
     type Input = crate::input::OptionInput;
     type Output = crate::output::OptionOutput;
     type Error = crate::error::OptionError;
-70
+}
-71
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for Option {
     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 Option {
     type RequestFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultRequestFmt;
     type ResponseFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultResponseFmt;
-77
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-80
+    }
-81
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-84
+    }
-85
+}
-86
 #[allow(missing_docs)] // documentation missing in model
 pub struct Result;
-89
 impl ::aws_smithy_http_server::operation::OperationShape for Result {
     const ID: ::aws_smithy_http_server::shape_id::ShapeId =
         ::aws_smithy_http_server::shape_id::ShapeId::new("crate#Result", "crate", "Result");
 impl ::aws_smithy_legacy_http_server::operation::OperationShape for Result {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new("crate#Result", "crate", "Result");
-93
     type Input = crate::input::ResultInput;
     type Output = crate::output::ResultOutput;
     type Error = crate::error::ResultError;
-97
+}
-98
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for Result {
     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 Result {
     type RequestFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultRequestFmt;
     type ResponseFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultResponseFmt;
-104
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-107
+    }
-108
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-111
+    }
-112
+}
-113
 #[allow(missing_docs)] // documentation missing in model
 pub struct ErrCollisions;
-116
 impl ::aws_smithy_http_server::operation::OperationShape for ErrCollisions {
     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 ErrCollisions {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "crate#ErrCollisions",
             "crate",
             "ErrCollisions",
         );
-124
     type Input = crate::input::ErrCollisionsInput;
     type Output = crate::output::ErrCollisionsOutput;
     type Error = crate::error::ErrCollisionsError;
-128
+}
-129
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for ErrCollisions {
     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 ErrCollisions {
     type RequestFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultRequestFmt;
     type ResponseFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultResponseFmt;
-135
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-138
+    }
-139
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-142
+    }
-143
+}
-144
 #[allow(missing_docs)] // documentation missing in model
 pub struct StructureNamePunning;
-147
 impl ::aws_smithy_http_server::operation::OperationShape for StructureNamePunning {
     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 StructureNamePunning {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "crate#StructureNamePunning",
             "crate",
             "StructureNamePunning",
         );
-155
     type Input = crate::input::StructureNamePunningInput;
     type Output = crate::output::StructureNamePunningOutput;
     type Error = crate::error::StructureNamePunningError;
-159
+}
-160
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for StructureNamePunning {
     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 StructureNamePunning
-+
+{
     type RequestFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultRequestFmt;
     type ResponseFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultResponseFmt;
-168
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-171
+    }
-172
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-175
+    }
-176
+}
-177
 #[allow(missing_docs)] // documentation missing in model
 pub struct ReservedWordsAsMembers;
-180
 impl ::aws_smithy_http_server::operation::OperationShape for ReservedWordsAsMembers {
     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 ReservedWordsAsMembers {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "crate#ReservedWordsAsMembers",
             "crate",
             "ReservedWordsAsMembers",
         );
-188
     type Input = crate::input::ReservedWordsAsMembersInput;
     type Output = crate::output::ReservedWordsAsMembersOutput;
     type Error = crate::error::ReservedWordsAsMembersError;
-192
+}
-193
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity
     for ReservedWordsAsMembers
-196
+{
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::DefaultRequestFmt;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::DefaultResponseFmt;
     type RequestFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultRequestFmt;
     type ResponseFmt =
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::DefaultResponseFmt;
-201
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-204
+    }
-205
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-208
+    }
-209
+}

tmp-codegen-diff/codegen-server-test-python/naming_test_ops/rust-server-codegen-python/src/protocol_serde/shape_err_collisions.rs

@@ -1,1 +126,126 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_err_collisions_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::ErrCollisionsInput,
     ::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::err_collisions_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();
         input.build()
     })
-24
+}
-25
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_err_collisions_http_response(
     #[allow(unused_variables)] output: crate::output::ErrCollisionsOutput,
 ) -> 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 = "";
         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)?
     })
-53
+}
-54
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_err_collisions_http_error(
     error: &crate::error::ErrCollisionsError,
 ) -> 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::ErrCollisionsError::CollidingError(output) => {
                 let payload =
                     crate::protocol_serde::shape_colliding_error::ser_colliding_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(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-85
+            }
             crate::error::ErrCollisionsError::CollidingException(output) => {
                 let payload = crate::protocol_serde::shape_colliding_exception::ser_colliding_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/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(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-104
+            }
             crate::error::ErrCollisionsError::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))?
-123
+            }
-124
+        }
     })
-126
+}

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