Server Test

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

@@ -19,19 +128,131 @@

 #![allow(rustdoc::invalid_html_tags)]
 #![forbid(unsafe_code)]
 #![cfg_attr(docsrs, feature(doc_cfg))]
 //! s3
-23
 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 //! A fast and customizable Rust implementation of the AmazonS3 Smithy service.
 //!
 //! # Using AmazonS3
 //!
 //! The primary entrypoint is [`AmazonS3`]: 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 [`AmazonS3::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 s3::{AmazonS3, AmazonS3Config};
 //! use s3::serve;
 //! use ::tokio::net::TcpListener;
 //!
 //! # let app = AmazonS3::builder(
 //! #     AmazonS3Config::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();
 //! let listener = TcpListener::bind(bind).await
 //!     .expect("failed to bind TCP listener");
 //! serve(listener, app.into_make_service()).await.unwrap();
 //! # }
 //! ```
 //!
 //! ### Running on Lambda
 //!
 //! ```rust,ignore
 //! use s3::server::routing::LambdaHandler;
 //! use s3::AmazonS3;
 //!
 //! # async fn dummy() {
 //! # let app = AmazonS3::builder(
 //! #     AmazonS3Config::builder()
 //! #         .build()
 //! # ).build_unchecked();
 //! let handler = LambdaHandler::new(app);
 //! lambda_http::run(handler).await.unwrap();
 //! # }
 //! ```
 //!
 //! # Building the AmazonS3
 //!
 //! To construct [`AmazonS3`] we use [`AmazonS3Builder`] returned by [`AmazonS3::builder`].
 //!
 //! ## Plugins
 //!
 //! The [`AmazonS3::builder`] method, returning [`AmazonS3Builder`],
 //! 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 s3::server::plugin::IdentityPlugin as LoggingPlugin;
 //! # use s3::server::plugin::IdentityPlugin as MetricsPlugin;
 //! # use ::hyper::Body;
 //! # use ::hyper::body::Incoming;
 //! use s3::server::plugin::HttpPlugins;
 //! use s3::{AmazonS3, AmazonS3Config, AmazonS3Builder};
 //!
 //! let http_plugins = HttpPlugins::new()
 //!         .push(LoggingPlugin)
 //!         .push(MetricsPlugin);
 //! let config = AmazonS3Config::builder().build();
 //! let builder: AmazonS3Builder<Body, _, _, _> = AmazonS3::builder(config);
 //! let builder: AmazonS3Builder<::hyper::body::Incoming, _, _, _> = AmazonS3::builder(config);
 //! ```
 //!
 //! Check out [`crate::server::plugin`] to learn more about plugins.
 //!
 //! ## Handlers
 //!
 //! [`AmazonS3Builder`] 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;

@@ -135,138 +243,250 @@

↥ Expand context

 //!
 //! async fn handler_with_one_extractor(input: Input, ext: Extension<State>) -> Output {
 //!     todo!()
 //! }
 //!
 //! async fn handler_with_two_extractors(
 //!     input: Input,
 //!     ext0: Extension<State>,
 //!     ext1: ConnectInfo<SocketAddr>,
 //! ) -> Output {
 //!     todo!()
 //! }
 //! ```
 //!
 //! See the [`operation module`](crate::operation) for information on precisely what constitutes a handler.
 //!
 //! ## Build
 //!
 //! You can convert [`AmazonS3Builder`] into [`AmazonS3`] using either [`AmazonS3Builder::build`] or [`AmazonS3Builder::build_unchecked`].
 //!

 //! [`AmazonS3Builder::build`] requires you to provide a handler for every single operation in your Smithy model. It will return an error if that is not the case.
 //!
 //! [`AmazonS3Builder::build_unchecked`], instead, does not require exhaustiveness. The server will automatically return 500 Internal Server Error to all requests for operations that do not have a registered handler.
 //! [`AmazonS3Builder::build_unchecked`] is particularly useful if you are deploying your Smithy service as a collection of Lambda functions, where each Lambda is only responsible for a subset of the operations in the Smithy service (or even a single one!).
 //!
 //! # Example
 //!
 //! ```rust,no_run
 //! # use std::net::SocketAddr;
 //! use s3::{AmazonS3, AmazonS3Config};
 //! use s3::serve;
 //! use ::tokio::net::TcpListener;
 //!
 //! #[::tokio::main]
 //! pub async fn main() {
 //!    let config = AmazonS3Config::builder().build();
 //!    let app = AmazonS3::builder(config)
 //!        .delete_object_tagging(delete_object_tagging)
 //!        .get_bucket_location(get_bucket_location)
 //!        .get_object(get_object)
 //!        .list_objects_v2(list_objects_v2)
 //!        .build()
 //!        .expect("failed to build an instance of AmazonS3");
 //!
 //!    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 listener = TcpListener::bind(bind).await
 //!        .expect("failed to bind TCP listener");
 //!    # let server = async { Ok::<_, ()>(()) };
 //!
 //!    // Run your service!
 //!    if let Err(err) = server.await {
 //!    if let Err(err) = serve(listener, app.into_make_service()).await {
 //!        eprintln!("server error: {:?}", err);
 //!    }
 //! }
 //!
 //! use s3::{input, output, error};
 //!
 //! async fn delete_object_tagging(input: input::DeleteObjectTaggingInput) -> Result<output::DeleteObjectTaggingOutput, error::DeleteObjectTaggingError> {
 //!     todo!()
 //! }
 //!
 //! async fn get_bucket_location(input: input::GetBucketLocationInput) -> Result<output::GetBucketLocationOutput, error::GetBucketLocationError> {
 //!     todo!()
 //! }
 //!
 //! async fn get_object(input: input::GetObjectInput) -> Result<output::GetObjectOutput, error::GetObjectError> {
 //!     todo!()
 //! }
 //!
 //! async fn list_objects_v2(input: input::ListObjectsV2Input) -> Result<output::ListObjectsV2Output, error::ListObjectsV2Error> {
 //!     todo!()
 //! }
 //!
 //! ```
 //!
 //! [`serve`]: https://docs.rs/hyper/0.14.16/hyper/server/struct.Builder.html#method.serve
 //! [`serve`]: crate::serve
 //! [hyper server]: https://docs.rs/hyper/latest/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::server::serve::serve;
 pub use crate::service::{
     AmazonS3, AmazonS3Builder, AmazonS3Config, AmazonS3ConfigBuilder, MissingOperationsError,
 };
-224
 /// 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::*;
-229
+}
-230

↧ Expand context

 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-233
 /// All error types that operations can return. Documentation on these types is copied from the model.
 pub mod error;
-236
 /// Input structures for operations. Documentation on these types is copied from the model.
 pub mod input;
-239
 /// Data structures used by operation inputs/outputs. Documentation on these types is copied from the model.
 pub mod model;
-242
 /// All operations that this crate can perform.
 pub mod operation;
-245
 /// A collection of types representing each operation defined in the service closure.
 ///
 /// The [plugin system](::aws_smithy_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

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

@@ -11,11 +71,71 @@

↥ Expand context

     type Output = Result<
         crate::input::GetObjectInput,
         ::aws_smithy_http_server::protocol::rest_xml::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_xml::RestXml,
         B,
     > for crate::input::GetObjectInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-33
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-37
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError;
     type Future = GetObjectInputFuture;
-40
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             crate::protocol_serde::shape_get_object::de_get_object_http_request(request).await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError::from(e)
             },
         );

↧ Expand context

         GetObjectInputFuture {
             inner: Box::pin(fut),
-54
+        }
-55
+    }
-56
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_xml::RestXml,
     > for crate::output::GetObjectOutput
-61
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_get_object::ser_get_object_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_xml::RestXml,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError::from(
                         e,

@@ -114,114 +174,174 @@

↥ Expand context

     type Output = Result<
         crate::input::DeleteObjectTaggingInput,
         ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError,
     >;
-118
     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)
-125
+    }
-126
+}
-127
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_xml::RestXml,
         B,
     > for crate::input::DeleteObjectTaggingInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-136
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-140
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError;
     type Future = DeleteObjectTaggingInputFuture;
-143
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             crate::protocol_serde::shape_delete_object_tagging::de_delete_object_tagging_http_request(request)
                             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError::from(e)
             },

↧ Expand context

         );
         DeleteObjectTaggingInputFuture {
             inner: Box::pin(fut),
-158
+        }
-159
+    }
-160
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_xml::RestXml,
     > for crate::output::DeleteObjectTaggingOutput
-165
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_delete_object_tagging::ser_delete_object_tagging_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_xml::RestXml>::into_response(::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError::from(e))
-172
+                        }
-173
+                    }
-174
+    }

@@ -204,204 +264,264 @@

↥ Expand context

     type Output = Result<
         crate::input::GetBucketLocationInput,
         ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError,
     >;
-208
     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)
-215
+    }
-216
+}
-217
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_xml::RestXml,
         B,
     > for crate::input::GetBucketLocationInput
 where

     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-226
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-230
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError;
     type Future = GetBucketLocationInputFuture;
