use crate::api::*;
use crate::{ApiError, ClientConfig, HttpClient, QueryBuilder, RequestOptions};
use reqwest::Method;
use std::collections::HashMap;
pub struct AccountsClient {
pub http_client: HttpClient,
}
impl AccountsClient {
pub fn new(config: ClientConfig) -> Result<Self, ApiError> {
Ok(Self {
http_client: HttpClient::new(config.clone())?,
})
}
pub async fn list_client_account_fields(
&self,
client_id: &str,
options: Option<RequestOptions>,
) -> Result<HashMap<String, CurrencyFieldSpec>, ApiError> {
self.http_client
.execute_request(
Method::GET,
&format!("v2/clients/{}/accounts/fields", client_id),
None,
None,
options,
)
.await
}
pub async fn list_client_accounts(
&self,
client_id: &str,
request: &ListClientAccountsQueryRequest,
options: Option<RequestOptions>,
) -> Result<PaginatedResponseClientAccountResponse, ApiError> {
self.http_client
.execute_request(
Method::GET,
&format!("v2/clients/{}/accounts", client_id),
None,
QueryBuilder::new()
.int("page", request.page.clone())
.serialize("page_size", request.page_size.clone())
.serialize("order_by", request.order_by.clone())
.build(),
options,
)
.await
}
pub async fn create_client_account(
&self,
client_id: &str,
request: &PartnerClientAccountCreateRequest,
options: Option<RequestOptions>,
) -> Result<ClientAccountResponse, ApiError> {
self.http_client
.execute_request(
Method::POST,
&format!("v2/clients/{}/accounts", client_id),
Some(serde_json::to_value(request).map_err(ApiError::Serialization)?),
None,
options,
)
.await
}
pub async fn get_client_account(
&self,
client_id: &str,
account_id: &str,
options: Option<RequestOptions>,
) -> Result<ClientAccountResponse, ApiError> {
self.http_client
.execute_request(
Method::GET,
&format!("v2/clients/{}/accounts/{}", client_id, account_id),
None,
None,
options,
)
.await
}
}