AWS SDK

AWS SDK

rev. db10d8b7d1ddffb641e5651cb5b4c7c7d63bda6a (ignoring whitespace)

Files changed:

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_guardrail_sensitive_information_policy_assessment.rs

@@ -0,1 +0,47 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_guardrail_sensitive_information_policy_assessment<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::GuardrailSensitiveInformationPolicyAssessment>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::GuardrailSensitiveInformationPolicyAssessmentBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "piiEntities" => {
          18  +
                            builder = builder.set_pii_entities(
          19  +
                                crate::protocol_serde::shape_guardrail_pii_entity_filter_list::de_guardrail_pii_entity_filter_list(tokens)?,
          20  +
                            );
          21  +
                        }
          22  +
                        "regexes" => {
          23  +
                            builder = builder.set_regexes(crate::protocol_serde::shape_guardrail_regex_filter_list::de_guardrail_regex_filter_list(
          24  +
                                tokens,
          25  +
                            )?);
          26  +
                        }
          27  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          28  +
                    },
          29  +
                    other => {
          30  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          31  +
                            "expected object key or end object, found: {:?}",
          32  +
                            other
          33  +
                        )))
          34  +
                    }
          35  +
                }
          36  +
            }
          37  +
            Ok(Some(
          38  +
                crate::serde_util::guardrail_sensitive_information_policy_assessment_correct_errors(builder)
          39  +
                    .build()
          40  +
                    .map_err(|err| ::aws_smithy_json::deserialize::error::DeserializeError::custom_source("Response was invalid", err))?,
          41  +
            ))
          42  +
        }
          43  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          44  +
            "expected start object or null",
          45  +
        )),
          46  +
    }
          47  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_guardrail_stream_configuration.rs

@@ -0,1 +0,19 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub fn ser_guardrail_stream_configuration(
           3  +
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
           4  +
    input: &crate::types::GuardrailStreamConfiguration,
           5  +
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
           6  +
    {
           7  +
        object.key("guardrailIdentifier").string(input.guardrail_identifier.as_str());
           8  +
    }
           9  +
    {
          10  +
        object.key("guardrailVersion").string(input.guardrail_version.as_str());
          11  +
    }
          12  +
    {
          13  +
        object.key("trace").string(input.trace.as_str());
          14  +
    }
          15  +
    {
          16  +
        object.key("streamProcessingMode").string(input.stream_processing_mode.as_str());
          17  +
    }
          18  +
    Ok(())
          19  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_guardrail_text_block.rs

@@ -0,1 +0,19 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub fn ser_guardrail_text_block(
           3  +
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
           4  +
    input: &crate::types::GuardrailTextBlock,
           5  +
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
           6  +
    {
           7  +
        object.key("text").string(input.text.as_str());
           8  +
    }
           9  +
    if let Some(var_1) = &input.qualifiers {
          10  +
        let mut array_2 = object.key("qualifiers").start_array();
          11  +
        for item_3 in var_1 {
          12  +
            {
          13  +
                array_2.value().string(item_3.as_str());
          14  +
            }
          15  +
        }
          16  +
        array_2.finish();
          17  +
    }
          18  +
    Ok(())
          19  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_guardrail_text_characters_coverage.rs

@@ -0,1 +0,47 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_guardrail_text_characters_coverage<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::GuardrailTextCharactersCoverage>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::GuardrailTextCharactersCoverageBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "guarded" => {
          18  +
                            builder = builder.set_guarded(
          19  +
                                ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
          20  +
                                    .map(i32::try_from)
          21  +
                                    .transpose()?,
          22  +
                            );
          23  +
                        }
          24  +
                        "total" => {
          25  +
                            builder = builder.set_total(
          26  +
                                ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
          27  +
                                    .map(i32::try_from)
          28  +
                                    .transpose()?,
          29  +
                            );
          30  +
                        }
          31  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          32  +
                    },
          33  +
                    other => {
          34  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          35  +
                            "expected object key or end object, found: {:?}",
          36  +
                            other
          37  +
                        )))
          38  +
                    }
          39  +
                }
          40  +
            }
          41  +
            Ok(Some(builder.build()))
          42  +
        }
          43  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          44  +
            "expected start object or null",
          45  +
        )),
          46  +
    }
          47  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_guardrail_topic.rs

