fraiseql-core 2.12.0

//! Type-erased relay cursor dispatch.
//!
//! `RelayDispatch` is a private type-erased relay executor stored as
//! `Option<Arc<dyn RelayDispatch>>` in `Executor<A>`.  It is populated at
//! construction time only when `A: RelayDatabaseAdapter`, giving us:
//!
//!  - No `unreachable!()` in non-relay adapters.
//!  - No capability flag to keep in sync.
//!  - `execute_relay_page` exists *only* on relay-capable adapters.
//!  - One clean runtime `Option::is_some()` check in the dispatcher.
//!
//! This design works in stable Rust because specialisation is not required —
//! the selection happens in two differently-named constructors.

use std::sync::Arc;

use futures::future::BoxFuture;

use crate::{
    compiler::aggregation::OrderByClause,
    db::{CursorValue, RelayDatabaseAdapter, WhereClause, traits::RelayPageResult},
    error::Result,
};

pub(in crate::runtime::executor) trait RelayDispatch:
    Send + Sync
{
    #[allow(clippy::too_many_arguments)] // Reason: relay pagination requires all cursor/filter/sort/count arguments plus session vars; no natural grouping
    fn execute_relay_page_with_session<'a>(
        &'a self,
        view: &'a str,
        cursor_column: &'a str,
        after: Option<CursorValue>,
        before: Option<CursorValue>,
        limit: u32,
        forward: bool,
        where_clause: Option<&'a WhereClause>,
        order_by: Option<&'a [OrderByClause]>,
        include_total_count: bool,
        session_vars: &'a [(&'a str, &'a str)],
    ) -> BoxFuture<'a, Result<RelayPageResult>>;
}

pub(in crate::runtime::executor) struct RelayDispatchImpl<A: RelayDatabaseAdapter>(
    pub(in crate::runtime::executor) Arc<A>,
);

impl<A: RelayDatabaseAdapter + Send + Sync + 'static> RelayDispatch for RelayDispatchImpl<A> {
    #[allow(clippy::too_many_arguments)] // Reason: relay pagination requires all cursor/filter/sort/count arguments plus session vars; no natural grouping
    fn execute_relay_page_with_session<'a>(
        &'a self,
        view: &'a str,
        cursor_column: &'a str,
        after: Option<CursorValue>,
        before: Option<CursorValue>,
        limit: u32,
        forward: bool,
        where_clause: Option<&'a WhereClause>,
        order_by: Option<&'a [OrderByClause]>,
        include_total_count: bool,
        session_vars: &'a [(&'a str, &'a str)],
    ) -> BoxFuture<'a, Result<RelayPageResult>> {
        Box::pin(self.0.execute_relay_page_with_session(
            view,
            cursor_column,
            after,
            before,
            limit,
            forward,
            where_clause,
            order_by,
            include_total_count,
            session_vars,
        ))
    }
}