use crate::sounding::Sounding;
use crate::ProfileField;
use nalgebra::Vector3;
fn horizontal_speed(w: Vector3<f64>) -> f64 {
w.x.hypot(w.z)
}
fn direction_from_deg(w: Vector3<f64>) -> f64 {
(w.z.atan2(w.x).to_degrees() + 180.0).rem_euclid(360.0)
}
const LAYER_TOPS_M: [f64; 4] = [1_000.0, 3_000.0, 6_000.0, 10_000.0];
#[derive(Debug, Clone, Copy, PartialEq)]
pub struct LayerError {
pub top_m: f64,
pub mean_abs_speed_error_mps: f64,
pub levels: usize,
}
#[derive(Debug, Clone, PartialEq)]
pub struct ValidationReport {
pub levels: usize,
pub speed_rmse_mps: f64,
pub direction_rmse_deg: f64,
pub layers: Vec<LayerError>,
}
pub fn validate(profile: &ProfileField, sounding: &Sounding) -> ValidationReport {
let mut speed_sq = 0.0;
let mut direction_sq = 0.0;
let mut layer_abs = vec![0.0; LAYER_TOPS_M.len() + 1];
let mut layer_n = vec![0usize; LAYER_TOPS_M.len() + 1];
for level in &sounding.levels {
let wind = profile.wind_at(level.altitude_m);
let speed_err = horizontal_speed(wind) - level.speed_mps;
speed_sq += speed_err * speed_err;
let mut dir_err = (direction_from_deg(wind) - level.direction_from_deg) % 360.0;
if dir_err > 180.0 {
dir_err -= 360.0;
} else if dir_err < -180.0 {
dir_err += 360.0;
}
direction_sq += dir_err * dir_err;
let layer = LAYER_TOPS_M
.iter()
.position(|top| level.altitude_m < *top)
.unwrap_or(LAYER_TOPS_M.len());
layer_abs[layer] += speed_err.abs();
layer_n[layer] += 1;
}
let n = sounding.levels.len().max(1) as f64;
ValidationReport {
levels: sounding.levels.len(),
speed_rmse_mps: (speed_sq / n).sqrt(),
direction_rmse_deg: (direction_sq / n).sqrt(),
layers: layer_abs
.into_iter()
.zip(layer_n)
.enumerate()
.filter(|(_, (_, count))| *count > 0)
.map(|(i, (abs, count))| LayerError {
top_m: LAYER_TOPS_M.get(i).copied().unwrap_or(f64::INFINITY),
mean_abs_speed_error_mps: abs / count as f64,
levels: count,
})
.collect(),
}
}