1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
/*
* @Author: Jerry.Yang
* @Date: 2024-11-05 10:39:54
* @LastEditors: yangjie04 yangjie04@qutoutiao.net
* @LastEditTime: 2025-02-15 16:10:19
* @Description: Implementation of request and response handling for describing RDS instance details.
*/
use crate::volcengine::error::error;
use crate::volcengine::request::request::RequestVolcengine;
use crate::volcengine::request::{request, response};
use std::collections::HashMap;
use volcengine_sdk_protobuf::protobuf::rds_instance;
/// Implementation of the `ApiRequest` trait for the `DescribeDbInstanceDetailReq` structure.
/// This implementation provides the necessary methods to convert the request into a format suitable for sending over HTTP.
impl request::ApiRequest for rds_instance::DescribeDbInstanceDetailReq {
/// Converts the request into a `HashMap` of headers.
/// This method formats the request parameters into a `HashMap` that can be used as query parameters in the HTTP request.
/// The `Request::format_request_to_hashmap` method is used to handle the conversion.
fn to_hashmap(&self) -> HashMap<String, String> {
request::Request::format_request_to_hashmap(self)
}
/// Serializes the request into a byte vector to be sent as the request body.
/// For this specific request, no request body is required, so an empty byte vector is returned.
fn to_body(&self) -> Vec<u8> {
Vec::new()
}
}
/// Implementation of the `ApiResponse` trait for the `DescribeDbInstanceDetailResp` structure.
/// This implementation provides the necessary methods to parse the HTTP response into a structured response object.
impl response::ApiResponse for rds_instance::DescribeDbInstanceDetailResp {
/// Deserializes the HTTP response into a structured response object.
/// This method takes an `http_response` object, parses its JSON body, and updates the current response object with the parsed data.
///
/// # Arguments
/// * `http_response` - The HTTP response object received from the server.
///
/// # Returns
/// * `Result<(), error::Error>` - Returns `Ok(())` if the response is successfully parsed, or an error if parsing fails.
async fn to_struct(&mut self, http_response: reqwest::Response) -> Result<(), error::Error> {
// Get the HTTP status code from the response.
let http_status = http_response.status();
// Convert the response body to a text string.
let txt_response = http_response
.text()
.await
.map_err(|e| error::Error::ErrParseResponse(e))?;
// Sanitize the response text by replacing `null` values with empty arrays.
// This is necessary because the response may contain `null` values that need to be handled properly.
let sanitized_response = txt_response.replace("\"tags\":null", "\"tags\":[]"); // Replace `null` with an empty array
// Parse the sanitized JSON response body into the expected structure.
let parsed_response: volcengine_sdk_protobuf::protobuf::rds_instance::DescribeDbInstanceDetailResp =
serde_json::from_str(&sanitized_response).map_err(|e| error::Error::ErrParseJson(e))?;
// Update the current response object with the parsed data.
*self = parsed_response;
// Check if the HTTP status code indicates an error.
if !http_status.is_success() {
// Check if `response_metadata` exists in the response.
if let Some(mut response_metadata) = self.response_metadata.take() {
// Ensure the `error` field exists in `response_metadata`.
let response_metadata_error = response_metadata.error.get_or_insert_with(
volcengine_sdk_protobuf::protobuf::rds_instance::ResponseMetadataErr::default,
);
// Set the `code_n` field to the HTTP status code.
response_metadata_error.code_n = Some(http_status.as_u16().into());
// Update `response_metadata` with the error information.
self.response_metadata = Some(response_metadata);
}
}
// Return successfully if no errors occurred.
Ok(())
}
}