use crate::error::{ApiError, Result};
use reqwest::Client;
use serde_json::Value;
use url::Url;
pub struct BadgeClient {
base_url: String,
client: Client,
}
impl BadgeClient {
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_repo_badge_list(
&self,
repo: String,
request_data: serde_json::Value,
) -> Result<Value> {
let path = format!("/{}/-/badge/list", repo);
let url = Url::parse(&format!("{}{}", self.base_url, path))?;
let mut request = self.client.request(
reqwest::Method::GET,
url
);
request = request.json(&request_data);
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_badge_git_sha_badge(
&self,
repo: String,
sha: String,
badge: String,
request_data: serde_json::Value,
) -> Result<Value> {
let path = format!("/{}/-/badge/git/{}/{}", repo, sha, badge);
let url = Url::parse(&format!("{}{}", self.base_url, path))?;
let mut request = self.client.request(
reqwest::Method::GET,
url
);
request = request.json(&request_data);
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 post_repo_badge_upload(
&self,
repo: String,
request_data: serde_json::Value,
) -> Result<Value> {
let path = format!("/{}/-/badge/upload", repo);
let url = Url::parse(&format!("{}{}", self.base_url, path))?;
let mut request = self.client.request(
reqwest::Method::POST,
url
);
request = request.json(&request_data);
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()))
}
}
}