babelforce-manager-sdk 0.46.0

use crate::error::{map_manager_err, ManagerError};
use crate::gen::manager::apis::configuration::Configuration;
use crate::gen::manager::apis::{manager_api, queue_api, queue_selection_api};
use crate::gen::manager::models;
use crate::http::{collect_all, fetch_page, Page};
use crate::retry::{with_retry, RetryPolicy};
use crate::token::SharedCfg;

/// Queues — `/api/v2/queues`, with a nested `selections` sub-resource.
pub struct QueuesResource {
    pub(crate) cfg: SharedCfg<Configuration>,
    pub(crate) retry: RetryPolicy,
    /// Queue selections — `/api/v2/queues/{queueId}/selections`.
    pub selections: QueueSelectionsResource,
}

impl QueuesResource {
    /// List all queues (auto-paginated).
    pub async fn list_all(&self) -> Result<Vec<models::Queue>, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        collect_all(&self.retry, map_manager_err, |page| async move {
            let r = queue_api::list_queues(cfg, Some(page), None).await?;
            Ok((
                r.items,
                r.pagination.pages.unwrap_or(1),
                r.pagination.current.unwrap_or(1),
            ))
        })
        .await
    }

    /// List one page of queues.
    pub async fn list_page(
        &self,
        page: i32,
        per_page: Option<i32>,
    ) -> Result<Page<models::Queue>, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        fetch_page(&self.retry, map_manager_err, || async move {
            let r = queue_api::list_queues(cfg, Some(page), per_page).await?;
            Ok((
                r.items,
                r.pagination.pages.unwrap_or(1),
                r.pagination.current.unwrap_or(1),
                r.pagination.total,
            ))
        })
        .await
    }

    /// Create a queue.
    pub async fn create(
        &self,
        body: models::RestCreateQueue,
    ) -> Result<models::QueueItemResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            queue_api::create_queue(cfg, body.clone())
        })
        .await
        .map_err(map_manager_err)
    }

    /// Get a queue by id.
    pub async fn get(&self, id: &str) -> Result<models::QueueItemResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, true, || queue_api::get_queue(cfg, id))
            .await
            .map_err(map_manager_err)
    }

    /// Update a queue.
    pub async fn update(
        &self,
        id: &str,
        body: models::RestUpdateQueue,
    ) -> Result<models::QueueItemResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            queue_api::update_queue(cfg, id, body.clone())
        })
        .await
        .map_err(map_manager_err)
    }

    /// Delete a queue.
    pub async fn delete(&self, id: &str) -> Result<(), ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || queue_api::delete_queue(cfg, id))
            .await
            .map_err(map_manager_err)?;
        Ok(())
    }

    /// List the triggers attached to a queue.
    pub async fn list_triggers(
        &self,
        queue_id: &str,
    ) -> Result<models::QueueTriggerListResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, true, || {
            queue_api::list_queue_triggers(cfg, queue_id)
        })
        .await
        .map_err(map_manager_err)
    }

    /// Bulk-update queues; returns the updated queues.
    pub async fn bulk_update(
        &self,
        body: models::QueueBulkUpdateRequest,
    ) -> Result<models::QueueListResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            queue_api::bulk_update_queues(cfg, body.clone())
        })
        .await
        .map_err(map_manager_err)
    }

    /// List queue selections across all queues.
    pub async fn global_selections(
        &self,
    ) -> Result<models::GlobalQueueSelectionListResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, true, || {
            queue_api::list_global_queue_selections(cfg, None, None, None, None, None)
        })
        .await
        .map_err(map_manager_err)
    }
}

/// Queue selections (routing rules) and their agent/group/tag membership.
pub struct QueueSelectionsResource {
    pub(crate) cfg: SharedCfg<Configuration>,
    pub(crate) retry: RetryPolicy,
}

