#[derive(Debug)]
pub enum ProjectGrantError {
RequestFailure(reqwest::Error),
InvalidHeaderValue(reqwest::header::InvalidHeaderValue),
UnexpectedStatus(reqwest::StatusCode),
Status404 {
message: String,
},
Status403 {
error: String,
},
Status400 {
errors: Vec<String>,
},
Status500 {
error: String,
},
Status401 {
message: String,
},
}
impl From<reqwest::Error> for ProjectGrantError {
fn from(error: reqwest::Error) -> ProjectGrantError {
ProjectGrantError::RequestFailure(error)
}
}
impl From<reqwest::header::InvalidHeaderValue> for ProjectGrantError {
fn from(error: reqwest::header::InvalidHeaderValue) -> ProjectGrantError {
ProjectGrantError::InvalidHeaderValue(error)
}
}
impl ProjectGrantError {
pub fn to_project_endpoint_error(&self) -> Option<crate::model::ProjectEndpointError> {
match self {
ProjectGrantError::Status500 { error } => Some(crate::model::ProjectEndpointError::Internal { error: error.clone() }),
ProjectGrantError::Status404 { message } => Some(crate::model::ProjectEndpointError::NotFound { message: message.clone() }),
ProjectGrantError::Status403 { error } => Some(crate::model::ProjectEndpointError::LimitExceeded { error: error.clone() }),
ProjectGrantError::Status401 { message } => Some(crate::model::ProjectEndpointError::Unauthorized { message: message.clone() }),
ProjectGrantError::Status400 { errors } => Some(crate::model::ProjectEndpointError::ArgValidation { errors: errors.clone() }),
_ => None
}
}
}
#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
struct ProjectEndpointErrorNotFoundPayload {
pub message: String,
}
#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
struct ProjectEndpointErrorLimitExceededPayload {
pub error: String,
}
#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
struct ProjectEndpointErrorArgValidationPayload {
pub errors: Vec<String>,
}
#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
struct ProjectEndpointErrorInternalPayload {
pub error: String,
}
#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
struct ProjectEndpointErrorUnauthorizedPayload {
pub message: String,
}
#[async_trait::async_trait]
pub trait ProjectGrant {
async fn get_project_grants(&self, project_id: &str, authorization: &str) -> Result<Vec<crate::model::ProjectGrant>, ProjectGrantError>;
async fn get_project_grant(&self, project_id: &str, grant_id: &str, authorization: &str) -> Result<crate::model::ProjectGrant, ProjectGrantError>;
async fn post_project_grant(&self, project_id: &str, field0: crate::model::ProjectGrantDataRequest, authorization: &str) -> Result<crate::model::ProjectGrant, ProjectGrantError>;
async fn post_project_grant_with_actions(&self, project_id: &str, field0: crate::model::ProjectGrantDataWithProjectActions, authorization: &str) -> Result<crate::model::ProjectGrant, ProjectGrantError>;
async fn delete_grant(&self, project_id: &str, grant_id: &str, authorization: &str) -> Result<(), ProjectGrantError>;
}
#[derive(Clone, Debug)]
pub struct ProjectGrantLive {
pub base_url: reqwest::Url,
pub allow_insecure: bool,
}
#[async_trait::async_trait]
impl ProjectGrant for ProjectGrantLive {
async fn get_project_grants(&self, project_id: &str, authorization: &str) -> Result<Vec<crate::model::ProjectGrant>, ProjectGrantError> {
let mut url = self.base_url.clone();
url.path_segments_mut().unwrap()
.push("v1")
.push("projects")
.push(project_id)
.push("grants");
let mut headers = reqwest::header::HeaderMap::new();
headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
{
let headers_vec: Vec<(&str, String)> = headers.iter().map(|(k, v)| crate::hide_authorization(k, v)).collect();
tracing::info!(method="get", url=url.to_string(), headers=?headers_vec, body="<no_body>", "get_project_grants");
}
let mut builder = reqwest::Client::builder();
if self.allow_insecure {
builder = builder.danger_accept_invalid_certs(true);
}
let client = builder.build()?;
let result = client
.get(url)
.headers(headers)
.send()
.await?;
match result.status().as_u16() {
200 => {
let body = result.json::<Vec<crate::model::ProjectGrant>>().await?;
Ok(body)
}
404 => {
let body = result.json::<ProjectEndpointErrorNotFoundPayload>().await?;
Err(ProjectGrantError::Status404 { message: body.message })
}
403 => {
let body = result.json::<ProjectEndpointErrorLimitExceededPayload>().await?;
Err(ProjectGrantError::Status403 { error: body.error })
}
400 => {
let body = result.json::<ProjectEndpointErrorArgValidationPayload>().await?;
Err(ProjectGrantError::Status400 { errors: body.errors })
}
500 => {
let body = result.json::<ProjectEndpointErrorInternalPayload>().await?;
Err(ProjectGrantError::Status500 { error: body.error })
}
401 => {
let body = result.json::<ProjectEndpointErrorUnauthorizedPayload>().await?;
Err(ProjectGrantError::Status401 { message: body.message })
}
_ => Err(ProjectGrantError::UnexpectedStatus(result.status()))
}
}
async fn get_project_grant(&self, project_id: &str, grant_id: &str, authorization: &str) -> Result<crate::model::ProjectGrant, ProjectGrantError> {
let mut url = self.base_url.clone();
url.path_segments_mut().unwrap()
.push("v1")
.push("projects")
.push(project_id)
.push("grants")
.push(grant_id);
let mut headers = reqwest::header::HeaderMap::new();
headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
{
let headers_vec: Vec<(&str, String)> = headers.iter().map(|(k, v)| crate::hide_authorization(k, v)).collect();
tracing::info!(method="get", url=url.to_string(), headers=?headers_vec, body="<no_body>", "get_project_grant");
}
let mut builder = reqwest::Client::builder();
if self.allow_insecure {
builder = builder.danger_accept_invalid_certs(true);
}
let client = builder.build()?;
let result = client
.get(url)
.headers(headers)
.send()
.await?;
match result.status().as_u16() {
200 => {
let body = result.json::<crate::model::ProjectGrant>().await?;
Ok(body)
}
404 => {
let body = result.json::<ProjectEndpointErrorNotFoundPayload>().await?;
Err(ProjectGrantError::Status404 { message: body.message })
}
403 => {
let body = result.json::<ProjectEndpointErrorLimitExceededPayload>().await?;
Err(ProjectGrantError::Status403 { error: body.error })
}
400 => {
let body = result.json::<ProjectEndpointErrorArgValidationPayload>().await?;
Err(ProjectGrantError::Status400 { errors: body.errors })
}
500 => {
let body = result.json::<ProjectEndpointErrorInternalPayload>().await?;
Err(ProjectGrantError::Status500 { error: body.error })
}
401 => {
let body = result.json::<ProjectEndpointErrorUnauthorizedPayload>().await?;
Err(ProjectGrantError::Status401 { message: body.message })
}
_ => Err(ProjectGrantError::UnexpectedStatus(result.status()))
}
}
async fn post_project_grant(&self, project_id: &str, field0: crate::model::ProjectGrantDataRequest, authorization: &str) -> Result<crate::model::ProjectGrant, ProjectGrantError> {
let mut url = self.base_url.clone();
url.path_segments_mut().unwrap()
.push("v1")
.push("projects")
.push(project_id)
.push("grants");
let mut headers = reqwest::header::HeaderMap::new();
headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
{
let headers_vec: Vec<(&str, String)> = headers.iter().map(|(k, v)| crate::hide_authorization(k, v)).collect();
tracing::info!(method="post", url=url.to_string(), headers=?headers_vec, body=serde_json::to_string(&field0).unwrap(), "post_project_grant");
}
let mut builder = reqwest::Client::builder();
if self.allow_insecure {
builder = builder.danger_accept_invalid_certs(true);
}
let client = builder.build()?;
let result = client
.post(url)
.headers(headers)
.json(&field0)
.send()
.await?;
match result.status().as_u16() {
200 => {
let body = result.json::<crate::model::ProjectGrant>().await?;
Ok(body)
}
404 => {
let body = result.json::<ProjectEndpointErrorNotFoundPayload>().await?;
Err(ProjectGrantError::Status404 { message: body.message })
}
403 => {
let body = result.json::<ProjectEndpointErrorLimitExceededPayload>().await?;
Err(ProjectGrantError::Status403 { error: body.error })
}
400 => {
let body = result.json::<ProjectEndpointErrorArgValidationPayload>().await?;
Err(ProjectGrantError::Status400 { errors: body.errors })
}
500 => {
let body = result.json::<ProjectEndpointErrorInternalPayload>().await?;
Err(ProjectGrantError::Status500 { error: body.error })
}
401 => {
let body = result.json::<ProjectEndpointErrorUnauthorizedPayload>().await?;
Err(ProjectGrantError::Status401 { message: body.message })
}
_ => Err(ProjectGrantError::UnexpectedStatus(result.status()))
}
}
async fn post_project_grant_with_actions(&self, project_id: &str, field0: crate::model::ProjectGrantDataWithProjectActions, authorization: &str) -> Result<crate::model::ProjectGrant, ProjectGrantError> {
let mut url = self.base_url.clone();
url.path_segments_mut().unwrap()
.push("v1")
.push("projects")
.push(project_id)
.push("grants");
let mut headers = reqwest::header::HeaderMap::new();
headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
{
let headers_vec: Vec<(&str, String)> = headers.iter().map(|(k, v)| crate::hide_authorization(k, v)).collect();
tracing::info!(method="post", url=url.to_string(), headers=?headers_vec, body=serde_json::to_string(&field0).unwrap(), "post_project_grant_with_actions");
}
let mut builder = reqwest::Client::builder();
if self.allow_insecure {
builder = builder.danger_accept_invalid_certs(true);
}
let client = builder.build()?;
let result = client
.post(url)
.headers(headers)
.json(&field0)
.send()
.await?;
match result.status().as_u16() {
200 => {
let body = result.json::<crate::model::ProjectGrant>().await?;
Ok(body)
}
404 => {
let body = result.json::<ProjectEndpointErrorNotFoundPayload>().await?;
Err(ProjectGrantError::Status404 { message: body.message })
}
403 => {
let body = result.json::<ProjectEndpointErrorLimitExceededPayload>().await?;
Err(ProjectGrantError::Status403 { error: body.error })
}
400 => {
let body = result.json::<ProjectEndpointErrorArgValidationPayload>().await?;
Err(ProjectGrantError::Status400 { errors: body.errors })
}
500 => {
let body = result.json::<ProjectEndpointErrorInternalPayload>().await?;
Err(ProjectGrantError::Status500 { error: body.error })
}
401 => {
let body = result.json::<ProjectEndpointErrorUnauthorizedPayload>().await?;
Err(ProjectGrantError::Status401 { message: body.message })
}
_ => Err(ProjectGrantError::UnexpectedStatus(result.status()))
}
}
async fn delete_grant(&self, project_id: &str, grant_id: &str, authorization: &str) -> Result<(), ProjectGrantError> {
let mut url = self.base_url.clone();
url.path_segments_mut().unwrap()
.push("v1")
.push("projects")
.push(project_id)
.push("grants")
.push(grant_id);
let mut headers = reqwest::header::HeaderMap::new();
headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
{
let headers_vec: Vec<(&str, String)> = headers.iter().map(|(k, v)| crate::hide_authorization(k, v)).collect();
tracing::info!(method="post", url=url.to_string(), headers=?headers_vec, body="<no_body>", "delete_grant");
}
let mut builder = reqwest::Client::builder();
if self.allow_insecure {
builder = builder.danger_accept_invalid_certs(true);
}
let client = builder.build()?;
let result = client
.post(url)
.headers(headers)
.send()
.await?;
match result.status().as_u16() {
200 => {
let body = ();
Ok(body)
}
404 => {
let body = result.json::<ProjectEndpointErrorNotFoundPayload>().await?;
Err(ProjectGrantError::Status404 { message: body.message })
}
403 => {
let body = result.json::<ProjectEndpointErrorLimitExceededPayload>().await?;
Err(ProjectGrantError::Status403 { error: body.error })
}
400 => {
let body = result.json::<ProjectEndpointErrorArgValidationPayload>().await?;
Err(ProjectGrantError::Status400 { errors: body.errors })
}
500 => {
let body = result.json::<ProjectEndpointErrorInternalPayload>().await?;
Err(ProjectGrantError::Status500 { error: body.error })
}
401 => {
let body = result.json::<ProjectEndpointErrorUnauthorizedPayload>().await?;
Err(ProjectGrantError::Status401 { message: body.message })
}
_ => Err(ProjectGrantError::UnexpectedStatus(result.status()))
}
}
}