use crate::error::{map_manager_err, ManagerError};
use crate::gen::manager::apis::configuration::Configuration;
use crate::gen::manager::apis::events_api as api;
use crate::gen::manager::models;
use crate::retry::{with_retry, RetryPolicy};
use crate::token::SharedCfg;
pub struct EventsResource {
pub(crate) cfg: SharedCfg<Configuration>,
pub(crate) retry: RetryPolicy,
}
impl EventsResource {
pub async fn list(&self) -> Result<Vec<models::Event>, ManagerError> {
let cfg = self.cfg.get().await?;
let cfg = cfg.as_ref();
let resp = with_retry(&self.retry, true, || api::list_events(cfg, None))
.await
.map_err(map_manager_err)?;
Ok(resp.items)
}
pub async fn create_custom(
&self,
body: models::CustomEventRequest,
) -> Result<models::EventItemResponse, ManagerError> {
let cfg = self.cfg.get().await?;
let cfg = cfg.as_ref();
with_retry(&self.retry, false, || {
api::create_custom_event(cfg, body.clone())
})
.await
.map_err(map_manager_err)
}
pub async fn delete_custom(&self, id: &str) -> Result<(), ManagerError> {
let cfg = self.cfg.get().await?;
let cfg = cfg.as_ref();
with_retry(&self.retry, false, || api::delete_custom_event(cfg, id))
.await
.map_err(map_manager_err)
}
}