Server Test Python

rev. 52a747aa19d8f7ff1fb936dafeb9929959f2f20f

Files changed:

tmp-codegen-diff/codegen-server-test-python/constraints/rust-server-codegen-python/src/protocol_serde/shape_event_streams_operation.rs

@@ -1,1 +68,58 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_event_streams_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::EventStreamsOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:

         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::event_streams_operation_input_internal::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
             let receiver =
                 crate::protocol_serde::shape_event_streams_operation_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_event_streams_operation_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::EventStreamsOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let body = ::aws_smithy_http_server::body::boxed(
             ::aws_smithy_http_server::body::Body::wrap_stream({
                 let error_marshaller = crate::event_stream_serde::EventErrorMarshaller::new();
                 let marshaller = crate::event_stream_serde::EventMarshaller::new();
                 let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};

tmp-codegen-diff/codegen-server-test-python/constraints_without_public_constrained_types/rust-server-codegen-python/src/protocol_serde/shape_event_streams_operation.rs

@@ -1,1 +68,58 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_event_streams_operation_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::EventStreamsOperationInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:

         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::event_streams_operation_input_internal::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
             let receiver =
                 crate::protocol_serde::shape_event_streams_operation_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-32
+        }
         input.build()?
     })
-35
+}
-36
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_event_streams_operation_http_response(

↧ Expand context

     #[allow(unused_variables)] output: crate::output::EventStreamsOperationOutput,
 ) -> std::result::Result<
     ::aws_smithy_http_server::response::Response,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
 > {
     Ok({
         #[allow(unused_mut)]
         let mut builder = ::http::Response::builder();
         builder = ::aws_smithy_http::header::set_response_header_if_absent(
             builder,
             ::http::header::CONTENT_TYPE,
             "application/vnd.amazon.eventstream",
         );
         let http_status: u16 = 200;
         builder = builder.status(http_status);
         let body = ::aws_smithy_http_server::body::boxed(
             ::aws_smithy_http_server::body::Body::wrap_stream({
                 let error_marshaller = crate::event_stream_serde::EventErrorMarshaller::new();
                 let marshaller = crate::event_stream_serde::EventMarshaller::new();
                 let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};

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

@@ -1,1 +68,57 @@

↥ Expand context

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 #[allow(clippy::unnecessary_wraps)]
 pub async fn de_capture_pokemon_http_request<B>(
     #[allow(unused_variables)] request: ::http::Request<B>,
 ) -> std::result::Result<
     crate::input::CapturePokemonInput,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
-8
+>
 where
     B: ::aws_smithy_http_server::body::HttpBody + Send,
     B: Into<::aws_smithy_types::byte_stream::ByteStream>,
     B::Data: Send,
     ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:

         From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
-15
+{
     Ok({
         #[allow(unused_mut)]
         let mut input = crate::input::capture_pokemon_input_internal::Builder::default();
         #[allow(unused_variables)]
         let ::aws_smithy_runtime_api::http::RequestParts {
             uri, headers, body, ..
         } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
         if let Some(value) = {
             let mut receiver =
                 crate::protocol_serde::shape_capture_pokemon_input::de_events_payload(
                     &mut body.into().into_inner(),
                 )?;
             if let Some(_initial_event) = receiver
                                                 .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
                                                 .await
                                                 .map_err(
                                                     |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
                                                         #[allow(clippy::useless_conversion)]
                                                         format!("{ev_error}").into()
--
+                                                    )
                                                 )? {
--
--
+                                            }
             let receiver = crate::protocol_serde::shape_capture_pokemon_input::de_events_payload(
                 &mut body.into().into_inner(),
             )?;
-+
             Some(receiver)
         } {
             input = input.set_events(value)
-31
+        }
         let input_string = uri.path();
         let (input_string, (_, m1)) =
             ::nom::sequence::tuple::<_, _, ::nom::error::Error<&str>, _>((
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::bytes::complete::tag::<_, _, ::nom::error::Error<&str>>(

↧ Expand context

                         "capture-pokemon-event",
                     ),
                 ),
                 ::nom::sequence::preceded(
                     ::nom::bytes::complete::tag("/"),
                     ::nom::branch::alt::<_, _, ::nom::error::Error<&str>, _>((
                         ::nom::bytes::complete::take_until("/"),
                         ::nom::combinator::rest,
                     )),
                 ),
             ))(input_string)?;
         debug_assert_eq!("", input_string);
         input =
             input.set_region(crate::protocol_serde::shape_capture_pokemon_input::de_region(m1)?);
         input.build()?
     })
-54
+}
-55
 #[allow(clippy::unnecessary_wraps)]
 pub fn ser_capture_pokemon_http_response(

Pages: 1