Server Test Python

rev. d06a46cae0f385cdae37a9f8264db3469a090ab5 (ignoring whitespace)

Files changed:

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

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

 [package]
 name = "simple"
 version = "0.0.1"
 authors = ["protocoltest@example.com"]
 description = "test"
 edition = "2021"
-8
 [package.metadata.smithy]
 codegen-version = "ci"
 protocol = "aws.protocols#restJson1"
 [dependencies.aws-smithy-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 = "simple"
 crate-type = ["cdylib"]
-58
-59

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

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

↥ Expand context

 //! The primary entrypoint is [`SimpleService`]: 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 [`SimpleService::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 simple::{SimpleService, SimpleServiceConfig};

 //!
 //! # let app = SimpleService::builder(
 //! #     SimpleServiceConfig::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 simple::server::routing::LambdaHandler;
 //! use simple::SimpleService;
 //!
 //! # async fn dummy() {
 //! # let app = SimpleService::builder(
 //! #     SimpleServiceConfig::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let handler = LambdaHandler::new(app);
 //! lambda_http::run(handler).await.unwrap();
 //! # }
 //! ```
 //!
 //! # Building the SimpleService
 //!
 //! To construct [`SimpleService`] we use [`SimpleServiceBuilder`] returned by [`SimpleService::builder`].
 //!
 //! ## Plugins
 //!
 //! The [`SimpleService::builder`] method, returning [`SimpleServiceBuilder`],
 //! 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 simple::server::plugin::IdentityPlugin as LoggingPlugin;
 //! # use simple::server::plugin::IdentityPlugin as MetricsPlugin;
 //! # use ::hyper::Body;
 //! use simple::server::plugin::HttpPlugins;
 //! use simple::{SimpleService, SimpleServiceConfig, SimpleServiceBuilder};
 //!
 //! let http_plugins = HttpPlugins::new()
 //!         .push(LoggingPlugin)
 //!         .push(MetricsPlugin);
 //! let config = SimpleServiceConfig::builder().build();
 //! let builder: SimpleServiceBuilder<Body, _, _, _> = SimpleService::builder(config);
 //! let builder: SimpleServiceBuilder<::hyper::Body, _, _, _> = SimpleService::builder(config);
 //! ```
 //!
 //! Check out [`crate::server::plugin`] to learn more about plugins.
 //!
 //! ## Handlers
 //!
 //! [`SimpleServiceBuilder`] 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 simple::{SimpleService, SimpleServiceConfig};
 //!
 //! #[::tokio::main]
 //! pub async fn main() {
 //!    let config = SimpleServiceConfig::builder().build();
 //!    let app = SimpleService::builder(config)
 //!        .operation(operation)
 //!        .build()
 //!        .expect("failed to build an instance of SimpleService");
 //!
 //!    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 simple::{input, output, error};
 //!
 //! async fn operation(input: input::OperationInput) -> Result<output::OperationOutput, error::OperationError> {
 //!     todo!()
 //! }
 //!
 //! ```
 //!
 //! [`serve`]: https://docs.rs/hyper/0.14.16/hyper/server/struct.Builder.html#method.serve
 //! [hyper server]: https://docs.rs/hyper/0.14.26/hyper/server/index.html
 //! [`tower::make::MakeService`]: https://docs.rs/tower/latest/tower/make/trait.MakeService.html
 //! [HTTP binding traits]: https://smithy.io/2.0/spec/http-bindings.html
 //! [operations]: https://smithy.io/2.0/spec/service-types.html#operation
 //! [hyper server]: https://docs.rs/hyper/latest/hyper/server/index.html
 //! [Service]: https://docs.rs/tower-service/latest/tower_service/trait.Service.html
 pub use crate::service::{
     MissingOperationsError, SimpleService, SimpleServiceBuilder, SimpleServiceConfig,
     SimpleServiceConfigBuilder,
 };
-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/simple/rust-server-codegen-python/src/operation.rs

@@ -1,1 +99,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
     /// [`OperationInput`](crate::input::OperationInput) using modelled bindings.
     pub struct OperationInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::OperationInput, ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-7
+    }
-8
+}
-9
 impl std::future::Future for OperationInputFuture {
     type Output = Result<
         crate::input::OperationInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-15
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-22
+    }
-23
+}
-24
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::OperationInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-33
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-37
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = OperationInputFuture;
-41
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-49
+            }
             crate::protocol_serde::shape_operation::de_operation_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
