babelforce_manager_sdk/resources/
events.rs

1use crate::error::{map_manager_err, ManagerError};
2use crate::gen::manager::apis::configuration::Configuration;
3use crate::gen::manager::apis::events_api as api;
4use crate::gen::manager::models;
5use crate::retry::{with_retry, RetryPolicy};
6use crate::token::SharedCfg;
7
8/// Event definitions & custom events — `/api/v2/events`.
9pub struct EventsResource {
10    pub(crate) cfg: SharedCfg<Configuration>,
11    pub(crate) retry: RetryPolicy,
12}
13
14impl EventsResource {
15    /// List the known events.
16    pub async fn list(&self) -> Result<Vec<models::Event>, ManagerError> {
17        let cfg = self.cfg.get().await?;
18        let cfg = cfg.as_ref();
19        let resp = with_retry(&self.retry, true, || api::list_events(cfg, None))
20            .await
21            .map_err(map_manager_err)?;
22        Ok(resp.items)
23    }
24
25    /// Create a custom event.
26    pub async fn create_custom(
27        &self,
28        body: models::CustomEventRequest,
29    ) -> Result<models::EventItemResponse, ManagerError> {
30        let cfg = self.cfg.get().await?;
31        let cfg = cfg.as_ref();
32        with_retry(&self.retry, false, || {
33            api::create_custom_event(cfg, body.clone())
34        })
35        .await
36        .map_err(map_manager_err)
37    }
38
39    /// Delete a custom event.
40    pub async fn delete_custom(&self, id: &str) -> Result<(), ManagerError> {
41        let cfg = self.cfg.get().await?;
42        let cfg = cfg.as_ref();
43        with_retry(&self.retry, false, || api::delete_custom_event(cfg, id))
44            .await
45            .map_err(map_manager_err)
46    }
47}
babelforce_manager_sdk/resources/events.rs

babelforce_manager_sdk/resources/
events.rs