@@ -0,1 +0,59 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_guardrail_topic<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::GuardrailTopic>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::GuardrailTopicBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "name" => {
          18  +
                            builder = builder.set_name(
          19  +
                                ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
          20  +
                                    .map(|s| s.to_unescaped().map(|u| u.into_owned()))
          21  +
                                    .transpose()?,
          22  +
                            );
          23  +
                        }
          24  +
                        "type" => {
          25  +
                            builder = builder.set_type(
          26  +
                                ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
          27  +
                                    .map(|s| s.to_unescaped().map(|u| crate::types::GuardrailTopicType::from(u.as_ref())))
          28  +
                                    .transpose()?,
          29  +
                            );
          30  +
                        }
          31  +
                        "action" => {
          32  +
                            builder = builder.set_action(
          33  +
                                ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
          34  +
                                    .map(|s| s.to_unescaped().map(|u| crate::types::GuardrailTopicPolicyAction::from(u.as_ref())))
          35  +
                                    .transpose()?,
          36  +
                            );
          37  +
                        }
          38  +
                        "detected" => {
          39  +
                            builder = builder.set_detected(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
          40  +
                        }
          41  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          42  +
                    },
          43  +
                    other => {
          44  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          45  +
                            "expected object key or end object, found: {:?}",
          46  +
                            other
          47  +
                        )))
          48  +
                    }
          49  +
                }
          50  +
            }
          51  +
            Ok(Some(crate::serde_util::guardrail_topic_correct_errors(builder).build().map_err(
          52  +
                |err| ::aws_smithy_json::deserialize::error::DeserializeError::custom_source("Response was invalid", err),
          53  +
            )?))
          54  +
        }
          55  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          56  +
            "expected start object or null",
          57  +
        )),
          58  +
    }
          59  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_guardrail_topic_list.rs

@@ -0,1 +0,32 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_guardrail_topic_list<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<::std::vec::Vec<crate::types::GuardrailTopic>>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartArray { .. }) => {
          11  +
            let mut items = Vec::new();
          12  +
            loop {
          13  +
                match tokens.peek() {
          14  +
                    Some(Ok(::aws_smithy_json::deserialize::Token::EndArray { .. })) => {
          15  +
                        tokens.next().transpose().unwrap();
          16  +
                        break;
          17  +
                    }
          18  +
                    _ => {
          19  +
                        let value = crate::protocol_serde::shape_guardrail_topic::de_guardrail_topic(tokens)?;
          20  +
                        if let Some(value) = value {
          21  +
                            items.push(value);
          22  +
                        }
          23  +
                    }
          24  +
                }
          25  +
            }
          26  +
            Ok(Some(items))
          27  +
        }
          28  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          29  +
            "expected start array or null",
          30  +
        )),
          31  +
    }
          32  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_guardrail_topic_policy_assessment.rs

@@ -0,1 +0,40 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_guardrail_topic_policy_assessment<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::GuardrailTopicPolicyAssessment>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::GuardrailTopicPolicyAssessmentBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "topics" => {
          18  +
                            builder = builder.set_topics(crate::protocol_serde::shape_guardrail_topic_list::de_guardrail_topic_list(tokens)?);
          19  +
                        }
          20  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          21  +
                    },
          22  +
                    other => {
          23  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          24  +
                            "expected object key or end object, found: {:?}",
          25  +
                            other
          26  +
                        )))
          27  +
                    }
          28  +
                }
          29  +
            }
          30  +
            Ok(Some(
          31  +
                crate::serde_util::guardrail_topic_policy_assessment_correct_errors(builder)
          32  +
                    .build()
          33  +
                    .map_err(|err| ::aws_smithy_json::deserialize::error::DeserializeError::custom_source("Response was invalid", err))?,
          34  +
            ))
          35  +
        }
          36  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          37  +
            "expected start object or null",
          38  +
        )),
          39  +
    }
          40  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_guardrail_trace_assessment.rs

@@ -0,1 +0,53 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_guardrail_trace_assessment<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::GuardrailTraceAssessment>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::GuardrailTraceAssessmentBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "modelOutput" => {
          18  +
                            builder = builder.set_model_output(crate::protocol_serde::shape_model_outputs::de_model_outputs(tokens)?);
          19  +
                        }
          20  +
                        "inputAssessment" => {
          21  +
                            builder = builder.set_input_assessment(
          22  +
                                crate::protocol_serde::shape_guardrail_assessment_map::de_guardrail_assessment_map(tokens)?,
          23  +
                            );
          24  +
                        }
          25  +
                        "outputAssessments" => {
          26  +
                            builder = builder.set_output_assessments(
          27  +
                                crate::protocol_serde::shape_guardrail_assessment_list_map::de_guardrail_assessment_list_map(tokens)?,
          28  +
                            );
          29  +
                        }
          30  +
                        "actionReason" => {
          31  +
                            builder = builder.set_action_reason(
          32  +
                                ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
          33  +
                                    .map(|s| s.to_unescaped().map(|u| u.into_owned()))
          34  +
                                    .transpose()?,
          35  +
                            );
          36  +
                        }
          37  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          38  +
                    },
          39  +
                    other => {
          40  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          41  +
                            "expected object key or end object, found: {:?}",
          42  +
                            other
          43  +
                        )))
          44  +
                    }
          45  +
                }
          46  +
            }
          47  +
            Ok(Some(builder.build()))
          48  +
        }
          49  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          50  +
            "expected start object or null",
          51  +
        )),
          52  +
    }
          53  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_guardrail_usage.rs