--
+                )
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e)
                     });
         OperationInputFuture {
             inner: Box::pin(fut),
-59
+        }
-60
+    }
-61
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::OperationOutput
-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_operation::ser_operation_http_response(self) {
             Ok(response) => response,
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-73
+            }
-74
+        }
-75
+    }
-76
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::OperationError
-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_operation::ser_operation_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                     ::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(
                         self.name(),
                     ),
                 );
                 response
-91
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-95
+            }
-96
+        }
-97
+    }
-98
+}

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(missing_docs)] // documentation missing in model
 pub struct Operation;
-4
 impl ::aws_smithy_http_server::operation::OperationShape for Operation {
     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 Operation {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.amazonaws.simple#Operation",
             "com.amazonaws.simple",
             "Operation",
         );
-12
     type Input = crate::input::OperationInput;
     type Output = crate::output::OperationOutput;
     type Error = crate::error::OperationError;
-16
+}
-17
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for Operation {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity for Operation {
     type RequestFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     type ResponseFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
     >;
-30
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-33
+    }
-34
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-37
+    }
-38
+}

tmp-codegen-diff/codegen-server-test-python/simple/rust-server-codegen-python/src/protocol_serde/shape_operation.rs

@@ -1,1 +127,127 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::OperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::operation_input_internal::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         let bytes = ::hyper::body::to_bytes(body).await?;
         if !bytes.is_empty() {
             ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(
             ::aws_smithy_legacy_http_server::protocol::content_type_header_classifier_smithy(
                 &headers,
                 Some("application/json"),
             )?;
             input = crate::protocol_serde::shape_operation::de_operation(bytes.as_ref(), input)?;
-29
+        }
         input.build()
     })
-32
+}
-33
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_operation_http_response(
     #[allow(unused_variables)] output: crate::output::OperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_operation_output::ser_operation_output_output_output(
                 &output,
             )?;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         let body = ::aws_smithy_legacy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-64
+}
-65
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_operation_http_error(
     error: &crate::error::OperationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::OperationError::InternalServerError(output) => {
                 let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "InternalServerError",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-98
+            }
-99
+        }
     })
-101
+}
-102
 pub(crate) fn de_operation(
     value: &[u8],
     mut builder: crate::input::operation_input_internal::Builder,
 ) -> ::std::result::Result<
     crate::input::operation_input_internal::Builder,

