1 - | // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
|
2 - | #[allow(clippy::unnecessary_wraps)]
|
3 - | pub fn de_transact_write_items_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::transact_write_items::TransactWriteItemsOutput,
|
9 - | crate::operation::transact_write_items::TransactWriteItemsError,
|
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::transact_write_items::TransactWriteItemsError::unhandled)?;
|
14 - | let generic = generic_builder.build();
|
15 - | let error_code = match generic.code() {
|
16 - | Some(code) => code,
|
17 - | None => return Err(crate::operation::transact_write_items::TransactWriteItemsError::unhandled(generic)),
|
18 - | };
|
19 - |
|
20 - | let _error_message = generic.message().map(|msg| msg.to_owned());
|
21 - | Err(match error_code {
|
22 - | "IdempotentParameterMismatchException" => {
|
23 - | crate::operation::transact_write_items::TransactWriteItemsError::IdempotentParameterMismatchError({
|
24 - | #[allow(unused_mut)]
|
25 - | let mut tmp = {
|
26 - | #[allow(unused_mut)]
|
27 - | let mut output = crate::types::error::builders::IdempotentParameterMismatchErrorBuilder::default();
|
28 - | output =
|
29 - | crate::protocol_serde::shape_idempotent_parameter_mismatch_exception::de_idempotent_parameter_mismatch_exception_json_err(
|
30 - | _response_body,
|
31 - | output,
|
32 - | )
|
33 - | .map_err(crate::operation::transact_write_items::TransactWriteItemsError::unhandled)?;
|
34 - | let output = output.meta(generic);
|
35 - | output.build()
|
36 - | };
|
37 - | if tmp.message.is_none() {
|
38 - | tmp.message = _error_message;
|
39 - | }
|
40 - | tmp
|
41 - | })
|
42 - | }
|
43 - | "InternalServerError" => crate::operation::transact_write_items::TransactWriteItemsError::InternalServerError({
|
44 - | #[allow(unused_mut)]
|
45 - | let mut tmp = {
|
46 - | #[allow(unused_mut)]
|
47 - | let mut output = crate::types::error::builders::InternalServerErrorBuilder::default();
|
48 - | output = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(_response_body, output)
|
49 - | .map_err(crate::operation::transact_write_items::TransactWriteItemsError::unhandled)?;
|
50 - | let output = output.meta(generic);
|
51 - | output.build()
|
52 - | };
|
53 - | if tmp.message.is_none() {
|
54 - | tmp.message = _error_message;
|
55 - | }
|
56 - | tmp
|
57 - | }),
|
58 - | "InvalidEndpointException" => crate::operation::transact_write_items::TransactWriteItemsError::InvalidEndpointError({
|
59 - | #[allow(unused_mut)]
|
60 - | let mut tmp = {
|
61 - | #[allow(unused_mut)]
|
62 - | let mut output = crate::types::error::builders::InvalidEndpointErrorBuilder::default();
|
63 - | output = crate::protocol_serde::shape_invalid_endpoint_exception::de_invalid_endpoint_exception_json_err(_response_body, output)
|
64 - | .map_err(crate::operation::transact_write_items::TransactWriteItemsError::unhandled)?;
|
65 - | let output = output.meta(generic);
|
66 - | output.build()
|
67 - | };
|
68 - | if tmp.message.is_none() {
|
69 - | tmp.message = _error_message;
|
70 - | }
|
71 - | tmp
|
72 - | }),
|
73 - | "ProvisionedThroughputExceededException" => {
|
74 - | crate::operation::transact_write_items::TransactWriteItemsError::ProvisionedThroughputExceededError({
|
75 - | #[allow(unused_mut)]
|
76 - | let mut tmp = {
|
77 - | #[allow(unused_mut)]
|
78 - | let mut output = crate::types::error::builders::ProvisionedThroughputExceededErrorBuilder::default();
|
79 - | output = crate::protocol_serde::shape_provisioned_throughput_exceeded_exception::de_provisioned_throughput_exceeded_exception_json_err(_response_body, output).map_err(crate::operation::transact_write_items::TransactWriteItemsError::unhandled)?;
|
80 - | let output = output.meta(generic);
|
81 - | output.build()
|
82 - | };
|
83 - | if tmp.message.is_none() {
|
84 - | tmp.message = _error_message;
|
85 - | }
|
86 - | tmp
|
87 - | })
|
88 - | }
|
89 - | "RequestLimitExceeded" => crate::operation::transact_write_items::TransactWriteItemsError::RequestLimitExceeded({
|
90 - | #[allow(unused_mut)]
|
91 - | let mut tmp = {
|
92 - | #[allow(unused_mut)]
|
93 - | let mut output = crate::types::error::builders::RequestLimitExceededBuilder::default();
|
94 - | output = crate::protocol_serde::shape_request_limit_exceeded::de_request_limit_exceeded_json_err(_response_body, output)
|
95 - | .map_err(crate::operation::transact_write_items::TransactWriteItemsError::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 - | "ResourceNotFoundException" => crate::operation::transact_write_items::TransactWriteItemsError::ResourceNotFoundError({
|
105 - | #[allow(unused_mut)]
|
106 - | let mut tmp = {
|
107 - | #[allow(unused_mut)]
|
108 - | let mut output = crate::types::error::builders::ResourceNotFoundErrorBuilder::default();
|
109 - | output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
|
110 - | .map_err(crate::operation::transact_write_items::TransactWriteItemsError::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 - | "TransactionCanceledException" => crate::operation::transact_write_items::TransactWriteItemsError::TransactionCanceledError({
|
120 - | #[allow(unused_mut)]
|
121 - | let mut tmp = {
|
122 - | #[allow(unused_mut)]
|
123 - | let mut output = crate::types::error::builders::TransactionCanceledErrorBuilder::default();
|
124 - | output =
|
125 - | crate::protocol_serde::shape_transaction_canceled_exception::de_transaction_canceled_exception_json_err(_response_body, output)
|
126 - | .map_err(crate::operation::transact_write_items::TransactWriteItemsError::unhandled)?;
|
127 - | let output = output.meta(generic);
|
128 - | output.build()
|
129 - | };
|
130 - | if tmp.message.is_none() {
|
131 - | tmp.message = _error_message;
|
132 - | }
|
133 - | tmp
|
134 - | }),
|
135 - | "TransactionInProgressException" => crate::operation::transact_write_items::TransactWriteItemsError::TransactionInProgressError({
|
136 - | #[allow(unused_mut)]
|
137 - | let mut tmp = {
|
138 - | #[allow(unused_mut)]
|
139 - | let mut output = crate::types::error::builders::TransactionInProgressErrorBuilder::default();
|
140 - | output = crate::protocol_serde::shape_transaction_in_progress_exception::de_transaction_in_progress_exception_json_err(
|
141 - | _response_body,
|
142 - | output,
|
143 - | )
|
144 - | .map_err(crate::operation::transact_write_items::TransactWriteItemsError::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 - | _ => crate::operation::transact_write_items::TransactWriteItemsError::generic(generic),
|
154 - | })
|
155 - | }
|
156 - |
|
157 - | #[allow(clippy::unnecessary_wraps)]
|
158 - | pub fn de_transact_write_items_http_response(
|
159 - | _response_status: u16,
|
160 - | _response_headers: &::aws_smithy_runtime_api::http::Headers,
|
161 - | _response_body: &[u8],
|
162 - | ) -> std::result::Result<
|
163 - | crate::operation::transact_write_items::TransactWriteItemsOutput,
|
164 - | crate::operation::transact_write_items::TransactWriteItemsError,
|
165 - | > {
|
166 - | Ok({
|
167 - | #[allow(unused_mut)]
|
168 - | let mut output = crate::operation::transact_write_items::builders::TransactWriteItemsOutputBuilder::default();
|
169 - | output = crate::protocol_serde::shape_transact_write_items::de_transact_write_items(_response_body, output)
|
170 - | .map_err(crate::operation::transact_write_items::TransactWriteItemsError::unhandled)?;
|
171 - | output.build()
|
172 - | })
|
173 - | }
|
174 - |
|
175 - | pub fn ser_transact_write_items_input(
|
176 - | input: &crate::operation::transact_write_items::TransactWriteItemsInput,
|
177 - | ) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
|
178 - | let mut out = String::new();
|
179 - | let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
|
180 - | crate::protocol_serde::shape_transact_write_items_input::ser_transact_write_items_input_input(&mut object, input)?;
|
181 - | object.finish();
|
182 - | Ok(::aws_smithy_types::body::SdkBody::from(out))
|
183 - | }
|
184 - |
|
185 - | pub(crate) fn de_transact_write_items(
|
186 - | _value: &[u8],
|
187 - | mut builder: crate::operation::transact_write_items::builders::TransactWriteItemsOutputBuilder,
|
188 - | ) -> ::std::result::Result<
|
189 - | crate::operation::transact_write_items::builders::TransactWriteItemsOutputBuilder,
|
190 - | ::aws_smithy_json::deserialize::error::DeserializeError,
|
191 - | > {
|
192 - | let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(crate::protocol_serde::or_empty_doc(_value)).peekable();
|
193 - | let tokens = &mut tokens_owned;
|
194 - | ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
|
195 - | loop {
|
196 - | match tokens.next().transpose()? {
|
197 - | Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
|
198 - | Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
|
199 - | "ConsumedCapacity" => {
|
200 - | builder = builder.set_consumed_capacity(crate::protocol_serde::shape_consumed_capacity_multiple::de_consumed_capacity_multiple(
|
201 - | tokens, _value,
|
202 - | )?);
|
203 - | }
|
204 - | "ItemCollectionMetrics" => {
|
205 - | builder = builder.set_item_collection_metrics(
|
206 - | crate::protocol_serde::shape_item_collection_metrics_per_table::de_item_collection_metrics_per_table(tokens, _value)?,
|
207 - | );
|
208 - | }
|
209 - | _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
|
210 - | },
|
211 - | other => {
|
212 - | return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
|
213 - | "expected object key or end object, found: {other:?}"
|
214 - | )))
|
215 - | }
|
216 - | }
|
217 - | }
|
218 - | if tokens.next().is_some() {
|
219 - | return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
|
220 - | "found more JSON tokens after completing parsing",
|
221 - | ));
|
222 - | }
|
223 - | Ok(builder)
|
224 - | }
|