Server Test Python

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

#[allow(clippy::unnecessary_wraps)]

pub async fn de_all_query_string_types_http_request<B>(

    #[allow(unused_variables)] request: ::http::Request<B>,

) -> std::result::Result<

    crate::input::AllQueryStringTypesInput,

>

where

    B::Data: Send,

{

    Ok({

        #[allow(unused_mut)]

        let mut input = crate::input::all_query_string_types_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();

        let query_string = uri.query().unwrap_or("");

        let pairs = ::form_urlencoded::parse(query_string.as_bytes());

            input = input.set_query_timestamp_list(Some(query_timestamp_list));

        }

        input.build()?

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_all_query_string_types_http_response(

    #[allow(unused_variables)] output: crate::output::AllQueryStringTypesOutput,

) -> std::result::Result<

> {

    Ok({

        #[allow(unused_mut)]

        let mut builder = ::http::Response::builder();

            builder,

            ::http::header::CONTENT_TYPE,

            "application/json",

        );

        let http_status: u16 = 200;

        builder = builder.status(http_status);

        let payload = "";

        let content_length = payload.len();

            builder,

            ::http::header::CONTENT_LENGTH,

            content_length,

        );

        builder.body(body)?

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_all_query_string_types_http_error(

    error: &crate::error::AllQueryStringTypesError,

) -> std::result::Result<

> {

    Ok({

        match error {

            crate::error::AllQueryStringTypesError::ValidationException(output) => {

                let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;

                #[allow(unused_mut)]

                let mut builder = ::http::Response::builder();

                    builder,

                    ::http::header::CONTENT_TYPE,

                    "application/json",

                );

                    builder,

                    ::http::header::HeaderName::from_static("x-amzn-errortype"),

                    "ValidationException",

                );

                let content_length = payload.len();

                    builder,

                    ::http::header::CONTENT_LENGTH,

                    content_length,

                );

                builder

                    .status(400)

            }

            crate::error::AllQueryStringTypesError::InternalServerError(output) => {

                let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;

                #[allow(unused_mut)]

                let mut builder = ::http::Response::builder();

                    builder,

                    ::http::header::CONTENT_TYPE,

                    "application/json",

                );

                    builder,

                    ::http::header::HeaderName::from_static("x-amzn-errortype"),

                    "InternalServerError",

                );

                let content_length = payload.len();

                    builder,

                    ::http::header::CONTENT_LENGTH,

                    content_length,

                );

                builder

                    .status(500)

            }

        }

    })

}

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

pub fn de_query_boolean(

    value: &str,

) -> std::result::Result<

    ::std::option::Option<bool>,

> {

    let value = <_ as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(value)?;

    Ok(Some(value))

}

pub fn de_query_byte(

    value: &str,

) -> std::result::Result<

    ::std::option::Option<i8>,

> {

    let value = <_ as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(value)?;

    Ok(Some(value))

}

pub fn de_query_double(

    value: &str,

) -> std::result::Result<

    ::std::option::Option<f64>,

> {

    let value = <_ as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(value)?;

    Ok(Some(value))

}

pub fn de_query_enum(

    value: &str,

) -> std::result::Result<

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

> {

    let value = value.to_owned();

    Ok(Some(value))

}

pub fn de_query_float(

    value: &str,

) -> std::result::Result<

    ::std::option::Option<f32>,

> {

    let value = <_ as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(value)?;

    Ok(Some(value))

}

pub fn de_query_integer(

    value: &str,

) -> std::result::Result<

    ::std::option::Option<i32>,

> {

    let value = <_ as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(value)?;

    Ok(Some(value))

}

pub fn de_query_integer_enum(

    value: &str,

) -> std::result::Result<

    ::std::option::Option<i32>,

> {

    let value = <_ as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(value)?;

    Ok(Some(value))

}

pub fn de_query_long(

    value: &str,

) -> std::result::Result<

    ::std::option::Option<i64>,