-233
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_XML,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection::NotAcceptable);
-241
+            }
             crate::protocol_serde::shape_get_bucket_location::de_get_bucket_location_http_request(
                 request,
-244
+            )

↧ Expand context

             .await
         };
         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError::from(e)
             },
         );
         GetBucketLocationInputFuture {
             inner: Box::pin(fut),
-256
+        }
-257
+    }
-258
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_xml::RestXml,
     > for crate::output::GetBucketLocationOutput
-263
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {

@@ -295,295 +406,410 @@

↥ Expand context

                         e,
                     ),
-297
+                )
-298
+            }
-299
+        }
-300
+    }
-301
+}
-302
 #[allow(unreachable_code, unused_variables)]
 #[cfg(test)]
 mod get_bucket_location_test {
-306
     /// S3 clients should use the @s3UnwrappedXmlOutput trait to determine
     /// that the response shape is not wrapped in a restxml operation-level XML node.
     ///
     /// Test ID: GetBucketLocationUnwrappedOutput
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn get_bucket_location_unwrapped_output_response() {

         let output = crate::output::GetBucketLocationOutput {
             location_constraint: ::std::option::Option::Some(
                 "us-west-2"
                     .parse::<crate::model::BucketLocationConstraint>()
                     .expect("static value validated to member"),
             ),
         };
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(200).expect("invalid expected HTTP status code"),
             ::http_1x::StatusCode::from_u16(200).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let body = ::hyper::body::to_bytes(http_response.into_body())
         use ::http_body_util::BodyExt;
         let body = http_response
             .into_body()
             .collect()
             .await
             .expect("unable to extract body to bytes");
             .expect("unable to collect body")
             .to_bytes();
         ::aws_smithy_protocol_test::assert_ok(
         ::aws_smithy_protocol_test::validate_body(&body, "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<LocationConstraint xmlns=\"http://s3.amazonaws.com/doc/2006-03-01/\">us-west-2</LocationConstraint>", ::aws_smithy_protocol_test::MediaType::from("unknown"))
         );
-338
+    }
-339
+}
-340
 ::pin_project_lite::pin_project! {
     /// A [`Future`](std::future::Future) aggregating the body bytes of a [`Request`] and constructing the
     /// [`ListObjectsV2Input`](crate::input::ListObjectsV2Input) using modelled bindings.
     pub struct ListObjectsV2InputFuture {
         inner: std::pin::Pin<Box<dyn std::future::Future<Output = Result<crate::input::ListObjectsV2Input, ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError>> + Send>>
-346
+    }
-347
+}
-348
 impl std::future::Future for ListObjectsV2InputFuture {
     type Output = Result<
         crate::input::ListObjectsV2Input,
         ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError,
     >;
-354
     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)
-361
+    }
-362
+}
-363
 impl<B>
     ::aws_smithy_http_server::request::FromRequest<
         ::aws_smithy_http_server::protocol::rest_xml::RestXml,
         B,
     > for crate::input::ListObjectsV2Input
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: 'static,
-372
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-376
+{
     type Rejection = ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError;
     type Future = ListObjectsV2InputFuture;
-379
     fn from_request(request: ::http::Request<B>) -> Self::Future {
     fn from_request(request: ::http_1x::Request<B>) -> Self::Future {
         let fut = async move {
             if !::aws_smithy_http_server::protocol::accept_header_classifier(
                 request.headers(),
                 &crate::mimes::CONTENT_TYPE_APPLICATION_XML,
             ) {
                 return Err(::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection::NotAcceptable);
-387
+            }
             crate::protocol_serde::shape_list_objects_v2::de_list_objects_v2_http_request(request)
                 .await
         };

↧ Expand context

         use ::futures_util::future::TryFutureExt;
         let fut = fut.map_err(
             |e: ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection| {
                 ::tracing::debug!(error = %e, "failed to deserialize request");
                 ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError::from(e)
             },
         );
         ListObjectsV2InputFuture {
             inner: Box::pin(fut),
-400
+        }
-401
+    }
-402
+}
 impl
     ::aws_smithy_http_server::response::IntoResponse<
         ::aws_smithy_http_server::protocol::rest_xml::RestXml,
     > for crate::output::ListObjectsV2Output
-407
+{
     fn into_response(self) -> ::aws_smithy_http_server::response::Response {
         match crate::protocol_serde::shape_list_objects_v2::ser_list_objects_v2_http_response(self)
-410
+        {

@@ -429,433 +974,1017 @@

↥ Expand context

                 response.extensions_mut().insert(
                     ::aws_smithy_http_server::extension::ModeledErrorExtension::new(self.name()),
                 );
                 response
-437
+            }
             Err(e) => {
                 ::tracing::error!(error = %e, "failed to serialize response");
                 ::aws_smithy_http_server::response::IntoResponse::<
                     ::aws_smithy_http_server::protocol::rest_xml::RestXml,
                 >::into_response(
                     ::aws_smithy_http_server::protocol::rest_xml::runtime_error::RuntimeError::from(
                         e,
                     ),
-446
+                )
-447
+            }
-448
+        }
-449
+    }
-450
+}
-451
 #[allow(unreachable_code, unused_variables)]

 #[cfg(test)]
 mod list_objects_v2_test {
-455
     /// S3 clients should map the default addressing style to virtual host.
     /// Test ID: S3DefaultAddressing
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn s3_default_addressing_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
         let mut http_request = ::http_1x::Request::builder()
             .uri("/")
             .method("GET")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
             .body(::aws_smithy_http_server::body::boxed(
                 ::http_body_util::Full::new(::bytes::Bytes::copy_from_slice(
                     &::aws_smithy_protocol_test::decode_body_data(
                         "".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     ),
                 )),
             ))
             .unwrap();
         *http_request.uri_mut() = "/?list-type=2".parse().unwrap();
         todo!("endpoint trait not supported yet");
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::AmazonS3Config::builder().build();
         let service = crate::service::AmazonS3::builder::<::hyper::body::Body, _, _, _>(config)
         let service =
             crate::service::AmazonS3::builder::<::aws_smithy_http_server::body::BoxBody, _, _, _>(
                 config,
-+
+            )
             .list_objects_v2(move |input: crate::input::ListObjectsV2Input| {
                 let sender = sender.clone();
                 async move {
                     let result = {
                         let expected = crate::input::ListObjectsV2Input {
                             bucket: "mybucket".to_owned(),
                             delimiter: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             fetch_owner: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                             request_payer: ::std::option::Option::None,
                             expected_bucket_owner: ::std::option::Option::None,
                         };
                         ::pretty_assertions::assert_eq!(input, expected);
                         let output = crate::output::ListObjectsV2Output {
                             is_truncated: ::std::option::Option::None,
                             contents: ::std::option::Option::None,
                             name: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             delimiter: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             common_prefixes: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             key_count: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             next_continuation_token: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                         };
                         Ok(output)
                     };
                     sender.send(()).await.expect("receiver dropped early");
                     result
-519
+                }
             })
             .build_unchecked();
         let http_response = ::tower::ServiceExt::oneshot(service, http_request)
             .await
             .expect("unable to make an HTTP request");
         assert!(
             receiver.recv().await.is_some(),
             "we expected operation handler to be invoked but it was not entered"
         );
-529
+    }
-530
     /// S3 clients should support the explicit virtual host addressing style.
     /// Test ID: S3VirtualHostAddressing
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn s3_virtual_host_addressing_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
         let mut http_request = ::http_1x::Request::builder()
             .uri("/")
             .method("GET")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
             .body(::aws_smithy_http_server::body::boxed(
                 ::http_body_util::Full::new(::bytes::Bytes::copy_from_slice(
                     &::aws_smithy_protocol_test::decode_body_data(
                         "".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     ),
                 )),
             ))
             .unwrap();
         *http_request.uri_mut() = "/?list-type=2".parse().unwrap();
         todo!("endpoint trait not supported yet");
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::AmazonS3Config::builder().build();
         let service = crate::service::AmazonS3::builder::<::hyper::body::Body, _, _, _>(config)
         let service =
             crate::service::AmazonS3::builder::<::aws_smithy_http_server::body::BoxBody, _, _, _>(
                 config,
-+
+            )
             .list_objects_v2(move |input: crate::input::ListObjectsV2Input| {
                 let sender = sender.clone();
                 async move {
                     let result = {
                         let expected = crate::input::ListObjectsV2Input {
                             bucket: "mybucket".to_owned(),
                             delimiter: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             fetch_owner: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                             request_payer: ::std::option::Option::None,
                             expected_bucket_owner: ::std::option::Option::None,
                         };
                         ::pretty_assertions::assert_eq!(input, expected);
                         let output = crate::output::ListObjectsV2Output {
                             is_truncated: ::std::option::Option::None,
                             contents: ::std::option::Option::None,
                             name: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             delimiter: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             common_prefixes: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             key_count: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             next_continuation_token: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                         };
                         Ok(output)
                     };
                     sender.send(()).await.expect("receiver dropped early");
                     result
-594
+                }
             })
             .build_unchecked();
         let http_response = ::tower::ServiceExt::oneshot(service, http_request)
             .await
             .expect("unable to make an HTTP request");
         assert!(
             receiver.recv().await.is_some(),
             "we expected operation handler to be invoked but it was not entered"
         );