@@ -0,1 +0,84 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_guardrail_usage<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::GuardrailUsage>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::GuardrailUsageBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "topicPolicyUnits" => {
          18  +
                            builder = builder.set_topic_policy_units(
          19  +
                                ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
          20  +
                                    .map(i32::try_from)
          21  +
                                    .transpose()?,
          22  +
                            );
          23  +
                        }
          24  +
                        "contentPolicyUnits" => {
          25  +
                            builder = builder.set_content_policy_units(
          26  +
                                ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
          27  +
                                    .map(i32::try_from)
          28  +
                                    .transpose()?,
          29  +
                            );
          30  +
                        }
          31  +
                        "wordPolicyUnits" => {
          32  +
                            builder = builder.set_word_policy_units(
          33  +
                                ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
          34  +
                                    .map(i32::try_from)
          35  +
                                    .transpose()?,
          36  +
                            );
          37  +
                        }
          38  +
                        "sensitiveInformationPolicyUnits" => {
          39  +
                            builder = builder.set_sensitive_information_policy_units(
          40  +
                                ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
          41  +
                                    .map(i32::try_from)
          42  +
                                    .transpose()?,
          43  +
                            );
          44  +
                        }
          45  +
                        "sensitiveInformationPolicyFreeUnits" => {
          46  +
                            builder = builder.set_sensitive_information_policy_free_units(
          47  +
                                ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
          48  +
                                    .map(i32::try_from)
          49  +
                                    .transpose()?,
          50  +
                            );
          51  +
                        }
          52  +
                        "contextualGroundingPolicyUnits" => {
          53  +
                            builder = builder.set_contextual_grounding_policy_units(
          54  +
                                ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
          55  +
                                    .map(i32::try_from)
          56  +
                                    .transpose()?,
          57  +
                            );
          58  +
                        }
          59  +
                        "contentPolicyImageUnits" => {
          60  +
                            builder = builder.set_content_policy_image_units(
          61  +
                                ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
          62  +
                                    .map(i32::try_from)
          63  +
                                    .transpose()?,
          64  +
                            );
          65  +
                        }
          66  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          67  +
                    },
          68  +
                    other => {
          69  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          70  +
                            "expected object key or end object, found: {:?}",
          71  +
                            other
          72  +
                        )))
          73  +
                    }
          74  +
                }
          75  +
            }
          76  +
            Ok(Some(crate::serde_util::guardrail_usage_correct_errors(builder).build().map_err(
          77  +
                |err| ::aws_smithy_json::deserialize::error::DeserializeError::custom_source("Response was invalid", err),
          78  +
            )?))
          79  +
        }
          80  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          81  +
            "expected start object or null",
          82  +
        )),
          83  +
    }
          84  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_guardrail_word_policy_assessment.rs

@@ -0,1 +0,47 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub(crate) fn de_guardrail_word_policy_assessment<'a, I>(
           3  +
    tokens: &mut ::std::iter::Peekable<I>,
           4  +
) -> ::std::result::Result<Option<crate::types::GuardrailWordPolicyAssessment>, ::aws_smithy_json::deserialize::error::DeserializeError>
           5  +
where
           6  +
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
           7  +
{
           8  +
    match tokens.next().transpose()? {
           9  +
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
          10  +
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut builder = crate::types::builders::GuardrailWordPolicyAssessmentBuilder::default();
          13  +
            loop {
          14  +
                match tokens.next().transpose()? {
          15  +
                    Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          16  +
                    Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
          17  +
                        "customWords" => {
          18  +
                            builder = builder.set_custom_words(
          19  +
                                crate::protocol_serde::shape_guardrail_custom_word_list::de_guardrail_custom_word_list(tokens)?,
          20  +
                            );
          21  +
                        }
          22  +
                        "managedWordLists" => {
          23  +
                            builder = builder.set_managed_word_lists(
          24  +
                                crate::protocol_serde::shape_guardrail_managed_word_list::de_guardrail_managed_word_list(tokens)?,
          25  +
                            );
          26  +
                        }
          27  +
                        _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
          28  +
                    },
          29  +
                    other => {
          30  +
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          31  +
                            "expected object key or end object, found: {:?}",
          32  +
                            other
          33  +
                        )))
          34  +
                    }
          35  +
                }
          36  +
            }
          37  +
            Ok(Some(
          38  +
                crate::serde_util::guardrail_word_policy_assessment_correct_errors(builder)
          39  +
                    .build()
          40  +
                    .map_err(|err| ::aws_smithy_json::deserialize::error::DeserializeError::custom_source("Response was invalid", err))?,
          41  +
            ))
          42  +
        }
          43  +
        _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
          44  +
            "expected start object or null",
          45  +
        )),
          46  +
    }
          47  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_image_source.rs

