fuel-dispatch 0.19.1

// SPDX-License-Identifier: MIT OR Apache-2.0
//! Lowering: parsed FKC schema (strings) → typed dispatch records
//! (adoption plan §2, §2.1 / §2.2 mapping tables, §2.3 cost AST, §6 caps).
//!
//! This slice converts a parsed [`FkcKernel`] into a [`ResolvedPrimitive`]
//! or [`ResolvedFused`] — typed records ready for the NEXT slice (the
//! trampoline / global cost-table / `register_into`). It stops at typed
//! records + a **parsed** cost AST; it does NOT build a `CostFn`
//! fn-pointer.
//!
//! Every string → typed conversion is an **explicit, exhaustive `match`**
//! (NOT `FromStr`-by-discriminant) so that adding a new source variant
//! (a new `OpKind`, a new `DType`) forces a compile error here to extend
//! the table — the table cannot silently drift behind the type. The one
//! exception is `fused_op`, whose name table is **generated** from
//! `fuel-graph`'s `default_registry()` so it cannot drift from the graph's
//! single source of truth.

use fuel_graph::registry::{FusedOpId, FusedOps};
use fuel_ir::DType;
use fuel_ir::dispatch::OpKind;
use fuel_ir::probe::BackendId;
use smallvec::SmallVec;

use crate::fkc::caps_map::{self, ResolvedLayout};
use crate::fkc::cost_expr::{self, CompiledCostExpr};
use crate::fkc::error::FkcError;
use crate::fkc::precision;
use crate::fkc::revhash;
use crate::fkc::schema::{CostBlock, FkcKernel};
use crate::fused::{KernelRevisionHash, PrecisionGuarantee};
use crate::kernel::{CostFn, KernelCaps, KernelDTypes, KernelRef};

// ===========================================================================
// LinkRegistry — entry_point symbol → KernelRef (P9, §12.6)
// ===========================================================================

/// Resolve a contract's `entry_point` symbol string into a concrete
/// [`KernelRef`] function pointer. Each provider crate implements this
/// over its exported `&'static [(&str, KernelRef)]` table (FKC §12.6); a
/// test stub maps every symbol to a dummy kernel.
///
/// The importer never fabricates a function pointer — it looks the symbol
/// up and errors ([`FkcError::UnknownEntryPoint`]) if absent. This keeps
/// P9 (serializable contracts, no pointers in the file) honest.
pub trait LinkRegistry {
    /// Resolve a primitive (`op_kind`) kernel's entry point.
    fn resolve_primitive(&self, symbol: &str) -> Option<KernelRef>;
    /// Resolve a fused (`fused_op`) kernel's entry point.
    fn resolve_fused(&self, symbol: &str) -> Option<KernelRef>;

    /// Resolve a contract's `cost.cost_fn` NAME into a concrete [`CostFn`]
    /// pointer — the cost-model analogue of [`Self::resolve_primitive`] (§4.4
    /// cost-fn trampoline, Task-F). A provider that pins real cost fns exports
    /// its own `&'static [(&str, CostFn)]` table and overrides this over it
    /// (exactly as it exports its `entry_point` table); the built-in default
    /// is `None` (no cost-fn table), so every existing `LinkRegistry` impl and
    /// test stub compiles unchanged and a section that names no cost fn is
    /// unaffected. The importer never fabricates a pointer: an unresolved name
    /// is a typed [`FkcError::UnknownCostFn`], never a silent `unknown_cost`
    /// fallback (P9 — the resolved cost model is a real registered fn, not a
    /// serialized pointer).
    fn resolve_cost_fn(&self, _name: &str) -> Option<CostFn> {
        None
    }
}

// ===========================================================================
// Resolved records
// ===========================================================================

/// A fully-lowered primitive (`op_kind`) contract — typed dispatch record
/// ready for the register slice. The cost is held as a parsed AST
/// ([`CompiledCostExpr`]), NOT a `CostFn` fn-pointer (the trampoline is the
/// next slice).
#[derive(Debug, Clone)]
pub struct ResolvedPrimitive {
    /// The dispatch op (key.0).
    pub op: OpKind,
    /// Per-operand dtypes, inputs in order then outputs (key.1).
    pub dtypes: KernelDTypes,
    /// The backend (key.2).
    pub backend: BackendId,
    /// Projected layout capabilities (§6) — one bool today, every parsed
    /// flag retained on `layouts`.
    pub caps: KernelCaps,
    /// Per-operand parsed five-flag layout sets (retained for forward use;
    /// §6 [consumer-ahead]).
    pub layouts: Vec<ResolvedLayout>,
    /// Lowered precision guarantee.
    pub precision: PrecisionGuarantee,
    /// Parsed cost AST (capacity-eval next slice; `Unknown` ⇒ `unknown_cost`).
    pub cost: CompiledCostExpr,
    /// A CONTRACT-PINNED [`CostFn`] resolved from `cost.cost_fn` through the
    /// `LinkRegistry` (§4.4 cost-fn trampoline, Task-F). `Some(fn)` ⇒ the
    /// register slice stamps THIS `CostFn` on the binding, which SURVIVES the
    /// `fill_unset_cost_for_backend` pass (that pass only replaces the
    /// `unknown_cost` sentinel); `None` ⇒ the imported `unknown_cost` sentinel
    /// (the fill pass upgrades it to the op/backend default). This is how the
    /// CUDA `flash_decoding` contract keeps its static infeasibility-gate cost.
    pub cost_fn: Option<CostFn>,
    /// The resolved kernel function pointer.
    pub kernel: KernelRef,
    /// The `kernel_source` tag (`BindingEntry.kernel_source`).
    pub kernel_source: String,
    /// The kernel revision hash (§4.7).
    pub revision: KernelRevisionHash,
    /// OPAQUE specialization-variant tag (contract `variant:`), retained
    /// verbatim from [`crate::fkc::schema::FkcKernel::variant`] so it survives
    /// to where records / `ImplId` construction (the emission step) will read
    /// it. Never parsed or validated here; the entry point remains the true
    /// kernel identity.
    pub variant: Option<String>,
}

/// A fully-lowered fused (`fused_op`) contract — analogous to
/// [`ResolvedPrimitive`] but targeting the `FusedKernelRegistry`
/// (`FusedOpId` instead of `OpKind`; the fused cost target).
#[derive(Debug, Clone)]
pub struct ResolvedFused {
    /// The fused op id (registry key, from `default_registry()`).
    pub id: FusedOpId,
    /// Per-operand dtypes, inputs in order then outputs.
    pub dtypes: KernelDTypes,
    /// The backend (registry key).
    pub backend: BackendId,
    /// Projected layout capabilities (§6).
    pub caps: KernelCaps,
    /// Per-operand parsed five-flag layout sets (retained; §6).
    pub layouts: Vec<ResolvedLayout>,
    /// Lowered precision guarantee.
    pub precision: PrecisionGuarantee,
    /// Parsed cost AST (the fused cost target; `Unknown` ⇒ `unknown_cost`).
    pub cost: CompiledCostExpr,
    /// The resolved kernel function pointer.
    pub kernel: KernelRef,
    /// The `kernel_source` tag.
    pub kernel_source: String,
    /// The kernel revision hash (§4.7; `BackendImpl.revision`).
    pub revision: KernelRevisionHash,
    /// OPAQUE specialization-variant tag (contract `variant:`), retained
    /// verbatim from [`crate::fkc::schema::FkcKernel::variant`] (see
    /// [`ResolvedPrimitive::variant`]).
    pub variant: Option<String>,
    /// §5.5 `return.bundle` slot names, in declared order (empty for a
    /// single-output section). Populated by
    /// `crate::fkc::return_check::bundle_slot_names` (Finding 5.4, Task
    /// 3.6); `register_into` (`register.rs`) threads non-empty values into
    /// `FusedKernelRegistry::record_bundle_slot_names`.
    pub bundle_slot_names: Vec<String>,
}

/// The result of lowering one kernel section: a primitive xor a fused
/// record (exactly one of `op_kind` / `fused_op`).
#[derive(Debug, Clone)]
pub enum Resolved {
    /// An `op_kind` contract → the binding table.
    Primitive(ResolvedPrimitive),
    /// A `fused_op` contract → the fused registry.
    Fused(ResolvedFused),
}

// ===========================================================================
// op_kind String → OpKind (explicit exhaustive match; §2.1)
// ===========================================================================

