edgee-api-client 1.3.0

pub mod auth;
pub mod data_collection;
mod upload;

pub const PROD_BASEURL: &str = "https://api.edgee.app";

progenitor::generate_api! {
    spec = "openapi.json",
    interface = Builder,
    derives = [ schemars::JsonSchema ],
}

/// This crate's entry point
///
/// Use this function to build a client configured to interact with Edgee API using provided
/// credentials
#[bon::builder(
    start_fn = new,
    finish_fn = connect,
    on(String, into),
)]
pub fn connect(#[builder(default = PROD_BASEURL)] baseurl: String, api_token: String) -> Client {
    use reqwest::header::{self, HeaderMap};

    let mut default_headers = HeaderMap::new();

    let auth_value = format!("Bearer {api_token}");
    default_headers.insert(header::AUTHORIZATION, auth_value.try_into().unwrap());

    let client = reqwest::Client::builder()
        .user_agent(concat!("edgee/", env!("CARGO_PKG_VERSION")))
        .default_headers(default_headers)
        .build()
        .unwrap();

    Client::new_with_client(&baseurl, client)
}

#[easy_ext::ext(ErrorExt)]
impl Error<types::ErrorResponse> {
    pub fn into_message(self) -> String {
        match self {
            Error::ErrorResponse(err) => err.error.message.clone(),
            _ => self.to_string(),
        }
    }
}

#[easy_ext::ext(ResultExt)]
impl<T> Result<T, Error<types::ErrorResponse>> {
    pub fn api_context(self, ctx: impl std::fmt::Display) -> anyhow::Result<T> {
        self.map_err(|err| anyhow::anyhow!("{ctx}: {}", err.into_message()))
    }

    pub fn api_with_context<F, C>(self, f: F) -> anyhow::Result<T>
    where
        F: FnOnce() -> C,
        C: std::fmt::Display,
    {
        self.map_err(|err| {
            let ctx = f();
            anyhow::anyhow!("{ctx}: {}", err.into_message())
        })
    }
}