2 2 | #[allow(clippy::unnecessary_wraps)]
|
3 3 | pub fn de_execute_statement_http_error(
|
4 4 | _response_status: u16,
|
5 5 | _response_headers: &::aws_smithy_runtime_api::http::Headers,
|
6 6 | _response_body: &[u8],
|
7 7 | ) -> std::result::Result<crate::operation::execute_statement::ExecuteStatementOutput, crate::operation::execute_statement::ExecuteStatementError> {
|
8 8 | #[allow(unused_mut)]
|
9 9 | let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
|
10 10 | .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
|
11 11 | let generic = generic_builder.build();
|
12 12 | let error_code = match generic.code() {
|
13 13 | Some(code) => code,
|
14 14 | None => return Err(crate::operation::execute_statement::ExecuteStatementError::unhandled(generic)),
|
15 15 | };
|
16 16 |
|
17 17 | let _error_message = generic.message().map(|msg| msg.to_owned());
|
18 18 | Err(match error_code {
|
19 19 | "ConditionalCheckFailedException" => crate::operation::execute_statement::ExecuteStatementError::ConditionalCheckFailedError({
|
20 20 | #[allow(unused_mut)]
|
21 21 | let mut tmp = {
|
22 22 | #[allow(unused_mut)]
|
23 23 | let mut output = crate::types::error::builders::ConditionalCheckFailedErrorBuilder::default();
|
24 24 | output = crate::protocol_serde::shape_conditional_check_failed_exception::de_conditional_check_failed_exception_json_err(
|
25 25 | _response_body,
|
26 26 | output,
|
27 27 | )
|
28 28 | .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
|
29 29 | let output = output.meta(generic);
|
30 30 | output.build()
|
31 31 | };
|
32 - | if tmp.message.is_none() {
|
33 - | tmp.message = _error_message;
|
34 - | }
|
35 32 | tmp
|
36 33 | }),
|
37 34 | "DuplicateItemException" => crate::operation::execute_statement::ExecuteStatementError::DuplicateItemError({
|
38 35 | #[allow(unused_mut)]
|
39 36 | let mut tmp = {
|
40 37 | #[allow(unused_mut)]
|
41 38 | let mut output = crate::types::error::builders::DuplicateItemErrorBuilder::default();
|
42 39 | output = crate::protocol_serde::shape_duplicate_item_exception::de_duplicate_item_exception_json_err(_response_body, output)
|
43 40 | .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
|
44 41 | let output = output.meta(generic);
|
45 42 | output.build()
|
46 43 | };
|
47 - | if tmp.message.is_none() {
|
48 - | tmp.message = _error_message;
|
49 - | }
|
50 44 | tmp
|
51 45 | }),
|
52 46 | "InternalServerError" => crate::operation::execute_statement::ExecuteStatementError::InternalServerError({
|
53 47 | #[allow(unused_mut)]
|
54 48 | let mut tmp = {
|
55 49 | #[allow(unused_mut)]
|
56 50 | let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
|
57 51 | output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output)
|
58 52 | .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
|
59 53 | let output = output.meta(generic);
|
60 54 | output.build()
|
61 55 | };
|
62 - | if tmp.message.is_none() {
|
63 - | tmp.message = _error_message;
|
64 - | }
|
65 56 | tmp
|
66 57 | }),
|
67 58 | "ItemCollectionSizeLimitExceededException" => {
|
68 59 | crate::operation::execute_statement::ExecuteStatementError::ItemCollectionSizeLimitExceededError({
|
69 60 | #[allow(unused_mut)]
|
70 61 | let mut tmp = {
|
71 62 | #[allow(unused_mut)]
|
72 63 | let mut output = crate::types::error::builders::ItemCollectionSizeLimitExceededErrorBuilder::default();
|
73 64 | output = crate::protocol_serde::shape_item_collection_size_limit_exceeded_exception::de_item_collection_size_limit_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
|
74 65 | let output = output.meta(generic);
|
75 66 | output.build()
|
76 67 | };
|
77 - | if tmp.message.is_none() {
|
78 - | tmp.message = _error_message;
|
79 - | }
|
80 68 | tmp
|
81 69 | })
|
82 70 | }
|
83 71 | "ProvisionedThroughputExceededException" => {
|
84 72 | crate::operation::execute_statement::ExecuteStatementError::ProvisionedThroughputExceededError({
|
85 73 | #[allow(unused_mut)]
|
86 74 | let mut tmp = {
|
87 75 | #[allow(unused_mut)]
|
88 76 | let mut output = crate::types::error::builders::ProvisionedThroughputExceededErrorBuilder::default();
|
89 77 | output = crate::protocol_serde::shape_provisioned_throughput_exceeded_exception::de_provisioned_throughput_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
|
90 78 | let output = output.meta(generic);
|
91 79 | output.build()
|
92 80 | };
|
93 - | if tmp.message.is_none() {
|
94 - | tmp.message = _error_message;
|
95 - | }
|
96 81 | tmp
|
97 82 | })
|
98 83 | }
|
99 84 | "RequestLimitExceeded" => crate::operation::execute_statement::ExecuteStatementError::RequestLimitExceeded({
|
100 85 | #[allow(unused_mut)]
|
101 86 | let mut tmp = {
|
102 87 | #[allow(unused_mut)]
|
103 88 | let mut output = crate::types::error::builders::RequestLimitExceededBuilder::default();
|
104 89 | output = crate::protocol_serde::shape_request_limit_exceeded::de_request_limit_exceeded_json_err(_response_body, output)
|
105 90 | .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
|
106 91 | let output = output.meta(generic);
|
107 92 | output.build()
|
108 93 | };
|
109 - | if tmp.message.is_none() {
|
110 - | tmp.message = _error_message;
|
111 - | }
|
112 94 | tmp
|
113 95 | }),
|
114 96 | "ResourceNotFoundException" => crate::operation::execute_statement::ExecuteStatementError::ResourceNotFoundError({
|
115 97 | #[allow(unused_mut)]
|
116 98 | let mut tmp = {
|
117 99 | #[allow(unused_mut)]
|
118 100 | let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
|
119 101 | output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
|
120 102 | .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
|
121 103 | let output = output.meta(generic);
|
122 104 | output.build()
|
123 105 | };
|
124 - | if tmp.message.is_none() {
|
125 - | tmp.message = _error_message;
|
126 - | }
|
127 106 | tmp
|
128 107 | }),
|
129 108 | "TransactionConflictException" => crate::operation::execute_statement::ExecuteStatementError::TransactionConflictError({
|
130 109 | #[allow(unused_mut)]
|
131 110 | let mut tmp = {
|
132 111 | #[allow(unused_mut)]
|
133 112 | let mut output = crate::types::error::builders::TransactionConflictErrorBuilder::default();
|
134 113 | output =
|
135 114 | crate::protocol_serde::shape_transaction_conflict_exception::de_transaction_conflict_exception_json_err(_response_body, output)
|
136 115 | .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
|
137 116 | let output = output.meta(generic);
|
138 117 | output.build()
|
139 118 | };
|
140 - | if tmp.message.is_none() {
|
141 - | tmp.message = _error_message;
|
142 - | }
|
143 119 | tmp
|
144 120 | }),
|
145 121 | _ => crate::operation::execute_statement::ExecuteStatementError::generic(generic),
|
146 122 | })
|
147 123 | }
|
148 124 |
|
149 125 | #[allow(clippy::unnecessary_wraps)]
|
150 126 | pub fn de_execute_statement_http_response(
|
151 127 | _response_status: u16,
|
152 128 | _response_headers: &::aws_smithy_runtime_api::http::Headers,
|
153 129 | _response_body: &[u8],
|
154 130 | ) -> std::result::Result<crate::operation::execute_statement::ExecuteStatementOutput, crate::operation::execute_statement::ExecuteStatementError> {
|
155 131 | Ok({
|
156 132 | #[allow(unused_mut)]
|
157 133 | let mut output = crate::operation::execute_statement::builders::ExecuteStatementOutputBuilder::default();
|
158 134 | output = crate::protocol_serde::shape_execute_statement::de_execute_statement(_response_body, output)
|
159 135 | .map_err(crate::operation::execute_statement::ExecuteStatementError::unhandled)?;
|
160 136 | output.build()
|
161 137 | })
|
162 138 | }
|
163 139 |
|
164 140 | pub fn ser_execute_statement_input(
|
165 141 | input: &crate::operation::execute_statement::ExecuteStatementInput,
|
166 142 | ) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
|
167 143 | let mut out = String::new();
|
168 144 | let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
|
169 145 | crate::protocol_serde::shape_execute_statement_input::ser_execute_statement_input_input(&mut object, input)?;
|
170 146 | object.finish();
|
171 147 | Ok(::aws_smithy_types::body::SdkBody::from(out))
|
172 148 | }
|