/// Map an `op_kind` string to an [`OpKind`]. The `match` is exhaustive
/// over `OpKind` so adding a new variant forces this table to grow
/// (a compile error, not a silent miss). `UnknownOpKind` on a bad string.
pub(crate) fn lower_op_kind(s: &str, section: &str) -> Result<OpKind, FkcError> {
    // Helper so the match arms read as `name => Variant`. We round-trip
    // through a known-exhaustive coverage check below.
    let mapped = match s {
        "MatMul" => Some(OpKind::MatMul),
        "AddElementwise" => Some(OpKind::AddElementwise),
        "SubElementwise" => Some(OpKind::SubElementwise),
        "MulElementwise" => Some(OpKind::MulElementwise),
        "DivElementwise" => Some(OpKind::DivElementwise),
        "ReluElementwise" => Some(OpKind::ReluElementwise),
        "NegElementwise" => Some(OpKind::NegElementwise),
        "SqrElementwise" => Some(OpKind::SqrElementwise),
        "SqrtElementwise" => Some(OpKind::SqrtElementwise),
        "RecipElementwise" => Some(OpKind::RecipElementwise),
        "AbsElementwise" => Some(OpKind::AbsElementwise),
        "TanhElementwise" => Some(OpKind::TanhElementwise),
        "ExpElementwise" => Some(OpKind::ExpElementwise),
        "LogElementwise" => Some(OpKind::LogElementwise),
        "SinElementwise" => Some(OpKind::SinElementwise),
        "CosElementwise" => Some(OpKind::CosElementwise),
        "SigmoidElementwise" => Some(OpKind::SigmoidElementwise),
        "SiluElementwise" => Some(OpKind::SiluElementwise),
        "GeluElementwise" => Some(OpKind::GeluTanhElementwise),
        "StepElementwise" => Some(OpKind::StepElementwise),
        "SumReduce" => Some(OpKind::SumReduce),
        "MaxReduce" => Some(OpKind::MaxReduce),
        "MinReduce" => Some(OpKind::MinReduce),
        "MeanReduce" => Some(OpKind::MeanReduce),
        "Cast" => Some(OpKind::Cast),
        "Conv2D" => Some(OpKind::Conv2D),
        "ConvTranspose2D" => Some(OpKind::ConvTranspose2D),
        "ReduceSumTo" => Some(OpKind::ReduceSumTo),
        "ReduceMaxTo" => Some(OpKind::ReduceMaxTo),
        "FusedLinear" => Some(OpKind::FusedLinear),
        "FlashAttn" => Some(OpKind::FlashAttn),
        "FlashAttnBackwardQ" => Some(OpKind::FlashAttnBackwardQ),
        "FlashAttnBackwardK" => Some(OpKind::FlashAttnBackwardK),
        "FlashAttnBackwardV" => Some(OpKind::FlashAttnBackwardV),
        "PagedAttn" => Some(OpKind::PagedAttn),
        "Affine" => Some(OpKind::Affine),
        "ClampElementwise" => Some(OpKind::ClampElementwise),
        "PowIElementwise" => Some(OpKind::PowIElementwise),
        "PowIElementwiseBackward" => Some(OpKind::PowIElementwiseBackward),
        "MaximumElementwise" => Some(OpKind::MaximumElementwise),
        "MinimumElementwise" => Some(OpKind::MinimumElementwise),
        "EqualElementwise" => Some(OpKind::EqualElementwise),
        "NotEqualElementwise" => Some(OpKind::NotEqualElementwise),
        "LessElementwise" => Some(OpKind::LessElementwise),
        "LessEqualElementwise" => Some(OpKind::LessEqualElementwise),
        "GreaterElementwise" => Some(OpKind::GreaterElementwise),
        "GreaterEqualElementwise" => Some(OpKind::GreaterEqualElementwise),
        "Where" => Some(OpKind::Where),
        "FloorElementwise" => Some(OpKind::FloorElementwise),
        "CeilElementwise" => Some(OpKind::CeilElementwise),
        "RoundElementwise" => Some(OpKind::RoundElementwise),
        "SignElementwise" => Some(OpKind::SignElementwise),
        "ErfElementwise" => Some(OpKind::ErfElementwise),
        "GeluErfElementwise" => Some(OpKind::GeluElementwise),
        "PowElementwise" => Some(OpKind::PowElementwise),
        "RsqrtElementwise" => Some(OpKind::RsqrtElementwise),
        "RemElementwise" => Some(OpKind::RemElementwise),
        "Flip" => Some(OpKind::Flip),
        "Roll" => Some(OpKind::Roll),
        "CumSum" => Some(OpKind::CumSum),
        "Pad" => Some(OpKind::Pad),
        "Triu" => Some(OpKind::Triu),
        "Tril" => Some(OpKind::Tril),
        "LogSoftmaxLastDim" => Some(OpKind::LogSoftmaxLastDim),
        "LogSoftmaxLastDimBackward" => Some(OpKind::LogSoftmaxLastDimBackward),
        "MaskedFill" => Some(OpKind::MaskedFill),
        "PadBackward" => Some(OpKind::PadBackward),
        "Concat" => Some(OpKind::Concat),
        "SoftmaxLastDim" => Some(OpKind::SoftmaxLastDim),
        "SoftmaxLastDimBackward" => Some(OpKind::SoftmaxLastDimBackward),
        "RmsNormLastDim" => Some(OpKind::RmsNormLastDim),
        "RmsNormLastDimBackward" => Some(OpKind::RmsNormLastDimBackward),
        "LayerNormLastDim" => Some(OpKind::LayerNormLastDim),
        "LayerNormLastDimBackward" => Some(OpKind::LayerNormLastDimBackward),
        "ReduceMaxToBackward" => Some(OpKind::ReduceMaxToBackward),
        "IndexSelect" => Some(OpKind::IndexSelect),
        "Gather" => Some(OpKind::Gather),
        "Rope" => Some(OpKind::Rope),
        "IndexAdd" => Some(OpKind::IndexAdd),
        "ScatterAdd" => Some(OpKind::ScatterAdd),
        "ArgMaxDim" => Some(OpKind::ArgMaxDim),
        "ArgMinDim" => Some(OpKind::ArgMinDim),
        "QMatMul" => Some(OpKind::QMatMul),
        "WriteSlice" => Some(OpKind::WriteSlice),
        "WriteSliceRotating" => Some(OpKind::WriteSliceRotating),
        "WriteSliceDoff" => Some(OpKind::WriteSliceDoff),
        "Copy" => Some(OpKind::Copy),
        "ReluInplace" => Some(OpKind::ReluInplace),
        "SiluInplace" => Some(OpKind::SiluInplace),
        "GeluInplace" => Some(OpKind::GeluTanhInplace),
        "TanhInplace" => Some(OpKind::TanhInplace),
        "SigmoidInplace" => Some(OpKind::SigmoidInplace),
        "NegInplace" => Some(OpKind::NegInplace),
        "AbsInplace" => Some(OpKind::AbsInplace),
        "SqrInplace" => Some(OpKind::SqrInplace),
        "SqrtInplace" => Some(OpKind::SqrtInplace),
        "RsqrtInplace" => Some(OpKind::RsqrtInplace),
        "RecipInplace" => Some(OpKind::RecipInplace),
        "ExpInplace" => Some(OpKind::ExpInplace),
        "LogInplace" => Some(OpKind::LogInplace),
        "SinInplace" => Some(OpKind::SinInplace),
        "CosInplace" => Some(OpKind::CosInplace),
        "SignInplace" => Some(OpKind::SignInplace),
        "FloorInplace" => Some(OpKind::FloorInplace),
        "CeilInplace" => Some(OpKind::CeilInplace),
        "RoundInplace" => Some(OpKind::RoundInplace),
        "ErfInplace" => Some(OpKind::ErfInplace),
        "GeluErfInplace" => Some(OpKind::GeluInplace),
        "ClampInplace" => Some(OpKind::ClampInplace),
        "PowIInplace" => Some(OpKind::PowIInplace),
        "InplaceAffine" => Some(OpKind::InplaceAffine),
        "FusedSoftmaxCrossEntropy" => Some(OpKind::FusedSoftmaxCrossEntropy),
        "CausalConv1d" => Some(OpKind::CausalConv1d),
        "SelectiveScan" => Some(OpKind::SelectiveScan),
        "SsdChunkScan" => Some(OpKind::SsdChunkScan),
        "Nf4Matmul" => Some(OpKind::Nf4Matmul),
        _ => None,
    };
    // NOTE: `OpKind` is `#[non_exhaustive]` in `fuel-core-types`, so a
    // wildcard-free exhaustiveness anchor is not possible across the crate
    // boundary. The string table above is still explicit + audited (each
    // `OpKind` variant has its own arm); a new upstream variant simply
    // won't be reachable until a token is added here (an `UnknownOpKind`
    // at runtime, not a compile error — the non_exhaustive contract).
    match mapped {
        Some(op) => Ok(op),
        None => Err(FkcError::UnknownOpKind {
            section: section.to_string(),
            op_kind: s.to_string(),
        }),
    }
}

// ===========================================================================
// fused_op String → FusedOpId (SCREAMING_SNAKE FusedOps constant table; §2.2)
// ===========================================================================

/// Map a `fused_op` token to its [`FusedOpId`].
///
/// **The spec/contracts use the `FusedOps` CONSTANT NAME** — SCREAMING_SNAKE,
/// e.g. `SOFTMAX_LAST_DIM` / `FLASH_ATTN` / `QMATMUL` (FKC §3.1 token format,
/// §3.7). This is NOT the registry entry's `name` field, which is PascalCase
/// (`"SoftmaxLastDim"`). The earlier `default_registry().id_for_name(...)`
/// resolver matched the PascalCase `name` and therefore always *missed* on a
/// real contract token.
///
/// The mapping is an explicit `match` from each SCREAMING_SNAKE constant name
/// to its `FusedOps::<NAME>` `FusedOpId` (`UnknownFusedOp` on a miss). It is
/// kept honest by the [`tests::every_registry_id_is_reachable_through_table`]
/// drift-guard: every `FusedOpId` present in `default_registry()` must be
/// reachable through this table, so adding a new `FusedOps` const without a
/// table entry fails that test.
pub(crate) fn lower_fused_op(s: &str, section: &str) -> Result<FusedOpId, FkcError> {
    fused_op_id_for_const_name(s).ok_or_else(|| FkcError::UnknownFusedOp {
        section: section.to_string(),
        fused_op: s.to_string(),
    })
}

/// The SCREAMING_SNAKE `FusedOps::*` constant-name → [`FusedOpId`] table.
/// Returns `None` for an unknown token. One arm per `FusedOps` associated
/// const (`fuel-graph/src/registry.rs`); the drift-guard test asserts this
/// covers every registered id.
pub(crate) fn fused_op_id_for_const_name(s: &str) -> Option<FusedOpId> {
    let id = match s {
        "SOFTMAX_LAST_DIM" => FusedOps::SOFTMAX_LAST_DIM,
        "FUSED_LINEAR" => FusedOps::FUSED_LINEAR,
        "RMS_NORM_LAST_DIM" => FusedOps::RMS_NORM_LAST_DIM,
        "LAYER_NORM_LAST_DIM" => FusedOps::LAYER_NORM_LAST_DIM,
        "ROPE" => FusedOps::ROPE,
        "CONV2D" => FusedOps::CONV2D,
        "SOFTMAX_LAST_DIM_BACKWARD" => FusedOps::SOFTMAX_LAST_DIM_BACKWARD,
        "LAYER_NORM_LAST_DIM_BACKWARD" => FusedOps::LAYER_NORM_LAST_DIM_BACKWARD,
        "RMS_NORM_LAST_DIM_BACKWARD" => FusedOps::RMS_NORM_LAST_DIM_BACKWARD,
        "REDUCE_MAX_TO_BACKWARD" => FusedOps::REDUCE_MAX_TO_BACKWARD,
        "CONV_TRANSPOSE2D" => FusedOps::CONV_TRANSPOSE2D,
        "FLASH_ATTN" => FusedOps::FLASH_ATTN,
        "PAGED_ATTN" => FusedOps::PAGED_ATTN,
        "QMATMUL" => FusedOps::QMATMUL,
        "POWI_BACKWARD" => FusedOps::POWI_BACKWARD,
        "INPLACE_AFFINE" => FusedOps::INPLACE_AFFINE,
        "FUSED_SOFTMAX_CROSS_ENTROPY" => FusedOps::FUSED_SOFTMAX_CROSS_ENTROPY,
        "CAUSAL_CONV1D" => FusedOps::CAUSAL_CONV1D,
        "SELECTIVE_SCAN" => FusedOps::SELECTIVE_SCAN,
        "SSD_CHUNK_SCAN" => FusedOps::SSD_CHUNK_SCAN,
        "NF4_MATMUL" => FusedOps::NF4_MATMUL,
        "FLASH_ATTN_BACKWARD_Q" => FusedOps::FLASH_ATTN_BACKWARD_Q,
        "FLASH_ATTN_BACKWARD_K" => FusedOps::FLASH_ATTN_BACKWARD_K,
        "FLASH_ATTN_BACKWARD_V" => FusedOps::FLASH_ATTN_BACKWARD_V,
        "AWQ_MATMUL" => FusedOps::AWQ_MATMUL,
        _ => return None,
    };
    Some(id)
}

// ===========================================================================
// dtype token / dtype_class String → DType (explicit match; §3.4)
// ===========================================================================