impl QueueSelectionsResource {
    /// List all selections for a queue (auto-paginated).
    pub async fn list_all(
        &self,
        queue_id: &str,
    ) -> Result<Vec<models::QueueSelection>, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        collect_all(&self.retry, map_manager_err, |page| async move {
            let r =
                queue_selection_api::list_queue_selections(cfg, queue_id, Some(page), None).await?;
            Ok((
                r.items,
                r.pagination.pages.unwrap_or(1),
                r.pagination.current.unwrap_or(1),
            ))
        })
        .await
    }

    /// Create a selection on a queue.
    pub async fn create(
        &self,
        queue_id: &str,
        body: models::RestCreateQueueSelection,
    ) -> Result<models::QueueSelectionItemResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            queue_selection_api::create_queue_selection(cfg, queue_id, body.clone())
        })
        .await
        .map_err(map_manager_err)
    }

    /// Get a selection.
    pub async fn get(
        &self,
        queue_id: &str,
        id: &str,
    ) -> Result<models::QueueSelectionItemResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, true, || {
            queue_selection_api::get_queue_selection(cfg, queue_id, id)
        })
        .await
        .map_err(map_manager_err)
    }

    /// Update a selection.
    pub async fn update(
        &self,
        queue_id: &str,
        id: &str,
        body: models::RestUpdateQueueSelection,
    ) -> Result<models::QueueSelectionItemResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            queue_selection_api::update_queue_selection(cfg, queue_id, id, body.clone())
        })
        .await
        .map_err(map_manager_err)
    }

    /// Delete a selection.
    pub async fn delete(&self, queue_id: &str, id: &str) -> Result<(), ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            queue_selection_api::delete_queue_selection(cfg, queue_id, id)
        })
        .await
        .map_err(map_manager_err)?;
        Ok(())
    }

    /// Resolve the agents currently selected for a queue.
    pub async fn select_agents(
        &self,
        queue_id: &str,
    ) -> Result<models::QueueSelectionResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, true, || {
            manager_api::get_agents_for_queue_selection(cfg, queue_id, None)
        })
        .await
        .map_err(map_manager_err)
    }

    /// Add an agent to a selection.
    pub async fn add_agent(
        &self,
        queue_id: &str,
        selection_id: &str,
        agent_id: &str,
    ) -> Result<models::QueueSelectionModificationResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            manager_api::add_agent_to_queue_selection(
                cfg,
                queue_id,
                selection_id,
                Some(addition(agent_id)),
            )
        })
        .await
        .map_err(map_manager_err)
    }

    /// Remove an agent from a selection.
    pub async fn remove_agent(
        &self,
        queue_id: &str,
        selection_id: &str,
        id: &str,
    ) -> Result<models::QueueSelectionModificationResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            manager_api::remove_agent_from_queue_selection(cfg, queue_id, selection_id, id)
        })
        .await
        .map_err(map_manager_err)
    }

    /// Add an agent group to a selection.
    pub async fn add_group(
        &self,
        queue_id: &str,
        selection_id: &str,
        group_id: &str,
    ) -> Result<models::QueueSelectionModificationResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            manager_api::add_group_to_queue_selection(
                cfg,
                queue_id,
                selection_id,
                Some(addition(group_id)),
            )
        })
        .await
        .map_err(map_manager_err)
    }

    /// Remove an agent group from a selection.
    pub async fn remove_group(
        &self,
        queue_id: &str,
        selection_id: &str,
        id: &str,
    ) -> Result<models::QueueSelectionModificationResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            manager_api::remove_group_from_queue_selection(cfg, queue_id, selection_id, id)
        })
        .await
        .map_err(map_manager_err)
    }

    /// Add a tag to a selection.
    pub async fn add_tag(
        &self,
        queue_id: &str,
        selection_id: &str,
        tag_id: &str,
    ) -> Result<models::QueueSelectionModificationResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            manager_api::add_tag_to_queue_selection(
                cfg,
                queue_id,
                selection_id,
                Some(addition(tag_id)),
            )
        })
        .await
        .map_err(map_manager_err)
    }

    /// Remove a tag from a selection.
    pub async fn remove_tag(
        &self,
        queue_id: &str,
        selection_id: &str,
        id: &str,
    ) -> Result<models::QueueSelectionModificationResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            manager_api::remove_tag_from_queue_selection(cfg, queue_id, selection_id, id)
        })
        .await
        .map_err(map_manager_err)
    }

    /// Set the priority order of a queue's selections.
    pub async fn set_priority(
        &self,
        queue_id: &str,
        items: Vec<models::QueueSelectionPriorityItem>,
    ) -> Result<models::QueueSelectionListResponse, ManagerError> {
        let cfg = self.cfg.get().await?;
        let cfg = cfg.as_ref();
        with_retry(&self.retry, false, || {
            queue_api::set_queue_selections_priority(cfg, queue_id, items.clone())
        })
        .await
        .map_err(map_manager_err)
    }
}

fn addition(id: &str) -> models::QueueSelectionAddition {
    models::QueueSelectionAddition {
        id: Some(id.to_string()),
    }
}