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