Client Test

rev. 883c1c11b9534c70b8710afacb15e36a4421ca4d (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-client-test/rpcv2Cbor_extras/rust-client-codegen/Cargo.toml

@@ -13,13 +69,66 @@

 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-async"
 [dependencies.aws-smithy-cbor]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-cbor"
 [dependencies.aws-smithy-eventstream]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-eventstream"
 [dependencies.aws-smithy-http]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-http"
 features = ["event-stream"]
 [dependencies.aws-smithy-runtime]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-runtime"
 features = ["client"]
 [dependencies.aws-smithy-runtime-api]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-runtime-api"
 features = ["client", "http-1x"]
 [dependencies.aws-smithy-types]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-types"
 features = ["http-body-1-x"]
 [dependencies.bytes]
 version = "1.4.0"
 [dependencies.fastrand]

 version = "2.0.0"
 [dependencies.futures-util]
 version = "0.3.25"
 features = ["alloc"]
 default-features = false
 [dependencies.http]
 version = "0.2.9"
 [dependencies.http-1x]
 version = "1"
 package = "http"
 [dependencies.http-body-1x]
 version = "1"
 package = "http-body"
 [dependencies.http-body-util]
 version = "0.1.3"
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.aws-smithy-protocol-test]
 path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-protocol-test"
 [dev-dependencies.pretty_assertions]
 version = "1.3.0"
 [dev-dependencies.tokio]
 version = "1.23.1"

↧ Expand context

 features = ["macros", "test-util", "rt-multi-thread"]
 [dev-dependencies.tracing-test]
 version = "0.2.5"
 features = ["no-env-filter"]
 [features]
 rt-tokio = ["aws-smithy-async/rt-tokio", "aws-smithy-types/rt-tokio"]
 test-util = ["aws-smithy-runtime/test-util"]
 behavior-version-latest = []
 rustls = ["aws-smithy-runtime/tls-rustls"]
 default-https-client = ["aws-smithy-runtime/default-https-client"]
 gated-tests = []
 default = ["rt-tokio", "rustls", "default-https-client"]
-65
-66

tmp-codegen-diff/codegen-client-test/rpcv2Cbor_extras/rust-client-codegen/src/operation/streaming_operation_with_initial_data.rs

@@ -200,200 +264,277 @@

↥ Expand context

             ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-204
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/vnd.amazon.eventstream");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http_1x::header::HeaderName::from_static("smithy-protocol"),
                 "rpc-v2-cbor",
             );
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http_1x::header::HeaderName::from_static("accept"),
                 "application/vnd.amazon.eventstream, application/cbor",
             );
             builder
         };

         let body = ::aws_smithy_types::body::SdkBody::from({
             let error_marshaller = crate::event_stream_serde::EventsErrorMarshaller::new();
             let marshaller = crate::event_stream_serde::EventsMarshaller::new();
             let (signer, signer_sender) = ::aws_smithy_eventstream::frame::DeferredSigner::new();
             _cfg.interceptor_state().store_put(signer_sender);
             ::aws_smithy_types::body::SdkBody::from_body_1_x(::http_body_util::StreamBody::new({
                 use ::futures_util::StreamExt;
                 let body =
                     crate::protocol_serde::shape_streaming_operation_with_initial_data::ser_streaming_operation_with_initial_data_input(&input)?;
                 let initial_message = crate::event_stream_serde::initial_message_from_body(body);
                 let mut buffer = ::std::vec::Vec::new();
                 ::aws_smithy_eventstream::frame::write_message_to(&initial_message, &mut buffer)?;
                 let initial_message_stream = futures_util::stream::iter(vec![Ok(::http_body_1x::Frame::data(buffer.into()))]);
                 let adapter = input.events.into_body_stream(marshaller, error_marshaller, signer);
                 initial_message_stream.chain(adapter)
-+
                 // Wrap the marshaller to handle both initial and regular messages
                 let wrapped_marshaller = ::aws_smithy_http::event_stream::EventOrInitialMarshaller::new(marshaller);
-+
                 // Create stream with initial message
                 let initial_stream = ::futures_util::stream::once(async move {
                     ::std::result::Result::Ok(::aws_smithy_http::event_stream::EventOrInitial::InitialMessage(initial_message))
                 });
-+
                 // Extract inner stream and map events
                 let event_stream = input
                     .events
                     .into_inner()
                     .map(|result| result.map(::aws_smithy_http::event_stream::EventOrInitial::Event));
-+
                 // Chain streams and convert to EventStreamSender
                 let combined = initial_stream.chain(event_stream);
                 ::aws_smithy_http::event_stream::EventStreamSender::from(combined).into_body_stream(wrapped_marshaller, error_marshaller, signer)
             }))
         });
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
-253
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-255
+    }
-256
+}
 #[derive(Debug)]