@@ -1,1 +75,86 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2      2   
pub fn ser_image_source(
    3      3   
    object_2: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
    4      4   
    input: &crate::types::ImageSource,
    5      5   
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
    6      6   
    match input {
    7      7   
        crate::types::ImageSource::Bytes(inner) => {
    8      8   
            object_2.key("bytes").string_unchecked(&::aws_smithy_types::base64::encode(inner));
    9      9   
        }
          10  +
        crate::types::ImageSource::S3Location(inner) => {
          11  +
            #[allow(unused_mut)]
          12  +
            let mut object_1 = object_2.key("s3Location").start_object();
          13  +
            crate::protocol_serde::shape_s3_location::ser_s3_location(&mut object_1, inner)?;
          14  +
            object_1.finish();
          15  +
        }
   10     16   
        crate::types::ImageSource::Unknown => return Err(::aws_smithy_types::error::operation::SerializationError::unknown_variant("ImageSource")),
   11     17   
    }
   12     18   
    Ok(())
   13     19   
}
   14     20   
   15     21   
pub(crate) fn de_image_source<'a, I>(
   16     22   
    tokens: &mut ::std::iter::Peekable<I>,
   17     23   
) -> ::std::result::Result<Option<crate::types::ImageSource>, ::aws_smithy_json::deserialize::error::DeserializeError>
   18     24   
where
   19     25   
    I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
   20     26   
{
   21     27   
    let mut variant = None;
   22     28   
    match tokens.next().transpose()? {
   23     29   
        Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => return Ok(None),
   24     30   
        Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => loop {
   25     31   
            match tokens.next().transpose()? {
   26     32   
                Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
   27     33   
                Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
   28     34   
                    if let ::std::option::Option::Some(::std::result::Result::Ok(::aws_smithy_json::deserialize::Token::ValueNull { .. })) =
   29     35   
                        tokens.peek()
   30     36   
                    {
   31     37   
                        let _ = tokens.next().expect("peek returned a token")?;
   32     38   
                        continue;
   33     39   
                    }
   34     40   
                    let key = key.to_unescaped()?;
   35     41   
                    if key == "__type" {
   36     42   
                        ::aws_smithy_json::deserialize::token::skip_value(tokens)?;
   37     43   
                        continue;
   38     44   
                    }
   39     45   
                    if variant.is_some() {
   40     46   
                        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
   41     47   
                            "encountered mixed variants in union",
   42     48   
                        ));
   43     49   
                    }
   44     50   
                    variant = match key.as_ref() {
   45     51   
                        "bytes" => Some(crate::types::ImageSource::Bytes(
   46     52   
                            ::aws_smithy_json::deserialize::token::expect_blob_or_null(tokens.next())?
   47     53   
                                .ok_or_else(|| ::aws_smithy_json::deserialize::error::DeserializeError::custom("value for 'bytes' cannot be null"))?,
   48     54   
                        )),
          55  +
                        "s3Location" => Some(crate::types::ImageSource::S3Location(
          56  +
                            crate::protocol_serde::shape_s3_location::de_s3_location(tokens)?.ok_or_else(|| {
          57  +
                                ::aws_smithy_json::deserialize::error::DeserializeError::custom("value for 's3Location' cannot be null")
          58  +
                            })?,
          59  +
                        )),
   49     60   
                        _ => {
   50     61   
                            ::aws_smithy_json::deserialize::token::skip_value(tokens)?;
   51     62   
                            Some(crate::types::ImageSource::Unknown)
   52     63   
                        }
   53     64   
                    };
   54     65   
                }
   55     66   
                other => {
   56     67   
                    return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
   57     68   
                        "expected object key or end object, found: {:?}",
   58     69   
                        other

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_invoke_model.rs

@@ -98,98 +205,228 @@
  118    118   
                )
  119    119   
                .map_err(crate::operation::invoke_model::InvokeModelError::unhandled)?;
  120    120   
                let output = output.meta(generic);
  121    121   
                output.build()
  122    122   
            };
  123    123   
            if tmp.message.is_none() {
  124    124   
                tmp.message = _error_message;
  125    125   
            }
  126    126   
            tmp
  127    127   
        }),
         128  +
        "ServiceUnavailableException" => crate::operation::invoke_model::InvokeModelError::ServiceUnavailableException({
         129  +
            #[allow(unused_mut)]
         130  +
            let mut tmp = {
         131  +
                #[allow(unused_mut)]
         132  +
                let mut output = crate::types::error::builders::ServiceUnavailableExceptionBuilder::default();
         133  +
                output =
         134  +
                    crate::protocol_serde::shape_service_unavailable_exception::de_service_unavailable_exception_json_err(_response_body, output)
         135  +
                        .map_err(crate::operation::invoke_model::InvokeModelError::unhandled)?;
         136  +
                let output = output.meta(generic);
         137  +
                output.build()
         138  +
            };
         139  +
            if tmp.message.is_none() {
         140  +
                tmp.message = _error_message;
         141  +
            }
         142  +
            tmp
         143  +
        }),
  128    144   
        "ThrottlingException" => crate::operation::invoke_model::InvokeModelError::ThrottlingException({
  129    145   
            #[allow(unused_mut)]
  130    146   
            let mut tmp = {
  131    147   
                #[allow(unused_mut)]
  132    148   
                let mut output = crate::types::error::builders::ThrottlingExceptionBuilder::default();
  133    149   
                output = crate::protocol_serde::shape_throttling_exception::de_throttling_exception_json_err(_response_body, output)
  134    150   
                    .map_err(crate::operation::invoke_model::InvokeModelError::unhandled)?;
  135    151   
                let output = output.meta(generic);
  136    152   
                output.build()
  137    153   
            };
  138    154   
            if tmp.message.is_none() {
  139    155   
                tmp.message = _error_message;
  140    156   
            }
  141    157   
            tmp
  142    158   
        }),
  143    159   
        "ValidationException" => crate::operation::invoke_model::InvokeModelError::ValidationException({
  144    160   
            #[allow(unused_mut)]
  145    161   
            let mut tmp = {
  146    162   
                #[allow(unused_mut)]
  147    163   
                let mut output = crate::types::error::builders::ValidationExceptionBuilder::default();
  148    164   
                output = crate::protocol_serde::shape_validation_exception::de_validation_exception_json_err(_response_body, output)
  149    165   
                    .map_err(crate::operation::invoke_model::InvokeModelError::unhandled)?;
  150    166   
                let output = output.meta(generic);
  151    167   
                output.build()
  152    168   
            };
  153    169   
            if tmp.message.is_none() {
  154    170   
                tmp.message = _error_message;
  155    171   
            }
  156    172   
            tmp
  157    173   
        }),
  158    174   
        _ => crate::operation::invoke_model::InvokeModelError::generic(generic),
  159    175   
    })
  160    176   
}
  161    177   
  162    178   