↧ Expand context

     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     let mut tokens_owned =
         ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value))
             .peekable();
     let tokens = &mut tokens_owned;
     ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
     loop {
         match tokens.next().transpose()? {
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 match key.to_unescaped()?.as_ref() {
                     "message" => {
                         builder = builder.set_message(
                             ::aws_smithy_json::deserialize::token::expect_string_or_null(
                                 tokens.next(),
                             )?
                             .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                             .transpose()?,
                         );

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

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

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

@@ -1,1 +634,647 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /// The service builder for [`SimpleService`].
 ///
 /// Constructed via [`SimpleService::builder`].
 pub struct SimpleServiceBuilder<Body, L, HttpPl, ModelPl> {
     operation: Option<::aws_smithy_http_server::routing::Route<Body>>,
     operation: Option<::aws_smithy_legacy_http_server::routing::Route<Body>>,
     layer: L,
     http_plugin: HttpPl,
     model_plugin: ModelPl,
-10
+}
-11
 impl<Body, L, HttpPl, ModelPl> SimpleServiceBuilder<Body, L, HttpPl, ModelPl> {
     /// Sets the [`Operation`](crate::operation_shape::Operation) 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 simple::{SimpleService, SimpleServiceConfig};
     ///
     /// use simple::{input, output, error};
     ///
     /// async fn handler(input: input::OperationInput) -> Result<output::OperationOutput, error::OperationError> {
     ///     todo!()
     /// }
     ///
     /// let config = SimpleServiceConfig::builder().build();
     /// let app = SimpleService::builder(config)
     ///     .operation(handler)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: SimpleService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: SimpleService<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn operation<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::Operation, HandlerExtractors>,
                         HandlerType: ::aws_smithy_legacy_http_server::operation::Handler<crate::operation_shape::Operation, HandlerExtractors>,
-41
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             SimpleService<L>,
                             crate::operation_shape::Operation,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::Operation, HandlerType>
                             ::aws_smithy_legacy_http_server::operation::IntoService<crate::operation_shape::Operation, 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<
                             SimpleService<L>,
                             crate::operation_shape::Operation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             SimpleService<L>,
                             crate::operation_shape::Operation,
-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<
                                     SimpleService<L>,
                                     crate::operation_shape::Operation,
                                     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::Operation::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.operation_custom(svc)
-78
+    }
-79
     /// Sets the [`Operation`](crate::operation_shape::Operation) 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 simple::{SimpleService, SimpleServiceConfig};
     ///
     /// use simple::{input, output, error};
     ///
     /// async fn handler(input: input::OperationInput) -> Result<output::OperationOutput, error::OperationError> {
     ///     todo!()
     /// }
     ///
     /// let config = SimpleServiceConfig::builder().build();
     /// let svc = ::tower::util::service_fn(handler);
     /// let app = SimpleService::builder(config)
     ///     .operation_service(svc)
     ///     /* Set other handlers */
     ///     .build()
     ///     .unwrap();
     /// # let app: SimpleService<::aws_smithy_http_server::routing::RoutingService<::aws_smithy_http_server::protocol::rest::router::RestRouter<::aws_smithy_http_server::routing::Route>, ::aws_smithy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// # let app: SimpleService<::aws_smithy_legacy_http_server::routing::RoutingService<::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<::aws_smithy_legacy_http_server::routing::Route>, ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>> = app;
     /// ```
     ///
                     pub fn operation_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::Operation, ServiceExtractors>,
                         S: ::aws_smithy_legacy_http_server::operation::OperationService<crate::operation_shape::Operation, ServiceExtractors>,
-109
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                         ModelPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             SimpleService<L>,
                             crate::operation_shape::Operation,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::Operation, S>
                             ::aws_smithy_legacy_http_server::operation::Normalize<crate::operation_shape::Operation, 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<
                             SimpleService<L>,
                             crate::operation_shape::Operation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                         HttpPl: ::aws_smithy_legacy_http_server::plugin::Plugin<
                             SimpleService<L>,
                             crate::operation_shape::Operation,
-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<
                                     SimpleService<L>,
                                     crate::operation_shape::Operation,
                                     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::Operation::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.operation_custom(svc)
-146
+    }
-147
     /// Sets the [`Operation`](crate::operation_shape::Operation) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn operation_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.operation = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self.operation = Some(::aws_smithy_legacy_http_server::routing::Route::new(svc));
         self
-163
+    }
-164
+}
-165
 impl<Body, L, HttpPl, ModelPl> SimpleServiceBuilder<Body, L, HttpPl, ModelPl> {
     /// Constructs a [`SimpleService`] from the arguments provided to the builder.
     ///
     /// Forgetting to register a handler for one or more operations will result in an error.
     ///
     /// Check out [`SimpleServiceBuilder::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<
         SimpleService<
             ::aws_smithy_http_server::routing::RoutingService<
                 ::aws_smithy_http_server::protocol::rest::router::RestRouter<L::Service>,
                 ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
             ::aws_smithy_legacy_http_server::routing::RoutingService<
                 ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<L::Service>,
                 ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
             >,
         >,
         MissingOperationsError,
-183
+    >
     where
         L: ::tower::Layer<::aws_smithy_http_server::routing::Route<Body>>,
         L: ::tower::Layer<::aws_smithy_legacy_http_server::routing::Route<Body>>,
-186
+    {
         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.operation.is_none() {
                 missing_operation_names
                     .insert(crate::operation_shape::Operation::ID, ".operation()");
-193
+            }
             if !missing_operation_names.is_empty() {
                 return Err(MissingOperationsError {
                     operation_names2setter_methods: missing_operation_names,
                 });
-198
+            }
             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";
-200
             ::aws_smithy_http_server::protocol::rest::router::RestRouter::from_iter([(
             ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter::from_iter([(
                 request_specs::operation(),
                 self.operation.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(SimpleService { svc })
-209
+    }
-210
     /// Constructs a [`SimpleService`] from the arguments provided to the builder.
     /// Operations without a handler default to returning 500 Internal Server Error to the caller.
     ///
     /// Check out [`SimpleServiceBuilder::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) -> SimpleService<L::Service>
     where
         Body: Send + 'static,
         L: ::tower::Layer<
             ::aws_smithy_http_server::routing::RoutingService<
                 ::aws_smithy_http_server::protocol::rest::router::RestRouter<
                     ::aws_smithy_http_server::routing::Route<Body>,
             ::aws_smithy_legacy_http_server::routing::RoutingService<
                 ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<
                     ::aws_smithy_legacy_http_server::routing::Route<Body>,
                 >,
                 ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
                 ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
             >,
         >,
-227
+    {
         let router = ::aws_smithy_http_server::protocol::rest::router::RestRouter::from_iter([(
         let router =
             ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter::from_iter([(
                 request_specs::operation(),
                 self.operation.unwrap_or_else(|| {
                 let svc = ::aws_smithy_http_server::operation::MissingFailure::<
                     ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
                     let svc = ::aws_smithy_legacy_http_server::operation::MissingFailure::<
                         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
                     >::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));
         SimpleService { svc }
-242
+    }
-243
+}
-244
 /// The error encountered when calling the [`SimpleServiceBuilder::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>,
-251
+}
-252
 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 `SimpleService`.\n\
                             We are missing handlers for the following operations:\n",
         )?;
         for operation_name in self.operation_names2setter_methods.keys() {
             writeln!(f, "- {}", operation_name.absolute())?;
-262
+        }
-263
         writeln!(f, "\nUse the dedicated methods on `SimpleServiceBuilder` to register the missing handlers:")?;
         for setter_name in self.operation_names2setter_methods.values() {
             writeln!(f, "- {}", setter_name)?;
-267
+        }
         Ok(())
-269
+    }
-270
+}
-271
 impl std::error::Error for MissingOperationsError {}
-273
 mod request_specs {
     pub(super) fn operation() -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
     pub(super) fn operation() -> ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec
-+
+    {
         ::aws_smithy_legacy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::POST,
                     ::aws_smithy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Literal(String::from("operation")),
                     ::aws_smithy_legacy_http_server::routing::request_spec::UriSpec::new(
                         ::aws_smithy_legacy_http_server::routing::request_spec::PathAndQuerySpec::new(
                             ::aws_smithy_legacy_http_server::routing::request_spec::PathSpec::from_vector_unchecked(vec![
     ::aws_smithy_legacy_http_server::routing::request_spec::PathSegment::Literal(String::from("operation")),
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
                             ::aws_smithy_legacy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-286
+                        )
                     ),
-288
+                )
-289
+    }
-290
+}
-291
 #[allow(missing_docs)] // documentation missing in model
 ///
 /// See the [root](crate) documentation for more information.
 #[derive(Clone)]
 pub struct SimpleService<
     S = ::aws_smithy_http_server::routing::RoutingService<
         ::aws_smithy_http_server::protocol::rest::router::RestRouter<
             ::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::rest::router::RestRouter<
             ::aws_smithy_legacy_http_server::routing::Route<
                 ::aws_smithy_legacy_http_server::body::BoxBody,
             >,
         >,
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     >,
 > {
     // This is the router wrapped by layers.
     svc: S,
-308
+}
-309
 impl SimpleService<()> {
     /// Constructs a builder for [`SimpleService`].
     /// 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: SimpleServiceConfig<L, HttpPl, ModelPl>,
     ) -> SimpleServiceBuilder<Body, L, HttpPl, ModelPl> {
         SimpleServiceBuilder {
             operation: None,
             layer: config.layers,
             http_plugin: config.http_plugins,
             model_plugin: config.model_plugins,
-327
+        }
-328
+    }
-329
     /// Constructs a builder for [`SimpleService`].
     /// You must specify what plugins should be applied to the operations in this service.
     ///
     /// Use [`SimpleService::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 `SimpleServiceConfig` 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,
     ) -> SimpleServiceBuilder<Body, ::tower::layer::util::Identity, HttpPl, ModelPl> {
         SimpleServiceBuilder {
             operation: None,
             layer: ::tower::layer::util::Identity::new(),
             http_plugin,
             model_plugin,
-355
+        }
-356
+    }
-357
     /// Constructs a builder for [`SimpleService`].
     ///
     /// Use [`SimpleService::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>() -> SimpleServiceBuilder<
         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,
-374
+        )
-375
+    }
-376
+}
-377
 impl<S> SimpleService<S> {
     /// Converts [`SimpleService`] 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)
-384
+    }
-385
     /// Converts [`SimpleService`] into a [`MakeService`](tower::make::MakeService) with [`ConnectInfo`](::aws_smithy_http_server::request::connect_info::ConnectInfo).
     /// Converts [`SimpleService`] 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)
-391
+    }
-392
+}
-393
 impl<S>
     SimpleService<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::rest::router::RestRouter<S>,
             ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         ::aws_smithy_legacy_http_server::routing::RoutingService<
             ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<S>,
             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         >,
-400
+    >
-401
+{
     /// Applies a [`Layer`](::tower::Layer) uniformly to all routes.
     #[deprecated(
         since = "0.57.0",
         note = "please add layers to the `SimpleServiceConfig` object instead; see https://github.com/smithy-lang/smithy-rs/discussions/3096"
     )]
     pub fn layer<L>(
         self,
         layer: &L,
     ) -> SimpleService<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::rest::router::RestRouter<L::Service>,
             ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
         ::aws_smithy_legacy_http_server::routing::RoutingService<
             ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<L::Service>,
             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         >,
-415
+    >
     where
         L: ::tower::Layer<S>,
-418
+    {
         SimpleService {
             svc: self.svc.map(|s| s.layer(layer)),
-421
+        }
-422
+    }
-423
     /// 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,
     ) -> SimpleService<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::rest::router::RestRouter<
                 ::aws_smithy_http_server::routing::Route<B>,
         ::aws_smithy_legacy_http_server::routing::RoutingService<
             ::aws_smithy_legacy_http_server::protocol::rest::router::RestRouter<
                 ::aws_smithy_legacy_http_server::routing::Route<B>,
             >,
             ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
             ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         >,
-436
+    >
     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,
-445
+    {
         self.layer(&::tower::layer::layer_fn(
             ::aws_smithy_http_server::routing::Route::new,
             ::aws_smithy_legacy_http_server::routing::Route::new,
         ))
-449
+    }
-450
+}
-451
 impl<S, R> ::tower::Service<R> for SimpleService<S>
 where
     S: ::tower::Service<R>,
-455
+{
     type Response = S::Response;
     type Error = S::Error;
     type Future = S::Future;
-459
     fn poll_ready(
         &mut self,
         cx: &mut std::task::Context,
     ) -> std::task::Poll<::std::result::Result<(), Self::Error>> {
         self.svc.poll_ready(cx)
-465
+    }
-466
     fn call(&mut self, request: R) -> Self::Future {
         self.svc.call(request)
-469
+    }
-470
+}
-471
 /// An enumeration of all [operations](https://smithy.io/2.0/spec/service-types.html#operation) in SimpleService.
 #[allow(clippy::enum_variant_names)]
 #[derive(Debug, PartialEq, Eq, Clone, Copy)]
 pub enum Operation {
     Operation,
-477
+}
-478
 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::Operation => ::aws_smithy_http_server::shape_id::ShapeId::new(
             Operation::Operation => ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
                 "com.amazonaws.simple#Operation",
                 "com.amazonaws.simple",
                 "Operation",
             ),
-488
+        }
-489
+    }
-490
+}
 impl<L> ::aws_smithy_http_server::service::ContainsOperation<crate::operation_shape::Operation>
 impl<L>
     ::aws_smithy_legacy_http_server::service::ContainsOperation<crate::operation_shape::Operation>
     for SimpleService<L>