> {

    let value = <_ as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(value)?;

    Ok(Some(value))

}

pub fn de_query_short(

    value: &str,

) -> std::result::Result<

    ::std::option::Option<i16>,

> {

    let value = <_ as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(value)?;

    Ok(Some(value))

}

pub fn de_query_string(

    value: &str,

) -> std::result::Result<

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

> {

    let value = value.to_owned();

    Ok(Some(value))

}

pub fn de_query_timestamp(

    value: &str,

) -> std::result::Result<

    ::std::option::Option<::aws_smithy_http_server_python::types::DateTime>,

> {

    let value = ::aws_smithy_types::DateTime::from_str(

        value,

        ::aws_smithy_types::date_time::Format::DateTime,

    )?

    .into();

    Ok(Some(value))

}

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

#[allow(clippy::unnecessary_wraps)]

pub async fn de_constant_and_variable_query_string_http_request<B>(

    #[allow(unused_variables)] request: ::http::Request<B>,

) -> std::result::Result<

    crate::input::ConstantAndVariableQueryStringInput,

>

where

    B::Data: Send,

{

    Ok({

        #[allow(unused_mut)]

        let mut input =

            crate::input::constant_and_variable_query_string_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();

        let query_string = uri.query().unwrap_or("");

        let pairs = ::form_urlencoded::parse(query_string.as_bytes());

        let mut baz_seen = false;

        let mut maybe_set_seen = false;

        for (k, v) in pairs {

            if !baz_seen && k == "baz" {

                input = input.set_baz(

                    crate::protocol_serde::shape_constant_and_variable_query_string_input::de_baz(

                        &v,

                    )?,

                );

                baz_seen = true;

            }

            if !maybe_set_seen && k == "maybeSet" {

                input = input.set_maybe_set(

                    crate::protocol_serde::shape_constant_and_variable_query_string_input::de_maybe_set(&v)?

                );

                maybe_set_seen = true;

            }

        }

        input.build()

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_constant_and_variable_query_string_http_response(

    #[allow(unused_variables)] output: crate::output::ConstantAndVariableQueryStringOutput,

) -> std::result::Result<

> {

    Ok({

        #[allow(unused_mut)]

        let mut builder = ::http::Response::builder();

            builder,

            ::http::header::CONTENT_TYPE,

            "application/json",

        );

        let http_status: u16 = 200;

        builder = builder.status(http_status);

        let payload = "";

        let content_length = payload.len();

            builder,

            ::http::header::CONTENT_LENGTH,

            content_length,

        );

        builder.body(body)?

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_constant_and_variable_query_string_http_error(

    error: &crate::error::ConstantAndVariableQueryStringError,

) -> std::result::Result<

> {

    Ok({

        match error {

            crate::error::ConstantAndVariableQueryStringError::InternalServerError(output) => {

                let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;

                #[allow(unused_mut)]

                let mut builder = ::http::Response::builder();

                    builder,

                    ::http::header::CONTENT_TYPE,

                    "application/json",

                );

                    builder,

                    ::http::header::HeaderName::from_static("x-amzn-errortype"),

                    "InternalServerError",

                );

                let content_length = payload.len();

                    builder,

                    ::http::header::CONTENT_LENGTH,

                    content_length,

                );

                builder

                    .status(500)

            }

        }

    })

}

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

pub fn de_baz(

    value: &str,

) -> std::result::Result<

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

> {

    let value = value.to_owned();

    Ok(Some(value))

}

pub fn de_maybe_set(

    value: &str,

) -> std::result::Result<

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

> {

    let value = value.to_owned();

    Ok(Some(value))

}

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

#[allow(clippy::unnecessary_wraps)]

pub async fn de_constant_query_string_http_request<B>(

    #[allow(unused_variables)] request: ::http::Request<B>,

) -> std::result::Result<

    crate::input::ConstantQueryStringInput,

>

where

    B::Data: Send,

{

    Ok({

        #[allow(unused_mut)]

        let mut input = crate::input::constant_query_string_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();

        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>>(

                        "ConstantQueryString",

                    ),

                ),

                ::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_hello(crate::protocol_serde::shape_constant_query_string_input::de_hello(m1)?);

        input.build()?

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_constant_query_string_http_response(

    #[allow(unused_variables)] output: crate::output::ConstantQueryStringOutput,

) -> std::result::Result<

> {

    Ok({

        #[allow(unused_mut)]

        let mut builder = ::http::Response::builder();

            builder,

            ::http::header::CONTENT_TYPE,

            "application/json",

        );

        let http_status: u16 = 200;

        builder = builder.status(http_status);

        let payload = "";

        let content_length = payload.len();

            builder,

            ::http::header::CONTENT_LENGTH,

            content_length,

        );

        builder.body(body)?

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_constant_query_string_http_error(

    error: &crate::error::ConstantQueryStringError,

) -> std::result::Result<

> {

    Ok({

        match error {

            crate::error::ConstantQueryStringError::ValidationException(output) => {

                let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;

                #[allow(unused_mut)]

                let mut builder = ::http::Response::builder();

                    builder,

                    ::http::header::CONTENT_TYPE,

                    "application/json",

                );

                    builder,

                    ::http::header::HeaderName::from_static("x-amzn-errortype"),

                    "ValidationException",

                );

                let content_length = payload.len();

                    builder,

                    ::http::header::CONTENT_LENGTH,

                    content_length,

                );

                builder

                    .status(400)

            }

            crate::error::ConstantQueryStringError::InternalServerError(output) => {

                let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;

                #[allow(unused_mut)]

                let mut builder = ::http::Response::builder();

                    builder,

                    ::http::header::CONTENT_TYPE,

                    "application/json",

                );

                    builder,

                    ::http::header::HeaderName::from_static("x-amzn-errortype"),

                    "InternalServerError",

                );

                let content_length = payload.len();

                    builder,

                    ::http::header::CONTENT_LENGTH,

                    content_length,

                );

                builder

                    .status(500)

            }

        }

    })

}

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

