golem-client 0.0.26

pub enum IsEnabledError {
    RequestFailure(reqwest::Error),
    InvalidHeaderValue(reqwest::header::InvalidHeaderValue),
    UnexpectedStatus(reqwest::StatusCode),
    Status500 {
        error: String,
    },
}

impl From<reqwest::Error> for IsEnabledError {
    fn from(error: reqwest::Error) -> IsEnabledError {
        IsEnabledError::RequestFailure(error)
    }
}

impl From<reqwest::header::InvalidHeaderValue> for IsEnabledError {
    fn from(error: reqwest::header::InvalidHeaderValue) -> IsEnabledError {
        IsEnabledError::InvalidHeaderValue(error)
    }
}

impl IsEnabledError {
    pub fn to_whitelist_endpoint_error(&self) -> Option<crate::model::WhitelistEndpointError> {
        match self {
            IsEnabledError::Status500 { error } => Some(crate::model::WhitelistEndpointError::Internal { error: error.clone() }), 
            _ => None
        }
    }
}

#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
struct WhitelistEndpointErrorInternalPayload {
    pub error: String,
}

pub enum SetEnabledError {
    RequestFailure(reqwest::Error),
    InvalidHeaderValue(reqwest::header::InvalidHeaderValue),
    UnexpectedStatus(reqwest::StatusCode),
    Status500 {
        error: String,
    },
}

impl From<reqwest::Error> for SetEnabledError {
    fn from(error: reqwest::Error) -> SetEnabledError {
        SetEnabledError::RequestFailure(error)
    }
}

impl From<reqwest::header::InvalidHeaderValue> for SetEnabledError {
    fn from(error: reqwest::header::InvalidHeaderValue) -> SetEnabledError {
        SetEnabledError::InvalidHeaderValue(error)
    }
}

impl SetEnabledError {
    pub fn to_whitelist_endpoint_error(&self) -> Option<crate::model::WhitelistEndpointError> {
        match self {
            SetEnabledError::Status500 { error } => Some(crate::model::WhitelistEndpointError::Internal { error: error.clone() }), 
            _ => None
        }
    }
}

pub enum GetWhitelistError {
    RequestFailure(reqwest::Error),
    InvalidHeaderValue(reqwest::header::InvalidHeaderValue),
    UnexpectedStatus(reqwest::StatusCode),
    Status500 {
        error: String,
    },
}

impl From<reqwest::Error> for GetWhitelistError {
    fn from(error: reqwest::Error) -> GetWhitelistError {
        GetWhitelistError::RequestFailure(error)
    }
}

impl From<reqwest::header::InvalidHeaderValue> for GetWhitelistError {
    fn from(error: reqwest::header::InvalidHeaderValue) -> GetWhitelistError {
        GetWhitelistError::InvalidHeaderValue(error)
    }
}

impl GetWhitelistError {
    pub fn to_whitelist_endpoint_error(&self) -> Option<crate::model::WhitelistEndpointError> {
        match self {
            GetWhitelistError::Status500 { error } => Some(crate::model::WhitelistEndpointError::Internal { error: error.clone() }), 
            _ => None
        }
    }
}

pub enum CountWhitelistError {
    RequestFailure(reqwest::Error),
    InvalidHeaderValue(reqwest::header::InvalidHeaderValue),
    UnexpectedStatus(reqwest::StatusCode),
    Status500 {
        error: String,
    },
}

impl From<reqwest::Error> for CountWhitelistError {
    fn from(error: reqwest::Error) -> CountWhitelistError {
        CountWhitelistError::RequestFailure(error)
    }
}

impl From<reqwest::header::InvalidHeaderValue> for CountWhitelistError {
    fn from(error: reqwest::header::InvalidHeaderValue) -> CountWhitelistError {
        CountWhitelistError::InvalidHeaderValue(error)
    }
}

impl CountWhitelistError {
    pub fn to_whitelist_endpoint_error(&self) -> Option<crate::model::WhitelistEndpointError> {
        match self {
            CountWhitelistError::Status500 { error } => Some(crate::model::WhitelistEndpointError::Internal { error: error.clone() }), 
            _ => None
        }
    }
}

