use crate::error::{map_manager_err, ManagerError};
use crate::gen::manager::apis::conference_api as api;
use crate::gen::manager::apis::configuration::Configuration;
use crate::gen::manager::models;
use crate::http::collect_all;
use crate::retry::{with_retry, RetryPolicy};
use crate::token::SharedCfg;
pub struct ConferencesResource {
pub(crate) cfg: SharedCfg<Configuration>,
pub(crate) retry: RetryPolicy,
}
impl ConferencesResource {
pub async fn list_all(&self) -> Result<Vec<models::Conference>, ManagerError> {
let cfg = self.cfg.get().await?;
let cfg = cfg.as_ref();
collect_all(&self.retry, map_manager_err, |page| async move {
let r = api::list_conferences(cfg, Some(page), None).await?;
Ok((
r.items,
r.pagination.pages.unwrap_or(1),
r.pagination.current.unwrap_or(1),
))
})
.await
}
pub async fn get(&self, id: &str) -> Result<models::ConferenceItemResponse, ManagerError> {
let cfg = self.cfg.get().await?;
let cfg = cfg.as_ref();
with_retry(&self.retry, true, || api::get_conference(cfg, id))
.await
.map_err(map_manager_err)
}
}