use async_trait::async_trait;
use crate::Context;
use crate::Error;
use crate::model::DeleteProjectGrantResponse;
use crate::model::ErrorBody;
use crate::model::ErrorsBody;
use crate::model::ProjectGrant;
use crate::model::ProjectGrantDataRequest;
use uuid::Uuid;
pub enum ProjectGrantError {
Error400(ErrorsBody),
Error401(ErrorBody),
Error403(ErrorBody),
Error404(ErrorBody),
Error500(ErrorBody),
}
#[async_trait]
pub trait ProjectGrantClient {
async fn get(&self, project_id: &Uuid) -> Result<Vec<ProjectGrant>, Error<ProjectGrantError>>;
async fn post(&self, project_id: &Uuid, value: &ProjectGrantDataRequest) -> Result<ProjectGrant, Error<ProjectGrantError>>;
async fn grant_id_get(&self, project_id: &Uuid, grant_id: &Uuid) -> Result<ProjectGrant, Error<ProjectGrantError>>;
async fn grant_id_delete(&self, project_id: &Uuid, grant_id: &Uuid) -> Result<DeleteProjectGrantResponse, Error<ProjectGrantError>>;
}
pub struct ProjectGrantClientLive {
pub context: Context,
}
#[async_trait]
impl ProjectGrantClient for ProjectGrantClientLive {
async fn get(&self, project_id: &Uuid) -> Result<Vec<ProjectGrant>, Error<ProjectGrantError>> {
let mut url = self.context.base_url.clone();
url.path_segments_mut().unwrap()
.push("v2")
.push("projects")
.push(&project_id.to_string())
.push("grants");
let mut request = self
.context
.client
.get(url.clone());
{
tracing::info!(method="get", endpoint="/v2/projects/{project_id}/grants", url=url.to_string(), "get");
}
if let Some(token) = self.context.bearer_token() {
request = request.bearer_auth(token);
}
let response = request.send().await?;
let status = response.status().as_u16();
match status {
200 => {
Ok(response.json::<Vec<ProjectGrant>>().await?)
}
400 => {
let body = response.json::<ErrorsBody>().await?;
Err(Error::Item(ProjectGrantError::Error400(body)))
}
401 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error401(body)))
}
403 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error403(body)))
}
404 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error404(body)))
}
500 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error500(body)))
}
_ => Err(Error::unexpected(status, response.bytes().await?)),
}
}
async fn post(&self, project_id: &Uuid, value: &ProjectGrantDataRequest) -> Result<ProjectGrant, Error<ProjectGrantError>> {
let mut url = self.context.base_url.clone();
url.path_segments_mut().unwrap()
.push("v2")
.push("projects")
.push(&project_id.to_string())
.push("grants");
let mut request = self
.context
.client
.post(url.clone());
{
tracing::info!(method="post", endpoint="/v2/projects/{project_id}/grants", url=url.to_string(), body=serde_json::to_string(value)?, "post");
}
if let Some(token) = self.context.bearer_token() {
request = request.bearer_auth(token);
}
request = request.json(value);
let response = request.send().await?;
let status = response.status().as_u16();
match status {
200 => {
Ok(response.json::<ProjectGrant>().await?)
}
400 => {
let body = response.json::<ErrorsBody>().await?;
Err(Error::Item(ProjectGrantError::Error400(body)))
}
401 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error401(body)))
}
403 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error403(body)))
}
404 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error404(body)))
}
500 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error500(body)))
}
_ => Err(Error::unexpected(status, response.bytes().await?)),
}
}
async fn grant_id_get(&self, project_id: &Uuid, grant_id: &Uuid) -> Result<ProjectGrant, Error<ProjectGrantError>> {
let mut url = self.context.base_url.clone();
url.path_segments_mut().unwrap()
.push("v2")
.push("projects")
.push(&project_id.to_string())
.push("grants")
.push(&grant_id.to_string());
let mut request = self
.context
.client
.get(url.clone());
{
tracing::info!(method="get", endpoint="/v2/projects/{project_id}/grants/{grant_id}", url=url.to_string(), "grant_id_get");
}
if let Some(token) = self.context.bearer_token() {
request = request.bearer_auth(token);
}
let response = request.send().await?;
let status = response.status().as_u16();
match status {
200 => {
Ok(response.json::<ProjectGrant>().await?)
}
400 => {
let body = response.json::<ErrorsBody>().await?;
Err(Error::Item(ProjectGrantError::Error400(body)))
}
401 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error401(body)))
}
403 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error403(body)))
}
404 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error404(body)))
}
500 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error500(body)))
}
_ => Err(Error::unexpected(status, response.bytes().await?)),
}
}
async fn grant_id_delete(&self, project_id: &Uuid, grant_id: &Uuid) -> Result<DeleteProjectGrantResponse, Error<ProjectGrantError>> {
let mut url = self.context.base_url.clone();
url.path_segments_mut().unwrap()
.push("v2")
.push("projects")
.push(&project_id.to_string())
.push("grants")
.push(&grant_id.to_string());
let mut request = self
.context
.client
.delete(url.clone());
{
tracing::info!(method="delete", endpoint="/v2/projects/{project_id}/grants/{grant_id}", url=url.to_string(), "grant_id_delete");
}
if let Some(token) = self.context.bearer_token() {
request = request.bearer_auth(token);
}
let response = request.send().await?;
let status = response.status().as_u16();
match status {
200 => {
Ok(response.json::<DeleteProjectGrantResponse>().await?)
}
400 => {
let body = response.json::<ErrorsBody>().await?;
Err(Error::Item(ProjectGrantError::Error400(body)))
}
401 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error401(body)))
}
403 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error403(body)))
}
404 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error404(body)))
}
500 => {
let body = response.json::<ErrorBody>().await?;
Err(Error::Item(ProjectGrantError::Error500(body)))
}
_ => Err(Error::unexpected(status, response.bytes().await?)),
}
}
}