-494
+{
     const VALUE: Operation = Operation::Operation;
-496
+}
-497
 impl<S> ::aws_smithy_http_server::service::ServiceShape for SimpleService<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 SimpleService<S> {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.amazonaws.simple#SimpleService",
             "com.amazonaws.simple",
             "SimpleService",
         );
-505
     const VERSION: Option<&'static str> = Some("");
-507
     type Protocol = ::aws_smithy_http_server::protocol::rest_json_1::RestJson1;
     type Protocol = ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1;
-509
     type Operations = Operation;
-511
+}
 /// Configuration for the [`SimpleService`]. This is the central place where to register and
 /// configure [`::tower::Layer`]s, HTTP plugins, and model plugins.
 ///
 /// ```rust,no_run
 /// # use simple::SimpleServiceConfig;
 /// # 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 = SimpleServiceConfig::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 SimpleServiceConfig<L, H, M> {
     layers: L,
     http_plugins: H,
     model_plugins: M,
-540
+}
-541
 impl SimpleServiceConfig<(), (), ()> {
     /// Returns a builder to construct the configuration.
     pub fn builder() -> SimpleServiceConfigBuilder<
         ::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,
     > {
         SimpleServiceConfigBuilder {
             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,
-553
+        }
-554
+    }
-555
+}
-556
 /// Builder returned by [`SimpleServiceConfig::builder()`].
 #[derive(::std::fmt::Debug)]
 pub struct SimpleServiceConfigBuilder<L, H, M> {
     pub(crate) layers: L,
     pub(crate) http_plugins: H,
     pub(crate) model_plugins: M,
-563
+}
-564
 impl<L, H, M> SimpleServiceConfigBuilder<L, H, M> {
     /// Add a [`::tower::Layer`] to the service.
     pub fn layer<NewLayer>(
         self,
         layer: NewLayer,
     ) -> SimpleServiceConfigBuilder<::tower::layer::util::Stack<NewLayer, L>, H, M> {
         SimpleServiceConfigBuilder {
             layers: ::tower::layer::util::Stack::new(layer, self.layers),
             http_plugins: self.http_plugins,
             model_plugins: self.model_plugins,
-575
+        }
-576
+    }
-577
     /// 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,
     ) -> SimpleServiceConfigBuilder<L, ::aws_smithy_http_server::plugin::PluginStack<NewPlugin, H>, M>