-604
+    }
-605
     /// S3 clients should support the explicit path addressing style.
     /// Test ID: S3PathAddressing
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn s3_path_addressing_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
         let mut http_request = ::http_1x::Request::builder()
             .uri("/mybucket")
             .method("GET")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
             .body(::aws_smithy_http_server::body::boxed(
                 ::http_body_util::Full::new(::bytes::Bytes::copy_from_slice(
                     &::aws_smithy_protocol_test::decode_body_data(
                         "".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     ),
                 )),
             ))
             .unwrap();
         *http_request.uri_mut() = "/mybucket?list-type=2".parse().unwrap();
         todo!("endpoint trait not supported yet");
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::AmazonS3Config::builder().build();
         let service = crate::service::AmazonS3::builder::<::hyper::body::Body, _, _, _>(config)
         let service =
             crate::service::AmazonS3::builder::<::aws_smithy_http_server::body::BoxBody, _, _, _>(
                 config,
-+
+            )
             .list_objects_v2(move |input: crate::input::ListObjectsV2Input| {
                 let sender = sender.clone();
                 async move {
                     let result = {
                         let expected = crate::input::ListObjectsV2Input {
                             bucket: "mybucket".to_owned(),
                             delimiter: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             fetch_owner: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                             request_payer: ::std::option::Option::None,
                             expected_bucket_owner: ::std::option::Option::None,
                         };
                         ::pretty_assertions::assert_eq!(input, expected);
                         let output = crate::output::ListObjectsV2Output {
                             is_truncated: ::std::option::Option::None,
                             contents: ::std::option::Option::None,
                             name: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             delimiter: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             common_prefixes: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             key_count: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             next_continuation_token: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                         };
                         Ok(output)
                     };
                     sender.send(()).await.expect("receiver dropped early");
                     result
-669
+                }
             })
             .build_unchecked();
         let http_response = ::tower::ServiceExt::oneshot(service, http_request)
             .await
             .expect("unable to make an HTTP request");
         assert!(
             receiver.recv().await.is_some(),
             "we expected operation handler to be invoked but it was not entered"
         );
-679
+    }
-680
     /// S3 clients should support the explicit virtual host
     /// addressing style with Dualstack.
     /// Test ID: S3VirtualHostDualstackAddressing
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn s3_virtual_host_dualstack_addressing_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
         let mut http_request = ::http_1x::Request::builder()
             .uri("/")
             .method("GET")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
             .body(::aws_smithy_http_server::body::boxed(
                 ::http_body_util::Full::new(::bytes::Bytes::copy_from_slice(
                     &::aws_smithy_protocol_test::decode_body_data(
                         "".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     ),
                 )),
             ))
             .unwrap();
         *http_request.uri_mut() = "/?list-type=2".parse().unwrap();
         todo!("endpoint trait not supported yet");
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::AmazonS3Config::builder().build();
         let service = crate::service::AmazonS3::builder::<::hyper::body::Body, _, _, _>(config)
         let service =
             crate::service::AmazonS3::builder::<::aws_smithy_http_server::body::BoxBody, _, _, _>(
                 config,
-+
+            )
             .list_objects_v2(move |input: crate::input::ListObjectsV2Input| {
                 let sender = sender.clone();
                 async move {
                     let result = {
                         let expected = crate::input::ListObjectsV2Input {
                             bucket: "mybucket".to_owned(),
                             delimiter: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             fetch_owner: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                             request_payer: ::std::option::Option::None,
                             expected_bucket_owner: ::std::option::Option::None,
                         };
                         ::pretty_assertions::assert_eq!(input, expected);
                         let output = crate::output::ListObjectsV2Output {
                             is_truncated: ::std::option::Option::None,
                             contents: ::std::option::Option::None,
                             name: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             delimiter: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             common_prefixes: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             key_count: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             next_continuation_token: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                         };
                         Ok(output)
                     };
                     sender.send(()).await.expect("receiver dropped early");
                     result
-745
+                }
             })
             .build_unchecked();
         let http_response = ::tower::ServiceExt::oneshot(service, http_request)
             .await
             .expect("unable to make an HTTP request");
         assert!(
             receiver.recv().await.is_some(),
             "we expected operation handler to be invoked but it was not entered"
         );
-755
+    }
-756
     /// S3 clients should support the explicit virtual host
     /// addressing style with S3 Accelerate.
     /// Test ID: S3VirtualHostAccelerateAddressing
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn s3_virtual_host_accelerate_addressing_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
         let mut http_request = ::http_1x::Request::builder()
             .uri("/")
             .method("GET")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
             .body(::aws_smithy_http_server::body::boxed(
                 ::http_body_util::Full::new(::bytes::Bytes::copy_from_slice(
                     &::aws_smithy_protocol_test::decode_body_data(
                         "".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     ),
                 )),
             ))
             .unwrap();
         *http_request.uri_mut() = "/?list-type=2".parse().unwrap();
         todo!("endpoint trait not supported yet");
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::AmazonS3Config::builder().build();
         let service = crate::service::AmazonS3::builder::<::hyper::body::Body, _, _, _>(config)
         let service =
             crate::service::AmazonS3::builder::<::aws_smithy_http_server::body::BoxBody, _, _, _>(
                 config,
-+
+            )
             .list_objects_v2(move |input: crate::input::ListObjectsV2Input| {
                 let sender = sender.clone();
                 async move {
                     let result = {
                         let expected = crate::input::ListObjectsV2Input {
                             bucket: "mybucket".to_owned(),
                             delimiter: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             fetch_owner: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                             request_payer: ::std::option::Option::None,
                             expected_bucket_owner: ::std::option::Option::None,
                         };
                         ::pretty_assertions::assert_eq!(input, expected);
                         let output = crate::output::ListObjectsV2Output {
                             is_truncated: ::std::option::Option::None,
                             contents: ::std::option::Option::None,
                             name: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             delimiter: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             common_prefixes: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             key_count: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             next_continuation_token: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                         };
                         Ok(output)
                     };
                     sender.send(()).await.expect("receiver dropped early");
                     result
-821
+                }
             })
             .build_unchecked();
         let http_response = ::tower::ServiceExt::oneshot(service, http_request)
             .await
             .expect("unable to make an HTTP request");
         assert!(
             receiver.recv().await.is_some(),
             "we expected operation handler to be invoked but it was not entered"
         );
-831
+    }
-832
     /// S3 clients should support the explicit virtual host
     /// addressing style with Dualstack and S3 Accelerate.
     /// Test ID: S3VirtualHostDualstackAccelerateAddressing
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn s3_virtual_host_dualstack_accelerate_addressing_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
         let mut http_request = ::http_1x::Request::builder()
             .uri("/")
             .method("GET")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
             .body(::aws_smithy_http_server::body::boxed(
                 ::http_body_util::Full::new(::bytes::Bytes::copy_from_slice(
                     &::aws_smithy_protocol_test::decode_body_data(
                         "".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     ),
                 )),
             ))
             .unwrap();
         *http_request.uri_mut() = "/?list-type=2".parse().unwrap();
         todo!("endpoint trait not supported yet");
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::AmazonS3Config::builder().build();
         let service = crate::service::AmazonS3::builder::<::hyper::body::Body, _, _, _>(config)
         let service =
             crate::service::AmazonS3::builder::<::aws_smithy_http_server::body::BoxBody, _, _, _>(
                 config,
-+
+            )
             .list_objects_v2(move |input: crate::input::ListObjectsV2Input| {
                 let sender = sender.clone();
                 async move {
                     let result = {
                         let expected = crate::input::ListObjectsV2Input {
                             bucket: "mybucket".to_owned(),
                             delimiter: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             fetch_owner: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                             request_payer: ::std::option::Option::None,
                             expected_bucket_owner: ::std::option::Option::None,
                         };
                         ::pretty_assertions::assert_eq!(input, expected);
                         let output = crate::output::ListObjectsV2Output {
                             is_truncated: ::std::option::Option::None,
                             contents: ::std::option::Option::None,
                             name: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             delimiter: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             common_prefixes: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             key_count: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             next_continuation_token: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                         };
                         Ok(output)
                     };
                     sender.send(()).await.expect("receiver dropped early");
                     result
-897
+                }
             })
             .build_unchecked();
         let http_response = ::tower::ServiceExt::oneshot(service, http_request)
             .await
             .expect("unable to make an HTTP request");
         assert!(
             receiver.recv().await.is_some(),
             "we expected operation handler to be invoked but it was not entered"
         );