pub fn de_hello(

    value: &str,

) -> std::result::Result<

    ::std::string::String,

> {

    let value = ::percent_encoding::percent_decode_str(value)

        .decode_utf8()?

        .into_owned();

    Ok(value)

}

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

#[allow(clippy::unnecessary_wraps)]

pub async fn de_content_type_parameters_http_request<B>(

    #[allow(unused_variables)] request: ::http::Request<B>,

) -> std::result::Result<

    crate::input::ContentTypeParametersInput,

>

where

    B::Data: Send,

{

    Ok({

        #[allow(unused_mut)]

        let mut input = crate::input::content_type_parameters_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();

        let bytes = ::hyper::body::to_bytes(body).await?;

        if !bytes.is_empty() {

                &headers,

                Some("application/json"),

            )?;

            input =

                crate::protocol_serde::shape_content_type_parameters::de_content_type_parameters(

                    bytes.as_ref(),

                    input,

                )?;

        }

        input.build()

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_content_type_parameters_http_response(

    #[allow(unused_variables)] output: crate::output::ContentTypeParametersOutput,

) -> std::result::Result<

> {

    Ok({

        #[allow(unused_mut)]

        let mut builder = ::http::Response::builder();

            builder,

            ::http::header::CONTENT_TYPE,

            "application/json",

        );

        let http_status: u16 = 200;

        builder = builder.status(http_status);

        let payload =

            crate::protocol_serde::shape_content_type_parameters_output::ser_content_type_parameters_output_output_output(&output)?

        ;

        let content_length = payload.len();

            builder,

            ::http::header::CONTENT_LENGTH,

            content_length,

        );

        builder.body(body)?

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_content_type_parameters_http_error(

    error: &crate::error::ContentTypeParametersError,

) -> std::result::Result<

> {

    Ok({

        match error {

            crate::error::ContentTypeParametersError::InternalServerError(output) => {

                let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;

                #[allow(unused_mut)]

                let mut builder = ::http::Response::builder();

                    builder,

                    ::http::header::CONTENT_TYPE,

                    "application/json",

                );

                    builder,

                    ::http::header::HeaderName::from_static("x-amzn-errortype"),

                    "InternalServerError",

                );

                let content_length = payload.len();

                    builder,

                    ::http::header::CONTENT_LENGTH,

                    content_length,

                );

                builder

                    .status(500)

            }

        }

    })

}

