aws_sdk_databasemigration/protocol_serde/
shape_delete_replication_task_assessment_run.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2#[allow(clippy::unnecessary_wraps)]
3pub fn de_delete_replication_task_assessment_run_http_error(
4    _response_status: u16,
5    _response_headers: &::aws_smithy_runtime_api::http::Headers,
6    _response_body: &[u8],
7) -> std::result::Result<
8    crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunOutput,
9    crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError,
10> {
11    #[allow(unused_mut)]
12    let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
13        .map_err(crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError::unhandled)?;
14    generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
15    let generic = generic_builder.build();
16    let error_code = match generic.code() {
17        Some(code) => code,
18        None => return Err(crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError::unhandled(generic)),
19    };
20
21    let _error_message = generic.message().map(|msg| msg.to_owned());
22    Err(match error_code {
23        "AccessDeniedFault" => {
24            crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError::AccessDeniedFault({
25                #[allow(unused_mut)]
26                let mut tmp = {
27                    #[allow(unused_mut)]
28                    let mut output = crate::types::error::builders::AccessDeniedFaultBuilder::default();
29                    output = crate::protocol_serde::shape_access_denied_fault::de_access_denied_fault_json_err(_response_body, output)
30                        .map_err(crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError::unhandled)?;
31                    let output = output.meta(generic);
32                    output.build()
33                };
34                if tmp.message.is_none() {
35                    tmp.message = _error_message;
36                }
37                tmp
38            })
39        }
40        "InvalidResourceStateFault" => {
41            crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError::InvalidResourceStateFault({
42                #[allow(unused_mut)]
43                let mut tmp = {
44                    #[allow(unused_mut)]
45                    let mut output = crate::types::error::builders::InvalidResourceStateFaultBuilder::default();
46                    output =
47                        crate::protocol_serde::shape_invalid_resource_state_fault::de_invalid_resource_state_fault_json_err(_response_body, output)
48                            .map_err(crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError::unhandled)?;
49                    let output = output.meta(generic);
50                    output.build()
51                };
52                if tmp.message.is_none() {
53                    tmp.message = _error_message;
54                }
55                tmp
56            })
57        }
58        "ResourceNotFoundFault" => {
59            crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError::ResourceNotFoundFault({
60                #[allow(unused_mut)]
61                let mut tmp = {
62                    #[allow(unused_mut)]
63                    let mut output = crate::types::error::builders::ResourceNotFoundFaultBuilder::default();
64                    output = crate::protocol_serde::shape_resource_not_found_fault::de_resource_not_found_fault_json_err(_response_body, output)
65                        .map_err(crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError::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        }
75        _ => crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError::generic(generic),
76    })
77}
78
79#[allow(clippy::unnecessary_wraps)]
80pub fn de_delete_replication_task_assessment_run_http_response(
81    _response_status: u16,
82    _response_headers: &::aws_smithy_runtime_api::http::Headers,
83    _response_body: &[u8],
84) -> std::result::Result<
85    crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunOutput,
86    crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError,
87> {
88    Ok({
89        #[allow(unused_mut)]
90        let mut output =
91            crate::operation::delete_replication_task_assessment_run::builders::DeleteReplicationTaskAssessmentRunOutputBuilder::default();
92        output =
93            crate::protocol_serde::shape_delete_replication_task_assessment_run::de_delete_replication_task_assessment_run(_response_body, output)
94                .map_err(crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunError::unhandled)?;
95        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
96        output.build()
97    })
98}
99
100pub fn ser_delete_replication_task_assessment_run_input(
101    input: &crate::operation::delete_replication_task_assessment_run::DeleteReplicationTaskAssessmentRunInput,
102) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
103    let mut out = String::new();
104    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
105    crate::protocol_serde::shape_delete_replication_task_assessment_run_input::ser_delete_replication_task_assessment_run_input_input(
106        &mut object,
107        input,
108    )?;
109    object.finish();
110    Ok(::aws_smithy_types::body::SdkBody::from(out))
111}
112
113pub(crate) fn de_delete_replication_task_assessment_run(
114    value: &[u8],
115    mut builder: crate::operation::delete_replication_task_assessment_run::builders::DeleteReplicationTaskAssessmentRunOutputBuilder,
116) -> ::std::result::Result<
117    crate::operation::delete_replication_task_assessment_run::builders::DeleteReplicationTaskAssessmentRunOutputBuilder,
118    ::aws_smithy_json::deserialize::error::DeserializeError,
119> {
120    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(value)).peekable();
121    let tokens = &mut tokens_owned;
122    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
123    loop {
124        match tokens.next().transpose()? {
125            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
126            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
127                "ReplicationTaskAssessmentRun" => {
128                    builder = builder.set_replication_task_assessment_run(
129                        crate::protocol_serde::shape_replication_task_assessment_run::de_replication_task_assessment_run(tokens)?,
130                    );
131                }
132                _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
133            },
134            other => {
135                return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
136                    "expected object key or end object, found: {:?}",
137                    other
138                )))
139            }
140        }
141    }
142    if tokens.next().is_some() {
143        return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
144            "found more JSON tokens after completing parsing",
145        ));
146    }
147    Ok(builder)
148}
aws_sdk_databasemigration/protocol_serde/shape_delete_replication_task_assessment_run.rs

aws_sdk_databasemigration/protocol_serde/
shape_delete_replication_task_assessment_run.rs