-907
+    }
-908
     /// S3 clients should resolve to the addressing style of the
     /// operation if defined on both the client and operation.
     /// Test ID: S3OperationAddressingPreferred
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn s3_operation_addressing_preferred_request() {
         #[allow(unused_mut)]
         let mut http_request = http::Request::builder()
         let mut http_request = ::http_1x::Request::builder()
             .uri("/")
             .method("GET")
             .body(::aws_smithy_http_server::body::Body::from(
                 ::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
             .body(::aws_smithy_http_server::body::boxed(
                 ::http_body_util::Full::new(::bytes::Bytes::copy_from_slice(
                     &::aws_smithy_protocol_test::decode_body_data(
                         "".as_bytes(),
                         ::aws_smithy_protocol_test::MediaType::from("unknown"),
                     ),
                 )),
             ))
             .unwrap();
         *http_request.uri_mut() = "/?list-type=2".parse().unwrap();
         todo!("endpoint trait not supported yet");
         #[allow(unused_mut)]
         let (sender, mut receiver) = ::tokio::sync::mpsc::channel(1);
         let config = crate::service::AmazonS3Config::builder().build();
         let service = crate::service::AmazonS3::builder::<::hyper::body::Body, _, _, _>(config)
         let service =
             crate::service::AmazonS3::builder::<::aws_smithy_http_server::body::BoxBody, _, _, _>(
                 config,
-+
+            )
             .list_objects_v2(move |input: crate::input::ListObjectsV2Input| {
                 let sender = sender.clone();
                 async move {
                     let result = {
                         let expected = crate::input::ListObjectsV2Input {
                             bucket: "mybucket".to_owned(),
                             delimiter: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             fetch_owner: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                             request_payer: ::std::option::Option::None,
                             expected_bucket_owner: ::std::option::Option::None,
                         };
                         ::pretty_assertions::assert_eq!(input, expected);
                         let output = crate::output::ListObjectsV2Output {
                             is_truncated: ::std::option::Option::None,
                             contents: ::std::option::Option::None,
                             name: ::std::option::Option::None,
                             prefix: ::std::option::Option::None,
                             delimiter: ::std::option::Option::None,
                             max_keys: ::std::option::Option::None,
                             common_prefixes: ::std::option::Option::None,
                             encoding_type: ::std::option::Option::None,
                             key_count: ::std::option::Option::None,
                             continuation_token: ::std::option::Option::None,
                             next_continuation_token: ::std::option::Option::None,
                             start_after: ::std::option::Option::None,
                         };
                         Ok(output)
                     };
                     sender.send(()).await.expect("receiver dropped early");
                     result
-973
+                }
             })
             .build_unchecked();
         let http_response = ::tower::ServiceExt::oneshot(service, http_request)
             .await
             .expect("unable to make an HTTP request");
         assert!(
             receiver.recv().await.is_some(),
             "we expected operation handler to be invoked but it was not entered"
         );
-983
+    }
-984
     /// S3 operations return Error XML nodes unwrapped by
     /// the ErrorResponse XML node.
     ///
     /// Test ID: S3OperationNoErrorWrappingResponse
     #[::tokio::test]
     #[::tracing_test::traced_test]
     #[should_panic]
     async fn s3_operation_no_error_wrapping_response_response() {
         let output = crate::error::NoSuchBucket {};
         let output = crate::error::ListObjectsV2Error::NoSuchBucket(output);
         use ::aws_smithy_http_server::response::IntoResponse;
         let http_response = output.into_response();
         ::pretty_assertions::assert_eq!(
             http::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
             ::http_1x::StatusCode::from_u16(400).expect("invalid expected HTTP status code"),
             http_response.status()
         );
         let expected_headers = [("Content-Type", "application/xml")];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(
             http_response.headers(),
             expected_headers,
         ));
         let body = ::hyper::body::to_bytes(http_response.into_body())
         use ::http_body_util::BodyExt;
         let body = http_response
             .into_body()
             .collect()
             .await
             .expect("unable to extract body to bytes");
             .expect("unable to collect body")
             .to_bytes();
         ::aws_smithy_protocol_test::assert_ok(
         ::aws_smithy_protocol_test::validate_body(&body, "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<Error>\n\t<Type>Sender</Type>\n\t<Code>NoSuchBucket</Code>\n</Error>", ::aws_smithy_protocol_test::MediaType::from("application/xml"))
         );
-1016
+    }
-1017
+}

tmp-codegen-diff/codegen-server-test/s3/rust-server-codegen/src/protocol_serde/shape_delete_object_tagging.rs

@@ -1,1 +34,34 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_delete_object_tagging_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::DeleteObjectTaggingInput,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{

↧ Expand context

     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::delete_object_tagging_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = crate::protocol_serde::shape_delete_object_tagging_input::de_expected_bucket_owner_header(&headers)? {
                                 input = input.set_expected_bucket_owner(Some(value))
-24
+                            }
         let input_string = uri.path();
         let (input_string, (m0, m1)) =
             ::nom::sequence::tuple::<_, _, ::nom::error::Error<&str>, _>((
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::branch::alt::<_, _, ::nom::error::Error<&str>, _>((
                         ::nom::bytes::complete::take_until("/"),
                         ::nom::combinator::rest,
                     )),
                 ),

@@ -39,39 +137,139 @@

↥ Expand context

             ))(input_string)?;
         debug_assert_eq!("", input_string);
         input = input
             .set_bucket(crate::protocol_serde::shape_delete_object_tagging_input::de_bucket(m0)?);
         input =
             input.set_key(crate::protocol_serde::shape_delete_object_tagging_input::de_key(m1)?);
         let query_string = uri.query().unwrap_or("");
         let pairs = ::form_urlencoded::parse(query_string.as_bytes());
         let mut version_id_seen = false;
         for (k, v) in pairs {
             if !version_id_seen && k == "versionId" {
                 input = input.set_version_id(
                     crate::protocol_serde::shape_delete_object_tagging_input::de_version_id(&v)?,
                 );
                 version_id_seen = true;
-54
+            }
-55
+        }
         input.build()?
     })
-58
+}

-59
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_delete_object_tagging_http_response(
     #[allow(unused_variables)] output: crate::output::DeleteObjectTaggingOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder =
             crate::protocol_serde::shape_delete_object_tagging::ser_delete_object_tagging_headers(
                 &output, builder,
             )?;
         let http_status: u16 = 204;
         builder = builder.status(http_status);
         let payload = "";
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-86
+}
-87
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_delete_object_tagging_http_error(
     error: &crate::error::DeleteObjectTaggingError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::DeleteObjectTaggingError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-110
+            }
-111
+        }
     })
-113
+}
-114
 pub fn ser_delete_object_tagging_headers(
     input: &crate::output::DeleteObjectTaggingOutput,
     mut builder: ::http::response::Builder,
 ) -> std::result::Result<::http::response::Builder, ::aws_smithy_types::error::operation::BuildError>
--
+{
     mut builder: ::http_1x::response::Builder,
 ) -> std::result::Result<
     ::http_1x::response::Builder,
     ::aws_smithy_types::error::operation::BuildError,
 > {
     if let ::std::option::Option::Some(inner_1) = &input.version_id {
         let formatted_2 = inner_1.as_str();
         if !formatted_2.is_empty() {
             let header_value = formatted_2;
             let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
             let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
                 ::aws_smithy_types::error::operation::BuildError::invalid_field(
                     "version_id",
                     format!(
                         "`{}` cannot be used as a header value: {}",
                         &header_value, err
                     ),
-133
+                )
             })?;
             builder = builder.header("x-amz-version-id", header_value);
-136
+        }

↧ Expand context

tmp-codegen-diff/codegen-server-test/s3/rust-server-codegen/src/protocol_serde/shape_get_bucket_location.rs

@@ -1,1 +114,114 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_get_bucket_location_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::GetBucketLocationInput,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::get_bucket_location_input::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 input_string = uri.path();
         let (input_string, m0) = ::nom::sequence::preceded(
             ::nom::bytes::complete::tag("/"),
             ::nom::branch::alt::<_, _, ::nom::error::Error<&str>, _>((
                 ::nom::bytes::complete::take_until("/"),
                 ::nom::combinator::rest,
             )),
         )(input_string)?;
         debug_assert_eq!("", input_string);
         input = input
             .set_bucket(crate::protocol_serde::shape_get_bucket_location_input::de_bucket(m0)?);
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_get_bucket_location_http_response(
     #[allow(unused_variables)] output: crate::output::GetBucketLocationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/xml",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_get_bucket_location::ser_get_bucket_location_output(
                 &output,
             )?;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-67
+}
-68
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_get_bucket_location_http_error(
     error: &crate::error::GetBucketLocationError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::GetBucketLocationError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/xml",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-96
+            }
-97
+        }
     })
-99
+}
-100