#[allow(clippy::unnecessary_wraps)]
  163    179   
pub fn de_invoke_model_http_response(
  164    180   
    _response_status: u16,
  165    181   
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
  166    182   
    _response_body: &[u8],
  167    183   
) -> std::result::Result<crate::operation::invoke_model::InvokeModelOutput, crate::operation::invoke_model::InvokeModelError> {
  168    184   
    Ok({
  169    185   
        #[allow(unused_mut)]
  170    186   
        let mut output = crate::operation::invoke_model::builders::InvokeModelOutputBuilder::default();
  171    187   
        output = output.set_body(crate::protocol_serde::shape_invoke_model_output::de_body_payload(_response_body)?);
  172    188   
        output = output.set_content_type(
  173    189   
            crate::protocol_serde::shape_invoke_model_output::de_content_type_header(_response_headers)
  174    190   
                .map_err(|_| crate::operation::invoke_model::InvokeModelError::unhandled("Failed to parse contentType from header `Content-Type"))?,
  175    191   
        );
         192  +
        output = output.set_performance_config_latency(
         193  +
            crate::protocol_serde::shape_invoke_model_output::de_performance_config_latency_header(_response_headers).map_err(|_| {
         194  +
                crate::operation::invoke_model::InvokeModelError::unhandled(
         195  +
                    "Failed to parse performanceConfigLatency from header `X-Amzn-Bedrock-PerformanceConfig-Latency",
         196  +
                )
         197  +
            })?,
         198  +
        );
  176    199   
        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
  177    200   
        crate::serde_util::invoke_model_output_output_correct_errors(output)
  178    201   
            .build()
  179    202   
            .map_err(crate::operation::invoke_model::InvokeModelError::unhandled)?
  180    203   
    })
  181    204   
}
  182    205   
  183    206   
pub fn ser_invoke_model_headers(
  184    207   
    input: &crate::operation::invoke_model::InvokeModelInput,
  185    208   
    mut builder: ::http::request::Builder,
@@ -212,235 +243,277 @@
  232    255   
        let formatted_10 = inner_9.as_str();
  233    256   
        let header_value = formatted_10;
  234    257   
        let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
  235    258   
            ::aws_smithy_types::error::operation::BuildError::invalid_field(
  236    259   
                "guardrail_version",
  237    260   
                format!("`{}` cannot be used as a header value: {}", &header_value, err),
  238    261   
            )
  239    262   
        })?;
  240    263   
        builder = builder.header("X-Amzn-Bedrock-GuardrailVersion", header_value);
  241    264   
    }
         265  +
    if let ::std::option::Option::Some(inner_11) = &input.performance_config_latency {
         266  +
        let formatted_12 = inner_11.as_str();
         267  +
        let header_value = formatted_12;
         268  +
        let header_value: ::http::HeaderValue = header_value.parse().map_err(|err| {
         269  +
            ::aws_smithy_types::error::operation::BuildError::invalid_field(
         270  +
                "performance_config_latency",
         271  +
                format!("`{}` cannot be used as a header value: {}", &header_value, err),
         272  +
            )
         273  +
        })?;
         274  +
        builder = builder.header("X-Amzn-Bedrock-PerformanceConfig-Latency", header_value);
         275  +
    }
  242    276   
    Ok(builder)
  243    277   
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_invoke_model_output.rs