/// Map a single dtype token to a [`DType`]. Explicit exhaustive `match`
/// (FDX codes are a different axis; this is NOT `FromStr`-by-discriminant).
///
/// Rejection is **two-way**: `ReservedScalarType` for a token KISS-CLASSIFY
/// §6.1 reserves at this schema version, `BadScalarType` for anything else.
/// Both are typed errors — what differs is which fact the contract author is
/// told, and therefore what they should do about it (§6.1-0001).
pub(crate) fn lower_dtype(token: &str, section: &str, operand: &str) -> Result<DType, FkcError> {
    let mapped = match token {
        "U8" => Some(DType::U8),
        "I8" => Some(DType::I8),
        "U32" => Some(DType::U32),
        "I16" => Some(DType::I16),
        "I32" => Some(DType::I32),
        "I64" => Some(DType::I64),
        "BF16" => Some(DType::BF16),
        "F16" => Some(DType::F16),
        "F32" => Some(DType::F32),
        "F64" => Some(DType::F64),
        "F8E4M3" => Some(DType::F8E4M3),
        "F6E2M3" => Some(DType::F6E2M3),
        "F6E3M2" => Some(DType::F6E3M2),
        "F4" => Some(DType::F4),
        "F8E8M0" => Some(DType::F8E8M0),
        "F8E5M2" => Some(DType::F8E5M2),
        "F8E6M2" => Some(DType::F8E6M2),
        "BOOL" => Some(DType::Bool),
        _ => None,
    };
    if let Some(dt) = mapped {
        // Exhaustiveness anchor (no wildcard): a new DType variant breaks
        // this match, forcing the token table above to grow.
        match dt {
            DType::U8
            | DType::I8
            | DType::U32
            | DType::I16
            | DType::I32
            | DType::I64
            | DType::BF16
            | DType::F16
            | DType::F32
            | DType::F64
            | DType::F8E4M3
            | DType::F8E5M2
            | DType::F6E2M3
            | DType::F6E3M2
            | DType::F4
            | DType::F8E8M0
            | DType::F8E6M2
            | DType::Bool => (),
        };
        Ok(dt)
    } else if fuel_ir::is_reserved_dtype_token(token) {
        // Recognized-but-reserved is a DIFFERENT rejection from unknown, and a
        // contract author must be able to tell them apart. (This is §6.1's
        // reserved vocabulary applied to an ingest surface Fuel really has —
        // NOT §6.1-0001 conformance, which binds a reader of a structure_key;
        // Fuel has no such reader. See `fuel_ir::RESERVED_DTYPE_TOKENS`.)
        //
        // Order matches KISS's own reference impl: reserved is checked BEFORE
        // unknown, because the reserved set is a SUBSET of the vocabulary and
        // an unknown-first check would swallow it.
        //
        // The list lives in `fuel-ir` and is CONSULTED, not copied. Two
        // hand-maintained lists is the drift pattern this repo keeps
        // re-finding: the copy that stops being edited silently reverts to
        // treating reserved tokens as unknown, and nothing fails.
        //
        // This does not contradict the module's "explicit table, never
        // `FromStr`-by-discriminant" rule. The accept table above is still the
        // exhaustive, compile-anchored `match`; what is shared here is the
        // RESERVED-token list — a fact about the standard rather than about
        // Fuel's as-built `DType` set, so it has no exhaustiveness anchor to
        // lose, and every reserved token is by definition absent from `DType`.
        //
        // Order is load-bearing: this arm is only reached because the accept
        // arms are exact literals and cannot capture a reserved token. That is
        // asserted rather than assumed (see the tests below) — `F8E5M2` is a
        // PREFIX of `F8E5M2FNUZ`, so any `starts_with`/`contains` classifier
        // here would read the reserved token as the supported one and compute
        // on `fnuz` bytes as if they were OCP: silent numerical corruption,
        // not a loud failure.
        Err(FkcError::ReservedScalarType {
            section: section.to_string(),
            operand: operand.to_string(),
            token: token.to_string(),
        })
    } else {
        Err(FkcError::BadScalarType {
            section: section.to_string(),
            operand: operand.to_string(),
            token: token.to_string(),
        })
    }
}

/// Expand a `dtype_class` shorthand (§3.4) into its dtype list. `any`
/// resolves to the operand's enumerated `dtypes` (passed in `enumerated`).
///
/// `pub(crate)`: also the single source of truth for
/// `shape_constraint::first_probe_dtype`'s dtype-class fallback pick (its
/// first element), so the §3.4 class -> dtype-list mapping is defined once.
pub(crate) fn expand_dtype_class(
    class: &str,
    enumerated: &[DType],
    section: &str,
    operand: &str,
) -> Result<Vec<DType>, FkcError> {
    match class {
        "float" => Ok(vec![DType::BF16, DType::F16, DType::F32, DType::F64]),
        "int" => Ok(vec![DType::I8, DType::I16, DType::I32, DType::I64]),
        "uint" => Ok(vec![DType::U8, DType::U32]),
        "any" => Ok(enumerated.to_vec()),
        other => Err(FkcError::BadScalarType {
            section: section.to_string(),
            operand: operand.to_string(),
            token: format!("dtype_class={other}"),
        }),
    }
}

// ===========================================================================
// backend String → BackendId (explicit match; §2.1)
// ===========================================================================

/// Map a `backend` string to a [`BackendId`]. Explicit exhaustive match.
fn lower_backend(s: &str, section: &str) -> Result<BackendId, FkcError> {
    let mapped = match s {
        "Cpu" => Some(BackendId::Cpu),
        "Cuda" => Some(BackendId::Cuda),
        "Vulkan" => Some(BackendId::Vulkan),
        "Metal" => Some(BackendId::Metal),
        _ => None,
    };
    // `BackendId` is `#[non_exhaustive]`; same note as `lower_op_kind` —
    // the explicit string table is the audit surface, not a compile gate.
    match mapped {
        Some(b) => Ok(b),
        None => Err(FkcError::UnknownBackend {
            section: section.to_string(),
            backend: s.to_string(),
        }),
    }
}

// ===========================================================================
// Per-operand dtype assembly → per-variant KernelDTypes (multi-dtype fan-out)
// ===========================================================================

/// One fanned variant of a section: its full binding key (`[in1, .., out]`)
/// plus the fan dtype that produced it.
#[derive(Debug, Clone)]
pub(crate) struct DtypeVariant {
    /// The binding-table key: input operand dtypes in order, then outputs.
    pub(crate) dtypes: KernelDTypes,
    /// The dtype the varying operands took for this variant. `Some(dt)` when
    /// the section fans out (drives the `<entry_point>_<suffix>` resolution);
    /// `None` for the single all-fixed variant (entry_point resolved as-is).
    pub(crate) fan_dtype: Option<DType>,
}

/// The canonical `DType → FKC dtype suffix` spelling used to build a fanning
/// section's per-variant `entry_point` symbol (`<base>_<suffix>`), e.g.
/// `F32 → "f32"`, `BF16 → "bf16"`, `U8 → "u8"`, `F8E4M3 → "f8e4m3"`.
///
/// This is the **inverse** of [`lower_dtype`] and is deliberately the SAME
/// spelling the byte-kernel `ep!` macro (`fkc/cpu_link.rs`) and the CPU
/// backend's per-(op,dtype) thunks use — it reuses [`DType::as_str`] rather
/// than hand-rolling a second table (the [`tests::dtype_suffix_is_the_inverse_of_lower_dtype`]
/// drift-guard locks the round-trip).
fn dtype_suffix(dt: DType) -> &'static str {
    dt.as_str()
}

/// A resolved input operand: its role name + its enumerated dtype list
/// (post `dtype_class` expansion; always ≥1) + whether it is OPTIONAL (§3.4).
struct InputOperand {
    name: String,
    dtypes: Vec<DType>,
    /// `optional: true` (§3.4): production registers the op BOTH with and
    /// without this operand. Only the LAST input may be optional.
    optional: bool,
}

/// Resolve one operand's enumerated dtype list (explicit `dtypes:` wins; a
/// `dtype_class` shorthand only fills an empty explicit list; §3.4). Errors
/// [`FkcError::BadScalarType`] on a bad token or an empty result.
fn resolve_operand_dtypes(
    d: &crate::fkc::schema::TensorDesc,
    section: &str,
    operand: &str,
) -> Result<Vec<DType>, FkcError> {
    let mut enumerated: Vec<DType> = Vec::new();
    for tok in &d.dtypes {
        enumerated.push(lower_dtype(tok, section, operand)?);
    }
    let resolved = if enumerated.is_empty() {
        if let Some(class) = &d.dtype_class {
            expand_dtype_class(class, &enumerated, section, operand)?
        } else {
            enumerated
        }
    } else {
        // Explicit list present ⇒ it is the enumeration (a `dtype_class`, if
        // also present, is descriptive only — the explicit list wins, §3.4).
        enumerated
    };
    if resolved.is_empty() {
        return Err(FkcError::BadScalarType {
            section: section.to_string(),
            operand: operand.to_string(),
            token: "<no dtypes and no dtype_class>".to_string(),
        });
    }
    Ok(resolved)
}

/// Assemble the per-variant binding-key dtype-lists for a section (§3.4
/// **multi-dtype fan-out**) plus the shared per-operand layouts.
///
/// A section whose operands are all single-dtype (or a `dtype_class` that
/// expands to exactly one) yields exactly ONE variant with `fan_dtype: None`
/// — today's behavior, and what keeps the per-(op,dtype) binary / affine /
/// cast families byte-identical. A section whose operand(s) **vary**
/// (enumerate >1 dtype, or a `dtype_class` that expands to >1) fans out into
/// N variants — one per fanned dtype.
///
/// Fan rules:
/// - The fan-out dtype set is the enumerated list of the operand(s) that
///   vary. ALL varying operands must enumerate the SAME list in the SAME
///   order; a disagreement is [`FkcError::FanoutDtypeMismatch`] (never a
///   silent pick).
/// - Per fanned dtype `dt`, each INPUT operand contributes its dtype at this
///   variant — a FIXED (single-enumerated) operand its one dtype (e.g.
///   `where`'s `cond` = U8), a VARYING operand `dt`. Then OUTPUTS:
///   `fixed(D)` → D; `passthrough(role)` → the dtype of the INPUT operand
///   named `role` **at this variant** (so `where`'s `passthrough(a)` mirrors
///   `a` = `dt`, NOT the first input `cond`). Key shape is inputs-then-outputs.
///
/// **Optional-operand fan-out (§3.4).** When the LAST input carries
/// `optional: true` (e.g. conv's `bias`), EACH dtype variant fans into TWO
/// keys — one OMITTING the optional operand (its dtype dropped from the input
/// tail) and one INCLUDING it — so `variants = (dtype fan-out) × (optional
/// {absent, present})`. Both keys resolve the SAME `entry_point`/kernel (the
/// optional operand rides through op-params, not a distinct symbol). Rules:
/// - Only the LAST input may be optional; an earlier optional operand would
///   leave a hole mid-key and is [`FkcError::OptionalOperandNotLast`] (never a
///   silent mis-key).
/// - An output may NOT `passthrough(role)` the optional operand — absent, the
///   two keys' output dtypes would disagree — that is
///   [`FkcError::PassthroughNamesOptionalOperand`]. `passthrough` of any other
///   (always-present) operand resolves identically for both keys.
/// - A section with NO optional operand behaves EXACTLY as before (one key per
///   dtype variant) — the already-migrated per-(op,dtype) families stay
///   byte-identical.
///
/// The PRESENT (full-operand) key is emitted FIRST so the fused path's
/// representative (first) variant is unchanged (`lower_fused` takes `.next()`).
fn assemble_dtype_variants(
    kernel: &FkcKernel,
    section: &str,
) -> Result<(Vec<DtypeVariant>, Vec<ResolvedLayout>), FkcError> {
    let mut inputs: Vec<InputOperand> = Vec::new();
    let mut layouts: Vec<ResolvedLayout> = Vec::new();

    if let Some(accept) = &kernel.accept {
        for d in &accept.inputs {
            let operand = d.name.as_deref().unwrap_or("<input>");
            let resolved = resolve_operand_dtypes(d, section, operand)?;
            inputs.push(InputOperand {
                name: operand.to_string(),
                dtypes: resolved,
                optional: d.optional,
            });
            layouts.push(caps_map::resolve_layout(
                d.layout.as_ref(),
                section,
                operand,
            )?);
        }
    }

    // §3.4 optional-operand support: at most the LAST input may be `optional`.
    // An earlier optional operand, when omitted, would leave a hole in the
    // MIDDLE of the key and mis-align every following operand — a typed error,
    // never a silent mis-key. `optional_last` drives the {absent, present} fan.
    let optional_last = inputs.last().map(|op| op.optional).unwrap_or(false);
    for (i, op) in inputs.iter().enumerate() {
        if op.optional && i != inputs.len() - 1 {
            return Err(FkcError::OptionalOperandNotLast {
                section: section.to_string(),
                operand: op.name.clone(),
            });
        }
    }

    // The fan-out dtype set = the enumerated list of the operand(s) that vary
    // (enumerate >1). All varying operands must agree on the SAME list/order.
    let mut fan_set: Option<&[DType]> = None;
    for operand in &inputs {
        if operand.dtypes.len() > 1 {
            match fan_set {
                None => fan_set = Some(&operand.dtypes),
                Some(existing) => {
                    if existing != operand.dtypes.as_slice() {
                        return Err(FkcError::FanoutDtypeMismatch {
                            section: section.to_string(),
                            operand: operand.name.clone(),
                            expected: format!("{existing:?}"),
                            found: format!("{:?}", operand.dtypes),
                        });
                    }
                }
            }
        }
    }

    // The list of fan dtypes: one all-fixed variant (None) when nothing
    // varies, else one variant per fanned dtype.
    let fan_dtypes: Vec<Option<DType>> = match fan_set {
        None => vec![None],
        Some(set) => set.iter().map(|dt| Some(*dt)).collect(),
    };

    // Capacity: one key per dtype variant, doubled when an optional operand
    // fans each into {absent, present}.
    let per_variant = if optional_last { 2 } else { 1 };
    let mut variants: Vec<DtypeVariant> = Vec::with_capacity(fan_dtypes.len() * per_variant);
    for fan in fan_dtypes {
        // Each input operand contributes its dtype at THIS variant: a fixed
        // operand its single dtype, a varying operand the fan dtype. Built with
        // ALL inputs (incl. the optional last); the absent-key drops its tail.
        let mut input_dtypes: KernelDTypes = SmallVec::new();
        for operand in &inputs {
            let dt = if operand.dtypes.len() > 1 {
                // Varying: fan_dtype is Some by construction here.
                fan.expect("a varying operand implies a fanned dtype")
            } else {
                operand.dtypes[0]
            };
            input_dtypes.push(dt);
        }

        // Outputs: `fixed(D)` → D; `passthrough(role)` → the role operand's
        // dtype at this variant. Built ONCE and shared by BOTH the present and
        // absent keys — an output may not `passthrough` the optional operand
        // (checked below), so the output tail is identical for both. Best-
        // effort otherwise: an output we cannot type (a passthrough naming no
        // known input, no inputs at all) is omitted from the key tail rather
        // than failing (full return validation is a separate slice).
        let mut output_dtypes: KernelDTypes = SmallVec::new();
        if let Some(ret) = &kernel.return_ {
            for out in &ret.outputs {
                let operand = out.name.as_deref().unwrap_or("<output>");
                if let Some(rule) = out.dtype_rule.as_deref()
                    && let Some(dt) = resolve_output_slot_dtype(
                        rule,
                        operand,
                        &inputs,
                        fan,
                        optional_last,
                        section,
                    )?
                {
                    output_dtypes.push(dt);
                }
            }
            // §5.5 multi-output bundle (Option C): a `return.bundle` packs
            // several logical slots into ONE output buffer whose PRIMARY
            // (first) slot's dtype tags the binding key — the multi-output
            // contract on [`crate::kernel::KernelRef`] states the key
            // "describes inputs + the bundle's primary dtype only". Derive that
            // one slot dtype through the SAME `dtype_rule`/passthrough path as a
            // regular output and append it to the key tail — so a 5-input scan
            // with a `passthrough(u)` bundle keys `[T; 6]`, byte-for-byte the
            // deleted hand-written reg. A section with NO bundle is unaffected
            // (the migrated per-(op,dtype) families stay byte-identical).
            if let Some(bundle) = &ret.bundle
                && let Some((slot, rule)) = bundle_primary_dtype_rule(bundle)
                && let Some(dt) =
                    resolve_output_slot_dtype(&rule, &slot, &inputs, fan, optional_last, section)?
            {
                output_dtypes.push(dt);
            }
        }

        if optional_last {
            // PRESENT (full-operand) key FIRST so `lower_fused`'s representative
            // (first) variant is unchanged: all inputs (incl. optional), outputs.
            let mut present: KernelDTypes = input_dtypes.clone();
            present.extend_from_slice(&output_dtypes);
            variants.push(DtypeVariant {
                dtypes: present,
                fan_dtype: fan,
            });
            // ABSENT key: inputs MINUS the optional last, then outputs. Both
            // resolve the SAME entry_point/kernel (same `fan_dtype`).
            let mut absent: KernelDTypes = SmallVec::new();
            absent.extend_from_slice(&input_dtypes[..input_dtypes.len() - 1]);
            absent.extend_from_slice(&output_dtypes);
            variants.push(DtypeVariant {
                dtypes: absent,
                fan_dtype: fan,
            });
        } else {
            let mut dtypes: KernelDTypes = input_dtypes;
            dtypes.extend_from_slice(&output_dtypes);
            variants.push(DtypeVariant {
                dtypes,
                fan_dtype: fan,
            });
        }
    }

    Ok((variants, layouts))
}

