Skip to main content

gam_terms/analytic_penalties/
isometry.rs

1use super::*;
2pub use gam_problem::WeightField;
3
4// ---------------------------------------------------------------------------
5// Isometry penalty
6// ---------------------------------------------------------------------------
7
8/// Choice of reference Riemannian metric `g^ref(t)` on the latent manifold.
9///
10/// `Euclidean` is the natural default: the reference metric is `I_d`, so the
11/// penalty pulls the decoder toward locally-isometric (length-preserving)
12/// behavior. `UserSupplied` lets the caller hand in a `(n_obs, d, d)` jet of
13/// per-row reference metrics (useful for warm-starting from a chart of a
14/// pre-fit GP-LVM).
15#[derive(Clone)]
16pub enum IsometryReference {
17    Euclidean,
18    UserSupplied(Arc<Array2<f64>>), // (n_obs, d*d) row-major flattened
19}
20
21impl std::fmt::Debug for IsometryReference {
22    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
23        match self {
24            IsometryReference::Euclidean => f.write_str("Euclidean"),
25            IsometryReference::UserSupplied(a) => f
26                .debug_tuple("UserSupplied")
27                .field(&format_args!("{}×{}", a.nrows(), a.ncols()))
28                .finish(),
29        }
30    }
31}
32
33/// Radial Duchon decoder metadata used to materialize
34/// `∂J_n[i, a] / ∂t_{n, c}` from `φ'(r)` and `φ''(r)` on demand.
35///
36/// `radial_coefficients[k, i]` is the decoder coefficient that maps radial
37/// basis column `k` into output channel `i`. Polynomial-tail columns are not
38/// represented here; callers whose decoder contains a non-linear polynomial
39/// tail should provide `jacobian_second_cache` directly.
40#[derive(Debug, Clone)]
41pub struct IsometryDuchonRadialSource {
42    pub centers: Arc<Array2<f64>>,
43    pub radial_coefficients: Arc<Array2<f64>>,
44    pub length_scale: Option<f64>,
45    pub nullspace_order: DuchonNullspaceOrder,
46    /// Forward hybrid spectral order `s = spec.power`. The Cartesian
47    /// derivative engine must resolve the same `(p, s, κ)` the forward
48    /// `build_duchon_basis` used, so it differentiates the exact resolved
49    /// hybrid Green's function `φ_{p,s,κ}` rather than a hard-coded `s = 0`
50    /// surrogate (issue #440).
51    pub power: usize,
52}
53
54/// Isometry-to-reference penalty (canonical-coordinate gauge term).
55///
56/// Lives on ext-coords: the target slice is a row of the `LatentCoordValues` flat
57/// vector (row-major `n_obs × d`). Owns one ρ-axis (`log μ_iso`).
58///
59/// Penalizes `½ μ Σ_n ‖g_n(t) − g^ref(t_n)‖²_F`, where the pullback metric
60/// at row `n` is
61///
62/// ```text
63///   g_n = J_n^T W_n J_n,    J_n ∈ ℝ^{p × d}
64/// ```
65///
66/// and `W_n` is a per-row low-rank PSD behavioral metric stored as
67/// `W_n = U_n U_n^T` with `U_n ∈ ℝ^{p × r}`. The canonical-coordinate
68/// statement is "one unit of motion in `t` ↦ one unit of behavioral change",
69/// so the `W_n` weighting is load-bearing.
70///
71/// In the SAE objective this is the extension-coordinate gauge fix: it prevents
72/// the latent chart from absorbing arbitrary smooth reparameterizations of the
73/// decoder manifold. ARD, sparsity, or rank penalties can then select axes or
74/// structure in a chart whose metric scale is pinned.
75///
76/// **Contraction order invariant.** Every place this struct touches `W_n`,
77/// the contraction is `(J^T U_n)(U_n^T J)` — never `J^T W_n J` with `W_n`
78/// materialized as `p × p`. Concretely we form `M_n = U_n^T J_n ∈ ℝ^{r × d}`
79/// once and then `g_n = M_n^T M_n` (`d × d`). Cost per row:
80/// `O(p · r · d + r · d²)`, independent of `p²`.
81///
82/// **When to use.** Whenever a `LatentCoord` block is in play without an
83/// auxiliary variable (`AuxPrior`) to break the diffeomorphism gauge. Fixes
84/// the audit finding that ARD is not a standalone gauge fix. With a Euclidean
85/// reference, the penalty pulls the decoder toward a local isometry, which is
86/// enough to make the inner Hessian on `t` full-rank and the IFT well-defined.
87///
88/// **Math.** Let `J_n ∈ ℝ^{p × d}` be the local decoder Jacobian. Then
89/// `g_n = J_n^T W_n J_n` and the penalty is
90/// `½ μ Σ_n ‖J_n^T W_n J_n − g^ref_n‖²_F`. Analytic gradient w.r.t. `t_n`:
91///
92/// ```text
93///   ∂P/∂t_{n,c}
94///     = μ Σ_{a,b} (g_n − g^ref_n)_{ab}
95///         [ H_{n,:,a,c}^T W_n J_{n,:,b}
96///           + J_{n,:,a}^T W_n H_{n,:,b,c} ],
97///   H_{n,i,a,c} = ∂J_{n,i,a}/∂t_{n,c}.
98/// ```
99///
100/// Gotchas:
101///
102/// * The value path returns the configured missing-cache default when the
103///   first-jet cache is absent; gradient/HVP paths need the first and second
104///   decoder jets and return zeros when the analytic jet source is unavailable.
105/// * The exact Hessian includes a residual-curvature term requiring the third
106///   decoder jet. REML/PIRLS curvature should prefer the Gauss-Newton PSD
107///   majorizer when a positive curvature block is required.
108/// * `W_n` is a metric weight, not a scalar confidence. Changing it changes the
109///   canonical units of latent motion.
110///
111/// The per-row Jacobian `J_n` is exactly the radial-derivative jet
112/// `design_gradient_wrt_t` already computes for `LatentCoordValues`; the
113/// second derivative `∂J/∂t` is built by the shared
114/// `crate::basis::radial_basis_cartesian_derivative` engine from the
115/// radial Hessian identity. A finite-difference oracle for the docstring is
116/// to central-difference `value(t ± h e_j)` against `grad_target(t)[j]`;
117/// the analytic value follows the oracle until finite-difference
118/// cancellation dominates. No autograd needed.
119///
120/// `μ = exp(ρ_iso)` is REML-selectable as one extra ρ axis.
121///
122/// `jacobian_cache_slot` and `jacobian_second_cache_slot` are interior-mutable
123/// (`RwLock<Option<Arc<…>>>`) so the SAE outer loop can refresh them in place
124/// each step without needing `&mut self` on the registry-held penalty (see
125/// `refresh_caches` and `crate::terms::sae::manifold::refresh_isometry_caches_from_atom`).
126/// Readers go through the [`Self::jacobian_cache`] / [`Self::jacobian_second_cache`]
127/// accessors, which take the read lock briefly and clone the inner `Arc`
128/// (refcount bump — no payload copy). Writers go through [`Self::refresh_caches`].
129#[derive(Debug)]
130pub struct IsometryPenalty {
131    pub target: PsiSlice,
132    pub reference: IsometryReference,
133    /// Index of this penalty's strength `log μ_iso` inside the *local* rho
134    /// view this penalty receives. Always `0` for now (single owned axis).
135    pub rho_index: usize,
136    /// Cached Jacobian `J ∈ ℝ^{n_obs × p × d}`, flattened row-major
137    /// `(n_obs, p*d)`. The owning driver refreshes this each IFT outer step
138    /// before invoking `value` / `grad_target`; in operator-only call sites
139    /// (Hessian-vector products) the cache must be live. Access through
140    /// [`Self::jacobian_cache`] / [`Self::set_jacobian_cache`].
141    pub jacobian_cache_slot: RwLock<Option<Arc<Array2<f64>>>>,
142    /// Optional cached per-row Jacobian *second derivative*
143    /// `H_n ∈ ℝ^{p × d × d}`, flattened row-major as `(n_obs, p*d*d)`.
144    /// `H_n[i, a, c] = ∂J_n[i, a] / ∂t_{n, c}`. Either this cache or
145    /// `duchon_radial_source` must be present for exact isometry
146    /// gradient/HVP calls. Access through [`Self::jacobian_second_cache`] /
147    /// [`Self::set_jacobian_second_cache`].
148    pub jacobian_second_cache_slot: RwLock<Option<Arc<Array2<f64>>>>,
149    /// Optional radial-Duchon source used to build `jacobian_second_cache`
150    /// analytically from `φ'(r)` and the public `φ''(r)` jet helper. This is
151    /// the exact chain-rule path for callers that do not pre-cache `∂J/∂t`.
152    pub duchon_radial_source: Option<Arc<IsometryDuchonRadialSource>>,
153    /// Optional cached per-row Jacobian *third derivative*
154    /// `K_n ∈ ℝ^{p × d × d × d}`, stored as an `Array3` with shape
155    /// `(n_obs, p, d * d * d)` where the third axis packs `(a, c, d)` in
156    /// row-major order `((a * d) + c) * d + dd`. `hvp` uses the full
157    /// residual-curvature Hessian (proposal §4(b)):
158    ///   B_{ab,cd} = K_{a,cd}^T W J_b + H_{a,c}^T W H_{b,d}
159    ///             + H_{a,d}^T W H_{b,c} + J_a^T W K_{b,cd}.
160    /// Either this cache or `duchon_radial_source` must be present for
161    /// analytic `hvp` calls. Interior-mutable (mirrors
162    /// `jacobian_second_cache_slot`) so the SAE outer loop can refresh `K` in
163    /// place each step. Access through [`Self::third_decoder_derivative`] /
164    /// [`Self::set_third_decoder_derivative`].
165    pub third_decoder_derivative_slot: RwLock<Option<Arc<ndarray::Array3<f64>>>>,
166    /// Output dimensionality `p` (column count of each per-row Jacobian).
167    pub p_out: usize,
168    /// Per-row behavioral metric in low-rank factored form. Defaults to
169    /// `Identity` (the unweighted `J^T J` pullback). When `Factored`, all
170    /// `g_n` contractions are done via `M_n = U_n^T J_n` (`r × d`), keeping
171    /// memory and FLOPs scaling at `O(p · r · d)` per row instead of
172    /// `O(p²)` per row.
173    pub weight: WeightField,
174    pub scalar_weight: f64,
175    pub weight_schedule: Option<ScalarWeightSchedule>,
176}
177
178pub(crate) struct IsometryHvpState<'a> {
179    d: usize,
180    n_obs: usize,
181    p: usize,
182    jac2: CowArray<'a, f64, Ix2>,
183    jac3: CowArray<'a, f64, Ix3>,
184    metric: IsometryMetricState,
185    wj_rows: Vec<Array2<f64>>,
186}
187
188#[derive(Debug, Clone)]
189struct IsometryMetricState {
190    g: Array2<f64>,
191    residual: Array2<f64>,
192    metric_grad: Array2<f64>,
193    normalizer: f64,
194    trace_denominator: f64,
195    residual_dot_g: f64,
196}
197
198impl IsometryMetricState {
199    fn residual_direction(&self, delta_g: ArrayView2<'_, f64>, d: usize) -> (Array2<f64>, f64) {
200        let n_obs = self.g.nrows();
201        let dd = d * d;
202        let mut delta_trace_sum = 0.0;
203        for n in 0..n_obs {
204            for a in 0..d {
205                delta_trace_sum += delta_g[[n, a * d + a]];
206            }
207        }
208        let delta_normalizer = delta_trace_sum / self.trace_denominator;
209        let inv_norm = 1.0 / self.normalizer;
210        let inv_norm_sq = inv_norm * inv_norm;
211        let mut delta_residual = Array2::<f64>::zeros((n_obs, dd));
212        for n in 0..n_obs {
213            for k in 0..dd {
214                delta_residual[[n, k]] =
215                    delta_g[[n, k]] * inv_norm - self.g[[n, k]] * delta_normalizer * inv_norm_sq;
216            }
217        }
218        (delta_residual, delta_normalizer)
219    }
220
221    fn metric_grad_direction(&self, delta_g: ArrayView2<'_, f64>, d: usize) -> Array2<f64> {
222        let n_obs = self.g.nrows();
223        let dd = d * d;
224        let (delta_residual, delta_normalizer) = self.residual_direction(delta_g, d);
225        let mut delta_residual_dot_g = 0.0;
226        for n in 0..n_obs {
227            for k in 0..dd {
228                delta_residual_dot_g += delta_residual[[n, k]] * self.g[[n, k]];
229                delta_residual_dot_g += self.residual[[n, k]] * delta_g[[n, k]];
230            }
231        }
232        let inv_norm = 1.0 / self.normalizer;
233        let inv_norm_sq = inv_norm * inv_norm;
234        let delta_trace_coeff = delta_residual_dot_g * inv_norm_sq / self.trace_denominator
235            - 2.0 * self.residual_dot_g * delta_normalizer * inv_norm_sq * inv_norm
236                / self.trace_denominator;
237        let mut out = Array2::<f64>::zeros((n_obs, dd));
238        for n in 0..n_obs {
239            for a in 0..d {
240                for b in 0..d {
241                    let k = a * d + b;
242                    let mut value = delta_residual[[n, k]] * inv_norm
243                        - self.residual[[n, k]] * delta_normalizer * inv_norm_sq;
244                    if a == b {
245                        value -= delta_trace_coeff;
246                    }
247                    out[[n, k]] = value;
248                }
249            }
250        }
251        out
252    }
253}
254
255/// Average trace per latent dimension `(1 / (N d)) Σ_n tr(m_n)` of a flattened
256/// `(n_obs, d*d)` row-major metric field. Shared by the decoder normalizer
257/// `gbar` and the reference normalizer `gref_bar`, so a decoder metric that is
258/// exactly proportional to a reference of arbitrary scale gives a zero residual.
259fn average_trace_per_dim(m: ArrayView2<'_, f64>, n_obs: usize, d: usize) -> f64 {
260    let denom = (n_obs * d) as f64;
261    let mut trace_sum = 0.0;
262    for n in 0..n_obs {
263        for a in 0..d {
264            trace_sum += m[[n, a * d + a]];
265        }
266    }
267    trace_sum / denom
268}
269
270fn isometry_dg_entry(
271    jac2: ArrayView2<'_, f64>,
272    wj: ArrayView2<'_, f64>,
273    n: usize,
274    d: usize,
275    p: usize,
276    a: usize,
277    b: usize,
278    c: usize,
279) -> f64 {
280    let mut s = 0.0;
281    for i in 0..p {
282        s += jac2[[n, (i * d + a) * d + c]] * wj[[i, b]];
283        s += wj[[i, a]] * jac2[[n, (i * d + b) * d + c]];
284    }
285    s
286}
287
288fn isometry_row_delta_g(
289    jac2: ArrayView2<'_, f64>,
290    wj: ArrayView2<'_, f64>,
291    v: ArrayView1<'_, f64>,
292    n: usize,
293    d: usize,
294    p: usize,
295) -> Array2<f64> {
296    let mut delta_g = Array2::<f64>::zeros((d, d));
297    for a in 0..d {
298        for b in 0..d {
299            let mut s = 0.0;
300            for c in 0..d {
301                s += isometry_dg_entry(jac2, wj, n, d, p, a, b, c) * v[n * d + c];
302            }
303            delta_g[[a, b]] = s;
304        }
305    }
306    delta_g
307}
308
309impl IsometryPenalty {
310    pub const DEFAULT_VALUE_ON_MISSING_CACHE: f64 = 0.0;
311
312    #[must_use]
313    pub fn new_euclidean(target: PsiSlice, p_out: usize) -> Self {
314        Self {
315            target,
316            reference: IsometryReference::Euclidean,
317            rho_index: 0,
318            jacobian_cache_slot: RwLock::new(None),
319            jacobian_second_cache_slot: RwLock::new(None),
320            duchon_radial_source: None,
321            third_decoder_derivative_slot: RwLock::new(None),
322            p_out,
323            weight: WeightField::Identity,
324            scalar_weight: 1.0,
325            weight_schedule: None,
326        }
327    }
328
329    /// Read-side accessor: takes the read lock briefly and clones the inner
330    /// `Arc` (refcount bump only; no payload copy). Returns `None` when the
331    /// cache has not been refreshed yet. Internally panics on poisoned lock
332    /// — the lock only wraps an `Option<Arc<…>>`, so the write side cannot
333    /// leave it in an invariant-violating state.
334    #[must_use]
335    pub fn jacobian_cache(&self) -> Option<Arc<Array2<f64>>> {
336        self.jacobian_cache_slot
337            .read()
338            .expect("IsometryPenalty::jacobian_cache_slot poisoned")
339            .clone()
340    }
341
342    /// Read the Jacobian cache under the *dimensional identity*
343    /// `(latent_dim, p_out)` of the atom currently being evaluated.
344    ///
345    /// The cache is interior-mutable and refreshed **per atom** (see
346    /// [`Self::refresh_caches`] and
347    /// `sae::manifold::refresh_isometry_caches_from_atom`). In a heterogeneous
348    /// SAE whose atoms have *mixed* latent dimensions (e.g. the standard zoo
349    /// `dims = [1,1,2,2,2,2,2,1]`) the slot can transiently hold a Jacobian
350    /// built for a **different** atom's `latent_dim` — its column count is
351    /// `p_out · d'` for that atom's `d'`, not this atom's `d`. Reshaping such a
352    /// cache at the wrong `d` would silently corrupt every downstream `J`
353    /// contraction (`projected_jacobian_row` / `weighted_jacobian_row`) or trip
354    /// the [`Self::pullback_metric`] shape invariant (`assert_eq!(jac.ncols(),
355    /// p·d)`) with a hard panic (issue #2294).
356    ///
357    /// The cache's built-for `latent_dim` is recoverable from its own shape:
358    /// with `p_out` fixed on the penalty, `ncols() == p_out · d_cache`. We
359    /// Per-atom SAE evaluation clones the registry descriptor, retargets it,
360    /// and refreshes that clone before any read, so a mismatched live cache is
361    /// an ownership/refresh invariant violation, not missing optional data.
362    /// Silently converting it to `None` would disable the isometry penalty and
363    /// change the fitted objective. Keep the mismatch hard: every caller sees
364    /// either no cache at all or a cache with the exact requested identity.
365    fn dimensioned_jacobian_cache(
366        &self,
367        method: &str,
368        latent_dim: usize,
369    ) -> Option<Arc<Array2<f64>>> {
370        let Some(jac) = self.jacobian_cache() else {
371            self.missing_cache_default(method, "jacobian_cache is None");
372            return None;
373        };
374        let expected = self
375            .p_out
376            .checked_mul(latent_dim)
377            .expect("IsometryPenalty Jacobian dimensional identity overflow");
378        assert_eq!(
379            jac.ncols(),
380            expected,
381            "IsometryPenalty::{method} stale cross-atom Jacobian cache: cache has {} columns, \
382             but this per-atom evaluation requires p_out {} × latent_dim {} = {}; the owner \
383             must clone, retarget, and refresh the penalty before evaluation",
384            jac.ncols(),
385            self.p_out,
386            latent_dim,
387            expected,
388        );
389        Some(jac)
390    }
391
392    /// Read-side accessor for the per-row Jacobian second derivative.
393    /// Mirrors [`Self::jacobian_cache`].
394    #[must_use]
395    pub fn jacobian_second_cache(&self) -> Option<Arc<Array2<f64>>> {
396        self.jacobian_second_cache_slot
397            .read()
398            .expect("IsometryPenalty::jacobian_second_cache_slot poisoned")
399            .clone()
400    }
401
402    /// Per-step refresh entry point. Takes `&self` (no `&mut`) so the SAE
403    /// outer loop can install fresh caches on an `Arc<IsometryPenalty>` held
404    /// in the analytic-penalty registry without disturbing the surrounding
405    /// dispatcher. Pass `None` for either argument to clear that cache (the
406    /// dispatcher will then either fall back to the Duchon radial source if
407    /// available, or return the zero safe default).
408    pub fn refresh_caches(&self, jac: Option<Arc<Array2<f64>>>, jac2: Option<Arc<Array2<f64>>>) {
409        *self
410            .jacobian_cache_slot
411            .write()
412            .expect("IsometryPenalty::jacobian_cache_slot poisoned") = jac;
413        *self
414            .jacobian_second_cache_slot
415            .write()
416            .expect("IsometryPenalty::jacobian_second_cache_slot poisoned") = jac2;
417    }
418
419    /// In-place writer for just the Jacobian cache (used by callers that
420    /// already own the radial Duchon source and only want to refresh `J`).
421    pub fn set_jacobian_cache(&self, jac: Option<Arc<Array2<f64>>>) {
422        *self
423            .jacobian_cache_slot
424            .write()
425            .expect("IsometryPenalty::jacobian_cache_slot poisoned") = jac;
426    }
427
428    /// In-place writer for just the Jacobian second-derivative cache.
429    pub fn set_jacobian_second_cache(&self, jac2: Option<Arc<Array2<f64>>>) {
430        *self
431            .jacobian_second_cache_slot
432            .write()
433            .expect("IsometryPenalty::jacobian_second_cache_slot poisoned") = jac2;
434    }
435
436    /// Read-side accessor for the per-row Jacobian third derivative `K`.
437    /// Mirrors [`Self::jacobian_second_cache`].
438    #[must_use]
439    pub fn third_decoder_derivative(&self) -> Option<Arc<ndarray::Array3<f64>>> {
440        self.third_decoder_derivative_slot
441            .read()
442            .expect("IsometryPenalty::third_decoder_derivative_slot poisoned")
443            .clone()
444    }
445
446    /// In-place writer for just the Jacobian third-derivative cache `K`.
447    pub fn set_third_decoder_derivative(&self, jac3: Option<Arc<ndarray::Array3<f64>>>) {
448        *self
449            .third_decoder_derivative_slot
450            .write()
451            .expect("IsometryPenalty::third_decoder_derivative_slot poisoned") = jac3;
452    }
453}
454
455impl Clone for IsometryPenalty {
456    fn clone(&self) -> Self {
457        Self {
458            target: self.target.clone(),
459            reference: self.reference.clone(),
460            rho_index: self.rho_index,
461            jacobian_cache_slot: RwLock::new(self.jacobian_cache()),
462            jacobian_second_cache_slot: RwLock::new(self.jacobian_second_cache()),
463            duchon_radial_source: self.duchon_radial_source.clone(),
464            third_decoder_derivative_slot: RwLock::new(self.third_decoder_derivative()),
465            p_out: self.p_out,
466            weight: self.weight.clone(),
467            scalar_weight: self.scalar_weight,
468            weight_schedule: self.weight_schedule.clone(),
469        }
470    }
471}
472
473impl IsometryPenalty {
474
475    #[must_use]
476    pub fn with_jacobian_cache(self, j: Arc<Array2<f64>>) -> Self {
477        self.set_jacobian_cache(Some(j));
478        self
479    }
480
481    #[must_use]
482    pub fn with_jacobian_second_cache(self, h: Arc<Array2<f64>>) -> Self {
483        self.set_jacobian_second_cache(Some(h));
484        self
485    }
486
487    impl_with_weight_schedule!(scalar_weight);
488
489    fn missing_cache_default(&self, method: &str, detail: &str) {
490        log::warn!(
491            "IsometryPenalty::{method} missing required derivative state: {detail}; \
492             returning the zero safe default"
493        );
494    }
495
496    fn has_jacobian_cache(&self, method: &str) -> bool {
497        if self.jacobian_cache().is_some() {
498            true
499        } else {
500            self.missing_cache_default(method, "jacobian_cache is None");
501            false
502        }
503    }
504
505    fn has_jacobian_second_source(&self, method: &str) -> bool {
506        if self.jacobian_second_cache().is_some() || self.duchon_radial_source.is_some() {
507            true
508        } else {
509            self.missing_cache_default(
510                method,
511                "both jacobian_second_cache and duchon_radial_source are None",
512            );
513            false
514        }
515    }
516
517    fn has_jacobian_third_source(&self, method: &str) -> bool {
518        if self.third_decoder_derivative().is_some() || self.duchon_radial_source.is_some() {
519            true
520        } else {
521            self.missing_cache_default(
522                method,
523                "both third_decoder_derivative cache and duchon_radial_source are None",
524            );
525            false
526        }
527    }
528
529    /// Build `M_n = U_n^T J_n ∈ ℝ^{r_n × d}` for row `n`. For
530    /// `WeightField::Identity`, `r_n = p` and `M_n = J_n`.
531    ///
532    /// This is the single contraction site where `W_n` (or its `U_n` factor)
533    /// is consumed. Every value/grad/hvp path funnels through here, so the
534    /// `(J^T U)(U^T J)` ordering invariant cannot be violated by accident.
535    fn projected_jacobian_row(&self, n: usize, d: usize) -> Option<Array2<f64>> {
536        let jac = self.dimensioned_jacobian_cache("projected_jacobian_row", d)?;
537        let jac_row = jac.row(n);
538        let jac_slice = jac_row
539            .as_slice()
540            .expect("jacobian cache must be in standard row-major layout");
541        match &self.weight {
542            WeightField::Identity => {
543                let p = self.p_out;
544                let mut m = Array2::<f64>::zeros((p, d));
545                for i in 0..p {
546                    for a in 0..d {
547                        m[[i, a]] = jac_slice[i * d + a];
548                    }
549                }
550                Some(m)
551            }
552            WeightField::Factored { u, rank, p_out } => {
553                let u_row = u.row(n);
554                let u_slice = u_row
555                    .as_slice()
556                    .expect("weight factor U must be in standard row-major layout");
557                Some(WeightField::project_jac_row_with_u(
558                    u_slice, jac_slice, *p_out, *rank, d,
559                ))
560            }
561        }
562    }
563
564    /// Form `W_n J_n` without materializing `W_n`.
565    fn weighted_jacobian_row(&self, n: usize, d: usize) -> Option<Array2<f64>> {
566        let jac = self.dimensioned_jacobian_cache("weighted_jacobian_row", d)?;
567        let p = self.p_out;
568        match &self.weight {
569            WeightField::Identity => {
570                let mut out = Array2::<f64>::zeros((p, d));
571                for i in 0..p {
572                    for a in 0..d {
573                        out[[i, a]] = jac[[n, i * d + a]];
574                    }
575                }
576                Some(out)
577            }
578            WeightField::Factored { u, rank, p_out } => {
579                assert_eq!(p, *p_out);
580                let r = *rank;
581                let m_n = self.projected_jacobian_row(n, d)?;
582                let mut out = Array2::<f64>::zeros((p, d));
583                for i in 0..p {
584                    for a in 0..d {
585                        let mut s = 0.0;
586                        for k in 0..r {
587                            s += u[[n, i * r + k]] * m_n[[k, a]];
588                        }
589                        out[[i, a]] = s;
590                    }
591                }
592                Some(out)
593            }
594        }
595    }
596
597    fn weighted_dot_decoder_vectors<F, G>(&self, n: usize, p: usize, x: F, y: G) -> f64
598    where
599        F: Fn(usize) -> f64,
600        G: Fn(usize) -> f64,
601    {
602        match &self.weight {
603            WeightField::Identity => {
604                let mut s = 0.0;
605                for i in 0..p {
606                    s += x(i) * y(i);
607                }
608                s
609            }
610            WeightField::Factored { u, rank, p_out } => {
611                assert_eq!(p, *p_out);
612                let r = *rank;
613                let mut s = 0.0;
614                for k in 0..r {
615                    let mut ux = 0.0;
616                    let mut uy = 0.0;
617                    for i in 0..p {
618                        let uik = u[[n, i * r + k]];
619                        ux += uik * x(i);
620                        uy += uik * y(i);
621                    }
622                    s += ux * uy;
623                }
624                s
625            }
626        }
627    }
628
629    fn target_matrix(target: ArrayView1<'_, f64>, n_obs: usize, d: usize) -> Array2<f64> {
630        let mut out = Array2::<f64>::zeros((n_obs, d));
631        for n in 0..n_obs {
632            for a in 0..d {
633                out[[n, a]] = target[n * d + a];
634            }
635        }
636        out
637    }
638
639    /// Second-order input-location derivative tensor of the Duchon decoder,
640    /// flattened to `(n_obs, p_out · d²)` with column layout
641    /// `i·d² + (a·d + c)`.
642    ///
643    /// Thin adapter over the shared [`radial_basis_cartesian_derivative`]
644    /// engine: it owns the radial-jet evaluation and the radial→Cartesian map;
645    /// here we only forward the source geometry.
646    fn duchon_radial_jacobian_second(
647        &self,
648        target: ArrayView1<'_, f64>,
649        n_obs: usize,
650        d: usize,
651        source: &IsometryDuchonRadialSource,
652    ) -> Result<Array2<f64>, BasisError> {
653        assert_eq!(source.centers.ncols(), d);
654        assert_eq!(source.radial_coefficients.nrows(), source.centers.nrows());
655        assert_eq!(source.radial_coefficients.ncols(), self.p_out);
656        let t = Self::target_matrix(target, n_obs, d);
657        radial_basis_cartesian_derivative(
658            2,
659            t.view(),
660            source.centers.view(),
661            source.radial_coefficients.view(),
662            source.length_scale,
663            source.nullspace_order,
664            source.power,
665        )
666    }
667
668    /// Third-order input-location derivative tensor of the Duchon decoder,
669    /// shaped `(n_obs, p_out, d³)` with last-axis layout `(a·d + c)·d + e`.
670    ///
671    /// Thin adapter over the shared [`radial_basis_cartesian_derivative`]
672    /// engine; the flat `(n_obs, p_out · d³)` result is reshaped to the
673    /// `Array3` consumed by the HVP path (row-major flatten of `(p_out, d³)`
674    /// is exactly `i·d³ + idx`).
675    fn duchon_radial_jacobian_third(
676        &self,
677        target: ArrayView1<'_, f64>,
678        n_obs: usize,
679        d: usize,
680        source: &IsometryDuchonRadialSource,
681    ) -> Result<ndarray::Array3<f64>, BasisError> {
682        assert_eq!(source.centers.ncols(), d);
683        assert_eq!(source.radial_coefficients.nrows(), source.centers.nrows());
684        assert_eq!(source.radial_coefficients.ncols(), self.p_out);
685        let t = Self::target_matrix(target, n_obs, d);
686        let flat = radial_basis_cartesian_derivative(
687            3,
688            t.view(),
689            source.centers.view(),
690            source.radial_coefficients.view(),
691            source.length_scale,
692            source.nullspace_order,
693            source.power,
694        )?;
695        Ok(flat
696            .into_shape_with_order((n_obs, self.p_out, d * d * d))
697            .expect("radial_basis_cartesian_derivative order-3 output reshapes to (n_obs, p, d³)"))
698    }
699
700    fn jacobian_second<'a>(
701        &'a self,
702        target: ArrayView1<'_, f64>,
703        n_obs: usize,
704        d: usize,
705    ) -> Option<CowArray<'a, f64, Ix2>> {
706        if let Some(jac2) = self.jacobian_second_cache() {
707            // Clone the underlying Array2 to detach from the Arc — the
708            // CowArray needs to outlive the temporary Arc returned by the
709            // accessor. The clone is `n_obs × p·d²` floats, paid once per
710            // grad_target / hvp_state invocation; same per-step cost as the
711            // pre-refactor code path which also took ownership via
712            // `jac2.view().to_owned()` semantics implicitly.
713            return Some(CowArray::from((*jac2).clone()));
714        }
715        let source = self.duchon_radial_source.as_ref()?;
716        match self.duchon_radial_jacobian_second(target, n_obs, d, source) {
717            Ok(jac2) => Some(CowArray::from(jac2)),
718            Err(err) => {
719                self.missing_cache_default(
720                    "jacobian_second",
721                    &format!("failed to materialize Duchon radial second derivative: {err}"),
722                );
723                None
724            }
725        }
726    }
727
728    fn jacobian_third<'a>(
729        &'a self,
730        target: ArrayView1<'_, f64>,
731        n_obs: usize,
732        d: usize,
733    ) -> Option<CowArray<'a, f64, Ix3>> {
734        if let Some(jac3) = self.third_decoder_derivative() {
735            return Some(CowArray::from(jac3.as_ref().clone()));
736        }
737        let source = self.duchon_radial_source.as_ref()?;
738        match self.duchon_radial_jacobian_third(target, n_obs, d, source) {
739            Ok(jac3) => Some(CowArray::from(jac3)),
740            Err(err) => {
741                self.missing_cache_default(
742                    "jacobian_third",
743                    &format!("failed to materialize Duchon radial third derivative: {err}"),
744                );
745                None
746            }
747        }
748    }
749
750    pub(crate) fn hvp_state<'a>(
751        &'a self,
752        target: ArrayView1<'_, f64>,
753    ) -> Option<IsometryHvpState<'a>> {
754        let d = self
755            .target
756            .latent_dim
757            .expect("IsometryPenalty requires latent_dim on its PsiSlice");
758        let n_obs = target.len() / d;
759        if !self.has_jacobian_cache("hvp")
760            || !self.has_jacobian_second_source("hvp")
761            || !self.has_jacobian_third_source("hvp")
762        {
763            return None;
764        }
765        let p = self.p_out;
766        let jac2 = self.jacobian_second(target.view(), n_obs, d)?;
767        let jac3 = self.jacobian_third(target.view(), n_obs, d)?;
768        let g = self.pullback_metric(d)?;
769        let metric = self.normalized_metric_state(g, n_obs, d)?;
770        let mut wj_rows = Vec::with_capacity(n_obs);
771        for n in 0..n_obs {
772            wj_rows.push(self.weighted_jacobian_row(n, d)?);
773        }
774        Some(IsometryHvpState {
775            d,
776            n_obs,
777            p,
778            jac2,
779            jac3,
780            metric,
781            wj_rows,
782        })
783    }
784
785    pub(crate) fn hvp_with_precomputed_state(
786        &self,
787        state: &IsometryHvpState<'_>,
788        rho: ArrayView1<'_, f64>,
789        v: ArrayView1<'_, f64>,
790    ) -> Array1<f64> {
791        let mu = validated_learnable_weight(self.scalar_weight, rho[self.rho_index]);
792        let d = state.d;
793        let n_obs = state.n_obs;
794        let p = state.p;
795        let jac2 = &state.jac2;
796        let jac3 = &state.jac3;
797        let metric = &state.metric;
798        let mut out = Array1::<f64>::zeros(v.len());
799        let mut delta_g = Array2::<f64>::zeros((n_obs, d * d));
800        for n in 0..n_obs {
801            let wj = &state.wj_rows[n];
802            let row_delta = isometry_row_delta_g(jac2.view(), wj.view(), v, n, d, p);
803            for a in 0..d {
804                for b in 0..d {
805                    delta_g[[n, a * d + b]] = row_delta[[a, b]];
806                }
807            }
808        }
809        let delta_metric_grad = metric.metric_grad_direction(delta_g.view(), d);
810
811        for n in 0..n_obs {
812            let wj = &state.wj_rows[n];
813            for c in 0..d {
814                let mut acc = 0.0;
815                for a in 0..d {
816                    for b in 0..d {
817                        let dg = isometry_dg_entry(jac2.view(), wj.view(), n, d, p, a, b, c);
818                        acc += dg * delta_metric_grad[[n, a * d + b]];
819                    }
820                }
821                out[n * d + c] = mu * acc;
822            }
823
824            for c in 0..d {
825                let mut acc_res = 0.0;
826                for a in 0..d {
827                    for b in 0..d {
828                        let metric_grad = metric.metric_grad[[n, a * d + b]];
829                        if metric_grad == 0.0 {
830                            continue;
831                        }
832                        let mut bv = 0.0;
833                        for dd in 0..d {
834                            let vd = v[n * d + dd];
835                            if vd == 0.0 {
836                                continue;
837                            }
838                            let mut k_a_cd_w_j_b = 0.0;
839                            for i in 0..p {
840                                k_a_cd_w_j_b += jac3[[n, i, ((a * d) + c) * d + dd]] * wj[[i, b]];
841                            }
842                            let h_a_c_w_h_b_d = self.weighted_dot_decoder_vectors(
843                                n,
844                                p,
845                                |i| jac2[[n, (i * d + a) * d + c]],
846                                |i| jac2[[n, (i * d + b) * d + dd]],
847                            );
848                            let h_a_d_w_h_b_c = self.weighted_dot_decoder_vectors(
849                                n,
850                                p,
851                                |i| jac2[[n, (i * d + a) * d + dd]],
852                                |i| jac2[[n, (i * d + b) * d + c]],
853                            );
854                            let mut j_a_w_k_b_cd = 0.0;
855                            for i in 0..p {
856                                j_a_w_k_b_cd += wj[[i, a]] * jac3[[n, i, ((b * d) + c) * d + dd]];
857                            }
858                            bv +=
859                                (k_a_cd_w_j_b + h_a_c_w_h_b_d + h_a_d_w_h_b_c + j_a_w_k_b_cd) * vd;
860                        }
861                        acc_res += metric_grad * bv;
862                    }
863                }
864                out[n * d + c] += mu * acc_res;
865            }
866        }
867        out
868    }
869
870    /// Per-row pullback metric `g_n = J_n^T W_n J_n = M_n^T M_n` with
871    /// `M_n = U_n^T J_n ∈ ℝ^{r_n × d}`. Returns `(n_obs, d, d)` flattened
872    /// row-major as `(n_obs, d*d)`.
873    ///
874    /// Cost per row: `O(p · r · d)` for the `M_n` build (single pass over
875    /// `U_n` and `J_n`) plus `O(r · d²)` for `M_n^T M_n`. The `p × p` weight
876    /// `W_n` is never materialized.
877    pub fn pullback_metric(&self, latent_dim: usize) -> Option<Array2<f64>> {
878        let jac = self.dimensioned_jacobian_cache("pullback_metric", latent_dim)?;
879        let n_obs = jac.nrows();
880        // `dimensioned_jacobian_cache` enforces the load-bearing `(n, p·d)`
881        // shape contract before the reshape loop below. A stale cross-atom
882        // cache is a hard owner/refresh invariant failure; it is never converted
883        // into a zero isometry contribution (#2294).
884        let mut g_all = Array2::<f64>::zeros((n_obs, latent_dim * latent_dim));
885        for n in 0..n_obs {
886            // M_n = U_n^T J_n  (or J_n itself when W = I).
887            let m = self.projected_jacobian_row(n, latent_dim)?;
888            let r = m.nrows();
889            // g_n = M_n^T M_n: (d × d) result, contracting r.
890            for a in 0..latent_dim {
891                for b in 0..latent_dim {
892                    let mut s = 0.0;
893                    for k in 0..r {
894                        s += m[[k, a]] * m[[k, b]];
895                    }
896                    g_all[[n, a * latent_dim + b]] = s;
897                }
898            }
899        }
900        Some(g_all)
901    }
902
903    /// The scale normalizer `gbar = (1 / (N d)) Σ_n tr(g_n)` of the cached
904    /// pullback metric — the single shared denominator the scale-invariant
905    /// gauge divides every per-row metric by.
906    ///
907    /// `value` / `grad_*` / `hvp` consume this implicitly through
908    /// `Self::normalized_metric_state`; the SAE arrow-Schur assembly cannot
909    /// (it builds explicit per-row `htt` / `htbeta` / `hbb` curvature blocks
910    /// from the raw pullback `g_n`, not through the trait operators), so it
911    /// reads `gbar` here and folds `1/gbar²` into its Gauss-Newton curvature.
912    /// That `1/gbar²` factor is exactly the frozen-normalizer Gauss-Newton
913    /// block of the normalized residual `R_n = g_n/gbar − g^ref_n`: the raw
914    /// block (the GN block of the *un-normalized* `½μ‖g_n − g^ref‖²`) scales
915    /// ∝‖B‖⁴ in the decoder magnitude while the normalized gradient is
916    /// scale-free, so without the factor the joint Newton step collapses and
917    /// the proximal ridge saturates at 1e15 (#795). It stays PSD (a positive
918    /// scalar on an already-PSD Gram block), so the Schur complement is
919    /// unaffected. `None` when the metric is unavailable or degenerate, mirror-
920    /// ing `normalized_metric_state`'s non-positive-normalizer guard.
921    pub fn metric_normalizer(&self, latent_dim: usize) -> Option<f64> {
922        let g = self.pullback_metric(latent_dim)?;
923        let n_obs = g.nrows();
924        let normalizer = average_trace_per_dim(g.view(), n_obs, latent_dim);
925        (normalizer.is_finite() && normalizer > f64::MIN_POSITIVE).then_some(normalizer)
926    }
927
928    /// Reference metric per row for the normalized pullback metric, `(n_obs, d*d)`.
929    fn reference_metric(&self, n_obs: usize, d: usize) -> CowArray<'_, f64, Ix2> {
930        match &self.reference {
931            IsometryReference::Euclidean => {
932                let mut out = Array2::<f64>::zeros((n_obs, d * d));
933                for n in 0..n_obs {
934                    for a in 0..d {
935                        out[[n, a * d + a]] = 1.0;
936                    }
937                }
938                CowArray::from(out)
939            }
940            IsometryReference::UserSupplied(a) => {
941                assert_eq!(a.nrows(), n_obs);
942                assert_eq!(a.ncols(), d * d);
943                CowArray::from(a.view())
944            }
945        }
946    }
947
948    /// Shared normalized metric state for the scale-invariant isometry gauge.
949    ///
950    /// The residual is `R_n = g_n / gbar - g_ref,n / gref_bar`, with
951    /// `gbar = (1 / (N d)) Σ_n tr(g_n)` and `gref_bar = (1 / (N d)) Σ_n tr(g_ref,n)`
952    /// (`gref_bar == 1` for the `Euclidean` reference). `g_ref / gref_bar` is
953    /// constant w.r.t. the decoder coordinates, so the metric gradient/Hessian
954    /// form below is unchanged. The metric-gradient is the exact
955    /// derivative of `0.5 Σ ||R_n||²` with respect to the raw pullback metrics:
956    ///
957    /// `A_n = R_n / gbar - (Σ_l R_l:g_l) I / (gbar² N d)`.
958    ///
959    /// All value, gradient, and HVP paths consume this state so the global
960    /// normalizer's derivative is never detached.
961    fn normalized_metric_state(
962        &self,
963        g: Array2<f64>,
964        n_obs: usize,
965        d: usize,
966    ) -> Option<IsometryMetricState> {
967        let dd = d * d;
968        let trace_denominator = (n_obs * d) as f64;
969        let normalizer = average_trace_per_dim(g.view(), n_obs, d);
970        if !(normalizer.is_finite() && normalizer > f64::MIN_POSITIVE) {
971            self.missing_cache_default(
972                "normalized_metric_state",
973                &format!(
974                    "unit-average-speed normalizer is non-positive or non-finite: {normalizer}"
975                ),
976            );
977            return None;
978        }
979        let g_ref = self.reference_metric(n_obs, d);
980        // Normalize the reference by its own average trace per dim so the gauge
981        // is scale-invariant on both sides: a decoder metric proportional to the
982        // reference (up to an arbitrary global scale, common for external chart
983        // metrics / GP-LVM warm starts) gives a zero residual. For `Euclidean`,
984        // `ref_normalizer == 1.0` exactly, preserving the prior behavior bit-for-bit.
985        let ref_normalizer = average_trace_per_dim(g_ref.view(), n_obs, d);
986        if !(ref_normalizer.is_finite() && ref_normalizer > f64::MIN_POSITIVE) {
987            self.missing_cache_default(
988                "normalized_metric_state",
989                &format!(
990                    "reference-metric normalizer is non-positive or non-finite: {ref_normalizer}"
991                ),
992            );
993            return None;
994        }
995        let mut residual = Array2::<f64>::zeros((n_obs, dd));
996        let inv_norm = 1.0 / normalizer;
997        let inv_ref_norm = 1.0 / ref_normalizer;
998        for n in 0..n_obs {
999            for k in 0..dd {
1000                residual[[n, k]] = g[[n, k]] * inv_norm - g_ref[[n, k]] * inv_ref_norm;
1001            }
1002        }
1003        let mut residual_dot_g = 0.0;
1004        for n in 0..n_obs {
1005            for k in 0..dd {
1006                residual_dot_g += residual[[n, k]] * g[[n, k]];
1007            }
1008        }
1009        let trace_coeff = residual_dot_g / (normalizer * normalizer * trace_denominator);
1010        let mut metric_grad = Array2::<f64>::zeros((n_obs, dd));
1011        for n in 0..n_obs {
1012            for a in 0..d {
1013                for b in 0..d {
1014                    let k = a * d + b;
1015                    let mut value = residual[[n, k]] * inv_norm;
1016                    if a == b {
1017                        value -= trace_coeff;
1018                    }
1019                    metric_grad[[n, k]] = value;
1020                }
1021            }
1022        }
1023        Some(IsometryMetricState {
1024            g,
1025            residual,
1026            metric_grad,
1027            normalizer,
1028            trace_denominator,
1029            residual_dot_g,
1030        })
1031    }
1032
1033    /// Exact closed-form gradient of the isometry penalty with respect to the
1034    /// cached decoder Jacobian `J ∈ ℝ^{n_obs × p × d}` (the autograd input that
1035    /// torch's `_IsometryPenaltyFn` differentiates). Returns the flattened
1036    /// `(n_obs, p*d)` layout that matches the Jacobian cache.
1037    ///
1038    /// Derivation (W-aware, reference-aware, weight-aware):
1039    ///
1040    ///   P        = ½ μ Σ_n ‖R_n‖²_F,
1041    ///   R_n      = g_n / gbar − g^ref_n,
1042    ///   gbar     = (1 / (N d)) Σ_n tr(g_n)
1043    ///   A_n      = ∂(P/μ)/∂g_n
1044    ///   ∂g_{ab}/∂J_{i,c}
1045    ///            = δ_{ca}(W J)_{i,b} + δ_{cb}(W J)_{i,a}   (W symmetric)
1046    ///   ∂P/∂J_{i,c}
1047    ///            = μ Σ_{a,b} A_{ab} ∂g_{ab}/∂J_{i,c}
1048    ///            = 2 μ Σ_b A_{cb} (W J)_{i,b}
1049    ///            = 2 μ ((W J) A)_{i,c}
1050    ///
1051    /// where `A` includes the exact derivative of the shared `gbar` normalizer.
1052    pub fn grad_jacobian(
1053        &self,
1054        target: ArrayView1<'_, f64>,
1055        rho: ArrayView1<'_, f64>,
1056    ) -> Array2<f64> {
1057        let d = self
1058            .target
1059            .latent_dim
1060            .expect("IsometryPenalty requires latent_dim on its PsiSlice");
1061        let n_obs = target.len() / d;
1062        let p = self.p_out;
1063        let mut grad = Array2::<f64>::zeros((n_obs, p * d));
1064        if !self.has_jacobian_cache("grad_jacobian") {
1065            return grad;
1066        }
1067        let Some(g) = self.pullback_metric(d) else {
1068            return grad;
1069        };
1070        let Some(metric) = self.normalized_metric_state(g, n_obs, d) else {
1071            return grad;
1072        };
1073        let mu = validated_learnable_weight(self.scalar_weight, rho[self.rho_index]);
1074        for n in 0..n_obs {
1075            let Some(wj) = self.weighted_jacobian_row(n, d) else {
1076                return Array2::<f64>::zeros((n_obs, p * d));
1077            };
1078            for i in 0..p {
1079                for c in 0..d {
1080                    let mut acc = 0.0;
1081                    for b in 0..d {
1082                        acc += metric.metric_grad[[n, c * d + b]] * wj[[i, b]];
1083                    }
1084                    grad[[n, i * d + c]] = 2.0 * mu * acc;
1085                }
1086            }
1087        }
1088        grad
1089    }
1090}
1091
1092impl AnalyticPenalty for IsometryPenalty {
1093    fn tier(&self) -> PenaltyTier {
1094        PenaltyTier::Psi
1095    }
1096
1097    fn validate_rho(&self, rho: ArrayView1<'_, f64>) -> Result<(), String> {
1098        if rho.len() != 1 {
1099            return Err(format!("isometry rho length {} != 1", rho.len()));
1100        }
1101        resolve_learnable_weight(self.scalar_weight, rho[self.rho_index])?;
1102        Ok(())
1103    }
1104
1105    fn rho_coordinate_domains(&self) -> Result<Vec<(f64, f64)>, String> {
1106        Ok(vec![
1107            learnable_weight_coordinate_domain(self.scalar_weight)?
1108                .ok_or_else(|| "isometry scalar weight must be positive".to_string())?,
1109        ])
1110    }
1111
1112    fn value(&self, target: ArrayView1<'_, f64>, rho: ArrayView1<'_, f64>) -> f64 {
1113        let d = self
1114            .target
1115            .latent_dim
1116            .expect("IsometryPenalty requires latent_dim on its PsiSlice");
1117        let n_obs = target.len() / d;
1118        if !self.has_jacobian_cache("value") {
1119            return Self::DEFAULT_VALUE_ON_MISSING_CACHE;
1120        }
1121        let Some(g) = self.pullback_metric(d) else {
1122            return Self::DEFAULT_VALUE_ON_MISSING_CACHE;
1123        };
1124        let Some(metric) = self.normalized_metric_state(g, n_obs, d) else {
1125            return Self::DEFAULT_VALUE_ON_MISSING_CACHE;
1126        };
1127        let mu = validated_learnable_weight(self.scalar_weight, rho[self.rho_index]);
1128        let mut acc = 0.0;
1129        for n in 0..n_obs {
1130            for k in 0..(d * d) {
1131                let diff = metric.residual[[n, k]];
1132                acc += diff * diff;
1133            }
1134        }
1135        0.5 * mu * acc
1136    }
1137
1138    fn grad_target(&self, target: ArrayView1<'_, f64>, rho: ArrayView1<'_, f64>) -> Array1<f64> {
1139        // Exact closed-form gradient, W-aware:
1140        //
1141        //   P     = ½ μ Σ_n ‖R_n‖²_F,   R_n = g_n / gbar − g^ref_n
1142        //   g_n   = J_n^T W_n J_n,      W_n = U_n U_n^T
1143        //   A_n   = ∂(P/μ)/∂g_n, including the exact derivative of
1144        //           gbar = (1 / (N d)) Σ_n tr(g_n)
1145        //   ∂g_{ab}/∂t_c
1146        //         = (H_{:,a,c})^T (W J)_{:,b}  +  (J_{:,a})^T W H_{:,b,c}
1147        //   ∂P/∂t_c
1148        //         = μ Σ_{a,b} A_{a,b} · ∂g_{ab}/∂t_c
1149        //
1150        // `H = ∂J/∂t` comes either from the live cache or from the radial
1151        // Duchon `φ''(r)` helper. The sign is positive: differentiating
1152        // `t - c` with respect to `t` contributes `+I`.
1153        let d = self
1154            .target
1155            .latent_dim
1156            .expect("IsometryPenalty requires latent_dim on its PsiSlice");
1157        let n_obs = target.len() / d;
1158        if !self.has_jacobian_cache("grad_target")
1159            || !self.has_jacobian_second_source("grad_target")
1160        {
1161            return Array1::<f64>::zeros(target.len());
1162        }
1163        let Some(g) = self.pullback_metric(d) else {
1164            return Array1::<f64>::zeros(target.len());
1165        };
1166        let Some(metric) = self.normalized_metric_state(g, n_obs, d) else {
1167            return Array1::<f64>::zeros(target.len());
1168        };
1169        let p = self.p_out;
1170        let mu = validated_learnable_weight(self.scalar_weight, rho[self.rho_index]);
1171        let mut grad = Array1::<f64>::zeros(target.len());
1172        let Some(jac2) = self.jacobian_second(target, n_obs, d) else {
1173            return grad;
1174        };
1175        assert_eq!(jac2.ncols(), p * d * d);
1176
1177        for n in 0..n_obs {
1178            let Some(wj) = self.weighted_jacobian_row(n, d) else {
1179                return grad;
1180            };
1181            for c in 0..d {
1182                let mut acc = 0.0;
1183                for a in 0..d {
1184                    for b in 0..d {
1185                        let mut dg = 0.0;
1186                        for i in 0..p {
1187                            dg += jac2[[n, (i * d + a) * d + c]] * wj[[i, b]];
1188                            dg += wj[[i, a]] * jac2[[n, (i * d + b) * d + c]];
1189                        }
1190                        acc += metric.metric_grad[[n, a * d + b]] * dg;
1191                    }
1192                }
1193                grad[n * d + c] = mu * acc;
1194            }
1195        }
1196        grad
1197    }
1198
1199    /// Fully analytic - wired through `radial_basis_cartesian_derivative`.
1200    fn hvp(
1201        &self,
1202        target: ArrayView1<'_, f64>,
1203        rho: ArrayView1<'_, f64>,
1204        v: ArrayView1<'_, f64>,
1205    ) -> Array1<f64> {
1206        // Fully analytic isometry Hessian-vector product wired through the
1207        // shared `radial_basis_cartesian_derivative` engine when no
1208        // third-derivative cache is supplied.
1209        //
1210        // The full Hessian of P_iso = (μ/2) Σ_n ||J^T W J / gbar - G_ref||²_F
1211        // (per proposal §4(b)) is
1212        //   μ [Dgᵀ · ∂²(0.5||R||²)/∂g² · Dg + A · ∂²g],
1213        // where R = g/gbar - G_ref and A = ∂(0.5||R||²)/∂g includes the global
1214        // gbar derivative.
1215        //   B_{ab,cd} = K_{a,cd}^T W J_b + H_{a,c}^T W H_{b,d}
1216        //             + H_{a,d}^T W H_{b,c} + J_a^T W K_{b,cd},
1217        // where K is the third decoder derivative and H is the second.
1218        let Some(state) = self.hvp_state(target) else {
1219            return Array1::<f64>::zeros(v.len());
1220        };
1221        self.hvp_with_precomputed_state(&state, rho, v)
1222    }
1223
1224    /// PSD majorizer-vector product `B_GN(target; ρ) v` for the **nonconvex**
1225    /// isometry penalty.
1226    ///
1227    /// The Gauss-Newton block differentiates the normalized residual
1228    /// `R = g/gbar - G_ref` itself and returns `μ DRᵀ DR v`. This is PSD by
1229    /// construction and includes the shared-normalizer derivative exactly;
1230    /// using only `∂g` would reintroduce scale coupling and would not be the
1231    /// Gauss-Newton operator of the objective being minimized.
1232    fn psd_majorizer_hvp(
1233        &self,
1234        target: ArrayView1<'_, f64>,
1235        rho: ArrayView1<'_, f64>,
1236        v: ArrayView1<'_, f64>,
1237    ) -> Array1<f64> {
1238        let d = self
1239            .target
1240            .latent_dim
1241            .expect("IsometryPenalty requires latent_dim on its PsiSlice");
1242        let n_obs = target.len() / d;
1243        if !self.has_jacobian_cache("psd_majorizer_hvp")
1244            || !self.has_jacobian_second_source("psd_majorizer_hvp")
1245        {
1246            return Array1::<f64>::zeros(v.len());
1247        }
1248        let Some(jac2) = self.jacobian_second(target, n_obs, d) else {
1249            return Array1::<f64>::zeros(v.len());
1250        };
1251        let Some(g) = self.pullback_metric(d) else {
1252            return Array1::<f64>::zeros(v.len());
1253        };
1254        let Some(metric) = self.normalized_metric_state(g, n_obs, d) else {
1255            return Array1::<f64>::zeros(v.len());
1256        };
1257        let p = self.p_out;
1258        let mu = validated_learnable_weight(self.scalar_weight, rho[self.rho_index]);
1259        let mut out = Array1::<f64>::zeros(v.len());
1260        let mut wj_rows = Vec::with_capacity(n_obs);
1261        for n in 0..n_obs {
1262            let Some(wj) = self.weighted_jacobian_row(n, d) else {
1263                return Array1::<f64>::zeros(v.len());
1264            };
1265            wj_rows.push(wj);
1266        }
1267        let mut delta_g = Array2::<f64>::zeros((n_obs, d * d));
1268        for n in 0..n_obs {
1269            let row_delta = isometry_row_delta_g(jac2.view(), wj_rows[n].view(), v, n, d, p);
1270            for a in 0..d {
1271                for b in 0..d {
1272                    delta_g[[n, a * d + b]] = row_delta[[a, b]];
1273                }
1274            }
1275        }
1276        let (delta_residual, _delta_normalizer) = metric.residual_direction(delta_g.view(), d);
1277        let mut g_dot_delta_residual = 0.0;
1278        for n in 0..n_obs {
1279            for k in 0..(d * d) {
1280                g_dot_delta_residual += metric.g[[n, k]] * delta_residual[[n, k]];
1281            }
1282        }
1283        let inv_norm = 1.0 / metric.normalizer;
1284        let inv_norm_sq = inv_norm * inv_norm;
1285        for n in 0..n_obs {
1286            let wj = &wj_rows[n];
1287            for c in 0..d {
1288                let mut trace_dg = 0.0;
1289                for a in 0..d {
1290                    trace_dg += isometry_dg_entry(jac2.view(), wj.view(), n, d, p, a, a, c);
1291                }
1292                let delta_normalizer_c = trace_dg / metric.trace_denominator;
1293                let mut acc = -delta_normalizer_c * inv_norm_sq * g_dot_delta_residual;
1294                for a in 0..d {
1295                    for b in 0..d {
1296                        let dg = isometry_dg_entry(jac2.view(), wj.view(), n, d, p, a, b, c);
1297                        acc += dg * inv_norm * delta_residual[[n, a * d + b]];
1298                    }
1299                }
1300                out[n * d + c] = mu * acc;
1301            }
1302        }
1303        out
1304    }
1305
1306    fn grad_rho(&self, target: ArrayView1<'_, f64>, rho: ArrayView1<'_, f64>) -> Array1<f64> {
1307        // P(ρ) = ½ μ · S, where S is the (ρ-independent) Frobenius sum and
1308        // μ = exp(ρ_iso). So ∂P/∂ρ_iso = P.
1309        let mut out = Array1::<f64>::zeros(self.rho_count());
1310        out[self.rho_index] = self.value(target, rho);
1311        out
1312    }
1313
1314    fn rho_count(&self) -> usize {
1315        1
1316    }
1317
1318    fn name(&self) -> &str {
1319        "isometry"
1320    }
1321
1322    impl_scalar_apply_schedule!(scalar_weight);
1323}