apalis-board-api 1.0.0

use apalis_core::error::BoxDynError;

/// Exposes Actix framework routes.
#[cfg(feature = "actix")]
pub mod actix;

/// Exposes Axum framework routes.
#[cfg(feature = "axum")]
pub mod axum;

/// Exposes Salvo framework routes.
#[cfg(feature = "salvo")]
pub mod salvo;

/// Trait for registering routes with a backend
pub trait RegisterRoute<B, T> {
    /// Register routes with the given backend
    #[must_use]
    fn register(self, queue: &str, backend: B) -> Self;
}

/// Builder for API routes
#[derive(Clone, Debug)]
pub struct ApiBuilder<R> {
    router: R,
    #[allow(unused)]
    /// may not be used in some conditional compilation
    root: bool,
}

impl<R> ApiBuilder<R> {
    /// Create a new ApiBuilder with default settings
    pub fn new(router: R) -> Self {
        Self { router, root: true }
    }
    /// Create a new ApiBuilder with a custom scope
    /// If `register_root` is true, the root routes (/queues, /tasks, /workers, /overview)
    /// will be registered on the provided scope.
    pub fn new_with_router(router: R, register_root: bool) -> Self {
        Self {
            router,
            root: register_root,
        }
    }

    /// Finalize the builder and return the router
    pub fn build(self) -> R {
        self.router
    }
}

/// Error type for Task push operations
#[derive(Debug, thiserror::Error)]
pub enum TaskRejection {
    /// A context header was present but could not be parsed
    #[error("Invalid context header: {name} - {reason}")]
    BadHeader {
        /// The name of the header that was invalid
        name: String,
        /// The reason the header was invalid
        reason: String,
    },
    /// The body (args) failed to deserialize
    #[error("Failed to deserialize body: {0}")]
    Body(BoxDynError),
}