/// Resolve `passthrough(role)` to the dtype of the input operand named
/// `role` at this variant: a varying operand takes `fan`, a fixed operand
/// its single dtype. Falls back to the first input's variant dtype when the
/// role names no input (best-effort — the prior behavior for an untyped
/// passthrough), and `None` when there are no inputs at all.
fn passthrough_dtype(inputs: &[InputOperand], role: &str, fan: Option<DType>) -> Option<DType> {
    let operand_dtype = |op: &InputOperand| -> DType {
        if op.dtypes.len() > 1 {
            fan.expect("a varying operand implies a fanned dtype")
        } else {
            op.dtypes[0]
        }
    };
    if let Some(op) = inputs.iter().find(|op| op.name == role) {
        Some(operand_dtype(op))
    } else {
        inputs.first().map(operand_dtype)
    }
}

/// Resolve ONE output slot's key dtype from its `dtype_rule` at this variant —
/// the single path shared by a regular `return.outputs` entry and a
/// `return.bundle`'s primary slot (§5.5). `fixed(D)` → `D`;
/// `passthrough(role)` → the role operand's dtype at this variant (best-effort
/// untyped fallback per [`passthrough_dtype`]); an unrecognized rule → `None`
/// (best-effort — the full return validation is a separate slice). A
/// `passthrough` naming the OPTIONAL last operand is the typed
/// [`FkcError::PassthroughNamesOptionalOperand`] (its dtype would disagree
/// between the operand's present/absent keys, §3.4/§5.1).
fn resolve_output_slot_dtype(
    rule: &str,
    operand: &str,
    inputs: &[InputOperand],
    fan: Option<DType>,
    optional_last: bool,
    section: &str,
) -> Result<Option<DType>, FkcError> {
    match parse_dtype_rule(rule, section, operand)? {
        DtypeRule::Fixed(dt) => Ok(Some(dt)),
        DtypeRule::Passthrough(role) => {
            if optional_last && inputs.last().map(|o| o.name == role).unwrap_or(false) {
                return Err(FkcError::PassthroughNamesOptionalOperand {
                    section: section.to_string(),
                    role,
                });
            }
            Ok(passthrough_dtype(inputs, &role, fan))
        }
        DtypeRule::Other => Ok(None),
    }
}

/// Extract the PRIMARY (first) slot's `(name, dtype_rule)` from a
/// `return.bundle` value (§5.5 Option C multi-output). The bundle is carried
/// opaquely in the schema — a `serde_yaml_ng::Value` sequence of
/// `{ name, dtype_rule, shape_rule, … }` slot maps (its rank/name validation is
/// a separate slice) — but the binding KEY only needs the first slot's
/// `dtype_rule` string, which is then fed through the regular
/// [`resolve_output_slot_dtype`] machinery exactly like a `return.outputs`
/// entry. Returns `None` when the bundle is not a non-empty sequence of maps or
/// the first slot declares no `dtype_rule` (best-effort — a malformed bundle is
/// a validation concern, never a key that silently mirrors the wrong operand).
fn bundle_primary_dtype_rule(bundle: &serde_yaml_ng::Value) -> Option<(String, String)> {
    let serde_yaml_ng::Value::Sequence(slots) = bundle else {
        return None;
    };
    let serde_yaml_ng::Value::Mapping(first) = slots.first()? else {
        return None;
    };
    let rule = first
        .get(serde_yaml_ng::Value::String("dtype_rule".into()))
        .and_then(|v| v.as_str())?
        .to_string();
    let name = first
        .get(serde_yaml_ng::Value::String("name".into()))
        .and_then(|v| v.as_str())
        .unwrap_or("<bundle>")
        .to_string();
    Some((name, rule))
}

/// A parsed `dtype_rule` (§5.1): `fixed(DType)`, `passthrough(role)`, or an
/// unrecognized rule (typed later).
enum DtypeRule {
    Fixed(DType),
    Passthrough(String),
    Other,
}

/// Parse a `dtype_rule` string into a [`DtypeRule`]. `BadScalarType` only if
/// `fixed(...)` names a bad dtype; `passthrough(role)` captures the role name.
fn parse_dtype_rule(rule: &str, section: &str, operand: &str) -> Result<DtypeRule, FkcError> {
    let rule = rule.trim();
    if let Some(inner) = rule
        .strip_prefix("fixed(")
        .and_then(|s| s.strip_suffix(")"))
    {
        Ok(DtypeRule::Fixed(lower_dtype(
            inner.trim(),
            section,
            operand,
        )?))
    } else if let Some(inner) = rule
        .strip_prefix("passthrough(")
        .and_then(|s| s.strip_suffix(")"))
    {
        Ok(DtypeRule::Passthrough(inner.trim().to_string()))
    } else {
        Ok(DtypeRule::Other)
    }
}

// ===========================================================================
// Cost block → CompiledCostExpr (primary: flops; §2.3 AST half)
// ===========================================================================

/// Compile a contract's cost block into a [`CompiledCostExpr`].
///
/// Strategy: this slice carries the AST. A cost block that is absent,
/// `class`-only, or `judge_measured` with no coefficient expressions
/// compiles to [`CompiledCostExpr::Unknown`] (the register slice maps
/// that to `unknown_cost`). When expressions ARE present, the **`flops`**
/// expression is compiled as the primary cost AST (the per-tier `memory`
/// beyond device_bytes and the other coefficient fields are parsed for
/// validation but the primary held expression is `flops`; a full
/// multi-field cost vector is a register-slice concern).
///
/// Every present cost expression is parse-validated (V-FKC-8); a malformed
/// one surfaces as [`FkcError::CostExprParse`] with the field name.
fn compile_cost(block: Option<&CostBlock>, section: &str) -> Result<CompiledCostExpr, FkcError> {
    let Some(cost) = block else {
        return Ok(CompiledCostExpr::Unknown);
    };

    // Parse-validate every present coefficient expression (so a malformed
    // bytes_moved is caught even though flops is the primary held AST).
    let parse = |field: &str, src: Option<&str>| -> Result<CompiledCostExpr, FkcError> {
        cost_expr::compile_field(src).map_err(|e| FkcError::CostExprParse {
            section: section.to_string(),
            field: field.to_string(),
            expr: src.unwrap_or("").to_string(),
            reason: e.to_string(),
        })
    };

    let flops = parse("flops", cost.flops.as_deref())?;
    let _bytes_moved = parse("bytes_moved", cost.bytes_moved.as_deref())?;
    // overhead_ns / memory.device_bytes are raw scalars (number or `~`);
    // when they are an expression STRING they are parse-validated too.
    if let Some(mem) = &cost.memory
        && let Some(serde_yaml_ng::Value::String(s)) = &mem.device_bytes
    {
        let _ = parse("memory.device_bytes", Some(s))?;
    }
    if let Some(serde_yaml_ng::Value::String(s)) = &cost.overhead_ns {
        let _ = parse("overhead_ns", Some(s))?;
    }

    // The primary held AST is flops. If flops is Unknown but bytes_moved
    // carries an expression, hold bytes_moved instead (so a cost block with
    // only a bytes_moved formula is not collapsed to Unknown).
    match flops {
        CompiledCostExpr::Unknown => Ok(_bytes_moved),
        expr => Ok(expr),
    }
}

// ===========================================================================
// The lowering entry points
// ===========================================================================

/// Resolve the effective `backend` / `kernel_source` / `entry_point` for a
/// kernel, applying the front-matter fallbacks the caller passes in.
struct Defaults<'a> {
    backend: &'a str,
    kernel_source: &'a str,
    revision_base: &'a str,
}