pub enum AddToWhitelistError {
    RequestFailure(reqwest::Error),
    InvalidHeaderValue(reqwest::header::InvalidHeaderValue),
    UnexpectedStatus(reqwest::StatusCode),
    Status500 {
        error: String,
    },
}

impl From<reqwest::Error> for AddToWhitelistError {
    fn from(error: reqwest::Error) -> AddToWhitelistError {
        AddToWhitelistError::RequestFailure(error)
    }
}

impl From<reqwest::header::InvalidHeaderValue> for AddToWhitelistError {
    fn from(error: reqwest::header::InvalidHeaderValue) -> AddToWhitelistError {
        AddToWhitelistError::InvalidHeaderValue(error)
    }
}

impl AddToWhitelistError {
    pub fn to_whitelist_endpoint_error(&self) -> Option<crate::model::WhitelistEndpointError> {
        match self {
            AddToWhitelistError::Status500 { error } => Some(crate::model::WhitelistEndpointError::Internal { error: error.clone() }), 
            _ => None
        }
    }
}

pub enum RemoveFromWhitelistError {
    RequestFailure(reqwest::Error),
    InvalidHeaderValue(reqwest::header::InvalidHeaderValue),
    UnexpectedStatus(reqwest::StatusCode),
    Status500 {
        error: String,
    },
}

impl From<reqwest::Error> for RemoveFromWhitelistError {
    fn from(error: reqwest::Error) -> RemoveFromWhitelistError {
        RemoveFromWhitelistError::RequestFailure(error)
    }
}

impl From<reqwest::header::InvalidHeaderValue> for RemoveFromWhitelistError {
    fn from(error: reqwest::header::InvalidHeaderValue) -> RemoveFromWhitelistError {
        RemoveFromWhitelistError::InvalidHeaderValue(error)
    }
}

impl RemoveFromWhitelistError {
    pub fn to_whitelist_endpoint_error(&self) -> Option<crate::model::WhitelistEndpointError> {
        match self {
            RemoveFromWhitelistError::Status500 { error } => Some(crate::model::WhitelistEndpointError::Internal { error: error.clone() }), 
            _ => None
        }
    }
}

#[async_trait::async_trait]
pub trait Whitelist {
    async fn is_enabled(&self, authorization: &str) -> Result<bool, IsEnabledError>;
    async fn set_enabled(&self, field0: bool, authorization: &str) -> Result<(), SetEnabledError>;
    async fn get_whitelist(&self, skip: i32, limit: i32, authorization: &str) -> Result<Vec<crate::model::WhitelistEmail>, GetWhitelistError>;
    async fn count_whitelist(&self, authorization: &str) -> Result<i64, CountWhitelistError>;
    async fn add_to_whitelist(&self, field0: Vec<String>, authorization: &str) -> Result<(), AddToWhitelistError>;
    async fn remove_from_whitelist(&self, field0: Vec<String>, authorization: &str) -> Result<(), RemoveFromWhitelistError>;
}

#[derive(Clone, Debug)]
pub struct WhitelistLive {
    pub base_url: reqwest::Url,
}

#[async_trait::async_trait]
impl Whitelist for WhitelistLive {
    async fn is_enabled(&self, authorization: &str) -> Result<bool, IsEnabledError> {
        let mut url = self.base_url.clone();
        url.set_path("whitelist/enabled");

        let mut headers = reqwest::header::HeaderMap::new();
        headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
        let result = reqwest::Client::builder()
            .build()?
            .get(url)
            .headers(headers)
            .send()
            .await?;
        match result.status().as_u16() {
            200 => {
                let body = result.json::<bool>().await?;
                Ok(body)
            }
            500 => {
                let body = result.json::<WhitelistEndpointErrorInternalPayload>().await?;
                Err(IsEnabledError::Status500 { error: body.error })
            }
            _ => Err(IsEnabledError::UnexpectedStatus(result.status()))
        }
    }