↧ Expand context

 struct StreamingOperationWithInitialDataEndpointParamsInterceptor;
-259
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for StreamingOperationWithInitialDataEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "StreamingOperationWithInitialDataEndpointParamsInterceptor"
-263
+    }
-264
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<StreamingOperationWithInitialDataInput>()

tmp-codegen-diff/codegen-client-test/rpcv2Cbor_extras/rust-client-codegen/src/operation/streaming_operation_with_optional_data.rs

@@ -200,200 +264,277 @@

↥ Expand context

             ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-204
+            }
             let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
             builder =
                 _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/vnd.amazon.eventstream");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http_1x::header::HeaderName::from_static("smithy-protocol"),
                 "rpc-v2-cbor",
             );
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http_1x::header::HeaderName::from_static("accept"),
                 "application/vnd.amazon.eventstream, application/cbor",
             );
             builder
         };

         let body = ::aws_smithy_types::body::SdkBody::from({
             let error_marshaller = crate::event_stream_serde::EventsErrorMarshaller::new();
             let marshaller = crate::event_stream_serde::EventsMarshaller::new();
             let (signer, signer_sender) = ::aws_smithy_eventstream::frame::DeferredSigner::new();
             _cfg.interceptor_state().store_put(signer_sender);
             ::aws_smithy_types::body::SdkBody::from_body_1_x(::http_body_util::StreamBody::new({
                 use ::futures_util::StreamExt;
                 let body =
                     crate::protocol_serde::shape_streaming_operation_with_optional_data::ser_streaming_operation_with_optional_data_input(&input)?;
                 let initial_message = crate::event_stream_serde::initial_message_from_body(body);
                 let mut buffer = ::std::vec::Vec::new();
                 ::aws_smithy_eventstream::frame::write_message_to(&initial_message, &mut buffer)?;
                 let initial_message_stream = futures_util::stream::iter(vec![Ok(::http_body_1x::Frame::data(buffer.into()))]);
                 let adapter = input.events.into_body_stream(marshaller, error_marshaller, signer);
                 initial_message_stream.chain(adapter)
-+
                 // Wrap the marshaller to handle both initial and regular messages
                 let wrapped_marshaller = ::aws_smithy_http::event_stream::EventOrInitialMarshaller::new(marshaller);
-+
                 // Create stream with initial message
                 let initial_stream = ::futures_util::stream::once(async move {
                     ::std::result::Result::Ok(::aws_smithy_http::event_stream::EventOrInitial::InitialMessage(initial_message))
                 });
-+
                 // Extract inner stream and map events
                 let event_stream = input
                     .events
                     .into_inner()
                     .map(|result| result.map(::aws_smithy_http::event_stream::EventOrInitial::Event));
-+
                 // Chain streams and convert to EventStreamSender
                 let combined = initial_stream.chain(event_stream);
                 ::aws_smithy_http::event_stream::EventStreamSender::from(combined).into_body_stream(wrapped_marshaller, error_marshaller, signer)
             }))
         });
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
-253
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-255
+    }
-256
+}
 #[derive(Debug)]

↧ Expand context

 struct StreamingOperationWithOptionalDataEndpointParamsInterceptor;
-259
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for StreamingOperationWithOptionalDataEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "StreamingOperationWithOptionalDataEndpointParamsInterceptor"
-263
+    }
-264
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<StreamingOperationWithOptionalDataInput>()

Pages: 1