↧ Expand context

 pub fn ser_get_bucket_location_output(
     output: &crate::output::GetBucketLocationOutput,
 ) -> ::std::result::Result<String, ::aws_smithy_types::error::operation::SerializationError> {
     let mut out = String::new();
-105
+    {
         let mut writer = ::aws_smithy_xml::encode::XmlWriter::new(&mut out);
         #[allow(unused_mut)]
         let mut root = writer
             .start_el("LocationConstraint")
             .write_ns("http://s3.amazonaws.com/doc/2006-03-01/", None);
         crate::protocol_serde::shape_get_bucket_location_output::ser_get_bucket_location_output_output(output, root)?
-112
+    }
     Ok(out)
-114
+}

tmp-codegen-diff/codegen-server-test/s3/rust-server-codegen/src/protocol_serde/shape_get_object.rs

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

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_get_object_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::GetObjectInput,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::get_object_input::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 input_string = uri.path();
         let (input_string, (m0, m1)) =
             ::nom::sequence::tuple::<_, _, ::nom::error::Error<&str>, _>((
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::branch::alt::<_, _, ::nom::error::Error<&str>, _>((
                         ::nom::bytes::complete::take_until("/"),
                         ::nom::combinator::rest,
                     )),
                 ),
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::combinator::rest::<_, ::nom::error::Error<&str>>,
                 ),
             ))(input_string)?;
         debug_assert_eq!("", input_string);
         input = input.set_bucket(crate::protocol_serde::shape_get_object_input::de_bucket(
             m0,
         )?);
         input = input.set_key(crate::protocol_serde::shape_get_object_input::de_key(m1)?);
         input.build()?
     })
-44
+}
-45
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_get_object_http_response(
     #[allow(unused_variables)] output: crate::output::GetObjectOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         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,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-68
+}
-69
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_get_object_http_error(
     error: &crate::error::GetObjectError,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::GetObjectError::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-92
+            }
-93
+        }
     })
-95
+}

tmp-codegen-diff/codegen-server-test/s3/rust-server-codegen/src/protocol_serde/shape_list_objects_v2.rs

@@ -1,1 +34,34 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_list_objects_v2_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
     #[allow(unused_variables)] request: ::http_1x::Request<B>,
 ) -> std::result::Result<
     crate::input::ListObjectsV2Input,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::RequestRejection:
         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-14
+{

↧ Expand context

     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::list_objects_v2_input::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) =
             crate::protocol_serde::shape_list_objects_v2_input::de_expected_bucket_owner_header(
                 &headers,
             )?
-26
+        {
             input = input.set_expected_bucket_owner(Some(value))
-28
+        }
         if let Some(value) =
             crate::protocol_serde::shape_list_objects_v2_input::de_request_payer_header(&headers)?
-31
+        {
             input = input.set_request_payer(Some(value))
-33
+        }
         let input_string = uri.path();

@@ -80,80 +198,198 @@

↥ Expand context

                 input = input.set_max_keys(
                     crate::protocol_serde::shape_list_objects_v2_input::de_max_keys(&v)?,
                 );
                 max_keys_seen = true;
-84
+            }
             if !prefix_seen && k == "prefix" {
                 input = input
                     .set_prefix(crate::protocol_serde::shape_list_objects_v2_input::de_prefix(&v)?);
                 prefix_seen = true;
-89
+            }
             if !start_after_seen && k == "start-after" {
                 input = input.set_start_after(
                     crate::protocol_serde::shape_list_objects_v2_input::de_start_after(&v)?,
                 );
                 start_after_seen = true;
-95
+            }
-96
+        }
         input.build()?
     })
-99
+}

-100
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_list_objects_v2_http_response(
     #[allow(unused_variables)] output: crate::output::ListObjectsV2Output,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         let mut builder = ::http_1x::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             ::http_1x::header::CONTENT_TYPE,
             "application/xml",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let payload =
             crate::protocol_serde::shape_list_objects_v2::ser_list_objects_v2_output(&output)?;
         let content_length = payload.len();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_LENGTH,
             ::http_1x::header::CONTENT_LENGTH,
             content_length,
         );
         let body = ::aws_smithy_http_server::body::to_boxed(payload);
         builder.body(body)?
     })
-129
+}
-130
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_list_objects_v2_http_error(
     error: &crate::error::ListObjectsV2Error,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_xml::rejection::ResponseRejection,
 > {
     Ok({
         match error {
             crate::error::ListObjectsV2Error::NoSuchBucket(output) => {
                 let payload =
                     crate::protocol_serde::shape_no_such_bucket::ser_no_such_bucket_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/xml",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-159
+            }
             crate::error::ListObjectsV2Error::ValidationException(output) => {
                 let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
                 #[allow(unused_mut)]
                 let mut builder = ::http::Response::builder();
                 let mut builder = ::http_1x::Response::builder();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_TYPE,
                     ::http_1x::header::CONTENT_TYPE,
                     "application/xml",
                 );
                 let content_length = payload.len();
                 builder = ::aws_smithy_http::header::set_response_header_if_absent(
                     builder,
                     ::http::header::CONTENT_LENGTH,
                     ::http_1x::header::CONTENT_LENGTH,
                     content_length,
                 );
                 builder
                     .status(400)
                     .body(::aws_smithy_http_server::body::to_boxed(payload))?
-178
+            }
-179
+        }
     })
-181
+}
-182

↧ Expand context

 pub fn ser_list_objects_v2_output(
     output: &crate::output::ListObjectsV2Output,
 ) -> ::std::result::Result<String, ::aws_smithy_types::error::operation::SerializationError> {
     let mut out = String::new();
-187
+    {
         let mut writer = ::aws_smithy_xml::encode::XmlWriter::new(&mut out);
         #[allow(unused_mut)]
         let mut root = writer
             .start_el("ListObjectsV2Output")
             .write_ns("http://s3.amazonaws.com/doc/2006-03-01/", None);
         crate::protocol_serde::shape_list_objects_v2_output::ser_list_objects_v2_output_output(
             output, root,
         )?
-196
+    }
     Ok(out)
-198
+}

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

@@ -38,38 +99,99 @@

↥ Expand context

     /// # let app: AmazonS3<::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_xml::RestXml>> = app;
     /// ```
     ///
                     pub fn delete_object_tagging<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::DeleteObjectTagging, HandlerExtractors>,
-44
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::DeleteObjectTagging,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::DeleteObjectTagging, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::DeleteObjectTagging,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::DeleteObjectTagging,

-58
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     AmazonS3<L>,
                                     crate::operation_shape::DeleteObjectTagging,
                                     ModelPl::Output
-64
+                                >
                             >::Output
                         >,
-67
                         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 as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-70
-71
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::DeleteObjectTagging::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.delete_object_tagging_custom(svc)

↧ Expand context

-80
+    }
-81
     /// Sets the [`DeleteObjectTagging`](crate::operation_shape::DeleteObjectTagging) 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.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use s3::{AmazonS3, AmazonS3Config};
     ///
     /// use s3::{input, output, error};
     ///
     /// async fn handler(input: input::DeleteObjectTaggingInput) -> Result<output::DeleteObjectTaggingOutput, error::DeleteObjectTaggingError> {
     ///     todo!()
     /// }
     ///
     /// let config = AmazonS3Config::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -105,105 +185,185 @@

↥ Expand context

     /// # let app: AmazonS3<::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_xml::RestXml>> = app;
     /// ```
     ///
                     pub fn delete_object_tagging_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::DeleteObjectTagging, ServiceExtractors>,
-111
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::DeleteObjectTagging,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::DeleteObjectTagging, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::DeleteObjectTagging,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::DeleteObjectTagging,

-125
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     AmazonS3<L>,
                                     crate::operation_shape::DeleteObjectTagging,
                                     ModelPl::Output
-131
+                                >
                             >::Output
                         >,
-134
                         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 as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-137
-138
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::DeleteObjectTagging::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.delete_object_tagging_custom(svc)
-147
+    }
-148
     /// Sets the [`DeleteObjectTagging`](crate::operation_shape::DeleteObjectTagging) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn delete_object_tagging_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 ::http_1x::Request<Body>,
                 Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-161
+    {
         self.delete_object_tagging = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-164
+    }
-165

↧ Expand context

     /// Sets the [`GetBucketLocation`](crate::operation_shape::GetBucketLocation) 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.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use s3::{AmazonS3, AmazonS3Config};
     ///
     /// use s3::{input, output, error};
     ///
     /// async fn handler(input: input::GetBucketLocationInput) -> Result<output::GetBucketLocationOutput, error::GetBucketLocationError> {
     ///     todo!()
     /// }
     ///
     /// let config = AmazonS3Config::builder().build();
     /// let app = AmazonS3::builder(config)
     ///     .get_bucket_location(handler)
     ///     /* Set other handlers */

@@ -188,188 +249,249 @@

↥ Expand context

     /// # let app: AmazonS3<::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_xml::RestXml>> = app;
     /// ```
     ///
                     pub fn get_bucket_location<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::GetBucketLocation, HandlerExtractors>,
-194
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetBucketLocation,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::GetBucketLocation, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetBucketLocation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetBucketLocation,

-208
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     AmazonS3<L>,
                                     crate::operation_shape::GetBucketLocation,
                                     ModelPl::Output