/// Lower one parsed [`FkcKernel`] into its [`Resolved`] records, resolving
/// each per-variant `entry_point` through `link`. Exactly one of `op_kind` /
/// `fused_op` must be present.
///
/// A primitive (`op_kind`) section **fans out** into one [`Resolved`] per
/// dtype variant (§3.4 multi-dtype fan-out); a section with no varying
/// operand yields exactly one. A fused (`fused_op`) section fans out the SAME
/// way — one [`Resolved::Fused`] per dtype variant (see [`lower_fused`]).
///
/// `defaults` carries the front-matter `backend` / `kernel_source` /
/// `revision_base` so a kernel that omits them inherits the provider's.
fn lower_kernel(
    kernel: &FkcKernel,
    defaults: &Defaults<'_>,
    link: &dyn LinkRegistry,
    warnings: &mut Vec<crate::fkc::ImportWarning>,
) -> Result<Vec<Resolved>, FkcError> {
    let section = kernel.kernel.as_str();

    // Exactly one of op_kind / fused_op.
    match (kernel.op_kind.as_deref(), kernel.fused_op.as_deref()) {
        (Some(op_str), None) => {
            let op = lower_op_kind(op_str, section)?;
            // Phase 1 has no primitive-side warnings producer yet.
            Ok(lower_primitive(kernel, op, defaults, link)?
                .into_iter()
                .map(Resolved::Primitive)
                .collect())
        }
        (None, Some(fused_str)) => {
            let id = lower_fused_op(fused_str, section)?;
            Ok(lower_fused(kernel, id, defaults, link, warnings)?
                .into_iter()
                .map(Resolved::Fused)
                .collect())
        }
        (op, fused) => Err(FkcError::OpTargetAmbiguous {
            section: section.to_string(),
            op_kind: op.map(String::from),
            fused_op: fused.map(String::from),
        }),
    }
}

/// Lower a primitive (`op_kind`) section into ONE [`ResolvedPrimitive`] per
/// dtype variant (§3.4 multi-dtype fan-out).
///
/// A section whose operand(s) vary fans out into N bindings — one per fanned
/// dtype, with the per-variant binding key rebuilt from
/// [`assemble_dtype_variants`]. Its declared `entry_point` is a **BASE**
/// symbol; each variant resolves `<base>_<dtype_suffix>` via `link`. A
/// non-fanning (single-variant) section keeps its specific `entry_point` and
/// resolves it AS-IS.
///
/// Everything except the per-variant `dtypes` + resolved `kernel` is
/// per-section (shared): backend, caps, layouts, precision, cost, and the
/// revision hash (which folds the declared BASE `entry_point`, so it is one
/// value for the whole section).
fn lower_primitive(
    kernel: &FkcKernel,
    op: OpKind,
    defaults: &Defaults<'_>,
    link: &dyn LinkRegistry,
) -> Result<Vec<ResolvedPrimitive>, FkcError> {
    let section = kernel.kernel.as_str();
    let backend_str = kernel.backend.as_deref().unwrap_or(defaults.backend);
    let backend = lower_backend(backend_str, section)?;
    let (variants, layouts) = assemble_dtype_variants(kernel, section)?;
    let caps = caps_map::project_kernel_caps(&layouts);
    let precision = precision::lower_precision(kernel.precision.as_ref(), section)?;
    let cost = compile_cost(kernel.cost.as_ref(), section)?;
    // §4.4 cost-fn trampoline (Task-F): a `cost.cost_fn` NAME pins a real,
    // shape-aware `CostFn` (per-section, shared by every dtype variant). Resolve
    // it ONCE through the LinkRegistry; an unresolved name is a typed error, not
    // a silent `unknown_cost` fallback. `None` ⇒ the register slice keeps the
    // imported `unknown_cost` sentinel (fill_unset then upgrades it).
    let cost_fn = match kernel.cost.as_ref().and_then(|c| c.cost_fn.as_deref()) {
        Some(name) => Some(
            link.resolve_cost_fn(name)
                .ok_or_else(|| FkcError::UnknownCostFn {
                    section: section.to_string(),
                    cost_fn: name.to_string(),
                })?,
        ),
        None => None,
    };

    let base_entry_point =
        kernel
            .entry_point
            .as_deref()
            .ok_or_else(|| FkcError::MissingRequiredField {
                section: section.to_string(),
                field: "entry_point".to_string(),
            })?;

    let kernel_source = kernel
        .kernel_source
        .as_deref()
        .unwrap_or(defaults.kernel_source)
        .to_string();
    // Per-section revision (same for all variants); folds the BASE entry_point
    // so it is byte-identical to the pre-fan-out single-binding revision.
    let revision = revhash::compute_revision(kernel, base_entry_point, defaults.revision_base)?;

    let mut out = Vec::with_capacity(variants.len());
    for variant in variants {
        // Per-variant entry_point: a fanning section's declared entry_point is
        // a BASE symbol → resolve `<base>_<suffix>`; a non-fanning section
        // keeps its specific symbol and resolves AS-IS.
        let symbol: std::borrow::Cow<'_, str> = match variant.fan_dtype {
            Some(dt) => std::borrow::Cow::Owned(format!("{base_entry_point}_{}", dtype_suffix(dt))),
            None => std::borrow::Cow::Borrowed(base_entry_point),
        };
        let kernel_ref =
            link.resolve_primitive(&symbol)
                .ok_or_else(|| FkcError::UnknownEntryPoint {
                    section: section.to_string(),
                    entry_point: symbol.into_owned(),
                })?;

        out.push(ResolvedPrimitive {
            op,
            dtypes: variant.dtypes,
            backend,
            caps,
            layouts: layouts.clone(),
            precision,
            cost: cost.clone(),
            cost_fn,
            kernel: kernel_ref,
            kernel_source: kernel_source.clone(),
            revision,
            // Retain the opaque `variant:` tag verbatim (per-section, shared by
            // every dtype variant) so it survives to the emission step.
            variant: kernel.variant.clone(),
        });
    }
    Ok(out)
}

/// Lower a fused (`fused_op`) section into ONE [`ResolvedFused`] per dtype
/// variant (§3.4 multi-dtype fan-out — the fused analogue of
/// [`lower_primitive`]).
///
/// A section whose operand(s) vary fans out into N fused impls — one per fanned
/// dtype, with the per-variant binding key rebuilt from
/// [`assemble_dtype_variants`] (so a multi-dtype `SOFTMAX_LAST_DIM` section
/// registers a per-dtype impl for each of `[F32, F64, BF16, F16]`, 1:1 with the
/// hand-written `register_default_fused_kernels` seam it replaces). Its declared
/// `entry_point` is a **BASE** symbol; each variant resolves
/// `<base>_<dtype_suffix>` via `link` ([`crate::fkc::cpu_link`]'s
/// `CPU_FUSED_NORM_ENTRY_POINTS` maps those per-dtype symbols to the per-dtype
/// wrappers). A non-fanning (single-variant) section keeps its specific
/// `entry_point` and resolves it AS-IS, yielding exactly one record —
/// byte-identical to the pre-fan-out behavior.
///
/// Everything except the per-variant `dtypes` + resolved `kernel` is
/// per-section (shared): backend, caps, layouts, precision, cost, and the
/// revision hash (which folds the declared BASE `entry_point`, so it is one
/// value for the whole section — the primitive precedent).
fn lower_fused(
    kernel: &FkcKernel,
    id: FusedOpId,
    defaults: &Defaults<'_>,
    link: &dyn LinkRegistry,
    warnings: &mut Vec<crate::fkc::ImportWarning>,
) -> Result<Vec<ResolvedFused>, FkcError> {
    // §5 (Finding 5.1): cross-check the section's declared return rules
    // against the REAL registered FusedOpEntry fn BEFORE anything else lowers
    // — a disagreement fails the import (never silently drifts from the
    // graph's single source of truth). See `return_check::cross_check_fused_section`
    // for the never-panic guard + soft-catch-solver-errors invariants.
    crate::fkc::return_check::cross_check_fused_section(kernel, id, warnings)?;
    let section = kernel.kernel.as_str();
    let backend_str = kernel.backend.as_deref().unwrap_or(defaults.backend);
    let backend = lower_backend(backend_str, section)?;
    let (variants, layouts) = assemble_dtype_variants(kernel, section)?;
    let caps = caps_map::project_kernel_caps(&layouts);
    let precision = precision::lower_precision(kernel.precision.as_ref(), section)?;
    let cost = compile_cost(kernel.cost.as_ref(), section)?;

    let base_entry_point =
        kernel
            .entry_point
            .as_deref()
            .ok_or_else(|| FkcError::MissingRequiredField {
                section: section.to_string(),
                field: "entry_point".to_string(),
            })?;

    let kernel_source = kernel
        .kernel_source
        .as_deref()
        .unwrap_or(defaults.kernel_source)
        .to_string();
    // Per-section revision (same for all variants); folds the BASE entry_point
    // so it is byte-identical to the pre-fan-out single-binding revision.
    let revision = revhash::compute_revision(kernel, base_entry_point, defaults.revision_base)?;

    let mut out = Vec::with_capacity(variants.len());
    for variant in variants {
        // Per-variant entry_point: a fanning section's declared entry_point is
        // a BASE symbol → resolve `<base>_<suffix>`; a non-fanning section
        // keeps its specific symbol and resolves AS-IS.
        let symbol: std::borrow::Cow<'_, str> = match variant.fan_dtype {
            Some(dt) => std::borrow::Cow::Owned(format!("{base_entry_point}_{}", dtype_suffix(dt))),
            None => std::borrow::Cow::Borrowed(base_entry_point),
        };
        let kernel_ref =
            link.resolve_fused(&symbol)
                .ok_or_else(|| FkcError::UnknownEntryPoint {
                    section: section.to_string(),
                    entry_point: symbol.into_owned(),
                })?;

        out.push(ResolvedFused {
            id,
            dtypes: variant.dtypes,
            backend,
            caps,
            layouts: layouts.clone(),
            precision,
            cost: cost.clone(),
            kernel: kernel_ref,
            kernel_source: kernel_source.clone(),
            revision,
            // Retain the opaque `variant:` tag verbatim (per-section, shared by
            // every dtype variant) so it survives to the emission step.
            variant: kernel.variant.clone(),
            // Finding 5.4 (Task 3.6): the real §5.5 bundle-slot-name
            // extraction. Per-section (same for every dtype variant), so
            // this recomputes per variant — cheap (a handful of YAML-slot
            // reads), and keeps this call site a single self-contained
            // expression rather than hoisting a shared local above the loop.
            bundle_slot_names: crate::fkc::return_check::bundle_slot_names(&kernel.return_),
        });
    }
    Ok(out)
}

