use crate::field::{ProfileField, WindField};
use crate::sounding::Sounding;
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(0.0, [0.0, level.altitude_m, 0.0]);
let speed_err = wind.speed_mps() - level.speed_mps;
speed_sq += speed_err * speed_err;
let mut dir_err = (wind.direction_from_deg() - 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(),
}
}