--
+    {
     ) -> SimpleServiceConfigBuilder<
         L,
         ::aws_smithy_legacy_http_server::plugin::PluginStack<NewPlugin, H>,
         M,
     > {
         SimpleServiceConfigBuilder {
             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,
-598
+        }
-599
+    }
-600
     /// 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,
     ) -> SimpleServiceConfigBuilder<L, H, ::aws_smithy_http_server::plugin::PluginStack<NewPlugin, M>>
--
+    {
     ) -> SimpleServiceConfigBuilder<
         L,
         H,
         ::aws_smithy_legacy_http_server::plugin::PluginStack<NewPlugin, M>,
     > {
         SimpleServiceConfigBuilder {
             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,
             ),
-621
+        }
-622
+    }
-623
     /// Build the configuration.
     pub fn build(self) -> super::SimpleServiceConfig<L, H, M> {
         super::SimpleServiceConfig {
             layers: self.layers,

↧ Expand context

             http_plugins: self.http_plugins,
             model_plugins: self.model_plugins,
-630
+        }
-631
+    }
-632
+}
 /// 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 [`Operation`], excluding all other operations.
 ///     struct ScopeA {
 ///         includes: [Operation]
 ///     }
 /// }
 ///

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

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

↥ Expand context

 [package]
 name = "unique_items"
 version = "0.0.1"
 authors = ["protocoltest@example.com"]
 description = "test"
 edition = "2021"
