Client Test

features = ["client", "test-util"]

[dev-dependencies.aws-smithy-types]

path = "/home/build/workspace/smithy-rs/rust-runtime/aws-smithy-types"

[dev-dependencies.bytes]

version = "1.4.0"

[dev-dependencies.pretty_assertions]

version = "1.3.0"

[dev-dependencies.tokio]

version = "1.23.1"

features = ["macros", "test-util", "rt-multi-thread"]

[features]

test-util = ["aws-smithy-runtime/test-util"]

rt-tokio = ["aws-smithy-async/rt-tokio", "aws-smithy-types/rt-tokio"]

behavior-version-latest = []

rustls = ["aws-smithy-runtime/tls-rustls"]

default = ["rt-tokio", "rustls"]

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Ensures that clients can correctly parse datetime (timestamps) with offsets

    /// Test ID: AwsQueryDateTimeWithNegativeOffset

    #[::tokio::test]

    async fn aws_query_date_time_with_negative_offset_response() {

        let expected_output = crate::operation::datetime_offsets::DatetimeOffsetsOutput::builder()

            .set_datetime(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(

                1576540098, 0_f64,

            )))

            .build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

        .header("Content-Type", "text/xml")

        .status(200)

                    .body(::aws_smithy_types::body::SdkBody::from("<DatetimeOffsetsResponse xmlns=\"https://example.com/\">\n    <DatetimeOffsetsResult>\n        <datetime>2019-12-16T22:48:18-01:00</datetime>\n    </DatetimeOffsetsResult>\n</DatetimeOffsetsResponse>\n"))

                    .unwrap()

                    ).unwrap();

        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;

        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;

        let op = crate::operation::datetime_offsets::DatetimeOffsets::new();

        let config = op.config().expect("the operation has config");

        let de = config

            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()

            .expect("the config must have a deserializer");

        let parsed = de.deserialize_streaming(&mut http_response);

        let parsed = parsed.unwrap_or_else(|| {

            let http_response =

                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));

            de.deserialize_nonstreaming(&http_response)

        });

        let parsed = parsed

            .expect("should be successful response")

            .downcast::<crate::operation::datetime_offsets::DatetimeOffsetsOutput>()

            .unwrap();

        ::pretty_assertions::assert_eq!(parsed.datetime, expected_output.datetime, "Unexpected value for `datetime`");

    }

    /// Ensures that clients can correctly parse datetime (timestamps) with offsets

    /// Test ID: AwsQueryDateTimeWithPositiveOffset

    #[::tokio::test]

    async fn aws_query_date_time_with_positive_offset_response() {

        let expected_output = crate::operation::datetime_offsets::DatetimeOffsetsOutput::builder()

            .set_datetime(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(

                1576540098, 0_f64,

            )))

            .build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

        .header("Content-Type", "text/xml")

        .status(200)

                    .body(::aws_smithy_types::body::SdkBody::from("<DatetimeOffsetsResponse xmlns=\"https://example.com/\">\n    <DatetimeOffsetsResult>\n        <datetime>2019-12-17T00:48:18+01:00</datetime>\n    </DatetimeOffsetsResult>\n</DatetimeOffsetsResponse>\n"))

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Empty input serializes no extra query params

    /// Test ID: QueryEmptyInputAndEmptyOutput

    #[::tokio::test]

    async fn query_empty_input_and_empty_output_request() {

        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);

        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");

        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());

        let result = client.empty_input_and_empty_output().send().await;

        let _ = dbg!(result);

        let http_request = request_receiver.expect_request();

        let expected_headers = [("Content-Type", "application/x-www-form-urlencoded")];

        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));

        let body = http_request.body().bytes().expect("body should be strict");

        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(

            body,

            "Action=EmptyInputAndEmptyOutput&Version=2020-01-08",

            ::aws_smithy_protocol_test::MediaType::from("application/x-www-form-urlencoded"),

        ));

        let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");

        ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");

        ::pretty_assertions::assert_eq!(uri.path(), "/", "path was incorrect");

    }

    /// Empty output

    /// Test ID: QueryEmptyInputAndEmptyOutput

    #[::tokio::test]

    async fn query_empty_input_and_empty_output_response() {

        let expected_output = crate::operation::empty_input_and_empty_output::EmptyInputAndEmptyOutputOutput::builder().build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(

            ::http::response::Builder::new()

                .status(200)

                .body(::aws_smithy_types::body::SdkBody::from(vec![]))

                .unwrap(),

        )

        .unwrap();

        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Operations can prepend to the given host if they define the

    /// endpoint trait.

    /// Test ID: AwsQueryEndpointTrait

    #[::tokio::test]

    async fn aws_query_endpoint_trait_request() {

        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);

        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");

        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());

        let result = client.endpoint_operation().send().await;

        let _ = dbg!(result);

        let http_request = request_receiver.expect_request();

        let expected_headers = [("Content-Type", "application/x-www-form-urlencoded")];

        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Operations can prepend to the given host if they define the

    /// endpoint trait, and can use the host label trait to define

    /// further customization based on user input.

    /// Test ID: AwsQueryEndpointTraitWithHostLabel

    #[::tokio::test]

    async fn aws_query_endpoint_trait_with_host_label_request() {

        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);

        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");

        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());

        let result = client

            .endpoint_with_host_label_operation()

            .set_label(::std::option::Option::Some("bar".to_owned()))

            .send()

            .await;

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Serializes flattened XML maps in responses

    /// Test ID: QueryQueryFlattenedXmlMap

    #[::tokio::test]

    async fn query_query_flattened_xml_map_response() {

        let expected_output = crate::operation::flattened_xml_map::FlattenedXmlMapOutput::builder()

            .set_my_map(::std::option::Option::Some({

                let mut ret = ::std::collections::HashMap::new();

                ret.insert(

                    "foo".to_owned(),

                    "Foo".parse::<crate::types::FooEnum>().expect("static value validated to member"),

                );

                ret.insert(

                    "baz".to_owned(),

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Serializes flattened XML maps in responses that have xmlName on members

    /// Test ID: QueryQueryFlattenedXmlMapWithXmlName

    #[::tokio::test]

    async fn query_query_flattened_xml_map_with_xml_name_response() {

        let expected_output = crate::operation::flattened_xml_map_with_xml_name::FlattenedXmlMapWithXmlNameOutput::builder()

            .set_my_map(::std::option::Option::Some({

                let mut ret = ::std::collections::HashMap::new();

                ret.insert("a".to_owned(), "A".to_owned());

                ret.insert("b".to_owned(), "B".to_owned());

                ret

            }))

            .build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Serializes flattened XML maps in responses that have xmlNamespace and xmlName on members

    /// Test ID: QueryQueryFlattenedXmlMapWithXmlNamespace

    #[::tokio::test]

    async fn query_query_flattened_xml_map_with_xml_namespace_response() {

        let expected_output = crate::operation::flattened_xml_map_with_xml_namespace::FlattenedXmlMapWithXmlNamespaceOutput::builder()

            .set_my_map(::std::option::Option::Some({

                let mut ret = ::std::collections::HashMap::new();

                ret.insert("a".to_owned(), "A".to_owned());

                ret.insert("b".to_owned(), "B".to_owned());

                ret

            }))

            .build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Ensures that clients can correctly parse datetime timestamps with fractional seconds

    /// Test ID: AwsQueryDateTimeWithFractionalSeconds

    #[::tokio::test]

    async fn aws_query_date_time_with_fractional_seconds_response() {

        let expected_output = crate::operation::fractional_seconds::FractionalSecondsOutput::builder()

            .set_datetime(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(

                946845296, 0.123_f64,

            )))

            .build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

        .header("Content-Type", "text/xml")

        .status(200)

                    .body(::aws_smithy_types::body::SdkBody::from("<FractionalSecondsResponse xmlns=\"https://example.com/\">\n    <FractionalSecondsResult>\n        <datetime>2000-01-02T20:34:56.123Z</datetime>\n    </FractionalSecondsResult>\n</FractionalSecondsResponse>\n"))

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Ensures that operations with errors successfully know how to deserialize the successful response

    /// Test ID: QueryGreetingWithErrors

    #[::tokio::test]

    async fn query_greeting_with_errors_response() {

        let expected_output = crate::operation::greeting_with_errors::GreetingWithErrorsOutput::builder()

            .set_greeting(::std::option::Option::Some("Hello".to_owned()))

            .build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

        .header("Content-Type", "text/xml")

        .status(200)

                    .body(::aws_smithy_types::body::SdkBody::from("<GreetingWithErrorsResponse xmlns=\"https://example.com/\">\n    <GreetingWithErrorsResult>\n        <greeting>Hello</greeting>\n    </GreetingWithErrorsResult>\n</GreetingWithErrorsResponse>\n"))

                    .unwrap()

                    ).unwrap();

        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;

        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;

        let op = crate::operation::greeting_with_errors::GreetingWithErrors::new();

        let config = op.config().expect("the operation has config");

        let de = config

            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()

            .expect("the config must have a deserializer");

        let parsed = de.deserialize_streaming(&mut http_response);

        let parsed = parsed.unwrap_or_else(|| {

            let http_response =

                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));

            de.deserialize_nonstreaming(&http_response)

        });

        let parsed = parsed

            .expect("should be successful response")

            .downcast::<crate::operation::greeting_with_errors::GreetingWithErrorsOutput>()

            .unwrap();

        ::pretty_assertions::assert_eq!(parsed.greeting, expected_output.greeting, "Unexpected value for `greeting`");

    }

    /// Parses simple XML errors

    /// Test ID: QueryInvalidGreetingError

    #[::tokio::test]

    async fn query_invalid_greeting_error_response() {

        let expected_output = crate::types::error::InvalidGreeting::builder()

            .set_message(::std::option::Option::Some("Hi".to_owned()))

            .build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

        .header("Content-Type", "text/xml")

        .status(400)

                    .body(::aws_smithy_types::body::SdkBody::from("<ErrorResponse>\n   <Error>\n      <Type>Sender</Type>\n      <Code>InvalidGreeting</Code>\n      <Message>Hi</Message>\n   </Error>\n   <RequestId>foo-id</RequestId>\n</ErrorResponse>\n"))

                    .unwrap()

                    ).unwrap();

        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;

        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;

        let op = crate::operation::greeting_with_errors::GreetingWithErrors::new();

        let config = op.config().expect("the operation has config");

        let de = config

            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()

            .expect("the config must have a deserializer");

        let parsed = de.deserialize_streaming(&mut http_response);

        let parsed = parsed.unwrap_or_else(|| {

            let http_response =

                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));

            de.deserialize_nonstreaming(&http_response)

        });

        let parsed = parsed.expect_err("should be error response");

        let parsed: &crate::operation::greeting_with_errors::GreetingWithErrorsError =

            parsed.as_operation_error().expect("operation error").downcast_ref().unwrap();

        if let crate::operation::greeting_with_errors::GreetingWithErrorsError::InvalidGreeting(parsed) = parsed {

            ::pretty_assertions::assert_eq!(parsed.message, expected_output.message, "Unexpected value for `message`");

        } else {

            panic!("wrong variant: Got: {:?}. Expected: {:?}", parsed, expected_output);

        }

    }

    /// Test ID: QueryComplexError

    #[::tokio::test]

    async fn query_complex_error_response() {

        let expected_output = crate::types::error::ComplexError::builder()

            .set_top_level(::std::option::Option::Some("Top level".to_owned()))

            .set_nested(::std::option::Option::Some(

                crate::types::ComplexNestedErrorData::builder()

                    .set_foo(::std::option::Option::Some("bar".to_owned()))

                    .build(),

            ))

            .build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

        .header("Content-Type", "text/xml")

        .status(400)

                    .body(::aws_smithy_types::body::SdkBody::from("<ErrorResponse>\n   <Error>\n      <Type>Sender</Type>\n      <Code>ComplexError</Code>\n      <TopLevel>Top level</TopLevel>\n      <Nested>\n          <Foo>bar</Foo>\n      </Nested>\n   </Error>\n   <RequestId>foo-id</RequestId>\n</ErrorResponse>\n"))

                    .unwrap()

                    ).unwrap();

        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;

        use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;

        let op = crate::operation::greeting_with_errors::GreetingWithErrors::new();

        let config = op.config().expect("the operation has config");

        let de = config

            .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()

            .expect("the config must have a deserializer");

        let parsed = de.deserialize_streaming(&mut http_response);

        let parsed = parsed.unwrap_or_else(|| {

            let http_response =

                http_response.map(|body| ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(body.bytes().unwrap())));

            de.deserialize_nonstreaming(&http_response)

        });

        let parsed = parsed.expect_err("should be error response");

        let parsed: &crate::operation::greeting_with_errors::GreetingWithErrorsError =

            parsed.as_operation_error().expect("operation error").downcast_ref().unwrap();

        if let crate::operation::greeting_with_errors::GreetingWithErrorsError::ComplexError(parsed) = parsed {

            ::pretty_assertions::assert_eq!(parsed.top_level, expected_output.top_level, "Unexpected value for `top_level`");

            ::pretty_assertions::assert_eq!(parsed.nested, expected_output.nested, "Unexpected value for `nested`");

        } else {

            panic!("wrong variant: Got: {:?}. Expected: {:?}", parsed, expected_output);

        }

    }

    /// Parses customized XML errors

    /// Test ID: QueryCustomizedError

    #[::tokio::test]

    async fn query_customized_error_response() {

        let expected_output = crate::types::error::CustomCodeError::builder()

            .set_message(::std::option::Option::Some("Hi".to_owned()))

            .build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

        .header("Content-Type", "text/xml")

        .status(402)

                    .body(::aws_smithy_types::body::SdkBody::from("<ErrorResponse>\n   <Error>\n      <Type>Sender</Type>\n      <Code>Customized</Code>\n      <Message>Hi</Message>\n   </Error>\n   <RequestId>foo-id</RequestId>\n</ErrorResponse>\n"))

                    .unwrap()

                    ).unwrap();

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Custom endpoints supplied by users can have paths

    /// Test ID: QueryHostWithPath

    #[::tokio::test]

    async fn query_host_with_path_request() {

        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);

        let config_builder = crate::config::Config::builder()

            .with_test_defaults()

            .endpoint_url("https://example.com/custom");

        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());

        let result = client.host_with_path_operation().send().await;

        let _ = dbg!(result);

        let http_request = request_receiver.expect_request();

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// The xmlName trait on the output structure is ignored in AWS Query

    /// Test ID: QueryIgnoresWrappingXmlName

    #[::tokio::test]

    async fn query_ignores_wrapping_xml_name_response() {

        let expected_output = crate::operation::ignores_wrapping_xml_name::IgnoresWrappingXmlNameOutput::builder()

            .set_foo(::std::option::Option::Some("bar".to_owned()))

            .build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(::http::response::Builder::new()

        .header("Content-Type", "text/xml")

        .status(200)

                    .body(::aws_smithy_types::body::SdkBody::from("<IgnoresWrappingXmlNameResponse xmlns=\"https://example.com/\">\n    <IgnoresWrappingXmlNameResult>\n        <foo>bar</foo>\n    </IgnoresWrappingXmlNameResult>\n</IgnoresWrappingXmlNameResponse>\n"))

                    .unwrap()

                    ).unwrap();

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// Serializes nested structures using dots

    /// Test ID: NestedStructures

    #[::tokio::test]

    async fn nested_structures_request() {

        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);

        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");

        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());

        let result = client

            .nested_structures()

            .set_nested(::std::option::Option::Some(

                crate::types::StructArg::builder()

                    .set_string_arg(::std::option::Option::Some("foo".to_owned()))

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// No input serializes no additional query params

    /// Test ID: QueryNoInputAndNoOutput

    #[::tokio::test]

    async fn query_no_input_and_no_output_request() {

        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);

        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");

        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());

        let result = client.no_input_and_no_output().send().await;

        let _ = dbg!(result);

        let http_request = request_receiver.expect_request();

        let expected_headers = [("Content-Type", "application/x-www-form-urlencoded")];

        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));

        let body = http_request.body().bytes().expect("body should be strict");

        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(

            body,

            "Action=NoInputAndNoOutput&Version=2020-01-08",

            ::aws_smithy_protocol_test::MediaType::from("application/x-www-form-urlencoded"),

        ));

        let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");

        ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");

        ::pretty_assertions::assert_eq!(uri.path(), "/", "path was incorrect");

    }

    /// Empty output. Note that no assertion is made on the output body itself.

    /// Test ID: QueryNoInputAndNoOutput

    #[::tokio::test]

    async fn query_no_input_and_no_output_response() {

        let expected_output = crate::operation::no_input_and_no_output::NoInputAndNoOutputOutput::builder().build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(

            ::http::response::Builder::new()

                .status(200)

                .body(::aws_smithy_types::body::SdkBody::from(vec![]))

                .unwrap(),

        )

        .unwrap();

        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;

        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {

            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)

        })?;

        cfg.interceptor_state()

            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));

        ::std::result::Result::Ok(())

    }

}