    async fn set_enabled(&self, field0: bool, authorization: &str) -> Result<(), SetEnabledError> {
        let mut url = self.base_url.clone();
        url.set_path("whitelist/enabled");

        let mut headers = reqwest::header::HeaderMap::new();
        headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
        let result = reqwest::Client::builder()
            .build()?
            .put(url)
            .headers(headers)
            .json(&field0)
            .send()
            .await?;
        match result.status().as_u16() {
            200 => {
                let body = result.json::<()>().await?;
                Ok(body)
            }
            500 => {
                let body = result.json::<WhitelistEndpointErrorInternalPayload>().await?;
                Err(SetEnabledError::Status500 { error: body.error })
            }
            _ => Err(SetEnabledError::UnexpectedStatus(result.status()))
        }
    }

    async fn get_whitelist(&self, skip: i32, limit: i32, authorization: &str) -> Result<Vec<crate::model::WhitelistEmail>, GetWhitelistError> {
        let mut url = self.base_url.clone();
        url.set_path("whitelist");
        url.query_pairs_mut().append_pair("skip", &format!("{skip}"));
        url.query_pairs_mut().append_pair("limit", &format!("{limit}"));
        let mut headers = reqwest::header::HeaderMap::new();
        headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
        let result = reqwest::Client::builder()
            .build()?
            .get(url)
            .headers(headers)
            .send()
            .await?;
        match result.status().as_u16() {
            200 => {
                let body = result.json::<Vec<crate::model::WhitelistEmail>>().await?;
                Ok(body)
            }
            500 => {
                let body = result.json::<WhitelistEndpointErrorInternalPayload>().await?;
                Err(GetWhitelistError::Status500 { error: body.error })
            }
            _ => Err(GetWhitelistError::UnexpectedStatus(result.status()))
        }
    }

    async fn count_whitelist(&self, authorization: &str) -> Result<i64, CountWhitelistError> {
        let mut url = self.base_url.clone();
        url.set_path("whitelist/count");

        let mut headers = reqwest::header::HeaderMap::new();
        headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
        let result = reqwest::Client::builder()
            .build()?
            .get(url)
            .headers(headers)
            .send()
            .await?;
        match result.status().as_u16() {
            200 => {
                let body = result.json::<i64>().await?;
                Ok(body)
            }
            500 => {
                let body = result.json::<WhitelistEndpointErrorInternalPayload>().await?;
                Err(CountWhitelistError::Status500 { error: body.error })
            }
            _ => Err(CountWhitelistError::UnexpectedStatus(result.status()))
        }
    }

    async fn add_to_whitelist(&self, field0: Vec<String>, authorization: &str) -> Result<(), AddToWhitelistError> {
        let mut url = self.base_url.clone();
        url.set_path("whitelist");

        let mut headers = reqwest::header::HeaderMap::new();
        headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
        let result = reqwest::Client::builder()
            .build()?
            .post(url)
            .headers(headers)
            .json(&field0)
            .send()
            .await?;
        match result.status().as_u16() {
            200 => {
                let body = result.json::<()>().await?;
                Ok(body)
            }
            500 => {
                let body = result.json::<WhitelistEndpointErrorInternalPayload>().await?;
                Err(AddToWhitelistError::Status500 { error: body.error })
            }
            _ => Err(AddToWhitelistError::UnexpectedStatus(result.status()))
        }
    }

    async fn remove_from_whitelist(&self, field0: Vec<String>, authorization: &str) -> Result<(), RemoveFromWhitelistError> {
        let mut url = self.base_url.clone();
        url.set_path("whitelist/remove");

        let mut headers = reqwest::header::HeaderMap::new();
        headers.append("authorization", reqwest::header::HeaderValue::from_str(&format!("{authorization}"))?);
        let result = reqwest::Client::builder()
            .build()?
            .post(url)
            .headers(headers)
            .json(&field0)
            .send()
            .await?;
        match result.status().as_u16() {
            200 => {
                let body = result.json::<()>().await?;
                Ok(body)
            }
            500 => {
                let body = result.json::<WhitelistEndpointErrorInternalPayload>().await?;
                Err(RemoveFromWhitelistError::Status500 { error: body.error })
            }
            _ => Err(RemoveFromWhitelistError::UnexpectedStatus(result.status()))
        }
    }
}