pub(crate) fn de_content_type_parameters(

    value: &[u8],

    mut builder: crate::input::content_type_parameters_input_internal::Builder,

) -> ::std::result::Result<

    crate::input::content_type_parameters_input_internal::Builder,

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

#[allow(clippy::unnecessary_wraps)]

pub async fn de_datetime_offsets_http_request<B>(

    #[allow(unused_variables)] request: ::http::Request<B>,

) -> std::result::Result<

    crate::input::DatetimeOffsetsInput,

>

where

    B::Data: Send,

{

    Ok({

        #[allow(unused_mut)]

        let mut input = crate::input::datetime_offsets_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();

        input.build()

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_datetime_offsets_http_response(

    #[allow(unused_variables)] output: crate::output::DatetimeOffsetsOutput,

) -> std::result::Result<

> {

    Ok({

        #[allow(unused_mut)]

        let mut builder = ::http::Response::builder();

            builder,

            ::http::header::CONTENT_TYPE,

            "application/json",

        );

        let http_status: u16 = 200;

        builder = builder.status(http_status);

        let payload =

            crate::protocol_serde::shape_datetime_offsets_output::ser_datetime_offsets_output_output_output(&output)?

        ;

        let content_length = payload.len();

            builder,

            ::http::header::CONTENT_LENGTH,

            content_length,

        );

        builder.body(body)?

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_datetime_offsets_http_error(

    error: &crate::error::DatetimeOffsetsError,

) -> std::result::Result<

> {

    Ok({

        match error {

            crate::error::DatetimeOffsetsError::InternalServerError(output) => {

                let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;

                #[allow(unused_mut)]

                let mut builder = ::http::Response::builder();

                    builder,

                    ::http::header::CONTENT_TYPE,

                    "application/json",

                );

                    builder,

                    ::http::header::HeaderName::from_static("x-amzn-errortype"),

                    "InternalServerError",

                );

                let content_length = payload.len();

                    builder,

                    ::http::header::CONTENT_LENGTH,

                    content_length,

                );

                builder

                    .status(500)

            }

        }

    })

}

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

#[allow(clippy::unnecessary_wraps)]

pub async fn de_document_type_http_request<B>(

    #[allow(unused_variables)] request: ::http::Request<B>,

) -> std::result::Result<

    crate::input::DocumentTypeInput,

>

where

    B::Data: Send,

{

    Ok({

        #[allow(unused_mut)]

        let mut input = crate::input::document_type_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();

        let bytes = ::hyper::body::to_bytes(body).await?;

        if !bytes.is_empty() {

                &headers,

                Some("application/json"),

            )?;

            input = crate::protocol_serde::shape_document_type::de_document_type(

                bytes.as_ref(),

                input,

            )?;

        }

        input.build()

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_document_type_http_response(

    #[allow(unused_variables)] output: crate::output::DocumentTypeOutput,

) -> std::result::Result<

> {

    Ok({

        #[allow(unused_mut)]

        let mut builder = ::http::Response::builder();

            builder,

            ::http::header::CONTENT_TYPE,

            "application/json",

        );

        let http_status: u16 = 200;

        builder = builder.status(http_status);

        let payload =

            crate::protocol_serde::shape_document_type_output::ser_document_type_output_output_output(&output)?

        ;

        let content_length = payload.len();

            builder,

            ::http::header::CONTENT_LENGTH,

            content_length,

        );

        builder.body(body)?

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_document_type_http_error(

    error: &crate::error::DocumentTypeError,

) -> std::result::Result<

> {

    Ok({

        match error {

            crate::error::DocumentTypeError::InternalServerError(output) => {

                let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;

                #[allow(unused_mut)]

                let mut builder = ::http::Response::builder();

                    builder,

                    ::http::header::CONTENT_TYPE,

                    "application/json",

                );

                    builder,

                    ::http::header::HeaderName::from_static("x-amzn-errortype"),

                    "InternalServerError",

                );

                let content_length = payload.len();

                    builder,

                    ::http::header::CONTENT_LENGTH,

                    content_length,

                );

                builder

                    .status(500)

            }

        }

    })

}

pub(crate) fn de_document_type(

    value: &[u8],

    mut builder: crate::input::document_type_input_internal::Builder,

) -> ::std::result::Result<

    crate::input::document_type_input_internal::Builder,

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

#[allow(clippy::unnecessary_wraps)]

pub async fn de_document_type_as_map_value_http_request<B>(

    #[allow(unused_variables)] request: ::http::Request<B>,

) -> std::result::Result<

    crate::input::DocumentTypeAsMapValueInput,

>

where

    B::Data: Send,

{

    Ok({

        #[allow(unused_mut)]

        let mut input = crate::input::document_type_as_map_value_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();

        let bytes = ::hyper::body::to_bytes(body).await?;

        if !bytes.is_empty() {

                &headers,

                Some("application/json"),

            )?;

            input = crate::protocol_serde::shape_document_type_as_map_value::de_document_type_as_map_value(bytes.as_ref(), input)?;

        }

        input.build()

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_document_type_as_map_value_http_response(

    #[allow(unused_variables)] output: crate::output::DocumentTypeAsMapValueOutput,

) -> std::result::Result<

> {

    Ok({

        #[allow(unused_mut)]

        let mut builder = ::http::Response::builder();

            builder,

            ::http::header::CONTENT_TYPE,

            "application/json",

        );

        let http_status: u16 = 200;

        builder = builder.status(http_status);

        let payload =

            crate::protocol_serde::shape_document_type_as_map_value_output::ser_document_type_as_map_value_output_output_output(&output)?

        ;

        let content_length = payload.len();

            builder,

            ::http::header::CONTENT_LENGTH,

            content_length,

        );

        builder.body(body)?

    })

}

#[allow(clippy::unnecessary_wraps)]

pub fn ser_document_type_as_map_value_http_error(

    error: &crate::error::DocumentTypeAsMapValueError,

) -> std::result::Result<

> {

    Ok({

        match error {

            crate::error::DocumentTypeAsMapValueError::InternalServerError(output) => {

                let payload = crate::protocol_serde::shape_internal_server_error::ser_internal_server_error_error(output)?;

                #[allow(unused_mut)]

                let mut builder = ::http::Response::builder();

                    builder,

                    ::http::header::CONTENT_TYPE,

                    "application/json",

                );

                    builder,

                    ::http::header::HeaderName::from_static("x-amzn-errortype"),

                    "InternalServerError",

                );

                let content_length = payload.len();

                    builder,

                    ::http::header::CONTENT_LENGTH,

                    content_length,

                );

                builder

                    .status(500)

            }

        }

    })

}

pub(crate) fn de_document_type_as_map_value(

    value: &[u8],

    mut builder: crate::input::document_type_as_map_value_input_internal::Builder,

) -> ::std::result::Result<

    crate::input::document_type_as_map_value_input_internal::Builder,

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

#[allow(clippy::unnecessary_wraps)]

pub async fn de_document_type_as_payload_http_request<B>(

    #[allow(unused_variables)] request: ::http::Request<B>,

) -> std::result::Result<

    crate::input::DocumentTypeAsPayloadInput,

>

where

    B::Data: Send,

{