#[allow(unreachable_code, unused_variables)]

#[cfg(test)]

    /// No input serializes no payload

    /// Test ID: QueryNoInputAndOutput

    #[::tokio::test]

    async fn query_no_input_and_output_request() {

        let (http_client, request_receiver) = ::aws_smithy_runtime::client::http::test_util::capture_request(None);

        let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");

        let client = crate::Client::from_conf(config_builder.http_client(http_client).build());

        let result = client.no_input_and_output().send().await;

        let _ = dbg!(result);

        let http_request = request_receiver.expect_request();

        let expected_headers = [("Content-Type", "application/x-www-form-urlencoded")];

        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));

        let body = http_request.body().bytes().expect("body should be strict");

        ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(

            body,

            "Action=NoInputAndOutput&Version=2020-01-08",

            ::aws_smithy_protocol_test::MediaType::from("application/x-www-form-urlencoded"),

        ));

        let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");

        ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");

        ::pretty_assertions::assert_eq!(uri.path(), "/", "path was incorrect");

    }

    /// Empty output

    /// Test ID: QueryNoInputAndOutput

    #[::tokio::test]

    async fn query_no_input_and_output_response() {

        let expected_output = crate::operation::no_input_and_output::NoInputAndOutputOutput::builder().build();

        let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(

            ::http::response::Builder::new()

                .status(200)

                .body(::aws_smithy_types::body::SdkBody::from(vec![]))

                .unwrap(),

        )

        .unwrap();

        use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;