icydb-core 0.213.35

IcyDB — A schema-first typed query engine and persistence runtime for Internet Computer canisters
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

//! Module: db::query::plan::validate::intent_policy
//! Responsibility: enforce high-level query-intent policy constraints before
//! access planning proceeds.
//! Does not own: symbol lookup or detailed order/group validation rules.
//! Boundary: keeps coarse query-shape policy checks centralized within plan validation.

use crate::db::query::plan::{
    OrderSpec, QueryMode,
    validate::PolicyPlanError,
    validate::plan_shape::{has_explicit_order, validate_order_shape},
};

/// Validate intent-level plan-shape rules derived from query mode + modifiers.
pub(in crate::db::query) fn validate_intent_plan_shape(
    mode: QueryMode,
    order: Option<&OrderSpec>,
    grouped: bool,
) -> Result<(), PolicyPlanError> {
    validate_order_shape(order)?;
    let is_delete_mode = mode.is_delete();

    // Delete queries still fail closed on grouped shapes before any lower plan
    // stages can reinterpret the same shape as a grouped read.
    if is_delete_mode && grouped {
        return Err(PolicyPlanError::delete_plan_with_grouping());
    }

    // Windowed deletes require explicit ordering so the delete slice is
    // deterministic before any executor routing proceeds.
    if is_delete_mode
        && matches!(&mode, QueryMode::Delete(spec) if spec.limit.is_some() || spec.offset() > 0)
        && !has_explicit_order(order)
    {
        return Err(PolicyPlanError::delete_window_requires_order());
    }

    Ok(())
}