@@ -1,1 +0,20 @@
    4      4   
) -> std::result::Result<::std::option::Option<::aws_smithy_types::Blob>, crate::operation::invoke_model::InvokeModelError> {
    5      5   
    (!body.is_empty()).then(|| Ok(::aws_smithy_types::Blob::new(body))).transpose()
    6      6   
}
    7      7   
    8      8   
pub(crate) fn de_content_type_header(
    9      9   
    header_map: &::aws_smithy_runtime_api::http::Headers,
   10     10   
) -> ::std::result::Result<::std::option::Option<::std::string::String>, ::aws_smithy_http::header::ParseError> {
   11     11   
    let headers = header_map.get_all("Content-Type");
   12     12   
    ::aws_smithy_http::header::one_or_none(headers)
   13     13   
}
          14  +
          15  +
pub(crate) fn de_performance_config_latency_header(
          16  +
    header_map: &::aws_smithy_runtime_api::http::Headers,
          17  +
) -> ::std::result::Result<::std::option::Option<crate::types::PerformanceConfigLatency>, ::aws_smithy_http::header::ParseError> {
          18  +
    let headers = header_map.get_all("X-Amzn-Bedrock-PerformanceConfig-Latency");
          19  +
    ::aws_smithy_http::header::one_or_none(headers)
          20  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_invoke_model_with_bidirectional_stream.rs

@@ -0,1 +0,245 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
#[allow(clippy::unnecessary_wraps)]
           3  +
pub fn de_invoke_model_with_bidirectional_stream_http_response(
           4  +
    response: &mut ::aws_smithy_runtime_api::http::Response,
           5  +
) -> std::result::Result<
           6  +
    crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamOutput,
           7  +
    crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError,
           8  +
> {
           9  +
    let mut _response_body = ::aws_smithy_types::body::SdkBody::taken();
          10  +
    std::mem::swap(&mut _response_body, response.body_mut());
          11  +
    let _response_body = &mut _response_body;
          12  +
          13  +
    let _response_status = response.status().as_u16();
          14  +
    let _response_headers = response.headers();
          15  +
    Ok({
          16  +
        #[allow(unused_mut)]
          17  +
        let mut output =
          18  +
            crate::operation::invoke_model_with_bidirectional_stream::builders::InvokeModelWithBidirectionalStreamOutputBuilder::default();
          19  +
        output = output.set_body(Some(
          20  +
            crate::protocol_serde::shape_invoke_model_with_bidirectional_stream_output::de_body_payload(_response_body)?,
          21  +
        ));
          22  +
        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
          23  +
        output
          24  +
            .build()
          25  +
            .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?
          26  +
    })
          27  +
}
          28  +
          29  +
#[allow(clippy::unnecessary_wraps)]
          30  +
pub fn de_invoke_model_with_bidirectional_stream_http_error(
          31  +
    _response_status: u16,
          32  +
    _response_headers: &::aws_smithy_runtime_api::http::Headers,
          33  +
    _response_body: &[u8],
          34  +
) -> std::result::Result<
          35  +
    crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamOutput,
          36  +
    crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError,
          37  +
> {
          38  +
    #[allow(unused_mut)]
          39  +
    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
          40  +
        .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
          41  +
    generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
          42  +
    let generic = generic_builder.build();
          43  +
    let error_code = match generic.code() {
          44  +
        Some(code) => code,
          45  +
        None => return Err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled(generic)),
          46  +
    };
          47  +
          48  +
    let _error_message = generic.message().map(|msg| msg.to_owned());
          49  +
    Err(match error_code {
          50  +
        "ModelTimeoutException" => {
          51  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::ModelTimeoutException({
          52  +
                #[allow(unused_mut)]
          53  +
                let mut tmp = {
          54  +
                    #[allow(unused_mut)]
          55  +
                    let mut output = crate::types::error::builders::ModelTimeoutExceptionBuilder::default();
          56  +
                    output = crate::protocol_serde::shape_model_timeout_exception::de_model_timeout_exception_json_err(_response_body, output)
          57  +
                        .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
          58  +
                    let output = output.meta(generic);
          59  +
                    output.build()
          60  +
                };
          61  +
                if tmp.message.is_none() {
          62  +
                    tmp.message = _error_message;
          63  +
                }
          64  +
                tmp
          65  +
            })
          66  +
        }
          67  +
        "AccessDeniedException" => {
          68  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::AccessDeniedException({
          69  +
                #[allow(unused_mut)]
          70  +
                let mut tmp = {
          71  +
                    #[allow(unused_mut)]
          72  +
                    let mut output = crate::types::error::builders::AccessDeniedExceptionBuilder::default();
          73  +
                    output = crate::protocol_serde::shape_access_denied_exception::de_access_denied_exception_json_err(_response_body, output)
          74  +
                        .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
          75  +
                    let output = output.meta(generic);
          76  +
                    output.build()
          77  +
                };
          78  +
                if tmp.message.is_none() {
          79  +
                    tmp.message = _error_message;
          80  +
                }
          81  +
                tmp
          82  +
            })
          83  +
        }
          84  +
        "ResourceNotFoundException" => {
          85  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::ResourceNotFoundException({
          86  +
                #[allow(unused_mut)]
          87  +
                let mut tmp = {
          88  +
                    #[allow(unused_mut)]
          89  +
                    let mut output = crate::types::error::builders::ResourceNotFoundExceptionBuilder::default();
          90  +
                    output =
          91  +
                        crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
          92  +
                            .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
          93  +
                    let output = output.meta(generic);
          94  +
                    output.build()
          95  +
                };
          96  +
                if tmp.message.is_none() {
          97  +
                    tmp.message = _error_message;
          98  +
                }
          99  +
                tmp
         100  +
            })
         101  +
        }
         102  +
        "ThrottlingException" => {
         103  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::ThrottlingException({
         104  +
                #[allow(unused_mut)]
         105  +
                let mut tmp = {
         106  +
                    #[allow(unused_mut)]
         107  +
                    let mut output = crate::types::error::builders::ThrottlingExceptionBuilder::default();
         108  +
                    output = crate::protocol_serde::shape_throttling_exception::de_throttling_exception_json_err(_response_body, output)
         109  +
                        .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
         110  +
                    let output = output.meta(generic);
         111  +
                    output.build()
         112  +
                };
         113  +
                if tmp.message.is_none() {
         114  +
                    tmp.message = _error_message;
         115  +
                }
         116  +
                tmp
         117  +
            })
         118  +
        }
         119  +
        "ServiceUnavailableException" => {
         120  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::ServiceUnavailableException({
         121  +
                #[allow(unused_mut)]
         122  +
                let mut tmp = {
         123  +
                    #[allow(unused_mut)]
         124  +
                    let mut output = crate::types::error::builders::ServiceUnavailableExceptionBuilder::default();
         125  +
                    output =
         126  +
                        crate::protocol_serde::shape_service_unavailable_exception::de_service_unavailable_exception_json_err(_response_body, output)
         127  +
                            .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
         128  +
                    let output = output.meta(generic);
         129  +
                    output.build()
         130  +
                };
         131  +
                if tmp.message.is_none() {
         132  +
                    tmp.message = _error_message;
         133  +
                }
         134  +
                tmp
         135  +
            })
         136  +
        }
         137  +
        "InternalServerException" => {
         138  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::InternalServerException({
         139  +
                #[allow(unused_mut)]
         140  +
                let mut tmp = {
         141  +
                    #[allow(unused_mut)]
         142  +
                    let mut output = crate::types::error::builders::InternalServerExceptionBuilder::default();
         143  +
                    output = crate::protocol_serde::shape_internal_server_exception::de_internal_server_exception_json_err(_response_body, output)
         144  +
                        .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
         145  +
                    let output = output.meta(generic);
         146  +
                    output.build()
         147  +
                };
         148  +
                if tmp.message.is_none() {
         149  +
                    tmp.message = _error_message;
         150  +
                }
         151  +
                tmp
         152  +
            })
         153  +
        }
         154  +
        "ModelStreamErrorException" => {
         155  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::ModelStreamErrorException({
         156  +
                #[allow(unused_mut)]
         157  +
                let mut tmp = {
         158  +
                    #[allow(unused_mut)]
         159  +
                    let mut output = crate::types::error::builders::ModelStreamErrorExceptionBuilder::default();
         160  +
                    output =
         161  +
                        crate::protocol_serde::shape_model_stream_error_exception::de_model_stream_error_exception_json_err(_response_body, output)
         162  +
                            .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
         163  +
                    let output = output.meta(generic);
         164  +
                    output.build()
         165  +
                };
         166  +
                if tmp.message.is_none() {
         167  +
                    tmp.message = _error_message;
         168  +
                }
         169  +
                tmp
         170  +
            })
         171  +
        }
         172  +
        "ValidationException" => {
         173  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::ValidationException({
         174  +
                #[allow(unused_mut)]
         175  +
                let mut tmp = {
         176  +
                    #[allow(unused_mut)]
         177  +
                    let mut output = crate::types::error::builders::ValidationExceptionBuilder::default();
         178  +
                    output = crate::protocol_serde::shape_validation_exception::de_validation_exception_json_err(_response_body, output)
         179  +
                        .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
         180  +
                    let output = output.meta(generic);
         181  +
                    output.build()
         182  +
                };
         183  +
                if tmp.message.is_none() {
         184  +
                    tmp.message = _error_message;
         185  +
                }
         186  +
                tmp
         187  +
            })
         188  +
        }
         189  +
        "ModelNotReadyException" => {
         190  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::ModelNotReadyException({
         191  +
                #[allow(unused_mut)]
         192  +
                let mut tmp = {
         193  +
                    #[allow(unused_mut)]
         194  +
                    let mut output = crate::types::error::builders::ModelNotReadyExceptionBuilder::default();
         195  +
                    output = crate::protocol_serde::shape_model_not_ready_exception::de_model_not_ready_exception_json_err(_response_body, output)
         196  +
                        .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
         197  +
                    let output = output.meta(generic);
         198  +
                    output.build()
         199  +
                };
         200  +
                if tmp.message.is_none() {
         201  +
                    tmp.message = _error_message;
         202  +
                }
         203  +
                tmp
         204  +
            })
         205  +
        }
         206  +
        "ModelErrorException" => {
         207  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::ModelErrorException({
         208  +
                #[allow(unused_mut)]
         209  +
                let mut tmp = {
         210  +
                    #[allow(unused_mut)]
         211  +
                    let mut output = crate::types::error::builders::ModelErrorExceptionBuilder::default();
         212  +
                    output = crate::protocol_serde::shape_model_error_exception::de_model_error_exception_json_err(_response_body, output)
         213  +
                        .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
         214  +
                    let output = output.meta(generic);
         215  +
                    output.build()
         216  +
                };
         217  +
                if tmp.message.is_none() {
         218  +
                    tmp.message = _error_message;
         219  +
                }
         220  +
                tmp
         221  +
            })
         222  +
        }
         223  +
        "ServiceQuotaExceededException" => {
         224  +
            crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::ServiceQuotaExceededException({
         225  +
                #[allow(unused_mut)]
         226  +
                let mut tmp = {
         227  +
                    #[allow(unused_mut)]
         228  +
                    let mut output = crate::types::error::builders::ServiceQuotaExceededExceptionBuilder::default();
         229  +
                    output = crate::protocol_serde::shape_service_quota_exceeded_exception::de_service_quota_exceeded_exception_json_err(
         230  +
                        _response_body,
         231  +
                        output,
         232  +
                    )
         233  +
                    .map_err(crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::unhandled)?;
         234  +
                    let output = output.meta(generic);
         235  +
                    output.build()
         236  +
                };
         237  +
                if tmp.message.is_none() {
         238  +
                    tmp.message = _error_message;
         239  +
                }
         240  +
                tmp
         241  +
            })
         242  +
        }
         243  +
        _ => crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError::generic(generic),
         244  +
    })
         245  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_invoke_model_with_bidirectional_stream_input.rs

@@ -0,1 +0,10 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub fn ser_chunk_payload(
           3  +
    input: &crate::types::BidirectionalInputPayloadPart,
           4  +
) -> std::result::Result<::std::vec::Vec<u8>, ::aws_smithy_types::error::operation::SerializationError> {
           5  +
    let mut out = String::new();
           6  +
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
           7  +
    crate::protocol_serde::shape_bidirectional_input_payload_part::ser_bidirectional_input_payload_part(&mut object, input)?;
           8  +
    object.finish();
           9  +
    Ok(out.into_bytes())
          10  +
}

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/protocol_serde/shape_invoke_model_with_bidirectional_stream_output.rs

@@ -0,1 +0,17 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
pub fn de_body_payload(
           3  +
    body: &mut ::aws_smithy_types::body::SdkBody,
           4  +
) -> std::result::Result<
           5  +
    crate::event_receiver::EventReceiver<
           6  +
        crate::types::InvokeModelWithBidirectionalStreamOutput,
           7  +
        crate::types::error::InvokeModelWithBidirectionalStreamOutputError,
           8  +
    >,
           9  +
    crate::operation::invoke_model_with_bidirectional_stream::InvokeModelWithBidirectionalStreamError,
          10  +
> {
          11  +
    let unmarshaller = crate::event_stream_serde::InvokeModelWithBidirectionalStreamOutputUnmarshaller::new();
          12  +
    let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
          13  +
    Ok(crate::event_receiver::EventReceiver::new(::aws_smithy_http::event_stream::Receiver::new(
          14  +
        unmarshaller,
          15  +
        body,
          16  +
    )))
          17  +
}