use crate::error::{ApiError, Result};
use reqwest::Client;
use serde_json::Value;
use url::Url;
pub struct ContributorsClient {
base_url: String,
client: Client,
}
impl ContributorsClient {
pub fn new(base_url: String, client: Client) -> Self {
Self { base_url, client }
}
pub fn with_auth(self, token: &str) -> Self {
self
}
pub async fn get_group_members_access_level(
&self,
group: String,
include_inherit: Option<bool>,
) -> Result<Value> {
let path = format!("/{}/-/members/access-level", group);
let mut url = Url::parse(&format!("{}{}", self.base_url, path))?;
if let Some(value) = include_inherit {
url.query_pairs_mut().append_pair("include_inherit", &value.to_string());
}
let request = self.client.request(
reqwest::Method::GET,
url
);
let response = request.send().await?;
if response.status().is_success() {
let json: Value = response.json().await?;
Ok(json)
} else {
Err(ApiError::HttpError(response.status().as_u16()))
}
}
pub async fn get_repo_members_username_access_level(
&self,
repo: String,
username: String,
) -> Result<Value> {
let path = format!("/{}/-/members/{}/access-level", repo, username);
let url = Url::parse(&format!("{}{}", self.base_url, path))?;
let request = self.client.request(
reqwest::Method::GET,
url
);
let response = request.send().await?;
if response.status().is_success() {
let json: Value = response.json().await?;
Ok(json)
} else {
Err(ApiError::HttpError(response.status().as_u16()))
}
}
pub async fn get_repo_members_access_level(
&self,
repo: String,
include_inherit: Option<bool>,
) -> Result<Value> {
let path = format!("/{}/-/members/access-level", repo);
let mut url = Url::parse(&format!("{}{}", self.base_url, path))?;
if let Some(value) = include_inherit {
url.query_pairs_mut().append_pair("include_inherit", &value.to_string());
}
let request = self.client.request(
reqwest::Method::GET,
url
);
let response = request.send().await?;
if response.status().is_success() {
let json: Value = response.json().await?;
Ok(json)
} else {
Err(ApiError::HttpError(response.status().as_u16()))
}
}
pub async fn get_group_members_username_access_level(
&self,
group: String,
username: String,
) -> Result<Value> {
let path = format!("/{}/-/members/{}/access-level", group, username);
let url = Url::parse(&format!("{}{}", self.base_url, path))?;
let request = self.client.request(
reqwest::Method::GET,
url
);
let response = request.send().await?;
if response.status().is_success() {
let json: Value = response.json().await?;
Ok(json)
} else {
Err(ApiError::HttpError(response.status().as_u16()))
}
}
}