aws_sdk_codepipeline/protocol_serde/
shape_update_pipeline.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2#[allow(clippy::unnecessary_wraps)]
3pub fn de_update_pipeline_http_error(
4    _response_status: u16,
5    _response_headers: &::aws_smithy_runtime_api::http::Headers,
6    _response_body: &[u8],
7) -> std::result::Result<crate::operation::update_pipeline::UpdatePipelineOutput, crate::operation::update_pipeline::UpdatePipelineError> {
8    #[allow(unused_mut)]
9    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
10        .map_err(crate::operation::update_pipeline::UpdatePipelineError::unhandled)?;
11    generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
12    let generic = generic_builder.build();
13    let error_code = match generic.code() {
14        Some(code) => code,
15        None => return Err(crate::operation::update_pipeline::UpdatePipelineError::unhandled(generic)),
16    };
17
18    let _error_message = generic.message().map(|msg| msg.to_owned());
19    Err(match error_code {
20        "InvalidActionDeclarationException" => crate::operation::update_pipeline::UpdatePipelineError::InvalidActionDeclarationException({
21            #[allow(unused_mut)]
22            let mut tmp = {
23                #[allow(unused_mut)]
24                let mut output = crate::types::error::builders::InvalidActionDeclarationExceptionBuilder::default();
25                output = crate::protocol_serde::shape_invalid_action_declaration_exception::de_invalid_action_declaration_exception_json_err(
26                    _response_body,
27                    output,
28                )
29                .map_err(crate::operation::update_pipeline::UpdatePipelineError::unhandled)?;
30                let output = output.meta(generic);
31                output.build()
32            };
33            if tmp.message.is_none() {
34                tmp.message = _error_message;
35            }
36            tmp
37        }),
38        "InvalidBlockerDeclarationException" => crate::operation::update_pipeline::UpdatePipelineError::InvalidBlockerDeclarationException({
39            #[allow(unused_mut)]
40            let mut tmp = {
41                #[allow(unused_mut)]
42                let mut output = crate::types::error::builders::InvalidBlockerDeclarationExceptionBuilder::default();
43                output = crate::protocol_serde::shape_invalid_blocker_declaration_exception::de_invalid_blocker_declaration_exception_json_err(
44                    _response_body,
45                    output,
46                )
47                .map_err(crate::operation::update_pipeline::UpdatePipelineError::unhandled)?;
48                let output = output.meta(generic);
49                output.build()
50            };
51            if tmp.message.is_none() {
52                tmp.message = _error_message;
53            }
54            tmp
55        }),
56        "InvalidStageDeclarationException" => crate::operation::update_pipeline::UpdatePipelineError::InvalidStageDeclarationException({
57            #[allow(unused_mut)]
58            let mut tmp = {
59                #[allow(unused_mut)]
60                let mut output = crate::types::error::builders::InvalidStageDeclarationExceptionBuilder::default();
61                output = crate::protocol_serde::shape_invalid_stage_declaration_exception::de_invalid_stage_declaration_exception_json_err(
62                    _response_body,
63                    output,
64                )
65                .map_err(crate::operation::update_pipeline::UpdatePipelineError::unhandled)?;
66                let output = output.meta(generic);
67                output.build()
68            };
69            if tmp.message.is_none() {
70                tmp.message = _error_message;
71            }
72            tmp
73        }),
74        "InvalidStructureException" => crate::operation::update_pipeline::UpdatePipelineError::InvalidStructureException({
75            #[allow(unused_mut)]
76            let mut tmp = {
77                #[allow(unused_mut)]
78                let mut output = crate::types::error::builders::InvalidStructureExceptionBuilder::default();
79                output = crate::protocol_serde::shape_invalid_structure_exception::de_invalid_structure_exception_json_err(_response_body, output)
80                    .map_err(crate::operation::update_pipeline::UpdatePipelineError::unhandled)?;
81                let output = output.meta(generic);
82                output.build()
83            };
84            if tmp.message.is_none() {
85                tmp.message = _error_message;
86            }
87            tmp
88        }),
89        "LimitExceededException" => crate::operation::update_pipeline::UpdatePipelineError::LimitExceededException({
90            #[allow(unused_mut)]
91            let mut tmp = {
92                #[allow(unused_mut)]
93                let mut output = crate::types::error::builders::LimitExceededExceptionBuilder::default();
94                output = crate::protocol_serde::shape_limit_exceeded_exception::de_limit_exceeded_exception_json_err(_response_body, output)
95                    .map_err(crate::operation::update_pipeline::UpdatePipelineError::unhandled)?;
96                let output = output.meta(generic);
97                output.build()
98            };
99            if tmp.message.is_none() {
100                tmp.message = _error_message;
101            }
102            tmp
103        }),
104        "ValidationException" => crate::operation::update_pipeline::UpdatePipelineError::ValidationException({
105            #[allow(unused_mut)]
106            let mut tmp = {
107                #[allow(unused_mut)]
108                let mut output = crate::types::error::builders::ValidationExceptionBuilder::default();
109                output = crate::protocol_serde::shape_validation_exception::de_validation_exception_json_err(_response_body, output)
110                    .map_err(crate::operation::update_pipeline::UpdatePipelineError::unhandled)?;
111                let output = output.meta(generic);
112                output.build()
113            };
114            if tmp.message.is_none() {
115                tmp.message = _error_message;
116            }
117            tmp
118        }),
119        _ => crate::operation::update_pipeline::UpdatePipelineError::generic(generic),
120    })
121}
122
123#[allow(clippy::unnecessary_wraps)]
124pub fn de_update_pipeline_http_response(
125    _response_status: u16,
126    _response_headers: &::aws_smithy_runtime_api::http::Headers,
127    _response_body: &[u8],
128) -> std::result::Result<crate::operation::update_pipeline::UpdatePipelineOutput, crate::operation::update_pipeline::UpdatePipelineError> {
129    Ok({
130        #[allow(unused_mut)]
131        let mut output = crate::operation::update_pipeline::builders::UpdatePipelineOutputBuilder::default();
132        output = crate::protocol_serde::shape_update_pipeline::de_update_pipeline(_response_body, output)
133            .map_err(crate::operation::update_pipeline::UpdatePipelineError::unhandled)?;
134        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
135        output.build()
136    })
137}
138
139pub fn ser_update_pipeline_input(
140    input: &crate::operation::update_pipeline::UpdatePipelineInput,
141) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
142    let mut out = String::new();
143    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
144    crate::protocol_serde::shape_update_pipeline_input::ser_update_pipeline_input_input(&mut object, input)?;
145    object.finish();
146    Ok(::aws_smithy_types::body::SdkBody::from(out))
147}
148
149pub(crate) fn de_update_pipeline(
150    value: &[u8],
151    mut builder: crate::operation::update_pipeline::builders::UpdatePipelineOutputBuilder,
152) -> ::std::result::Result<
153    crate::operation::update_pipeline::builders::UpdatePipelineOutputBuilder,
154    ::aws_smithy_json::deserialize::error::DeserializeError,
155> {
156    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
157    let tokens = &mut tokens_owned;
158    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
159    loop {
160        match tokens.next().transpose()? {
161            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
162            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
163                "pipeline" => {
164                    builder = builder.set_pipeline(crate::protocol_serde::shape_pipeline_declaration::de_pipeline_declaration(tokens)?);
165                }
166                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
167            },
168            other => {
169                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
170                    "expected object key or end object, found: {:?}",
171                    other
172                )))
173            }
174        }
175    }
176    if tokens.next().is_some() {
177        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
178            "found more JSON tokens after completing parsing",
179        ));
180    }
181    Ok(builder)
182}