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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
use crate::{errors::{CrateResult, Error}, utils::{handle_response, handle_response_alt}};
use reqwest::{IntoUrl, Response, StatusCode, Url, header::HeaderMap, multipart};
use serde::{Serialize, de::DeserializeOwned};
pub struct RestApiClientBuilder<ApiErrorType>
where
ApiErrorType: DeserializeOwned + ToString + Clone
{
http_client: reqwest::Client,
api_base_url: Result<Url, reqwest::Error>,
placeholder: Option<ApiErrorType>
}
impl<ApiErrorType> RestApiClientBuilder<ApiErrorType>
where
ApiErrorType: DeserializeOwned + ToString + Clone
{
pub fn new<T: IntoUrl>(http_client: reqwest::Client, api_base_url: T) -> Self {
Self{
http_client: http_client,
api_base_url: api_base_url.into_url(),
placeholder: None
}
}
pub fn build(self) -> CrateResult<RestApiClient<ApiErrorType>> {
Ok(
RestApiClient{
http_client: self.http_client,
api_base_url: self.api_base_url?,
placeholder: None
}
)
}
}
#[derive(Clone)]
pub struct RestApiClient<ApiErrorType>
where
ApiErrorType: DeserializeOwned + ToString + Clone
{
http_client: reqwest::Client,
api_base_url: Url,
placeholder: Option<ApiErrorType>
}
impl<ApiErrorType> RestApiClient<ApiErrorType>
where
ApiErrorType: DeserializeOwned + ToString + Clone
{
pub async fn get<ResponseDataType>(&self, path: &str) -> CrateResult<(ResponseDataType, HeaderMap)>
where
ResponseDataType: DeserializeOwned
{
let url = self.api_base_url.to_string() + path;
let response = self.http_client.get(url).send().await?;
handle_response::<ResponseDataType, ApiErrorType>(response).await
}
pub async fn post<RequestDataType, ResponseDataType>(&self, request_data: RequestDataType, path: &str) -> CrateResult<(ResponseDataType, HeaderMap)>
where
RequestDataType: Serialize,
ResponseDataType: DeserializeOwned
{
let url = self.api_base_url.to_string() + path;
let response = self.http_client.post(url).json(&request_data).send().await?;
handle_response::<ResponseDataType, ApiErrorType>(response).await
}
pub async fn patch<RequestDataType, ResponseDataType>(&self, request_data: RequestDataType, path: &str) -> CrateResult<(ResponseDataType, HeaderMap)>
where
RequestDataType: Serialize,
ResponseDataType: DeserializeOwned
{
let url = self.api_base_url.to_string() + path;
let response = self.http_client.patch(url).json(&request_data).send().await?;
handle_response::<ResponseDataType, ApiErrorType>(response).await
}
pub async fn put<RequestDataType, ResponseDataType>(&self, request_data: RequestDataType, path: &str) -> CrateResult<(ResponseDataType, HeaderMap)>
where
RequestDataType: Serialize,
ResponseDataType: DeserializeOwned
{
let url = self.api_base_url.to_string() + path;
let response = self.http_client.put(url).json(&request_data).send().await?;
handle_response::<ResponseDataType, ApiErrorType>(response).await
}
pub async fn delete<ResponseDataType>(&self, path: &str) -> CrateResult<(ResponseDataType, HeaderMap)>
where
ResponseDataType: DeserializeOwned
{
let url = self.api_base_url.to_string() + path;
let response = self.http_client.delete(url).send().await?;
handle_response::<ResponseDataType, ApiErrorType>(response).await
}
pub async fn post_alt<RequestDataType>(&self, request_data: RequestDataType, path: &str) -> CrateResult<HeaderMap>
where
RequestDataType: Serialize,
{
let url = self.api_base_url.to_string() + path;
let response = self.http_client.post(url).json(&request_data).send().await?;
handle_response_alt::<ApiErrorType>(response).await
}
pub async fn patch_alt<RequestDataType>(&self, request_data: RequestDataType, path: &str) -> CrateResult<HeaderMap>
where
RequestDataType: Serialize,
{
let url = self.api_base_url.to_string() + path;
let response = self.http_client.patch(url).json(&request_data).send().await?;
handle_response_alt::<ApiErrorType>(response).await
}
pub async fn put_alt<RequestDataType>(&self, request_data: RequestDataType, path: &str) -> CrateResult<HeaderMap>
where
RequestDataType: Serialize,
{
let url = self.api_base_url.to_string() + path;
let response = self.http_client.put(url).json(&request_data).send().await?;
handle_response_alt::<ApiErrorType>(response).await
}
pub async fn delete_alt(&self, path: &str) -> CrateResult<HeaderMap>
{
let url = self.api_base_url.to_string() + path;
let response = self.http_client.delete(url).send().await?;
handle_response_alt::<ApiErrorType>(response).await
}
pub async fn post_multipart_alt(&self, form: multipart::Form, path: &str) -> CrateResult<HeaderMap>
where
{
let url = self.api_base_url.to_string() + path;
let response = self.http_client.post(url).multipart(form).send().await?;
handle_response_alt::<ApiErrorType>(response).await
}
}