/// Lower every kernel section of a parsed file into [`Resolved`] records,
/// using the file's front-matter for the backend / kernel_source /
/// revision_base defaults and resolving entry points through `link`.
///
/// **Describe-only sections (`registrable: false`, §3.10) are excluded** from
/// the lowered set: they are documentation, carry no dispatch target, and are
/// never registered — so they never become a [`Resolved`] record, never
/// resolve an `entry_point`, and never reach the binding table / fused
/// registry (§9.3, §12.5).
pub fn lower_file(
    file: &crate::fkc::schema::FkcFile,
    link: &dyn LinkRegistry,
    warnings: &mut Vec<crate::fkc::ImportWarning>,
) -> Result<Vec<Resolved>, FkcError> {
    let provider = &file.front_matter.provider;
    let defaults = Defaults {
        backend: provider.backend.as_str(),
        kernel_source: provider.kernel_source.as_str(),
        revision_base: provider.revision_base.as_deref().unwrap_or(""),
    };
    // Each registrable section lowers to ONE-OR-MORE Resolved records (a
    // primitive section fans out over its dtype variants, §3.4); flatten them
    // into the provider's flat list.
    let mut out = Vec::new();
    for kernel in file.kernels.iter().filter(|k| k.registrable) {
        // §3.10: describe-only documentation sections are skipped above.
        out.extend(lower_kernel(kernel, &defaults, link, warnings)?);
    }
    Ok(out)
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::fkc::parse_file;
    use std::sync::{Arc, RwLock};

    const ELEMENTWISE_BINARY: &str =
        include_str!("../../../docs/kernel-contracts/cpu/elementwise-binary.fkc.md");
    const QUANT_MATMUL: &str =
        include_str!("../../../docs/kernel-contracts/cpu/quant-matmul.fkc.md");
    /// A real FUSED contract bundle whose `fused_op: SOFTMAX_LAST_DIM` etc.
    /// must now resolve through the SCREAMING_SNAKE constant table (Task 1).
    const FUSED_NORM_SOFTMAX: &str =
        include_str!("../../../docs/kernel-contracts/fused/norm-softmax.fkc.md");

    // ---- KISS-CLASSIFY §6.1 reserved vocabulary: reserved != unknown ----

    /// At the FKC parse site — a real ingest surface, since contract files are
    /// external and hand-authored — a reserved spelling declines **matchably
    /// differently** from an unknown one. Deleting the `ReservedScalarType`
    /// arm in `lower_dtype` makes this fail; that is the born-red evidence for
    /// this half of GAP-155.
    #[test]
    fn a_reserved_dtype_token_declines_distinctly_from_an_unknown_one() {
        let reserved = lower_dtype("F8E4M3FNUZ", "sec", "lhs").expect_err("must not lower");
        assert!(
            matches!(reserved, FkcError::ReservedScalarType { .. }),
            "a §6.1-reserved token must decline AS reserved, not as a bad token \
             — a contract author told 'bad dtype token' goes hunting for a typo \
             that does not exist; got {reserved:?}",
        );

        // The other side. Without this, collapsing EVERYTHING into
        // ReservedScalarType would pass the assertion above.
        let unknown = lower_dtype("NOT_A_DTYPE", "sec", "lhs").expect_err("must not lower");
        assert!(
            matches!(unknown, FkcError::BadScalarType { .. }),
            "an unknown token must stay BadScalarType; got {unknown:?}",
        );
    }

    /// Binds this site to `fuel-ir`'s list rather than to a copy of it. If
    /// someone adds a token to `RESERVED_DTYPE_TOKENS` and this site keeps a
    /// private list, the new token silently reverts to "unknown" here — a
    /// drift that no other test would notice.
    #[test]
    fn every_shared_reserved_token_declines_as_reserved_at_this_site() {
        for tok in fuel_ir::RESERVED_DTYPE_TOKENS {
            // FKC spells dtype tokens uppercase; the shared list is canonical
            // lowercase. That mismatch is exactly why the lookup is
            // case-insensitive, so exercise the FKC spelling here.
            let upper = tok.to_ascii_uppercase();
            let err = lower_dtype(&upper, "sec", "lhs")
                .expect_err("a reserved token must never lower to a DType");
            assert!(
                matches!(err, FkcError::ReservedScalarType { .. }),
                "{upper} is in RESERVED_DTYPE_TOKENS but declined as {err:?} — this \
                 site has drifted from the shared list",
            );
        }
        // Non-vacuity: an empty list would pass the loop above silently.
        assert!(!fuel_ir::RESERVED_DTYPE_TOKENS.is_empty());
    }

    /// The delimiter trap. Every supported FP8 token is a PREFIX of a reserved
    /// one (`F8E5M2` / `F8E5M2FNUZ`), so a `starts_with`-style classifier would
    /// accept the reserved token AS the supported one. That failure is silent:
    /// `fnuz` uses a different exponent bias, so the same bytes decode to
    /// different numbers and the kernel returns wrong answers rather than an
    /// error.
    #[test]
    fn a_reserved_token_is_not_accepted_as_the_token_it_extends() {
        assert!(
            !matches!(lower_dtype("F8E5M2FNUZ", "sec", "lhs"), Ok(DType::F8E5M2)),
            "F8E5M2FNUZ must not lower to its OCP prefix F8E5M2",
        );
        assert!(
            !matches!(lower_dtype("F8E4M3FNUZ", "sec", "lhs"), Ok(DType::F8E4M3)),
            "F8E4M3FNUZ must not lower to its OCP prefix F8E4M3",
        );
        // Non-vacuity, both ways: the prefixes really are accepted tokens here
        // (so the pairs above are genuine traps), and the reserved forms really
        // do extend them.
        assert_eq!(lower_dtype("F8E5M2", "sec", "lhs").unwrap(), DType::F8E5M2);
        assert_eq!(lower_dtype("F8E4M3", "sec", "lhs").unwrap(), DType::F8E4M3);
        assert!(
            fuel_ir::RESERVED_DTYPE_TOKENS
                .iter()
                .any(|t| t.eq_ignore_ascii_case("F8E5M2FNUZ")),
        );
    }

    // ---- A test LinkRegistry stub mapping every entry_point to a dummy ----

    fn dummy_kernel(
        _inputs: &[Arc<RwLock<fuel_memory::Storage>>],
        _outputs: &mut [Arc<RwLock<fuel_memory::Storage>>],
        _layouts: &[fuel_ir::Layout],
        _params: &crate::kernel::OpParams,
    ) -> fuel_ir::Result<()> {
        Ok(())
    }

    struct StubLink;
    impl LinkRegistry for StubLink {
        fn resolve_primitive(&self, _symbol: &str) -> Option<KernelRef> {
            Some(dummy_kernel)
        }
        fn resolve_fused(&self, _symbol: &str) -> Option<KernelRef> {
            Some(dummy_kernel)
        }
    }

    /// A stub that resolves nothing (for the UnknownEntryPoint negative).
    struct EmptyLink;
    impl LinkRegistry for EmptyLink {
        fn resolve_primitive(&self, _symbol: &str) -> Option<KernelRef> {
            None
        }
        fn resolve_fused(&self, _symbol: &str) -> Option<KernelRef> {
            None
        }
    }

    /// Lower every dtype variant of one section (a primitive fans out; a
    /// fused section yields one).
    fn lower_all(src: &str, kernel_name: &str) -> Result<Vec<Resolved>, FkcError> {
        let file = parse_file(src).expect("parses");
        let provider = &file.front_matter.provider;
        let defaults = Defaults {
            backend: provider.backend.as_str(),
            kernel_source: provider.kernel_source.as_str(),
            revision_base: provider.revision_base.as_deref().unwrap_or(""),
        };
        let kernel = file
            .kernels
            .iter()
            .find(|k| k.kernel == kernel_name)
            .unwrap_or_else(|| panic!("kernel {kernel_name} present"));
        lower_kernel(kernel, &defaults, &StubLink, &mut Vec::new())
    }

    /// The first (representative) variant of a section — convenience for the
    /// single-variant positive tests.
    fn lower_one(src: &str, kernel_name: &str) -> Result<Resolved, FkcError> {
        Ok(lower_all(src, kernel_name)?
            .into_iter()
            .next()
            .expect("a section lowers to ≥1 variant"))
    }

    // =====================================================================
    // POSITIVE: real contracts lower
    // =====================================================================

    #[test]
    fn lowers_real_add_f32() {
        let r = lower_one(ELEMENTWISE_BINARY, "add_f32").expect("add_f32 lowers");
        let Resolved::Primitive(p) = r else {
            panic!("add_f32 is a primitive");
        };
        assert_eq!(p.op, OpKind::AddElementwise);
        // inputs lhs, rhs (F32, F32) then output (passthrough → F32).
        assert_eq!(p.dtypes.as_slice(), &[DType::F32, DType::F32, DType::F32]);
        assert_eq!(p.backend, BackendId::Cpu);
        // contiguous-only contract ⇒ strided_input false.
        assert!(!p.caps.strided_input);
        // precision mapped (bit-stable, ulp 0).
        assert!(p.precision.bit_stable_on_same_hardware);
        assert_eq!(p.precision.max_ulp, Some(0));
        // a non-null KernelRef.
        assert_eq!(
            p.kernel as *const () as usize,
            dummy_kernel as *const () as usize
        );
        // cost: flops = "n" parsed (not Unknown).
        assert!(matches!(p.cost, CompiledCostExpr::Expr(_)));
        assert_eq!(p.kernel_source, "portable-cpu");
    }

    #[test]
    fn lowers_binary_chassis_section_fans_out_over_all_dtypes() {
        // The umbrella `binary` section has two operands both enumerating
        // [F32,F64,BF16,F16] (a UNIFORM multi-dtype section), so it FANS OUT
        // into one binding per dtype (§3.4) — not a single first-dtype
        // representative. `passthrough(lhs)` mirrors lhs at each variant.
        let all = lower_all(ELEMENTWISE_BINARY, "binary").expect("binary lowers");
        assert_eq!(all.len(), 4, "4 dtypes ⇒ 4 fanned variants");
        let keys: Vec<Vec<DType>> = all
            .iter()
            .map(|r| {
                let Resolved::Primitive(p) = r else {
                    panic!("binary is a primitive")
                };
                assert_eq!(p.op, OpKind::AddElementwise);
                p.dtypes.to_vec()
            })
            .collect();
        assert_eq!(
            keys,
            vec![
                vec![DType::F32, DType::F32, DType::F32],
                vec![DType::F64, DType::F64, DType::F64],
                vec![DType::BF16, DType::BF16, DType::BF16],
                vec![DType::F16, DType::F16, DType::F16],
            ],
            "each variant keys on [lhs, rhs, out(passthrough lhs)] at that dtype"
        );
    }

    #[test]
    fn lowers_real_qmatmul_q4_0() {
        let r = lower_one(QUANT_MATMUL, "qmatmul_q4_0_f32").expect("q4_0 lowers");
        let Resolved::Primitive(p) = r else {
            panic!("QMatMul is a primitive")
        };
        assert_eq!(p.op, OpKind::QMatMul);
        // activations F32, weight U8, output fixed(F32).
        assert_eq!(p.dtypes.as_slice(), &[DType::F32, DType::U8, DType::F32]);
        assert_eq!(p.backend, BackendId::Cpu);
        // judge_measured with all-`~` coefficients ⇒ Unknown cost sentinel.
        assert_eq!(p.cost, CompiledCostExpr::Unknown);
        assert!(p.precision.bit_stable_on_same_hardware);
    }

    #[test]
    fn lowers_real_nf4_matmul_f32() {
        // NF4 reaches the dedicated OpKind::Nf4Matmul path → it LOWERS in
        // this slice (the AFFINE_BLOCK / MxNotYetRegistrable gate is a
        // register-slice concern; lowering produces a typed record).
        let r = lower_one(QUANT_MATMUL, "nf4_matmul_f32").expect("nf4 lowers");
        let Resolved::Primitive(p) = r else { panic!() };
        assert_eq!(p.op, OpKind::Nf4Matmul);
        // activations F32, w_packed U8, absmax F32, output passthrough → F32.
        assert_eq!(
            p.dtypes.as_slice(),
            &[DType::F32, DType::U8, DType::F32, DType::F32]
        );
    }

    #[test]
    fn lower_file_lowers_every_kernel() {
        let file = parse_file(ELEMENTWISE_BINARY).expect("parses");
        let resolved = lower_file(&file, &StubLink, &mut Vec::new()).expect("all lower");
        // Every *registrable* section lowers; describe-only sections (§3.10,
        // e.g. the shared `binary` chassis umbrella) are filtered out first.
        let registrable = file.kernels.iter().filter(|k| k.registrable).count();
        assert_eq!(resolved.len(), registrable);
    }

    #[test]
    fn cost_trampoline_evaluates_matmul_declared_flops() {
        // The matmul contract declares `flops: "2 * batch * m * n * k"`. Lower it
        // (StubLink resolves entry_points to dummies — we only need the parsed
        // cost AST), then run that AST through the cost trampoline for a
        // 2×(3×4×5) batched matmul → 2·2·3·4·5 = 240 flops. This is what FKC
        // import previously dropped in favor of the `unknown_cost` sentinel.
        const MATMUL: &str = include_str!("../../../docs/kernel-contracts/cpu/matmul.fkc.md");
        let file = parse_file(MATMUL).expect("matmul contract parses");
        let resolved =
            lower_file(&file, &StubLink, &mut Vec::new()).expect("matmul contract lowers");
        let prim = resolved
            .iter()
            .find_map(|r| match r {
                Resolved::Primitive(p) if p.op == OpKind::MatMul => Some(p),
                _ => None,
            })
            .expect("a MatMul primitive in the matmul contract");
        let params = crate::kernel::OpParams::Matmul {
            lhs_batch_dims: vec![2],
            rhs_batch_dims: vec![2],
            m: 3,
            n: 4,
            k: 5,
            m_compute: crate::kernel::MatmulM::All,
        };
        let est = crate::fkc::cost_estimate(
            &prim.cost,
            OpKind::MatMul,
            &[],
            &[DType::F32, DType::F32, DType::F32],
            &params,
        )
        .expect("declared matmul cost evaluates");
        assert_eq!(est.flops, 240, "2 * batch(2) * m(3) * n(4) * k(5) = 240");
    }

    /// Task 1 end-to-end verification: a REAL fused contract from the corpus
    /// (`fused/norm-softmax.fkc.md`, `fused_op: SOFTMAX_LAST_DIM`) lowers via
    /// the stub link — proving the SCREAMING_SNAKE token now resolves.
    #[test]
    fn lowers_real_fused_softmax_last_dim() {
        let r = lower_one(FUSED_NORM_SOFTMAX, "softmax_last_dim")
            .expect("softmax_last_dim (fused) lowers");
        let Resolved::Fused(f) = r else {
            panic!("softmax_last_dim is a fused op");
        };
        assert_eq!(f.id, FusedOps::SOFTMAX_LAST_DIM);
        assert_eq!(f.backend, BackendId::Cpu);
        assert_eq!(f.kernel_source, "portable-cpu");

        // The whole bundle lowers (every fused_op token resolves). Each of the
        // 8 `fused_op` sections enumerates `dtypes: [F32, F64, BF16, F16]` and
        // now FANS into one `ResolvedFused` per dtype (§3.4 fused dtype-fan), so
        // the lowered set is 8 sections × 4 dtypes = 32 (was 8 pre-fan, when
        // `lower_fused` took only the representative first variant).
        let file = parse_file(FUSED_NORM_SOFTMAX).expect("parses");
        let resolved =
            lower_file(&file, &StubLink, &mut Vec::new()).expect("all fused kernels lower");
        assert_eq!(
            resolved.len(),
            file.kernels.len() * 4,
            "each fused section fans over its 4 dtypes (8 sections × 4 = 32)",
        );
        assert!(resolved.iter().all(|r| matches!(r, Resolved::Fused(_))));
    }

    // =====================================================================
    // FUSED dtype-fan (§3.4): a multi-dtype `fused_op` section fans into N
    // per-dtype ResolvedFused (mirroring the primitive fan-out), each keyed
    // on its own dtype tuple; a single-dtype fused section yields exactly one.
    // =====================================================================

    /// A synthetic FUSED bundle exercising the fused dtype-fan. `fanned_softmax`
    /// declares `fused_op: SOFTMAX_LAST_DIM`, a BASE `entry_point`, and its input
    /// `x` enumerates `[F32, F64, BF16, F16]` — so it must fan into 4 per-dtype
    /// `ResolvedFused` (keys `[T, T]`), each resolving `<base>_<dt>`.
    /// `single_norm` is the backward-compat guard: a single-dtype (F32-only)
    /// section → EXACTLY ONE `ResolvedFused`, its declared symbol resolved AS-IS.
    const FUSED_FANOUT_SYNTH: &str = r#"---
fkc_version: 1
provider:
  name: test-provider
  backend: Cpu
  kernel_source: "test-cpu"
---

# fused dtype-fan synthetic

## fanned_softmax

A blurb.

```fkc
kernel: fanned_softmax
fused_op: SOFTMAX_LAST_DIM
blurb: "synthetic multi-dtype fused softmax"
entry_point: "x::softmax_cpu"
accept:
  inputs:
    - name: x
      dtypes: [F32, F64, BF16, F16]
return:
  outputs:
    - name: out
      dtype_rule: passthrough(x)
```

## single_norm

A blurb.

```fkc
kernel: single_norm
fused_op: RMS_NORM_LAST_DIM
blurb: "synthetic single-dtype fused rms-norm"
entry_point: "x::rms_norm_f32_cpu"
accept:
  inputs:
    - name: x
      dtypes: [F32]
return:
  outputs:
    - name: out
      dtype_rule: passthrough(x)
```
"#;

    #[test]
    fn fused_multi_dtype_section_fans_into_per_dtype_resolved_fused() {
        // BORN-RED → GREEN: `fanned_softmax` (input `x` over 4 dtypes, BASE
        // entry_point) must fan into 4 `ResolvedFused` — one per dtype — each
        // keyed `[dt, dt]`. Pre-change `lower_fused` took only the representative
        // (first) variant → 1 record (RED); the fan yields 4 (GREEN).
        let all = lower_all(FUSED_FANOUT_SYNTH, "fanned_softmax").expect("fanned_softmax lowers");
        assert_eq!(
            all.len(),
            4,
            "4 dtypes ⇒ 4 fanned ResolvedFused (pre-change: 1 representative only)",
        );
        let keys: Vec<Vec<DType>> = all
            .iter()
            .map(|r| {
                let Resolved::Fused(f) = r else {
                    panic!("fanned_softmax is a fused op")
                };
                assert_eq!(f.id, FusedOps::SOFTMAX_LAST_DIM);
                assert_eq!(f.backend, BackendId::Cpu);
                f.dtypes.to_vec()
            })
            .collect();
        assert_eq!(
            keys,
            vec![
                vec![DType::F32, DType::F32],
                vec![DType::F64, DType::F64],
                vec![DType::BF16, DType::BF16],
                vec![DType::F16, DType::F16],
            ],
            "each variant keys on [x, out(passthrough x)] at that dtype",
        );
    }

    #[test]
    fn fused_single_dtype_section_yields_exactly_one_resolved_fused() {
        // Backward-compat hard gate: a single-dtype fused section produces
        // EXACTLY ONE `ResolvedFused`, byte-identical to today (its declared
        // `entry_point` resolves AS-IS — no `_<suffix>` appended).
        let all = lower_all(FUSED_FANOUT_SYNTH, "single_norm").expect("single_norm lowers");
        assert_eq!(
            all.len(),
            1,
            "single-dtype fused section ⇒ exactly one ResolvedFused"
        );
        let Resolved::Fused(f) = &all[0] else {
            panic!("single_norm is a fused op");
        };
        assert_eq!(f.id, FusedOps::RMS_NORM_LAST_DIM);
        assert_eq!(f.dtypes.as_slice(), &[DType::F32, DType::F32]);
    }

    // =====================================================================
    // return.bundle key derivation (§5.5 Option C multi-output)
    // =====================================================================

    /// A synthetic contract exercising the `return.bundle` key-derivation gap.
    /// `bundle_op` has TWO inputs (`a`, `b`) and a `return.bundle` (Option C
    /// multi-output: one packed buffer) whose PRIMARY slot mirrors input `a`
    /// (`passthrough(a)` → F32) and NO `return.outputs` — so its binding key
    /// must be `[a, b, out] = [F32; 3]` (N+1 slots). The importer previously
    /// read `return.outputs` ONLY, so a bundle-only section produced the N-slot
    /// short key `[F32, F32]` (missing the bundled output slot) — exactly why
    /// the `selective_scan_*` / `ssd_chunk_scan_*` families were deferred.
    /// `plain_op` is the no-bundle backward-compat guard: TWO inputs + a regular
    /// `return.outputs`, key `[F32, F32, F32]` (unchanged).
    /// A `dtype_rule: passthrough(<role>)` naming the LAST input when that
    /// input is OPTIONAL. Rejected: with the optional operand absent there is
    /// no operand to take a dtype from, so the output dtype would be
    /// unresolvable in exactly one arm of the {absent, present} fan.
    const PASSTHROUGH_OPTIONAL_SYNTH: &str = r#"---
fkc_version: 1
provider:
  name: test-provider
  backend: Cpu
  kernel_source: "test-cpu"
---

# passthrough-names-optional synthetic

## bad_passthrough

A blurb.

```fkc
kernel: bad_passthrough
op_kind: AddElementwise
blurb: "output passthrough names the optional last operand"
entry_point: "x::add_cpu"
accept:
  inputs:
    - name: x
      dtypes: [F32]
    - name: bias
      dtypes: [F32]
      optional: true
return:
  outputs:
    - name: out
      dtype_rule: passthrough(bias)
```
"#;

    /// GAP-036: closes a clause that the derived clause->test coverage gate
    /// (`tests/fkc_clause_coverage.rs`) found unreachable by any test.
    ///
    /// `FkcError::PassthroughNamesOptionalOperand` was constructed on a live
    /// production path (`resolve_output_slot_dtype`) yet nothing proved that
    /// path was reachable — the "existence != enforcement" shape. The gate
    /// flagged it; this is the provoking test.
    ///
    /// The positive control is the `bias`-vs-`x` contrast: the SAME contract
    /// with `passthrough(x)` must lower cleanly. Without it this test would
    /// still pass if the contract were malformed for some unrelated reason and
    /// every lowering failed — it would be asserting "an error happened",
    /// not "THIS rule fired".
    #[test]
    fn passthrough_naming_the_optional_last_operand_is_rejected() {
        let err = lower_all(PASSTHROUGH_OPTIONAL_SYNTH, "bad_passthrough")
            .expect_err("passthrough(bias) names the optional last operand");
        match err {
            FkcError::PassthroughNamesOptionalOperand { ref role, .. } => {
                assert_eq!(role, "bias", "the rejected role is the optional operand");
            }
            other => panic!("expected PassthroughNamesOptionalOperand, got {other:?}"),
        }

        // POSITIVE CONTROL: the identical contract passing through the REQUIRED
        // operand lowers. Proves the rejection above is caused by the operand
        // being optional, not by the fixture being broken.
        let ok = PASSTHROUGH_OPTIONAL_SYNTH.replace("passthrough(bias)", "passthrough(x)");
        lower_all(&ok, "bad_passthrough")
            .expect("passthrough(x) names a REQUIRED operand and must lower cleanly");
    }

    const BUNDLE_SYNTH: &str = r#"---
fkc_version: 1
provider:
  name: test-provider
  backend: Cpu
  kernel_source: "test-cpu"
---

# bundle key-derivation synthetic

## bundle_op

A blurb.

```fkc
kernel: bundle_op
op_kind: SelectiveScan
blurb: "synthetic multi-output bundle op"
entry_point: "x::bundle_op"
accept:
  inputs:
    - name: a
      dtypes: [F32]
    - name: b
      dtypes: [F32]
return:
  bundle:
    - { name: y,  dtype_rule: passthrough(a), shape_rule: same_as(a), layout_guarantee: contiguous }
    - { name: st, dtype_rule: passthrough(a), shape_rule: same_as(a), layout_guarantee: contiguous }
```

## plain_op

A blurb.

```fkc
kernel: plain_op
op_kind: AddElementwise
blurb: "synthetic no-bundle op"
entry_point: "x::plain_op"
accept:
  inputs:
    - name: a
      dtypes: [F32]
    - name: b
      dtypes: [F32]
return:
  outputs:
    - name: out
      dtype_rule: passthrough(a)
```
"#;

    #[test]
    fn return_bundle_appends_primary_output_slot_to_key() {
        // A `return.bundle` (Option C multi-output, one packed buffer) must
        // contribute its PRIMARY slot's dtype to the binding key tail — so a
        // bundle-only section with N inputs keys `[in.., out] = N+1 slots`, NOT
        // the N-slot short key the importer built when it read `return.outputs`
        // only. The primary slot mirrors input `a` (`passthrough(a)` → F32).
        let r = lower_one(BUNDLE_SYNTH, "bundle_op").expect("bundle_op lowers");
        let Resolved::Primitive(p) = r else {
            panic!("bundle_op is a primitive");
        };
        assert_eq!(
            p.dtypes.as_slice(),
            &[DType::F32, DType::F32, DType::F32],
            "a `return.bundle` must append its primary output slot to the key \
             (2 inputs + 1 bundle out = 3); the importer previously built the \
             2-slot short key `[F32, F32]` from `return.outputs` only",
        );
    }

    #[test]
    fn no_bundle_section_key_is_unchanged() {
        // Backward-compat guard: a section WITHOUT a `return.bundle` is
        // byte-identical to today — 2 inputs + 1 regular `passthrough(a)`
        // output = `[F32; 3]`, with NO phantom bundle slot appended.
        let r = lower_one(BUNDLE_SYNTH, "plain_op").expect("plain_op lowers");
        let Resolved::Primitive(p) = r else {
            panic!("plain_op is a primitive");
        };
        assert_eq!(
            p.dtypes.as_slice(),
            &[DType::F32, DType::F32, DType::F32],
            "a no-bundle section keys on inputs + regular outputs only",
        );
    }

    // =====================================================================
    // variant: retained opaque tag (Baracuda `variant:`)
    // =====================================================================

    /// A synthetic contract whose primitive section declares an opaque
    /// specialization `variant:` tag, plus a sibling section that omits it (the
    /// backward-compat `None` guard). The tag is a top-level per-kernel field
    /// (NOT `accept.op_params.variant`, which names the `OpParams` Rust
    /// variant) and must survive lowering onto `ResolvedPrimitive.variant`
    /// verbatim.
    const VARIANT_SYNTH: &str = r#"---
fkc_version: 1
provider:
  name: test-provider
  backend: Cpu
  kernel_source: "test-cpu"
---

# variant retention synthetic

## tagged_op

A blurb.

```fkc
kernel: tagged_op
op_kind: MatMul
blurb: "synthetic split-K partial variant"
entry_point: "x::tagged_op"
variant: "splitk_partial"
accept:
  inputs:
    - name: lhs
      dtypes: [F32]
    - name: rhs
      dtypes: [F32]
return:
  outputs:
    - name: out
      dtype_rule: fixed(F32)
```

## untagged_op

A blurb.

```fkc
kernel: untagged_op
op_kind: MatMul
blurb: "synthetic no-variant op"
entry_point: "x::untagged_op"
accept:
  inputs:
    - name: lhs
      dtypes: [F32]
    - name: rhs
      dtypes: [F32]
return:
  outputs:
    - name: out
      dtype_rule: fixed(F32)
```
"#;

    #[test]
    fn variant_tag_is_retained_on_resolved_primitive() {
        // A contract-declared `variant:` tag must ride verbatim onto the
        // lowered record so it can reach the (later) records / ImplId emission
        // step. RED before the wiring: the tag is dropped (retained `None`);
        // GREEN once `lower_primitive` clones `kernel.variant`.
        let r = lower_one(VARIANT_SYNTH, "tagged_op").expect("tagged_op lowers");
        let Resolved::Primitive(p) = r else {
            panic!("tagged_op is a primitive");
        };
        assert_eq!(
            p.variant.as_deref(),
            Some("splitk_partial"),
            "the opaque `variant:` tag must survive lowering onto \
             ResolvedPrimitive.variant (it was dropped)",
        );
    }

    #[test]
    fn no_variant_section_retains_none() {
        // Backward-compat guard: a section that omits `variant:` lowers with
        // `variant: None` (every existing contract is unaffected, additive §11).
        let r = lower_one(VARIANT_SYNTH, "untagged_op").expect("untagged_op lowers");
        let Resolved::Primitive(p) = r else {
            panic!("untagged_op is a primitive");
        };
        assert_eq!(p.variant, None, "a section without `variant:` retains None");
    }

    // =====================================================================
    // NEGATIVES
    // =====================================================================

    #[test]
    fn bogus_op_kind_is_unknown_op_kind() {
        let err = lower_op_kind("NotARealOp", "k").expect_err("bogus op");
        assert!(matches!(err, FkcError::UnknownOpKind { .. }), "got {err:?}");
    }

    #[test]
    fn bogus_dtype_is_bad_scalar_type() {
        let err = lower_dtype("F99", "k", "lhs").expect_err("bogus dtype");
        assert!(matches!(err, FkcError::BadScalarType { .. }), "got {err:?}");
    }

    /// DRIFT GUARD (§3.4 fan-out): the `DType → FKC dtype suffix` spelling
    /// used to build a fanning section's `<entry_point>_<suffix>` symbol must
    /// stay the exact INVERSE of `lower_dtype` — i.e. uppercasing the suffix
    /// round-trips back to the same `DType`. This locks `dtype_suffix`
    /// (`DType::as_str`, the `ep!`/byte-kernel convention) to the token table
    /// so the two cannot drift into a second spelling.
    #[test]
    fn dtype_suffix_is_the_inverse_of_lower_dtype() {
        for dt in [
            DType::U8,
            DType::I8,
            DType::U32,
            DType::I16,
            DType::I32,
            DType::I64,
            DType::BF16,
            DType::F16,
            DType::F32,
            DType::F64,
            DType::F8E4M3,
            DType::F6E2M3,
            DType::F6E3M2,
            DType::F4,
            DType::F8E8M0,
            DType::F8E6M2,
        ] {
            let suffix = super::dtype_suffix(dt);
            let token = suffix.to_uppercase();
            assert_eq!(
                super::lower_dtype(&token, "k", "op").expect("round-trips"),
                dt,
                "suffix {suffix:?} (token {token:?}) must lower back to {dt:?}",
            );
        }
    }

    #[test]
    fn bogus_fused_op_is_unknown_fused_op() {
        let err = lower_fused_op("NotAFusedOp", "k").expect_err("bogus fused");
        assert!(
            matches!(err, FkcError::UnknownFusedOp { .. }),
            "got {err:?}"
        );
    }

    #[test]
    fn screaming_snake_const_name_resolves_not_pascalcase() {
        // The contract token is the SCREAMING_SNAKE FusedOps constant name.
        assert_eq!(
            lower_fused_op("SOFTMAX_LAST_DIM", "k").unwrap(),
            FusedOps::SOFTMAX_LAST_DIM
        );
        assert_eq!(
            lower_fused_op("FLASH_ATTN", "k").unwrap(),
            FusedOps::FLASH_ATTN
        );
        assert_eq!(lower_fused_op("QMATMUL", "k").unwrap(), FusedOps::QMATMUL);
        // The PascalCase registry `name` (what the OLD id_for_name resolver
        // matched) must NOT resolve — that was the bug.
        assert!(lower_fused_op("SoftmaxLastDim", "k").is_err());
        assert!(lower_fused_op("FlashAttn", "k").is_err());
    }

    /// DRIFT GUARD (Task 1): every `FusedOpId` present in `default_registry()`
    /// must be reachable through the SCREAMING_SNAKE constant-name table — so
    /// adding a new `FusedOps` const + registry entry without a table arm
    /// fails this test (it would otherwise be silently unimportable).
    #[test]
    fn every_registry_id_is_reachable_through_table() {
        use std::collections::HashSet;
        // Every id the constant-name table can produce.
        let reachable: HashSet<FusedOpId> = [
            "SOFTMAX_LAST_DIM",
            "FUSED_LINEAR",
            "RMS_NORM_LAST_DIM",
            "LAYER_NORM_LAST_DIM",
            "ROPE",
            "CONV2D",
            "SOFTMAX_LAST_DIM_BACKWARD",
            "LAYER_NORM_LAST_DIM_BACKWARD",
            "RMS_NORM_LAST_DIM_BACKWARD",
            "REDUCE_MAX_TO_BACKWARD",
            "CONV_TRANSPOSE2D",
            "FLASH_ATTN",
            "PAGED_ATTN",
            "QMATMUL",
            "POWI_BACKWARD",
            "INPLACE_AFFINE",
            "FUSED_SOFTMAX_CROSS_ENTROPY",
            "CAUSAL_CONV1D",
            "SELECTIVE_SCAN",
            "SSD_CHUNK_SCAN",
            "NF4_MATMUL",
            "FLASH_ATTN_BACKWARD_Q",
            "FLASH_ATTN_BACKWARD_K",
            "FLASH_ATTN_BACKWARD_V",
            "AWQ_MATMUL",
        ]
        .iter()
        .map(|n| super::fused_op_id_for_const_name(n).expect("table arm exists"))
        .collect();

        // Every registered id MUST be in `reachable`.
        for entry in fuel_graph::registry::default_registry().entries_iter() {
            assert!(
                reachable.contains(&entry.id),
                "FusedOpId {:?} (registry name {:?}) is registered but NOT reachable through the \
                 SCREAMING_SNAKE constant-name table — add a `fused_op_id_for_const_name` arm",
                entry.id,
                entry.name,
            );
        }
    }

    #[test]
    fn bogus_backend_is_unknown_backend() {
        let err = lower_backend("Tpu", "k").expect_err("bogus backend");
        assert!(
            matches!(err, FkcError::UnknownBackend { .. }),
            "got {err:?}"
        );
    }

    #[test]
    fn unknown_entry_point_errors() {
        let file = parse_file(ELEMENTWISE_BINARY).expect("parses");
        let provider = &file.front_matter.provider;
        let defaults = Defaults {
            backend: provider.backend.as_str(),
            kernel_source: provider.kernel_source.as_str(),
            revision_base: provider.revision_base.as_deref().unwrap_or(""),
        };
        let kernel = file.kernels.iter().find(|k| k.kernel == "add_f32").unwrap();
        let err = lower_kernel(kernel, &defaults, &EmptyLink, &mut Vec::new())
            .expect_err("no entry point");
        assert!(
            matches!(err, FkcError::UnknownEntryPoint { .. }),
            "got {err:?}"
        );
    }

    #[test]
    fn malformed_cost_expr_is_cost_expr_parse() {
        let mut block = CostBlock {
            provenance: Some("declared".into()),
            class: None,
            cost_fn: None,
            flops: Some("2 * * n".into()), // malformed
            bytes_moved: None,
            overhead_ns: None,
            memory: None,
        };
        let err = compile_cost(Some(&block), "k").expect_err("malformed flops");
        assert!(matches!(err, FkcError::CostExprParse { .. }), "got {err:?}");

        // Also catch a malformed bytes_moved even when flops is fine.
        block.flops = Some("n".into());
        block.bytes_moved = Some("3 * n *".into());
        let err = compile_cost(Some(&block), "k").expect_err("malformed bytes_moved");
        assert!(matches!(err, FkcError::CostExprParse { field, .. } if field == "bytes_moved"));
    }

    #[test]
    fn both_op_kind_and_fused_op_is_ambiguous() {
        let file = parse_file(ELEMENTWISE_BINARY).expect("parses");
        let mut kernel = file.kernels[0].clone();
        kernel.fused_op = Some("SoftmaxLastDim".into()); // now both present
        let defaults = Defaults {
            backend: "Cpu",
            kernel_source: "x",
            revision_base: "",
        };
        let err =
            lower_kernel(&kernel, &defaults, &StubLink, &mut Vec::new()).expect_err("ambiguous");
        assert!(
            matches!(err, FkcError::OpTargetAmbiguous { .. }),
            "got {err:?}"
        );
    }
}