-214
+                                >
                             >::Output
                         >,
-217
                         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 as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-220
-221
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::GetBucketLocation::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.get_bucket_location_custom(svc)

↧ Expand context

-230
+    }
-231
     /// Sets the [`GetBucketLocation`](crate::operation_shape::GetBucketLocation) 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.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use s3::{AmazonS3, AmazonS3Config};
     ///
     /// use s3::{input, output, error};
     ///
     /// async fn handler(input: input::GetBucketLocationInput) -> Result<output::GetBucketLocationOutput, error::GetBucketLocationError> {
     ///     todo!()
     /// }
     ///
     /// let config = AmazonS3Config::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -255,255 +335,335 @@

↥ Expand context

     /// # let app: AmazonS3<::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_xml::RestXml>> = app;
     /// ```
     ///
                     pub fn get_bucket_location_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::GetBucketLocation, ServiceExtractors>,
-261
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetBucketLocation,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::GetBucketLocation, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetBucketLocation,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetBucketLocation,

-275
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     AmazonS3<L>,
                                     crate::operation_shape::GetBucketLocation,
                                     ModelPl::Output
-281
+                                >
                             >::Output
                         >,
-284
                         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 as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-287
-288
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::GetBucketLocation::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.get_bucket_location_custom(svc)
-297
+    }
-298
     /// Sets the [`GetBucketLocation`](crate::operation_shape::GetBucketLocation) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn get_bucket_location_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 ::http_1x::Request<Body>,
                 Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-311
+    {
         self.get_bucket_location = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-314
+    }
-315

↧ Expand context

     /// Sets the [`GetObject`](crate::operation_shape::GetObject) 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.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use s3::{AmazonS3, AmazonS3Config};
     ///
     /// use s3::{input, output, error};
     ///
     /// async fn handler(input: input::GetObjectInput) -> Result<output::GetObjectOutput, error::GetObjectError> {
     ///     todo!()
     /// }
     ///
     /// let config = AmazonS3Config::builder().build();
     /// let app = AmazonS3::builder(config)
     ///     .get_object(handler)
     ///     /* Set other handlers */

@@ -338,338 +399,399 @@

↥ Expand context

     /// # let app: AmazonS3<::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_xml::RestXml>> = app;
     /// ```
     ///
                     pub fn get_object<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::GetObject, HandlerExtractors>,
-344
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetObject,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::GetObject, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetObject,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetObject,

-358
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     AmazonS3<L>,
                                     crate::operation_shape::GetObject,
                                     ModelPl::Output
-364
+                                >
                             >::Output
                         >,
-367
                         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 as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-370
-371
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::GetObject::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.get_object_custom(svc)

↧ Expand context

-380
+    }
-381
     /// Sets the [`GetObject`](crate::operation_shape::GetObject) 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.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use s3::{AmazonS3, AmazonS3Config};
     ///
     /// use s3::{input, output, error};
     ///
     /// async fn handler(input: input::GetObjectInput) -> Result<output::GetObjectOutput, error::GetObjectError> {
     ///     todo!()
     /// }
     ///
     /// let config = AmazonS3Config::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -405,405 +485,485 @@

↥ Expand context

     /// # let app: AmazonS3<::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_xml::RestXml>> = app;
     /// ```
     ///
                     pub fn get_object_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::GetObject, ServiceExtractors>,
-411
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetObject,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::GetObject, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetObject,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::GetObject,

-425
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     AmazonS3<L>,
                                     crate::operation_shape::GetObject,
                                     ModelPl::Output
-431
+                                >
                             >::Output
                         >,
-434
                         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 as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-437
-438
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::GetObject::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.get_object_custom(svc)
-447
+    }
-448
     /// Sets the [`GetObject`](crate::operation_shape::GetObject) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn get_object_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 ::http_1x::Request<Body>,
                 Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-461
+    {
         self.get_object = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-464
+    }
-465

↧ Expand context

     /// Sets the [`ListObjectsV2`](crate::operation_shape::ListObjectsV2) 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.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use s3::{AmazonS3, AmazonS3Config};
     ///
     /// use s3::{input, output, error};
     ///
     /// async fn handler(input: input::ListObjectsV2Input) -> Result<output::ListObjectsV2Output, error::ListObjectsV2Error> {
     ///     todo!()
     /// }
     ///
     /// let config = AmazonS3Config::builder().build();
     /// let app = AmazonS3::builder(config)
     ///     .list_objects_v2(handler)
     ///     /* Set other handlers */

@@ -488,488 +549,549 @@

↥ Expand context

     /// # let app: AmazonS3<::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_xml::RestXml>> = app;
     /// ```
     ///
                     pub fn list_objects_v2<HandlerType, HandlerExtractors, UpgradeExtractors>(self, handler: HandlerType) -> Self
                     where
                         HandlerType: ::aws_smithy_http_server::operation::Handler<crate::operation_shape::ListObjectsV2, HandlerExtractors>,
-494
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::ListObjectsV2,
                             ::aws_smithy_http_server::operation::IntoService<crate::operation_shape::ListObjectsV2, HandlerType>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::ListObjectsV2,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::ListObjectsV2,

-508
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     AmazonS3<L>,
                                     crate::operation_shape::ListObjectsV2,
                                     ModelPl::Output
-514
+                                >
                             >::Output
                         >,
-517
                         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 as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-520
-521
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ListObjectsV2::from_handler(handler);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.list_objects_v2_custom(svc)

↧ Expand context

-530
+    }
-531
     /// Sets the [`ListObjectsV2`](crate::operation_shape::ListObjectsV2) 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.
     ///
     /// # Example
     ///
     /// ```no_run
     /// use s3::{AmazonS3, AmazonS3Config};
     ///
     /// use s3::{input, output, error};
     ///
     /// async fn handler(input: input::ListObjectsV2Input) -> Result<output::ListObjectsV2Output, error::ListObjectsV2Error> {
     ///     todo!()
     /// }
     ///
     /// let config = AmazonS3Config::builder().build();
     /// let svc = ::tower::util::service_fn(handler);

@@ -555,555 +635,635 @@

↥ Expand context

     /// # let app: AmazonS3<::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_xml::RestXml>> = app;
     /// ```
     ///
                     pub fn list_objects_v2_service<S, ServiceExtractors, UpgradeExtractors>(self, service: S) -> Self
                     where
                         S: ::aws_smithy_http_server::operation::OperationService<crate::operation_shape::ListObjectsV2, ServiceExtractors>,
-561
                         ModelPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::ListObjectsV2,
                             ::aws_smithy_http_server::operation::Normalize<crate::operation_shape::ListObjectsV2, S>
                         >,
                         ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::ListObjectsV2,
                             ModelPl::Output
                         >,
                         HttpPl: ::aws_smithy_http_server::plugin::Plugin<
                             AmazonS3<L>,
                             crate::operation_shape::ListObjectsV2,

-575
+                            <
                                 ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>
                                 as ::aws_smithy_http_server::plugin::Plugin<
                                     AmazonS3<L>,
                                     crate::operation_shape::ListObjectsV2,
                                     ModelPl::Output
-581
+                                >
                             >::Output
                         >,
-584
                         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 as ::tower::Service<::http::Request<Body>>>::Future: Send + 'static,
                         HttpPl::Output: ::tower::Service<::http_1x::Request<Body>, Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>, Error = ::std::convert::Infallible> + Clone + Send + 'static,
                         <HttpPl::Output as ::tower::Service<::http_1x::Request<Body>>>::Future: Send + 'static,
-587
-588
+                    {
         use ::aws_smithy_http_server::operation::OperationShapeExt;
         use ::aws_smithy_http_server::plugin::Plugin;
         let svc = crate::operation_shape::ListObjectsV2::from_service(service);
         let svc = self.model_plugin.apply(svc);
         let svc = ::aws_smithy_http_server::operation::UpgradePlugin::<UpgradeExtractors>::new()
             .apply(svc);
         let svc = self.http_plugin.apply(svc);
         self.list_objects_v2_custom(svc)
-597
+    }
-598
     /// Sets the [`ListObjectsV2`](crate::operation_shape::ListObjectsV2) to a custom [`Service`](tower::Service).
     /// not constrained by the Smithy contract.
     fn list_objects_v2_custom<S>(mut self, svc: S) -> Self
     where
         S: ::tower::Service<
                 ::http::Request<Body>,
                 Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
                 ::http_1x::Request<Body>,
                 Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
                 Error = ::std::convert::Infallible,
             > + Clone
             + Send
             + 'static,
         S::Future: Send + 'static,
-611
+    {
         self.list_objects_v2 = Some(::aws_smithy_http_server::routing::Route::new(svc));
         self
-614
+    }
-615
+}

↧ Expand context