-8
 [package.metadata.smithy]
 codegen-version = "ci"
 protocol = "aws.protocols#restJson1"
 [dependencies.aws-smithy-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 = "unique_items"
 crate-type = ["cdylib"]
-58
-59

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

@@ -78,78 +138,138 @@

↥ Expand context

         Set(crate::model::simple_set_internal::ConstraintViolation),
         /// Constraint violation occurred building member `complex_set` when building `MalformedUniqueItemsInput`.
         #[doc(hidden)]
         ComplexSet(crate::model::complex_set_internal::ConstraintViolation),
-82
+    }
     impl ::std::fmt::Display for ConstraintViolation {
         fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
             match self {
                 ConstraintViolation::Set(_) => write!(f, "constraint violation occurred building member `set` when building `MalformedUniqueItemsInput`"),
                 ConstraintViolation::ComplexSet(_) => write!(f, "constraint violation occurred building member `complex_set` when building `MalformedUniqueItemsInput`"),
-88
+            }
-89
+        }
-90
+    }
     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::Set(inner) => {
                     inner.as_validation_exception_field(path + "/set")
-100
+                }
                 ConstraintViolation::ComplexSet(inner) => {
                     inner.as_validation_exception_field(path + "/complexSet")
-103
+                }
-104
+            }
-105
+        }
-106
+    }
     impl ::std::convert::From<ConstraintViolation>
         for ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection
         for ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection
-109
+    {
         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")
-123
+                            )
-124
+        }
-125
+    }
     impl ::std::convert::From<Builder>
         for crate::constrained::MaybeConstrained<crate::input::MalformedUniqueItemsInput>
