use std::cell::RefCell;
use std::rc::Rc;
use crate::core::constraint::BoxConstraints;
use crate::core::problem::CostFunction;
use crate::{Bobyqa, BobyqaState, Executor, MaxCostEvals, TerminationReason};
struct Fixture {
problem: String,
n: usize,
rho_beg: f64,
rho_end: f64,
max_fun: usize,
npt: usize,
x0: Vec<f64>,
xl: Vec<f64>,
xu: Vec<f64>,
evals: Vec<(f64, Vec<f64>)>,
final_nf: usize,
final_f: f64,
final_x: Vec<f64>,
}
fn kv<'a>(tok: &'a str, key: &str) -> &'a str {
let (k, v) = tok
.split_once('=')
.unwrap_or_else(|| panic!("expected key=value, got {tok:?}"));
assert_eq!(k, key, "expected key {key:?}, got {k:?}");
v
}
fn parse_fixture(text: &str) -> Fixture {
let mut problem = None;
let mut n = None;
let mut rho_beg = None;
let mut rho_end = None;
let mut max_fun = None;
let mut npt = None;
let mut x0 = None;
let mut xl = None;
let mut xu = None;
let mut evals = Vec::new();
let mut final_line = None;
let floats = |rest: &str| -> Vec<f64> {
rest.split_whitespace()
.map(|s| s.parse().unwrap())
.collect::<Vec<f64>>()
};
for line in text.lines() {
let line = line.trim();
if line.is_empty() {
continue;
}
if let Some(rest) = line.strip_prefix("# config") {
let t: Vec<&str> = rest.split_whitespace().collect();
problem = Some(kv(t[0], "problem").to_string());
n = Some(kv(t[1], "n").parse().unwrap());
rho_beg = Some(kv(t[2], "rho_beg").parse().unwrap());
rho_end = Some(kv(t[3], "rho_end").parse().unwrap());
max_fun = Some(kv(t[4], "maxfun").parse().unwrap());
npt = Some(kv(t[5], "npt").parse().unwrap());
} else if let Some(rest) = line.strip_prefix("# x0") {
x0 = Some(floats(rest));
} else if let Some(rest) = line.strip_prefix("# xl") {
xl = Some(floats(rest));
} else if let Some(rest) = line.strip_prefix("# xu") {
xu = Some(floats(rest));
} else if let Some(rest) = line.strip_prefix("# final") {
final_line = Some(rest.to_string());
} else if line.starts_with('#') {
continue; } else {
let mut t = line.split_whitespace();
let _idx: usize = t.next().unwrap().parse().unwrap();
let f: f64 = t.next().unwrap().parse().unwrap();
let x: Vec<f64> = t.map(|s| s.parse().unwrap()).collect();
evals.push((f, x));
}
}
let fl = final_line.expect("fixture missing `# final` line");
let mut t = fl.split_whitespace();
let final_nf: usize = kv(t.next().unwrap(), "nf").parse().unwrap();
let _rc: i32 = kv(t.next().unwrap(), "rc").parse().unwrap();
let final_f: f64 = kv(t.next().unwrap(), "f").parse().unwrap();
assert_eq!(t.next(), Some("x="), "expected `x=` before final x");
let final_x: Vec<f64> = t.map(|s| s.parse().unwrap()).collect();
Fixture {
problem: problem.expect("problem"),
n: n.expect("n"),
rho_beg: rho_beg.expect("rho_beg"),
rho_end: rho_end.expect("rho_end"),
max_fun: max_fun.expect("maxfun"),
npt: npt.expect("npt"),
x0: x0.expect("x0"),
xl: xl.expect("xl"),
xu: xu.expect("xu"),
evals,
final_nf,
final_f,
final_x,
}
}
fn objective(problem: &str, x: &[f64]) -> f64 {
match problem {
"rosenbrock" => {
let mut s = 0.0;
for i in 0..x.len() - 1 {
let t = x[i + 1] - x[i] * x[i];
s += 100.0 * t * t + (1.0 - x[i]) * (1.0 - x[i]);
}
s
}
"sphere" => {
let mut s = 0.0;
for &xi in x {
let d = xi - 3.0;
s += d * d;
}
s
}
"chrosen" => {
let mut s = 0.0;
for i in 0..x.len() - 1 {
let a = x[i] - 1.0;
let b = x[i + 1] - x[i] * x[i];
s += a * a + 100.0 * b * b;
}
s
}
other => panic!("unknown problem {other:?}"),
}
}
struct Tracing<'a> {
problem: &'a str,
lower: Vec<f64>,
upper: Vec<f64>,
trace: Rc<RefCell<Vec<Vec<f64>>>>,
}
impl CostFunction for Tracing<'_> {
type Param = Vec<f64>;
type Output = f64;
type Error = std::convert::Infallible;
fn cost(&self, x: &Vec<f64>) -> Result<f64, std::convert::Infallible> {
self.trace.borrow_mut().push(x.clone());
Ok(objective(self.problem, x))
}
}
impl BoxConstraints for Tracing<'_> {
fn lower(&self) -> &Vec<f64> {
&self.lower
}
fn upper(&self) -> &Vec<f64> {
&self.upper
}
}
fn contains(xs: &[Vec<f64>], want: &[f64], tol: f64) -> bool {
xs.iter().any(|got| {
got.len() == want.len() && got.iter().zip(want).all(|(a, b)| (a - b).abs() <= tol)
})
}
fn check_parity(text: &str) {
let fx = parse_fixture(text);
let n = fx.n;
assert_eq!(fx.x0.len(), n);
assert_eq!(fx.xl.len(), n);
assert_eq!(fx.xu.len(), n);
assert_eq!(fx.npt, 2 * n + 1, "fixtures use the recommended npt = 2n+1");
for (k, (f_prima, x)) in fx.evals.iter().enumerate() {
let f_rust = objective(&fx.problem, x);
let tol = 1e-12 * f_prima.abs().max(1.0);
assert!(
(f_rust - f_prima).abs() <= tol,
"{} eval {}: objective mismatch C vs Rust: prima={:.17e} rust={:.17e} diff={:.3e}",
fx.problem,
k,
f_prima,
f_rust,
(f_rust - f_prima).abs(),
);
}
let trace = Rc::new(RefCell::new(Vec::new()));
let problem = Tracing {
problem: &fx.problem,
lower: fx.xl.clone(),
upper: fx.xu.clone(),
trace: Rc::clone(&trace),
};
let result = Executor::new(
problem,
Bobyqa::new()
.with_rho_beg(fx.rho_beg)
.with_rho_end(fx.rho_end)
.with_npt(fx.npt),
BobyqaState::new(fx.x0.clone()),
)
.terminate_on(MaxCostEvals(fx.max_fun as u64))
.run()
.unwrap();
let trace = trace.borrow();
assert!(
trace.len() >= fx.npt,
"{}: basin made only {} evals, fewer than npt={}",
fx.problem,
trace.len(),
fx.npt,
);
let basin_init = &trace[..fx.npt];
for (f_prima, want) in &fx.evals[..fx.npt] {
let _ = f_prima;
assert!(
contains(basin_init, want, 1e-12),
"{}: initial design missing PRIMA point {:?}\n basin init = {:?}",
fx.problem,
want,
basin_init,
);
}
assert_eq!(
result.reason,
TerminationReason::SolverConverged,
"{}: basin stopped on the eval budget, not convergence",
fx.problem,
);
let f_tol = 1e-6 * (1.0 + fx.final_f.abs());
assert!(
(result.best_cost() - fx.final_f).abs() <= f_tol,
"{}: final f mismatch: prima={:.17e} basin={:.17e} diff={:.3e} tol={:.3e}",
fx.problem,
fx.final_f,
result.best_cost(),
(result.best_cost() - fx.final_f).abs(),
f_tol,
);
let x_inf = result
.best_param()
.iter()
.zip(&fx.final_x)
.map(|(a, b)| (a - b).abs())
.fold(0.0_f64, f64::max);
assert!(
x_inf <= 1e-4,
"{}: final x mismatch (||.||_inf = {:.3e} > 1e-4)\n prima={:?}\n basin={:?}",
fx.problem,
x_inf,
fx.final_x,
result.best_param(),
);
let nf_margin = (0.25 * fx.final_nf as f64).max(10.0);
let nf_diff = (result.cost_evals() as f64 - fx.final_nf as f64).abs();
assert!(
nf_diff <= nf_margin,
"{}: nf out of margin: prima={} basin={} diff={} margin={:.1}",
fx.problem,
fx.final_nf,
result.cost_evals(),
nf_diff,
nf_margin,
);
}
macro_rules! parity_test {
($name:ident, $file:literal) => {
#[test]
fn $name() {
check_parity(include_str!(concat!(
env!("CARGO_MANIFEST_DIR"),
"/tests/fixtures/",
$file
)));
}
};
}
parity_test!(rosenbrock_2d_matches_prima, "bobyqa_rosenbrock_2d.tsv");
parity_test!(sphere_2d_matches_prima, "bobyqa_sphere_2d.tsv");
parity_test!(chrosen_5d_matches_prima, "bobyqa_chrosen_5d.tsv");