-616
 impl<Body, L, HttpPl, ModelPl> AmazonS3Builder<Body, L, HttpPl, ModelPl> {
     /// Constructs a [`AmazonS3`] from the arguments provided to the builder.
     ///
     /// Forgetting to register a handler for one or more operations will result in an error.
     ///
     /// Check out [`AmazonS3Builder::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<
         AmazonS3<
             ::aws_smithy_http_server::routing::RoutingService<
                 ::aws_smithy_http_server::protocol::rest::router::RestRouter<L::Service>,
                 ::aws_smithy_http_server::protocol::rest_xml::RestXml,
             >,
         >,
         MissingOperationsError,
-634
+    >
     where

@@ -764,764 +872,872 @@

↥ Expand context

-764
+}
-765
 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 `AmazonS3`.\n\
                             We are missing handlers for the following operations:\n",
         )?;
         for operation_name in self.operation_names2setter_methods.keys() {
             writeln!(f, "- {}", operation_name.absolute())?;
-775
+        }
-776
         writeln!(
             f,
             "\nUse the dedicated methods on `AmazonS3Builder` to register the missing handlers:"
         )?;
         for setter_name in self.operation_names2setter_methods.values() {
             writeln!(f, "- {}", setter_name)?;
-783
+        }

         Ok(())
-785
+    }
-786
+}
-787
 impl std::error::Error for MissingOperationsError {}
-789
 mod request_specs {
     pub(super) fn delete_object_tagging(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::DELETE,
                     ::http_1x::Method::DELETE,
                     ::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::Label,
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Greedy,
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::QuerySegment::Key(String::from("tagging")),
 ])
-804
+                        )
                     ),
-806
+                )
-807
+    }
     pub(super) fn get_bucket_location(
     ) -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::GET,
                     ::http_1x::Method::GET,
                     ::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::Label,
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::QuerySegment::Key(String::from("location")),
 ])
-820
+                        )
                     ),
-822
+                )
-823
+    }
     pub(super) fn get_object() -> ::aws_smithy_http_server::routing::request_spec::RequestSpec {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::GET,
                     ::http_1x::Method::GET,
                     ::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::Label,
     ::aws_smithy_http_server::routing::request_spec::PathSegment::Greedy,
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
 ])
-835
+                        )
                     ),
-837
+                )
-838
+    }
     pub(super) fn list_objects_v2() -> ::aws_smithy_http_server::routing::request_spec::RequestSpec
-840
+    {
         ::aws_smithy_http_server::routing::request_spec::RequestSpec::new(
                     ::http::Method::GET,
                     ::http_1x::Method::GET,
                     ::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::Label,
 ]),
                             ::aws_smithy_http_server::routing::request_spec::QuerySpec::from_vector_unchecked(vec![
     ::aws_smithy_http_server::routing::request_spec::QuerySegment::KeyValue(String::from("list-type"), String::from("2")),
 ])
-851
+                        )
                     ),

↧ Expand context

-853
+                )
-854
+    }
-855
+}
-856
 #[allow(missing_docs)] // documentation missing in model
 ///
 /// See the [root](crate) documentation for more information.
 #[derive(Clone)]
 pub struct AmazonS3<
     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>,
         >,
         ::aws_smithy_http_server::protocol::rest_xml::RestXml,
     >,
 > {
     // This is the router wrapped by layers.
     svc: S,
-871
+}
-872

@@ -976,976 +1037,1037 @@

↥ Expand context

         layer: &L,
     ) -> AmazonS3<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::rest::router::RestRouter<L::Service>,
             ::aws_smithy_http_server::protocol::rest_xml::RestXml,
         >,
-982
+    >
     where
         L: ::tower::Layer<S>,
-985
+    {
         AmazonS3 {
             svc: self.svc.map(|s| s.layer(layer)),
-988
+        }
-989
+    }
-990
     /// Applies [`Route::new`](::aws_smithy_http_server::routing::Route::new) to all routes.
     ///
     /// This has the effect of erasing all types accumulated via layers.
     pub fn boxed<B>(
         self,

     ) -> AmazonS3<
         ::aws_smithy_http_server::routing::RoutingService<
             ::aws_smithy_http_server::protocol::rest::router::RestRouter<
                 ::aws_smithy_http_server::routing::Route<B>,
             >,
             ::aws_smithy_http_server::protocol::rest_xml::RestXml,
         >,
-1003
+    >
     where
         S: ::tower::Service<
             ::http::Request<B>,
             Response = ::http::Response<::aws_smithy_http_server::body::BoxBody>,
             ::http_1x::Request<B>,
             Response = ::http_1x::Response<::aws_smithy_http_server::body::BoxBody>,
             Error = std::convert::Infallible,
         >,
         S: Clone + Send + 'static,
         S::Future: Send + 'static,
-1012
+    {
         self.layer(&::tower::layer::layer_fn(
             ::aws_smithy_http_server::routing::Route::new,
         ))
-1016
+    }
-1017
+}

↧ Expand context

-1018
 impl<S, R> ::tower::Service<R> for AmazonS3<S>
 where
     S: ::tower::Service<R>,
-1022
+{
     type Response = S::Response;
     type Error = S::Error;
     type Future = S::Future;
-1026
     fn poll_ready(
         &mut self,
         cx: &mut std::task::Context,
     ) -> std::task::Poll<::std::result::Result<(), Self::Error>> {
         self.svc.poll_ready(cx)
-1032
+    }
-1033
     fn call(&mut self, request: R) -> Self::Future {
         self.svc.call(request)
-1036
+    }
-1037
+}

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

@@ -0,1 +0,46 @@

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "simple-http0x"
 version = "0.0.1"
 authors = ["protocoltest@example.com"]
 description = "test"
 edition = "2021"
-+
 [package.metadata.smithy]
 codegen-version = "ci"
 protocol = "aws.protocols#restJson1"
 [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.pin-project-lite]
 version = "0.2"
 [dependencies.tower]
 version = "0.4"
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.tokio]
 version = "1.23.1"
 [features]
 rt-tokio = ["aws-smithy-types/rt-tokio"]
 aws-lambda = ["aws-smithy-legacy-http-server/aws-lambda"]
 request-id = ["aws-smithy-legacy-http-server/request-id"]
 default = ["rt-tokio", "request-id"]
-+
-+

tmp-codegen-diff/codegen-server-test/simple-http0x/rust-server-codegen/src/constrained.rs

@@ -0,1 +0,16 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-+
 pub(crate) trait Constrained {
     type Unconstrained;
-+
+}
-+
 #[derive(Debug, Clone)]
 #[allow(dead_code)]
 pub(crate) enum MaybeConstrained<T: Constrained> {
     Constrained(T),
     Unconstrained(T::Unconstrained),
-+
+}

tmp-codegen-diff/codegen-server-test/simple-http0x/rust-server-codegen/src/error.rs

@@ -0,1 +0,1 @@

tmp-codegen-diff/codegen-server-test/simple-http0x/rust-server-codegen/src/input.rs

@@ -0,1 +0,62 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(missing_docs)] // documentation missing in model
 #[derive(
     ::std::clone::Clone, ::std::cmp::Eq, ::std::cmp::PartialEq, ::std::fmt::Debug, ::std::hash::Hash,
 )]
 pub struct OperationInput {
     #[allow(missing_docs)] // documentation missing in model
     pub message: ::std::option::Option<::std::string::String>,
-+
+}
 impl OperationInput {
     #[allow(missing_docs)] // documentation missing in model
     pub fn message(&self) -> ::std::option::Option<&str> {
         self.message.as_deref()
-+
+    }
-+
+}
 impl OperationInput {
     /// Creates a new builder-style object to manufacture [`OperationInput`](crate::input::OperationInput).
     pub fn builder() -> crate::input::operation_input::Builder {
         crate::input::operation_input::Builder::default()
-+
+    }
-+
+}
 impl crate::constrained::Constrained for crate::input::OperationInput {
     type Unconstrained = crate::input::operation_input::Builder;
-+
+}
 /// See [`OperationInput`](crate::input::OperationInput).
 pub mod operation_input {
-+
     impl ::std::convert::From<Builder> for crate::input::OperationInput {
         fn from(builder: Builder) -> Self {
             builder.build()
-+
+        }
-+
+    }
     /// A builder for [`OperationInput`](crate::input::OperationInput).
     #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
     pub struct Builder {
         pub(crate) message: ::std::option::Option<::std::string::String>,
-+
+    }
     impl Builder {
         #[allow(missing_docs)] // documentation missing in model
         pub fn message(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
             self.message = input;
             self
-+
+        }
         #[allow(missing_docs)] // documentation missing in model
         pub(crate) fn set_message(
             mut self,
             input: Option<impl ::std::convert::Into<::std::string::String>>,
         ) -> Self {
             self.message = input.map(|v| v.into());
             self
-+
+        }
         /// Consumes the builder and constructs a [`OperationInput`](crate::input::OperationInput).
         pub fn build(self) -> crate::input::OperationInput {
             self.build_enforcing_all_constraints()
-+
+        }
         fn build_enforcing_all_constraints(self) -> crate::input::OperationInput {
             crate::input::OperationInput {
                 message: self.message,
-+
+            }
-+
+        }
-+
+    }
-+
+}