-128
+    {
         fn from(builder: Builder) -> Self {
             Self::Unconstrained(builder)
-131
+        }
-132
+    }
     impl ::std::convert::TryFrom<Builder> for crate::input::MalformedUniqueItemsInput {
         type Error = ConstraintViolation;
-135
         fn try_from(builder: Builder) -> ::std::result::Result<Self, Self::Error> {
             builder.build()
-138
+        }

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

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

↥ Expand context

 //! The primary entrypoint is [`UniqueItemsService`]: 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 [`UniqueItemsService::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 unique_items::{UniqueItemsService, UniqueItemsServiceConfig};

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

↥ Expand context

 //! use unique_items::{UniqueItemsService, UniqueItemsServiceConfig};
 //!
 //! #[::tokio::main]
 //! pub async fn main() {
 //!    let config = UniqueItemsServiceConfig::builder().build();
 //!    let app = UniqueItemsService::builder(config)
 //!        .malformed_unique_items(malformed_unique_items)
 //!        .build()
 //!        .expect("failed to build an instance of UniqueItemsService");
 //!
 //!    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 unique_items::{input, output, error};
 //!
 //! async fn malformed_unique_items(input: input::MalformedUniqueItemsInput) -> Result<output::MalformedUniqueItemsOutput, error::MalformedUniqueItemsError> {
 //!     todo!()
 //! }
 //!
 //! ```
 //!
 //! [`serve`]: https://docs.rs/hyper/0.14.16/hyper/server/struct.Builder.html#method.serve
 //! [hyper server]: https://docs.rs/hyper/0.14.26/hyper/server/index.html
 //! [`tower::make::MakeService`]: https://docs.rs/tower/latest/tower/make/trait.MakeService.html
 //! [HTTP binding traits]: https://smithy.io/2.0/spec/http-bindings.html
 //! [operations]: https://smithy.io/2.0/spec/service-types.html#operation
 //! [hyper server]: https://docs.rs/hyper/latest/hyper/server/index.html
 //! [Service]: https://docs.rs/tower-service/latest/tower_service/trait.Service.html
 pub use crate::service::{
     MissingOperationsError, UniqueItemsService, UniqueItemsServiceBuilder,
     UniqueItemsServiceConfig, UniqueItemsServiceConfigBuilder,
 };
-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
 /// Data structures used by operation inputs/outputs. Documentation on these types is copied from the model.
 pub mod model;
-222
 /// All operations that this crate can perform.
 pub mod operation;
-225
 /// 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;
-234
 /// Output structures for operations. Documentation on these types is copied from the model.
 pub mod output;
-237
 /// Export PyO3 symbols in the shared library
 pub mod python_module_export;
-240
 /// Operation adapters that delegate to Python handlers.

↧ Expand context

 pub mod python_operation_adaptor;
-243
 /// Python server and application implementation.
 pub mod python_server_application;
-246
 mod service;
-248
 /// Data primitives referenced by other data types.
 pub mod types;
-251
 /// Unconstrained types for constrained shapes.
 mod unconstrained;
-254
 /// Constrained types for constrained shapes.
 mod constrained;
-257
 mod mimes;
-259
 pub(crate) mod protocol_serde;
-261

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

@@ -1,1 +98,95 @@

 // 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
     /// [`MalformedUniqueItemsInput`](crate::input::MalformedUniqueItemsInput) using modelled bindings.
     pub struct MalformedUniqueItemsInputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedUniqueItemsInput, ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::MalformedUniqueItemsInput, ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError>> + Send>>
-7
+    }
-8
+}
-9
 impl std::future::Future for MalformedUniqueItemsInputFuture {
     type Output = Result<
         crate::input::MalformedUniqueItemsInput,
         ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError,
     >;
-15
     fn poll(
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Self::Output> {
         let this = self.project();
         this.inner.as_mut().poll(cx)
-22
+    }
-23
+}
-24
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::request::FromRequest<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
         B,
     > for crate::input::MalformedUniqueItemsInput
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B: 'static,
-33
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-37
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Rejection =
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError;
     type Future = MalformedUniqueItemsInputFuture;
-41
     fn from_request(request: ::http::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
             if !::aws_smithy_legacy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_JSON,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
                 return Err(::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection::NotAcceptable);
-49
+            }
             crate::protocol_serde::shape_malformed_unique_items::de_malformed_unique_items_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
         let fut = fut.map_err(|e: ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection| {
                         ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(
                     e,
--
+                )
             },
         );
                         ::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e)
                     });
         MalformedUniqueItemsInputFuture {
             inner: Box::pin(fut),
-60
+        }
-61
+    }
-62
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::output::MalformedUniqueItemsOutput
-67
+{
     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_malformed_unique_items::ser_malformed_unique_items_http_response(self) {
                         Ok(response) => response,
                         Err(e) => {
                             ::tracing::error!(error = %e, "failed to serialize response");
                             ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                             ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-74
+                        }
-75
+                    }
-76
+    }
-77
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_json_1::RestJson1,
     ::aws_smithy_legacy_http_server::response::IntoResponse<
         ::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1,
     > for crate::error::MalformedUniqueItemsError
-82
+{
     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_malformed_unique_items::ser_malformed_unique_items_http_error(&self) {
             Ok(mut response) => {
                 response.extensions_mut().insert(::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response.extensions_mut().insert(::aws_smithy_legacy_http_server::extension::ModeledErrorExtension::new(self.name()));
                 response
             },
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<::aws_smithy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
                 ::aws_smithy_legacy_http_server::response::IntoResponse::<::aws_smithy_legacy_http_server::protocol::rest_json_1::RestJson1>::into_response(::aws_smithy_legacy_http_server::protocol::rest_json_1::runtime_error::RuntimeError::from(e))
-92
+            }
-93
+        }
-94
+    }
-95
+}

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

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(missing_docs)] // documentation missing in model
 pub struct MalformedUniqueItems;
