Client Test

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

pub fn ser_http_checksum_required_input_input(

    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,

    input: &crate::operation::http_checksum_required::HttpChecksumRequiredInput,

) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {

    if let Some(var_1) = &input.foo {

        object.key("foo").string(var_1.as_str());

    }

    Ok(())

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_empty_prefix_headers_http_error(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<

    crate::operation::http_empty_prefix_headers::HttpEmptyPrefixHeadersOutput,

    crate::operation::http_empty_prefix_headers::HttpEmptyPrefixHeadersError,

> {

    #[allow(unused_mut)]

    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)

        .map_err(crate::operation::http_empty_prefix_headers::HttpEmptyPrefixHeadersError::unhandled)?;

    let generic = generic_builder.build();

    Err(crate::operation::http_empty_prefix_headers::HttpEmptyPrefixHeadersError::generic(generic))

}

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_empty_prefix_headers_http_response(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<

    crate::operation::http_empty_prefix_headers::HttpEmptyPrefixHeadersOutput,

    crate::operation::http_empty_prefix_headers::HttpEmptyPrefixHeadersError,

> {

    Ok({

        #[allow(unused_mut)]

        let mut output = crate::operation::http_empty_prefix_headers::builders::HttpEmptyPrefixHeadersOutputBuilder::default();

        output = output.set_prefix_headers(

            crate::protocol_serde::shape_http_empty_prefix_headers_output::de_prefix_headers_prefix_header(_response_headers).map_err(|_| {

                crate::operation::http_empty_prefix_headers::HttpEmptyPrefixHeadersError::unhandled(

                    "Failed to parse prefixHeaders from prefix header `",

                )

            })?,

        );

        output = output.set_specific_header(

            crate::protocol_serde::shape_http_empty_prefix_headers_output::de_specific_header_header(_response_headers).map_err(|_| {

                crate::operation::http_empty_prefix_headers::HttpEmptyPrefixHeadersError::unhandled(

                    "Failed to parse specificHeader from header `hello",

                )

            })?,

        );

        output.build()

    })

}

pub fn ser_http_empty_prefix_headers_headers(

    input: &crate::operation::http_empty_prefix_headers::HttpEmptyPrefixHeadersInput,

    mut builder: ::http_1x::request::Builder,

) -> std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {

    if let ::std::option::Option::Some(inner_1) = &input.specific_header {

        let formatted_2 = inner_1.as_str();

        let header_value = formatted_2;

        let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {

            ::aws_smithy_types::error::operation::BuildError::invalid_field(

                "specific_header",

                format!("`{}` cannot be used as a header value: {}", &header_value, err),

            )

        })?;

        builder = builder.header("hello", header_value);

    }

    if let ::std::option::Option::Some(inner_3) = &input.prefix_headers {

        {

            for (k, v) in inner_3 {

                use std::str::FromStr;

                let header_name = ::http_1x::HeaderName::from_str(&format!("{}{}", "", &k)).map_err(|err| {

                    ::aws_smithy_types::error::operation::BuildError::invalid_field(

                        "prefix_headers",

                        format!("`{k}` cannot be used as a header name: {err}"),

                    )

                })?;

                let header_value = v.as_str();

                let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {

                    ::aws_smithy_types::error::operation::BuildError::invalid_field(

                        "prefix_headers",

                        format!("`{v}` cannot be used as a header value: {err}"),

                    )

                })?;

                builder = builder.header(header_name, header_value);

            }

        }

    }

    Ok(builder)

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

pub(crate) fn de_prefix_headers_prefix_header(

    header_map: &::aws_smithy_runtime_api::http::Headers,

) -> std::result::Result<

    ::std::option::Option<::std::collections::HashMap<::std::string::String, ::std::string::String>>,

    ::aws_smithy_http::header::ParseError,

> {

    let headers = ::aws_smithy_http::header::headers_for_prefix(header_map.iter().map(|(k, _)| k), "");

    let out: std::result::Result<_, _> = headers.map(|(key, header_name)| {

                            let values = header_map.get_all(header_name);

                            crate::protocol_serde::shape_http_empty_prefix_headers_output::de_prefix_headers_inner(values).map(|v| (key.to_string(), v.expect(

                                "we have checked there is at least one value for this header name; please file a bug report under https://github.com/smithy-lang/smithy-rs/issues"

                            )))

                        }).collect();

    out.map(Some)

}

pub(crate) fn de_specific_header_header(

    header_map: &::aws_smithy_runtime_api::http::Headers,

) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {

    let headers = header_map.get_all("hello");

    ::aws_smithy_http::header::one_or_none(headers)

}

pub fn de_prefix_headers_inner<'a>(

    headers: impl ::std::iter::Iterator<Item = &'a str>,

) -> std::result::Result<Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {

    ::aws_smithy_http::header::one_or_none(headers)

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_enum_payload_http_error(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<crate::operation::http_enum_payload::HttpEnumPayloadOutput, crate::operation::http_enum_payload::HttpEnumPayloadError> {

    #[allow(unused_mut)]

    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)

        .map_err(crate::operation::http_enum_payload::HttpEnumPayloadError::unhandled)?;

    let generic = generic_builder.build();

    Err(crate::operation::http_enum_payload::HttpEnumPayloadError::generic(generic))

}

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_enum_payload_http_response(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<crate::operation::http_enum_payload::HttpEnumPayloadOutput, crate::operation::http_enum_payload::HttpEnumPayloadError> {

    Ok({

        #[allow(unused_mut)]

        let mut output = crate::operation::http_enum_payload::builders::HttpEnumPayloadOutputBuilder::default();

        output = output.set_payload(crate::protocol_serde::shape_http_enum_payload_output::de_payload_payload(_response_body)?);

        output.build()

    })

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

pub fn ser_payload_http_payload(

    payload: ::std::option::Option<crate::types::StringEnum>,

) -> ::std::result::Result<::std::vec::Vec<u8>, ::aws_smithy_types::error::operation::BuildError> {

    let payload = match payload {

        Some(t) => t,

        None => return Ok(Vec::new()),

    };

    Ok(payload.as_str().as_bytes().to_vec())

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

pub(crate) fn de_payload_payload(

    body: &[u8],

) -> std::result::Result<::std::option::Option<crate::types::StringEnum>, crate::operation::http_enum_payload::HttpEnumPayloadError> {

    (!body.is_empty())

        .then(|| {

            let body_str = std::str::from_utf8(body).map_err(crate::operation::http_enum_payload::HttpEnumPayloadError::unhandled)?;

            Ok(crate::types::StringEnum::from(body_str))

        })

        .transpose()

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_payload_traits_http_error(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<crate::operation::http_payload_traits::HttpPayloadTraitsOutput, crate::operation::http_payload_traits::HttpPayloadTraitsError>

{

    #[allow(unused_mut)]

    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)

        .map_err(crate::operation::http_payload_traits::HttpPayloadTraitsError::unhandled)?;

    let generic = generic_builder.build();

    Err(crate::operation::http_payload_traits::HttpPayloadTraitsError::generic(generic))

}

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_payload_traits_http_response(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<crate::operation::http_payload_traits::HttpPayloadTraitsOutput, crate::operation::http_payload_traits::HttpPayloadTraitsError>

{

    Ok({

        #[allow(unused_mut)]

        let mut output = crate::operation::http_payload_traits::builders::HttpPayloadTraitsOutputBuilder::default();

        output = output.set_blob(crate::protocol_serde::shape_http_payload_traits_output::de_blob_payload(_response_body)?);

        output = output.set_foo(

            crate::protocol_serde::shape_http_payload_traits_output::de_foo_header(_response_headers)

                .map_err(|_| crate::operation::http_payload_traits::HttpPayloadTraitsError::unhandled("Failed to parse foo from header `X-Foo"))?,

        );

        output.build()

    })

}

pub fn ser_http_payload_traits_headers(

    input: &crate::operation::http_payload_traits::HttpPayloadTraitsInput,

    mut builder: ::http_1x::request::Builder,

) -> std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {

    if let ::std::option::Option::Some(inner_1) = &input.foo {

        let formatted_2 = inner_1.as_str();

        let header_value = formatted_2;

        let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {

            ::aws_smithy_types::error::operation::BuildError::invalid_field(

                "foo",

                format!("`{}` cannot be used as a header value: {}", &header_value, err),

            )

        })?;

        builder = builder.header("X-Foo", header_value);

    }

    Ok(builder)

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

pub fn ser_blob_http_payload(

    payload: ::std::option::Option<::aws_smithy_types::Blob>,

) -> ::std::result::Result<::std::vec::Vec<u8>, ::aws_smithy_types::error::operation::BuildError> {

    let payload = match payload {

        Some(t) => t,

        None => return Ok(Vec::new()),

    };

    Ok(payload.into_inner())

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

pub(crate) fn de_blob_payload(

    body: &[u8],

) -> std::result::Result<::std::option::Option<::aws_smithy_types::Blob>, crate::operation::http_payload_traits::HttpPayloadTraitsError> {

    (!body.is_empty()).then(|| Ok(::aws_smithy_types::Blob::new(body))).transpose()

}

pub(crate) fn de_foo_header(

    header_map: &::aws_smithy_runtime_api::http::Headers,

) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {

    let headers = header_map.get_all("X-Foo");

    ::aws_smithy_http::header::one_or_none(headers)

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_payload_traits_with_media_type_http_error(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<

    crate::operation::http_payload_traits_with_media_type::HttpPayloadTraitsWithMediaTypeOutput,

    crate::operation::http_payload_traits_with_media_type::HttpPayloadTraitsWithMediaTypeError,

> {

    #[allow(unused_mut)]

    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)

        .map_err(crate::operation::http_payload_traits_with_media_type::HttpPayloadTraitsWithMediaTypeError::unhandled)?;

    let generic = generic_builder.build();

    Err(crate::operation::http_payload_traits_with_media_type::HttpPayloadTraitsWithMediaTypeError::generic(generic))

}

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_payload_traits_with_media_type_http_response(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<

    crate::operation::http_payload_traits_with_media_type::HttpPayloadTraitsWithMediaTypeOutput,

    crate::operation::http_payload_traits_with_media_type::HttpPayloadTraitsWithMediaTypeError,

> {

    Ok({

        #[allow(unused_mut)]

        let mut output = crate::operation::http_payload_traits_with_media_type::builders::HttpPayloadTraitsWithMediaTypeOutputBuilder::default();

        output = output.set_blob(crate::protocol_serde::shape_http_payload_traits_with_media_type_output::de_blob_payload(

            _response_body,

        )?);

        output = output.set_foo(

            crate::protocol_serde::shape_http_payload_traits_with_media_type_output::de_foo_header(_response_headers).map_err(|_| {

                crate::operation::http_payload_traits_with_media_type::HttpPayloadTraitsWithMediaTypeError::unhandled(

                    "Failed to parse foo from header `X-Foo",

                )

            })?,

        );

        output.build()

    })

}

pub fn ser_http_payload_traits_with_media_type_headers(

    input: &crate::operation::http_payload_traits_with_media_type::HttpPayloadTraitsWithMediaTypeInput,

    mut builder: ::http_1x::request::Builder,

) -> std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {

    if let ::std::option::Option::Some(inner_1) = &input.foo {

        let formatted_2 = inner_1.as_str();

        let header_value = formatted_2;

        let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {

            ::aws_smithy_types::error::operation::BuildError::invalid_field(

                "foo",

                format!("`{}` cannot be used as a header value: {}", &header_value, err),

            )

        })?;

        builder = builder.header("X-Foo", header_value);

    }

    Ok(builder)

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

pub fn ser_blob_http_payload(

    payload: ::std::option::Option<::aws_smithy_types::Blob>,

) -> ::std::result::Result<::std::vec::Vec<u8>, ::aws_smithy_types::error::operation::BuildError> {

    let payload = match payload {

        Some(t) => t,

        None => return Ok(Vec::new()),

    };

    Ok(payload.into_inner())

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

pub(crate) fn de_blob_payload(

    body: &[u8],

) -> std::result::Result<

    ::std::option::Option<::aws_smithy_types::Blob>,

    crate::operation::http_payload_traits_with_media_type::HttpPayloadTraitsWithMediaTypeError,

> {

    (!body.is_empty()).then(|| Ok(::aws_smithy_types::Blob::new(body))).transpose()

}

pub(crate) fn de_foo_header(

    header_map: &::aws_smithy_runtime_api::http::Headers,

) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {

    let headers = header_map.get_all("X-Foo");

    ::aws_smithy_http::header::one_or_none(headers)

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_payload_with_structure_http_error(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<

    crate::operation::http_payload_with_structure::HttpPayloadWithStructureOutput,

    crate::operation::http_payload_with_structure::HttpPayloadWithStructureError,

> {

    #[allow(unused_mut)]

    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)

        .map_err(crate::operation::http_payload_with_structure::HttpPayloadWithStructureError::unhandled)?;

    let generic = generic_builder.build();

    Err(crate::operation::http_payload_with_structure::HttpPayloadWithStructureError::generic(

        generic,

    ))

}

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_payload_with_structure_http_response(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<

    crate::operation::http_payload_with_structure::HttpPayloadWithStructureOutput,

    crate::operation::http_payload_with_structure::HttpPayloadWithStructureError,

> {

    Ok({

        #[allow(unused_mut)]

        let mut output = crate::operation::http_payload_with_structure::builders::HttpPayloadWithStructureOutputBuilder::default();

        output = output.set_nested(crate::protocol_serde::shape_http_payload_with_structure_output::de_nested_payload(

            _response_body,

        )?);

        output.build()

    })

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

pub fn ser_nested_http_payload(

    payload: &::std::option::Option<crate::types::NestedPayload>,

) -> ::std::result::Result<::std::vec::Vec<u8>, ::aws_smithy_types::error::operation::BuildError> {

    let payload = match payload.as_ref() {

        Some(t) => t,

        None => return Ok(crate::protocol_serde::rest_json_unset_struct_payload()),

    };

    Ok(crate::protocol_serde::shape_http_payload_with_structure_input::ser_nested_payload(

        payload,

    )?)

}

pub fn ser_nested_payload(

    input: &crate::types::NestedPayload,

) -> std::result::Result<::std::vec::Vec<u8>, ::aws_smithy_types::error::operation::SerializationError> {

    let mut out = String::new();

    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);

    crate::protocol_serde::shape_nested_payload::ser_nested_payload(&mut object, input)?;

    object.finish();

    Ok(out.into_bytes())

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

pub(crate) fn de_nested_payload(

    body: &[u8],

) -> std::result::Result<

    ::std::option::Option<crate::types::NestedPayload>,

    crate::operation::http_payload_with_structure::HttpPayloadWithStructureError,

> {

    (!body.is_empty())

        .then(|| {

            crate::protocol_serde::shape_nested_payload::de_nested_payload_payload(body)

                .map_err(crate::operation::http_payload_with_structure::HttpPayloadWithStructureError::unhandled)

        })

        .transpose()

}

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_payload_with_union_http_error(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<

    crate::operation::http_payload_with_union::HttpPayloadWithUnionOutput,

    crate::operation::http_payload_with_union::HttpPayloadWithUnionError,

> {

    #[allow(unused_mut)]

    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)

        .map_err(crate::operation::http_payload_with_union::HttpPayloadWithUnionError::unhandled)?;

    let generic = generic_builder.build();

    Err(crate::operation::http_payload_with_union::HttpPayloadWithUnionError::generic(generic))

}

#[allow(clippy::unnecessary_wraps)]

pub fn de_http_payload_with_union_http_response(

    _response_status: u16,

    _response_headers: &::aws_smithy_runtime_api::http::Headers,

    _response_body: &[u8],

) -> std::result::Result<

    crate::operation::http_payload_with_union::HttpPayloadWithUnionOutput,

    crate::operation::http_payload_with_union::HttpPayloadWithUnionError,

> {

    Ok({

        #[allow(unused_mut)]

        let mut output = crate::operation::http_payload_with_union::builders::HttpPayloadWithUnionOutputBuilder::default();

        output = output.set_nested(crate::protocol_serde::shape_http_payload_with_union_output::de_nested_payload(

            _response_body,

        )?);

        output.build()

    })

}