tmp-codegen-diff/codegen-server-test/simple-http0x/rust-server-codegen/src/lib.rs

@@ -0,1 +0,245 @@

 #![allow(deprecated)]
 #![allow(unknown_lints)]
 #![allow(clippy::module_inception)]
 #![allow(clippy::upper_case_acronyms)]
 #![allow(clippy::large_enum_variant)]
 #![allow(clippy::wrong_self_convention)]
 #![allow(clippy::should_implement_trait)]
 #![allow(clippy::disallowed_names)]
 #![allow(clippy::vec_init_then_push)]
 #![allow(clippy::type_complexity)]
 #![allow(clippy::needless_return)]
 #![allow(clippy::derive_partial_eq_without_eq)]
 #![allow(clippy::result_large_err)]
 #![allow(clippy::unnecessary_map_on_constructor)]
 #![allow(clippy::deprecated_semver)]
 #![allow(clippy::uninlined_format_args)]
 #![allow(rustdoc::bare_urls)]
 #![allow(rustdoc::redundant_explicit_links)]
 #![allow(rustdoc::invalid_html_tags)]
 #![forbid(unsafe_code)]
 #![cfg_attr(docsrs, feature(doc_cfg))]
 //! simple-http0x
-+
 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 //! A fast and customizable Rust implementation of the SimpleService Smithy service.
 //!
 //! # Using SimpleService
 //!
 //! 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`], and [`crate::output`],
 //! modules provide the types used in each operation.
 //!
 //! ### Running on Hyper
 //!
 //! ```rust,no_run
 //! # use std::net::SocketAddr;
 //! # async fn dummy() {
 //! use simple_http0x::{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_http0x::server::routing::LambdaHandler;
 //! use simple_http0x::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_http0x::server::plugin::IdentityPlugin as LoggingPlugin;
 //! # use simple_http0x::server::plugin::IdentityPlugin as MetricsPlugin;
 //! # use ::hyper::Body;
 //! use simple_http0x::server::plugin::HttpPlugins;
 //! use simple_http0x::{SimpleService, SimpleServiceConfig, SimpleServiceBuilder};
 //!
 //! let http_plugins = HttpPlugins::new()
 //!         .push(LoggingPlugin)
 //!         .push(MetricsPlugin);
 //! let config = SimpleServiceConfig::builder().build();
 //! 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:
 //!
 //! * 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;
 //! # use std::net::SocketAddr;
 //! use simple_http0x::server::request::{extension::Extension, connect_info::ConnectInfo};
 //!
 //! async fn handler_with_no_extensions(input: Input) -> Output {
 //!     todo!()
 //! }
 //!
 //! async fn handler_with_one_extractor(input: Input, ext: Extension<State>) -> Output {
 //!     todo!()
 //! }
 //!
 //! async fn handler_with_two_extractors(
 //!     input: Input,
 //!     ext0: Extension<State>,
 //!     ext1: ConnectInfo<SocketAddr>,
 //! ) -> Output {
 //!     todo!()
 //! }
 //! ```
 //!
 //! See the [`operation module`](crate::operation) for information on precisely what constitutes a handler.
 //!
 //! ## Build
 //!
 //! You can convert [`SimpleServiceBuilder`] into [`SimpleService`] using either [`SimpleServiceBuilder::build`] or [`SimpleServiceBuilder::build_unchecked`].
 //!
 //! [`SimpleServiceBuilder::build`] requires you to provide a handler for every single operation in your Smithy model. It will return an error if that is not the case.
 //!
 //! [`SimpleServiceBuilder::build_unchecked`], instead, does not require exhaustiveness. The server will automatically return 500 Internal Server Error to all requests for operations that do not have a registered handler.
 //! [`SimpleServiceBuilder::build_unchecked`] is particularly useful if you are deploying your Smithy service as a collection of Lambda functions, where each Lambda is only responsible for a subset of the operations in the Smithy service (or even a single one!).
 //!
 //! # Example
 //!
 //! ```rust,no_run
 //! # use std::net::SocketAddr;
 //! use simple_http0x::{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_http0x::{input, output};
 //!
 //! async fn operation(input: input::OperationInput) -> output::OperationOutput {
 //!     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
 //! [Service]: https://docs.rs/tower-service/latest/tower_service/trait.Service.html
 pub use crate::service::{
     MissingOperationsError, SimpleService, SimpleServiceBuilder, SimpleServiceConfig,
     SimpleServiceConfigBuilder,
 };
-+
 /// 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_legacy_http_server::*;
-+
+}
-+
 /// Crate version number.
 pub static PKG_VERSION: &str = env!("CARGO_PKG_VERSION");
-+
 /// All error types that operations can return. Documentation on these types is copied from the model.
 pub mod error;
-+
 /// Input structures for operations. Documentation on these types is copied from the model.
 pub mod input;
-+
 /// All operations that this crate can perform.
 pub mod operation;
-+
 /// A collection of types representing each operation defined in the service closure.
 ///
 /// 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_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;
-+
 /// Output structures for operations. Documentation on these types is copied from the model.
 pub mod output;
-+
 mod service;
-+
 /// Data primitives referenced by other data types.
 pub mod types;
-+
 /// Constrained types for constrained shapes.
 mod constrained;
-+
 mod mimes;
-+
 pub(crate) mod protocol_serde;

-8
 [package.metadata.smithy]
 codegen-version = "ci"
 protocol = "aws.protocols#restXml"
 [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-runtime-api]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-runtime-api"
 features = ["http-1x"]
 [dependencies.aws-smithy-types]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-types"
 features = ["http-body-1-x"]
 [dependencies.aws-smithy-xml]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-xml"
 [dependencies.form_urlencoded]
 version = "1"
 [dependencies.futures-util]
 version = "0.3"
 [dependencies.http]
 version = "0.2.9"
 [dependencies.http-1x]
 version = "1"
 package = "http"
 [dependencies.mime]
 version = "0.3"
 [dependencies.nom]
 version = "7"
 [dependencies.percent-encoding]
 version = "2.0.0"
 [dependencies.pin-project-lite]
 version = "0.2"
 [dependencies.tower]
 version = "0.4"
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.aws-smithy-protocol-test]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-protocol-test"
 features = ["http-1x"]
 [dev-dependencies.bytes]
 version = "1.4.0"
 [dev-dependencies.http-body-util]
 version = "0.1.3"
 [dev-dependencies.hyper]
 version = "0.14.26"
 version = "1"
 [dev-dependencies.pretty_assertions]
 version = "1.3.0"
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
 [dev-dependencies.tracing-test]
 version = "0.2.5"
 features = ["no-env-filter"]
 [features]
 rt-tokio = ["aws-smithy-types/rt-tokio"]

 aws-lambda = ["aws-smithy-http-server/aws-lambda"]
 request-id = ["aws-smithy-http-server/request-id"]
 default = ["rt-tokio", "request-id"]
-65
-66

135 137	`}`
136 138	`Ok(builder)`
137 139	`}`

Server Test

Files changed:

tmp-codegen-diff/codegen-server-test/s3-http0x/rust-server-codegen/src/types.rs

tmp-codegen-diff/codegen-server-test/s3/rust-server-codegen/Cargo.toml

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

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

tmp-codegen-diff/codegen-server-test/s3/rust-server-codegen/src/protocol_serde/shape_delete_object_tagging.rs

tmp-codegen-diff/codegen-server-test/s3/rust-server-codegen/src/protocol_serde/shape_get_bucket_location.rs

tmp-codegen-diff/codegen-server-test/s3/rust-server-codegen/src/protocol_serde/shape_get_object.rs

tmp-codegen-diff/codegen-server-test/s3/rust-server-codegen/src/protocol_serde/shape_list_objects_v2.rs

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

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

tmp-codegen-diff/codegen-server-test/simple-http0x/rust-server-codegen/src/constrained.rs

tmp-codegen-diff/codegen-server-test/simple-http0x/rust-server-codegen/src/error.rs

tmp-codegen-diff/codegen-server-test/simple-http0x/rust-server-codegen/src/input.rs

tmp-codegen-diff/codegen-server-test/simple-http0x/rust-server-codegen/src/lib.rs

tmp-codegen-diff/codegen-server-test/simple-http0x/rust-server-codegen/src/mimes.rs

tmp-codegen-diff/codegen-server-test/simple-http0x/rust-server-codegen/src/operation.rs

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub use ::aws_smithy_types::date_time::Format as DateTimeFormat;
 pub use ::aws_smithy_types::error::display::DisplayErrorContext;
 pub use ::aws_smithy_types::Blob;
 pub use ::aws_smithy_types::DateTime;

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 pub(crate) static CONTENT_TYPE_APPLICATION_JSON: std::sync::LazyLock<::mime::Mime> =
     std::sync::LazyLock::new(|| {
         "application/json"
             .parse::<::mime::Mime>()
             .expect("BUG: MIME parsing failed, content_type is not valid")
     });