use crate::api::*;
use crate::{ApiError, ClientConfig, HttpClient, QueryBuilder, RequestOptions};
use reqwest::Method;
pub struct IntegrationsClient {
pub http_client: HttpClient,
}
impl IntegrationsClient {
pub fn new(config: ClientConfig) -> Result<Self, ApiError> {
Ok(Self {
http_client: HttpClient::new(config.clone())?,
})
}
pub async fn list_all_integrations(
&self,
request: &ListAllIntegrationsQueryRequest,
options: Option<RequestOptions>,
) -> Result<GetIntegrationsResponse, ApiError> {
self.http_client
.execute_request(
Method::GET,
"integrations",
None,
QueryBuilder::new()
.int("page", request.page.clone())
.int("limit", request.limit.clone())
.string("search", request.search.clone())
.build(),
options,
)
.await
}
pub async fn create_an_integration(
&self,
request: &PostIntegrationsRequest,
options: Option<RequestOptions>,
) -> Result<PostIntegrationsResponse, ApiError> {
self.http_client
.execute_request(
Method::POST,
"integrations",
Some(serde_json::to_value(request).unwrap_or_default()),
None,
options,
)
.await
}
pub async fn get_an_integration(
&self,
id: &String,
options: Option<RequestOptions>,
) -> Result<GetIntegrationsIDResponse, ApiError> {
self.http_client
.execute_request(
Method::GET,
&format!("integrations/{}", id),
None,
None,
options,
)
.await
}
pub async fn delete_an_integration(
&self,
id: &String,
options: Option<RequestOptions>,
) -> Result<DeleteIntegrationsIDResponse, ApiError> {
self.http_client
.execute_request(
Method::DELETE,
&format!("integrations/{}", id),
None,
None,
options,
)
.await
}
pub async fn update_an_integration(
&self,
id: &String,
request: &PatchIntegrationsIDRequest,
options: Option<RequestOptions>,
) -> Result<PatchIntegrationsIDResponse, ApiError> {
self.http_client
.execute_request(
Method::PATCH,
&format!("integrations/{}", id),
Some(serde_json::to_value(request).unwrap_or_default()),
None,
options,
)
.await
}
}