-4
 impl ::aws_smithy_http_server::operation::OperationShape for MalformedUniqueItems {
     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 MalformedUniqueItems {
     const ID: ::aws_smithy_legacy_http_server::shape_id::ShapeId =
         ::aws_smithy_legacy_http_server::shape_id::ShapeId::new(
             "com.amazonaws.constraints#MalformedUniqueItems",
             "com.amazonaws.constraints",
             "MalformedUniqueItems",
         );
-12
     type Input = crate::input::MalformedUniqueItemsInput;
     type Output = crate::output::MalformedUniqueItemsOutput;
     type Error = crate::error::MalformedUniqueItemsError;
-16
+}
-17
 impl ::aws_smithy_http_server::instrumentation::sensitivity::Sensitivity for MalformedUniqueItems {
     type RequestFmt = ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_http_server::instrumentation::MakeIdentity,
 impl ::aws_smithy_legacy_http_server::instrumentation::sensitivity::Sensitivity
     for MalformedUniqueItems
-+
+{
     type RequestFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::uri::MakeUri<
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
             ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         >,
     >;
     type ResponseFmt = ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_http_server::instrumentation::MakeIdentity,
     type ResponseFmt = ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt<
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
         ::aws_smithy_legacy_http_server::instrumentation::MakeIdentity,
     >;
-32
     fn request_fmt() -> Self::RequestFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::RequestFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::RequestFmt::new()
-35
+    }
-36
     fn response_fmt() -> Self::ResponseFmt {
         ::aws_smithy_http_server::instrumentation::sensitivity::ResponseFmt::new()
         ::aws_smithy_legacy_http_server::instrumentation::sensitivity::ResponseFmt::new()
-39
+    }
-40
+}

tmp-codegen-diff/codegen-server-test-python/unique_items/rust-server-codegen-python/src/protocol_serde/shape_malformed_unique_items.rs

@@ -1,1 +151,151 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_malformed_unique_items_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::MalformedUniqueItemsInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: ::aws_smithy_legacy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::RequestRejection:
         From<<B as ::aws_smithy_legacy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::malformed_unique_items_input_internal::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         let bytes = ::hyper::body::to_bytes(body).await?;
         if !bytes.is_empty() {
             ::aws_smithy_http_server::protocol::content_type_header_classifier_smithy(
             ::aws_smithy_legacy_http_server::protocol::content_type_header_classifier_smithy(
                 &headers,
                 Some("application/json"),
             )?;
             input = crate::protocol_serde::shape_malformed_unique_items::de_malformed_unique_items(
                 bytes.as_ref(),
                 input,
             )?;
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_malformed_unique_items_http_response(
     #[allow(unused_variables)] output: crate::output::MalformedUniqueItemsOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/json",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload = "";
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
         builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         let body = ::aws_smithy_legacy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-64
+}
-65
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_malformed_unique_items_http_error(
     error: &crate::error::MalformedUniqueItemsError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
     ::aws_smithy_legacy_http_server::response::Response,
     ::aws_smithy_legacy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::MalformedUniqueItemsError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "ValidationException",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-98
+            }
             crate::error::MalformedUniqueItemsError::InternalServerError(output) => {
                 let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     "application/json",
                 );
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::HeaderName::from_static("x-amzn-errortype"),
                     "InternalServerError",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                 builder = ::aws_smithy_legacy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(500)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
                     .body(::aws_smithy_legacy_http_server::body::to_boxed(payload))?
-122
+            }
-123
+        }
     })
-125
+}
-126
 pub(crate) fn de_malformed_unique_items(
     value: &[u8],
     mut builder: crate::input::malformed_unique_items_input_internal::Builder,
 ) -> ::std::result::Result<
     crate::input::malformed_unique_items_input_internal::Builder,

↧ Expand context

     ::aws_smithy_json::deserialize::error::DeserializeError,
 > {
     let mut tokens_owned =
         ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value))
             .peekable();
     let tokens = &mut tokens_owned;
     ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
     loop {
         match tokens.next().transpose()? {
             Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
             Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                 match key.to_unescaped()?.as_ref() {
                     "complexSet" => {
                         builder = builder.set_complex_set(
                             crate::protocol_serde::shape_complex_set::de_complex_set(tokens)?,
                         );
-148
+                    }
                     "set" => {
                         builder = builder.set_set(
                             crate::protocol_serde::shape_simple_set::de_simple_set(tokens)?,

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