parse_monitors/monitors/

reports.rs

use crate::{detrend_mut, MonitorsError, Vector};
#[cfg(feature = "plot")]
use plotters::prelude::*;
use std::{
    collections::BTreeMap,
    ops::{Add, Deref, DerefMut, Div},
    path::Path,
};
use welch_sde::{Build, PowerSpectrum};

mod loader;
pub use loader::MonitorsLoader;

type Result<T> = std::result::Result<T, super::MonitorsError>;

pub struct FemNodes(BTreeMap<String, Vector>);
impl Deref for FemNodes {
    type Target = BTreeMap<String, Vector>;

    fn deref(&self) -> &Self::Target {
        &self.0
    }
}
impl DerefMut for FemNodes {
    fn deref_mut(&mut self) -> &mut Self::Target {
        &mut self.0
    }
}
impl Default for FemNodes {
    fn default() -> Self {
        let mut fem = FemNodes(BTreeMap::new());
        fem.insert("M1cov1".to_string(), [0., 13.5620, 5.3064].into());
        fem.insert("M1cov2".to_string(), [11.7451, 6.7810, 5.3064].into());
        fem.insert("M1cov3".to_string(), [11.7451, -6.7810, 5.3064].into());
        fem.insert("M1cov4".to_string(), [0., -13.5621, 5.3064].into());
        fem.insert("M1cov5".to_string(), [-11.7451, -6.7810, 5.3064].into());
        fem.insert("M1cov6".to_string(), [-11.7451, 6.7810, 5.3064].into());
        fem.insert("M1covin1".to_string(), [2.3650, 4.0963, 4.7000].into());
        fem.insert("M1covin2".to_string(), [4.3000, 0., 4.7000].into());
        fem.insert("M1covin3".to_string(), [2.3650, -4.0963, 4.7000].into());
        fem.insert("M1covin4".to_string(), [-2.3650, -4.0963, 4.7000].into());
        fem.insert("M1covin5".to_string(), [-4.3000, 0., 4.7000].into());
        fem.insert("M1covin6".to_string(), [-2.3650, 4.0963, 4.7000].into());
        fem
    }
}
/// A force ['Vector'] and a moment ['Vector']
#[derive(Default, Debug, Clone)]
pub struct Exertion {
    pub force: Vector,
    pub moment: Vector,
    /// Center of pressure
    pub cop: Option<Vector>,
}
impl Exertion {
    /// Build from a force ['Vector']
    #[allow(dead_code)]
    pub fn from_force(force: Vector) -> Self {
        Self {
            force,
            ..Default::default()
        }
    }
    /// Build from a force x ['Vector'] component
    pub fn from_force_x(value: f64) -> Self {
        Self {
            force: Vector::from_x(value),
            ..Default::default()
        }
    }
    /// Build from a force y ['Vector'] component
    pub fn from_force_y(value: f64) -> Self {
        Self {
            force: Vector::from_y(value),
            ..Default::default()
        }
    }
    /// Build from a force z ['Vector'] component
    pub fn from_force_z(value: f64) -> Self {
        Self {
            force: Vector::from_z(value),
            ..Default::default()
        }
    }
    /// Build from a moment ['Vector']
    #[allow(dead_code)]
    pub fn from_moment(moment: Vector) -> Self {
        Self {
            moment,
            ..Default::default()
        }
    }
    /// Build from a moment x ['Vector'] component
    pub fn from_moment_x(value: f64) -> Self {
        Self {
            moment: Vector::from_x(value),
            ..Default::default()
        }
    }
    /// Build from a moment y ['Vector'] component
    pub fn from_moment_y(value: f64) -> Self {
        Self {
            moment: Vector::from_y(value),
            ..Default::default()
        }
    }
    /// Build from a moment z ['Vector'] component
    pub fn from_moment_z(value: f64) -> Self {
        Self {
            moment: Vector::from_z(value),
            ..Default::default()
        }
    }
    pub fn into_local(&mut self, node: Vector) -> &mut Self {
        if let Some(v) = node.cross(&self.force) {
            self.moment = (&self.moment - v).expect("into_local failed");
        }
        self
    }
}
impl From<([f64; 3], ([f64; 3], [f64; 3]))> for Exertion {
    fn from(cop_fm: ([f64; 3], ([f64; 3], [f64; 3]))) -> Self {
        let (c, (f, m)) = cop_fm;
        Self {
            force: f.into(),
            moment: m.into(),
            cop: Some(c.into()),
        }
    }
}
impl From<Exertion> for Option<Vec<f64>> {
    fn from(e: Exertion) -> Self {
        let f: Option<Vec<f64>> = (&e.force).into();
        let m: Option<Vec<f64>> = (&e.moment).into();
        f.zip(m)
            .map(|(f, m): (Vec<f64>, Vec<f64>)| f.into_iter().chain(m.into_iter()).collect())
    }
}
impl From<&Exertion> for Option<Vec<f64>> {
    fn from(e: &Exertion) -> Self {
        let f: Option<Vec<f64>> = (&e.force).into();
        let m: Option<Vec<f64>> = (&e.moment).into();
        f.zip(m)
            .map(|(f, m): (Vec<f64>, Vec<f64>)| f.into_iter().chain(m.into_iter()).collect())
    }
}
impl From<&mut Exertion> for Option<Vec<f64>> {
    fn from(e: &mut Exertion) -> Self {
        let f: Option<Vec<f64>> = (&e.force).into();
        let m: Option<Vec<f64>> = (&e.moment).into();
        f.zip(m)
            .map(|(f, m): (Vec<f64>, Vec<f64>)| f.into_iter().chain(m.into_iter()).collect())
    }
}
impl Add for &Exertion {
    type Output = Exertion;

    fn add(self, rhs: Self) -> Self::Output {
        Exertion {
            force: self.force.clone() + rhs.force.clone(),
            moment: self.moment.clone() + rhs.moment.clone(),
            cop: None,
        }
    }
}
impl Div<f64> for &Exertion {
    type Output = Option<Exertion>;

    fn div(self, rhs: f64) -> Self::Output {
        if let (Some(force), Some(moment)) = (self.force.clone() / rhs, self.moment.clone() / rhs) {
            Some(Exertion {
                force,
                moment,
                cop: None,
            })
        } else {
            None
        }
    }
}

/// Gather all the monitors of a CFD run
#[derive(Default, Debug)]
pub struct Monitors {
    pub time: Vec<f64>,
    pub heat_transfer_coefficients: BTreeMap<String, Vec<f64>>,
    pub forces_and_moments: BTreeMap<String, Vec<Exertion>>,
    pub total_forces_and_moments: Vec<Exertion>,
    //    pub segments_integrated_forces: Option<Vec<Mirror>>,
    time_idx: usize,
    data: Option<Vec<f64>>,
}
impl Monitors {
    pub fn loader<S, const YEAR: u32>(data_path: S) -> MonitorsLoader<YEAR>
    where
        S: AsRef<Path> + std::convert::AsRef<std::ffi::OsStr>,
    {
        MonitorsLoader::default().data_path(data_path)
    }
    pub fn len(&self) -> usize {
        self.time.len()
    }

    pub fn is_empty(&self) -> bool {
        self.len() == 0
    }
    pub fn detrend(&mut self) -> &mut Self {
        for value in self.forces_and_moments.values_mut() {
            for k in 0..3 {
                let mut f_k: Vec<f64> = value.iter().map(|e| e.force[k]).collect();
                detrend_mut(&self.time, &mut f_k, 1).unwrap();
                value
                    .iter_mut()
                    .zip(f_k)
                    .for_each(|(e, f_k)| e.force[k] = f_k);
                let mut m_k: Vec<f64> = value.iter().map(|e| e.moment[k]).collect();
                detrend_mut(&self.time, &mut m_k, 1).unwrap();
                value
                    .iter_mut()
                    .zip(m_k)
                    .for_each(|(e, m_k)| e.moment[k] = m_k);
            }
        }
        self
    }
    /// Keeps only the last `period` seconds of the monitors
    pub fn keep_last(&mut self, period: usize) -> &mut Self {
        let n_sample = 1 + period * crate::FORCE_SAMPLING_FREQUENCY as usize;
        let i = if self.len() > n_sample {
            self.len() - n_sample
        } else {
            0
        };
        let _: Vec<_> = self.time.drain(..i).collect();
        for value in self.heat_transfer_coefficients.values_mut() {
            let _: Vec<_> = value.drain(..i).collect();
        }
        for value in self.forces_and_moments.values_mut() {
            let _: Vec<_> = value.drain(..i).collect();
        }
        if i < self.total_forces_and_moments.len() {
            let _: Vec<_> = self.total_forces_and_moments.drain(..i).collect();
        }
        self
    }
    pub fn into_local(&mut self) -> &mut Self {
        let nodes = FemNodes::default();
        for (key, value) in self.forces_and_moments.iter_mut() {
            if let Some(node) = nodes.get(key) {
                value.iter_mut().for_each(|v| {
                    (*v).into_local(node.clone());
                });
            }
        }
        self
    }
    /// Return a latex table with HTC monitors summary
    pub fn htc_latex_table(&self, stats_duration: f64) -> Option<String> {
        let max_value = |x: &[f64]| x.iter().cloned().fold(std::f64::NEG_INFINITY, f64::max);
        let min_value = |x: &[f64]| x.iter().cloned().fold(std::f64::INFINITY, f64::min);
        let minmax = |x: &[f64]| (min_value(x), max_value(x));
        let stats = |x: &[f64]| {
            let n = x.len() as f64;
            let mean = x.iter().sum::<f64>() / n;
            let std = (x.iter().map(|x| x - mean).fold(0f64, |s, x| s + x * x) / n).sqrt();
            (mean, std)
        };
        if self.heat_transfer_coefficients.is_empty() {
            None
        } else {
            let duration = self.time.last().unwrap();
            let time_filter: Vec<_> = self
                .time
                .iter()
                .map(|t| t - duration + stats_duration >= 0f64)
                .collect();
            let data: Vec<_> = self
                .heat_transfer_coefficients
                .iter()
                .map(|(key, value)| {
                    let time_filtered_value: Vec<_> = value
                        .iter()
                        .zip(time_filter.iter())
                        .filter(|(_, t)| **t)
                        .map(|(v, _)| *v)
                        .collect();
                    let (mean, std) = stats(&time_filtered_value);
                    let (min, max) = minmax(&time_filtered_value);
                    format!(
                        " {:} & {:.3} & {:.3} & {:.3} & {:.3} \\\\",
                        key, mean, std, min, max
                    )
                })
                .collect();
            Some(data.join("\n"))
        }
    }
    /// Return a latex table with force monitors summary
    pub fn force_latex_table(&self, stats_duration: f64) -> Option<String> {
        let max_value = |x: &[Vector]| {
            x.iter()
                .filter_map(|x| x.magnitude())
                .fold(std::f64::NEG_INFINITY, f64::max)
        };
        let min_value = |x: &[Vector]| {
            x.iter()
                .filter_map(|x| x.magnitude())
                .fold(std::f64::INFINITY, f64::min)
        };
        let minmax = |x: &[Vector]| (min_value(x), max_value(x));
        let stats = |x: &[Vector]| {
            let n = x.len() as f64;
            if let Some(mean) = x.iter().fold(Vector::zero(), |s, x| s + x) / n {
                let std = (x
                    .iter()
                    .filter_map(|x| x - mean.clone())
                    .filter_map(|x| x.norm_squared())
                    .sum::<f64>()
                    / n)
                    .sqrt();
                Some((mean.magnitude(), std))
            } else {
                None
            }
        };
        if self.forces_and_moments.is_empty() {
            None
        } else {
            let duration = self.time.last().unwrap();
            let time_filter: Vec<_> = self
                .time
                .iter()
                .map(|t| t - duration + stats_duration - crate::FORCE_SAMPLING > 0f64)
                .collect();
            let data: Vec<_> = self
                .forces_and_moments
                .iter()
                .map(|(key, value)| {
                    let force: Vec<Vector> = value
                        .iter()
                        .zip(time_filter.iter())
                        .filter(|(_, t)| **t)
                        .map(|(e, _)| e.force.clone())
                        .collect();
                    match stats(&force) {
                        Some((Some(mean), std)) => {
                            let (min, max) = minmax(&force);
                            format!(
                                " {:} & {:.3} & {:.3} & {:.3} & {:.3} \\\\",
                                key.replace("_", " "),
                                mean,
                                std,
                                min,
                                max
                            )
                        }
                        _ => format!(" {:} \\\\", key.replace("_", " ")),
                    }
                })
                .collect();
            Some(data.join("\n"))
        }
    }
    /// Return a latex table with moment monitors summary
    pub fn moment_latex_table(&self, stats_duration: f64) -> Option<String> {
        let max_value = |x: &[Vector]| {
            x.iter()
                .filter_map(|x| x.magnitude())
                .fold(std::f64::NEG_INFINITY, f64::max)
        };
        let min_value = |x: &[Vector]| {
            x.iter()
                .filter_map(|x| x.magnitude())
                .fold(std::f64::INFINITY, f64::min)
        };
        let minmax = |x: &[Vector]| (min_value(x), max_value(x));
        let stats = |x: &[Vector]| {
            let n = x.len() as f64;
            if let Some(mean) = x.iter().fold(Vector::zero(), |s, x| s + x) / n {
                let std = (x
                    .iter()
                    .filter_map(|x| x - mean.clone())
                    .filter_map(|x| x.norm_squared())
                    .sum::<f64>()
                    / n)
                    .sqrt();
                Some((mean.magnitude(), std))
            } else {
                None
            }
        };
        if self.forces_and_moments.is_empty() {
            None
        } else {
            let duration = self.time.last().unwrap();
            let time_filter: Vec<_> = self
                .time
                .iter()
                .map(|t| t - duration + stats_duration - crate::FORCE_SAMPLING > 0f64)
                .collect();
            let data: Vec<_> = self
                .forces_and_moments
                .iter()
                .map(|(key, value)| {
                    let moment: Vec<Vector> = value
                        .iter()
                        .zip(time_filter.iter())
                        .filter(|(_, t)| **t)
                        .map(|(e, _)| e.moment.clone())
                        .collect();
                    match stats(&moment) {
                        Some((Some(mean), std)) => {
                            let (min, max) = minmax(&moment);
                            format!(
                                " {:} & {:.3} & {:.3} & {:.3} & {:.3} \\\\",
                                key.replace("_", " "),
                                mean,
                                std,
                                min,
                                max
                            )
                        }
                        _ => format!(" {:} \\\\", key.replace("_", " ")),
                    }
                })
                .collect();
            Some(data.join("\n"))
        }
    }
    /// Print out a monitors summary
    pub fn summary(&mut self) {
        let max_value = |x: &[f64]| x.iter().cloned().fold(std::f64::NEG_INFINITY, f64::max);
        let min_value = |x: &[f64]| x.iter().cloned().fold(std::f64::INFINITY, f64::min);
        let minmax = |x| (min_value(x), max_value(x));
        let stats = |x: &[f64]| {
            let n = x.len() as f64;
            let mean = x.iter().sum::<f64>() / n;
            let std = (x.iter().map(|x| x - mean).fold(0f64, |s, x| s + x * x) / n).sqrt();
            (mean, std)
        };
        println!("SUMMARY:");
        println!(" - # of records: {}", self.len());
        println!(
            " - time range: [{:8.3}-{:8.3}]s",
            self.time[0],
            self.time.last().unwrap()
        );
        let n_htc = self.heat_transfer_coefficients.len();
        if !self.heat_transfer_coefficients.is_empty() {
            println!(" - # of HTC elements: {}", n_htc);
            println!(" - HTC [W/m^2-K]:");
            println!(
                "    {:^16}: ({:^12}, {:^12})  ({:^12}, {:^12})",
                "ELEMENT", "MEAN", "STD", "MIN", "MAX"
            );
            self.heat_transfer_coefficients
                .iter()
                .for_each(|(key, value)| {
                    println!(
                        "  - {:16}: {:>12.3?}  {:>12.3?}",
                        key,
                        stats(value),
                        minmax(value)
                    );
                });
        }
        let n_fm = self.forces_and_moments.len();
        if !self.forces_and_moments.is_empty() {
            println!(" - # of elements with forces & moments: {}", n_fm);
            let (total_force, total_moment): (Vec<_>, Vec<_>) =
                self.forces_and_moments.values().fold(
                    (
                        vec![Vector::zero(); self.len()],
                        vec![Vector::zero(); self.len()],
                    ),
                    |(mut fa, mut ma), value| {
                        fa.iter_mut()
                            .zip(value.iter())
                            .for_each(|(mut fa, e)| fa += &e.force);
                        ma.iter_mut()
                            .zip(value.iter())
                            .for_each(|(mut ma, e)| ma += &e.moment);
                        (fa, ma)
                    },
                );
            let total_force: Vec<Vector> = total_force.iter().map(|x| x.clone()).collect();
            let total_moment: Vec<Vector> = total_moment.iter().map(|x| x.clone()).collect();
            println!(" - Forces magnitude [N]:");
            println!("    {:^16}: [{:^12}]   [{:^12}]", "ELEMENT", "MEAN", "STD");
            self.forces_and_moments.iter().for_each(|(key, value)| {
                let force: Vec<Vector> = value.iter().map(|e| e.force.clone()).collect();
                Self::display(key, &force);
            });
            Self::display("TOTAL", &total_force);
            println!(" - Moments magnitude [N-m]:");
            println!("    {:^16}: [{:^12}]   [{:^12}]", "ELEMENT", "MEAN", "STD");
            self.forces_and_moments.iter().for_each(|(key, value)| {
                let moment: Vec<Vector> = value.iter().map(|e| e.moment.clone()).collect();
                Self::display(key, &moment);
            });
            Self::display("TOTAL", &total_moment);
            self.total_forces_and_moments = total_force
                .into_iter()
                .zip(total_moment.into_iter())
                .map(|(force, moment)| Exertion {
                    force,
                    moment,
                    cop: None,
                })
                .collect();
        }
    }
    pub fn total_exertion(&mut self) -> &mut Self {
        let (total_force, total_moment): (Vec<_>, Vec<_>) = self.forces_and_moments.values().fold(
            (
                vec![Vector::zero(); self.len()],
                vec![Vector::zero(); self.len()],
            ),
            |(mut fa, mut ma), value| {
                fa.iter_mut()
                    .zip(value.iter())
                    .for_each(|(mut fa, e)| fa += &e.force);
                ma.iter_mut()
                    .zip(value.iter())
                    .for_each(|(mut ma, e)| ma += &e.moment);
                (fa, ma)
            },
        );
        self.total_forces_and_moments = total_force
            .into_iter()
            .zip(total_moment.into_iter())
            .map(|(force, moment)| Exertion {
                force,
                moment,
                cop: None,
            })
            .collect();
        self
    }
    pub fn display(key: &str, data: &[Vector]) {
        /*
            let max_value = |x: &[f64]| x.iter().cloned().fold(std::f64::NEG_INFINITY, f64::max);
            let min_value = |x: &[f64]| x.iter().cloned().fold(std::f64::INFINITY, f64::min);
            let stats = |x: &[f64]| {
                let n = x.len() as f64;
                let mean = x.iter().sum::<f64>() / n;
                let std = (x.iter().map(|x| x - mean).fold(0f64, |s, x| s + x * x) / n).sqrt();
                (mean, std)
            };
        */
        let stats = |x: &[Vector]| -> Option<(Vec<f64>, Vec<f64>)> {
            let n = x.len() as f64;
            if let Some(mean) = x.iter().fold(Vector::zero(), |s, x| s + x) / n {
                let std = x
                    .iter()
                    .filter_map(|x| x - mean.clone())
                    .filter_map(|x| -> Option<Vec<f64>> { x.into() })
                    .fold(vec![0f64; 3], |mut a, x| {
                        a.iter_mut().zip(x.iter()).for_each(|(a, &x)| *a += x * x);
                        a
                    });
                let mean: Option<Vec<f64>> = mean.into();
                Some((
                    mean.unwrap(),
                    std.iter()
                        .map(|x| (*x / n as f64).sqrt())
                        .collect::<Vec<_>>(),
                ))
            } else {
                None
            }
        };

        match stats(data) {
            Some((mean, std)) => {
                println!("  - {:16}: {:>12.3?}  {:>12.3?}", key, mean, std);
            }
            None => println!("  - {:16}: {:?}", key, None::<f64>),
        }
    }
    pub fn to_csv(&self, filename: String) -> Result<Vec<()>> {
        let mut wtr = csv::Writer::from_path(filename)?;
        let mut keys = vec![String::from("Time [s]")];
        keys.extend(
            self.forces_and_moments
                .keys()
                .filter(|&k| k.as_str() != "M1covin2")
                .flat_map(|k| {
                    vec![
                        format!("{} X force [N]", k),
                        format!("{} Y force [N]", k),
                        format!("{} Z force [N]", k),
                        format!("{} X moment [N-m]", k),
                        format!("{} Y moment [N-m]", k),
                        format!("{} Z moment [N-m]", k),
                    ]
                }),
        );
        wtr.write_record(&keys)?;
        Ok(self
            .time
            .iter()
            .enumerate()
            .map(|(k, t)| {
                let mut record = vec![format!("{}", t)];
                record.extend(
                    self.forces_and_moments
                        .iter()
                        .filter(|(k, _)| k.as_str() != "M1covin2")
                        .flat_map(|(_, v)| {
                            vec![
                                format!("{}", v[k].force.x.unwrap()),
                                format!("{}", v[k].force.y.unwrap()),
                                format!("{}", v[k].force.z.unwrap()),
                                format!("{}", v[k].moment.x.unwrap()),
                                format!("{}", v[k].moment.y.unwrap()),
                                format!("{}", v[k].moment.z.unwrap()),
                            ]
                        }),
                );
                wtr.write_record(&record)
            })
            .collect::<std::result::Result<Vec<()>, csv::Error>>()?)
    }
    #[cfg(feature = "windloading")]
    pub fn m1covers_windloads(&self) -> Result<(), Box<dyn std::error::Error>> {
        use windloading::{Loads, WindLoads};
        let keys = vec![
            "M1cov1", "M1cov6", "M1cov5", "M1cov4", "M1cov3", "M1cov2", "M1covin2", "M1covin1",
            "M1covin6", "M1covin5", "M1covin4", "M1covin3",
        ];
        let mut loads: Vec<Vec<f64>> = Vec::with_capacity(72 * self.len());
        for k in 0..self.len() {
            let mut fm: Vec<f64> = Vec::with_capacity(72);
            for &key in &keys {
                let exrt = self.forces_and_moments.get(key).unwrap().get(k).unwrap();
                fm.append(
                    &mut exrt
                        .force
                        .as_array()
                        .iter()
                        .cloned()
                        .chain(exrt.moment.as_array().iter().cloned())
                        .cloned()
                        .collect::<Vec<f64>>(),
                );
            }
            loads.push(fm);
        }
        let mut windloads: WindLoads = Default::default();
        windloads.time = self.time.clone();
        windloads.loads = vec![Some(Loads::OSSMirrorCovers6F(loads))];
        let mut file = std::fs::File::create("windloads.pkl")?;
        serde_pickle::to_writer(&mut file, &windloads, Default::default())?;
        Ok(())
    }
    #[cfg(feature = "plot")]
    pub fn plot_htc(&self) {
        if self.heat_transfer_coefficients.is_empty() {
            return;
        }

        let max_value =
            |x: &[f64]| -> f64 { x.iter().cloned().fold(std::f64::NEG_INFINITY, f64::max) };
        let min_value = |x: &[f64]| -> f64 { x.iter().cloned().fold(std::f64::INFINITY, f64::min) };
        let minmax = |x| (min_value(x), max_value(x));

        //let plot = BitMapBackend::new("HTC.png", (768, 512)).into_drawing_area();
        let plot = SVGBackend::new("HTC.svg", (768, 512)).into_drawing_area();
        plot.fill(&WHITE).unwrap();

        let (min_values, max_values): (Vec<_>, Vec<_>) = self
            .heat_transfer_coefficients
            .values()
            .map(|values| minmax(values))
            .unzip();
        let xrange = *self.time.last().unwrap() - self.time[0];
        let mut chart = ChartBuilder::on(&plot)
            .set_label_area_size(LabelAreaPosition::Left, 40)
            .set_label_area_size(LabelAreaPosition::Bottom, 40)
            .margin(10)
            .build_cartesian_2d(
                -xrange * 1e-2..xrange * (1. + 1e-2),
                min_value(&min_values)..max_value(&max_values),
            )
            .unwrap();
        chart
            .configure_mesh()
            .x_desc("Time [s]")
            .y_desc("HTC [W/m^2-K]")
            .draw()
            .unwrap();

        let mut colors = colorous::TABLEAU10.iter().cycle();
        let mut rgbs = vec![];

        for (key, values) in self.heat_transfer_coefficients.iter() {
            let color = colors.next().unwrap();
            let rgb = RGBColor(color.r, color.g, color.b);
            rgbs.push(rgb);
            chart
                .draw_series(LineSeries::new(
                    self.time
                        .iter()
                        .zip(values.iter())
                        .map(|(&x, &y)| (x - self.time[0], y)),
                    &rgb,
                ))
                .unwrap()
                .label(key)
                .legend(|(x, y)| PathElement::new(vec![(x, y), (x + 20, y)], &BLACK));
        }
        chart
            .configure_series_labels()
            .border_style(&BLACK)
            .background_style(&WHITE.mix(0.8))
            .position(SeriesLabelPosition::UpperRight)
            .draw()
            .unwrap();
    }
    #[cfg(feature = "plot")]
    pub fn plot_forces(&self, filename: Option<&str>) -> Result<()> {
        if self.forces_and_moments.is_empty() {
            return Err(MonitorsError::PlotForces(
                filename.unwrap_or("FORCES.png").to_string(),
            ));
        }

        let max_value = |x: &[f64]| -> f64 {
            x.iter()
                .cloned()
                .rev()
                .take(400 * 20)
                .fold(std::f64::NEG_INFINITY, f64::max)
        };
        let min_value = |x: &[f64]| -> f64 {
            x.iter()
                .cloned()
                .rev()
                .take(400 * 20)
                .fold(std::f64::INFINITY, f64::min)
        };

        let plot =
            BitMapBackend::new(filename.unwrap_or("FORCES.png"), (768, 512)).into_drawing_area();
        plot.fill(&WHITE).unwrap();

        let (min_values, max_values): (Vec<_>, Vec<_>) = self
            .forces_and_moments
            .values()
            .map(|values| {
                let force_magnitude: Option<Vec<f64>> =
                    values.iter().map(|e| e.force.magnitude()).collect();
                (
                    min_value(force_magnitude.as_ref().unwrap()),
                    max_value(force_magnitude.as_ref().unwrap()),
                )
            })
            .unzip();
        let xrange = *self.time.last().unwrap() - self.time[0];
        let minmax_padding = 0.1;
        let mut chart = ChartBuilder::on(&plot)
            .set_label_area_size(LabelAreaPosition::Left, 60)
            .set_label_area_size(LabelAreaPosition::Bottom, 40)
            .margin(10)
            .build_cartesian_2d(
                -xrange * 1e-2..xrange * (1. + 1e-2),
                min_value(&min_values) * (1. - minmax_padding)
                    ..max_value(&max_values) * (1. + minmax_padding),
            )
            .unwrap();
        chart
            .configure_mesh()
            .x_desc("Time [s]")
            .y_desc("Force [N]")
            .draw()
            .unwrap();

        let mut colors = colorous::TABLEAU10.iter().cycle();

        for (key, values) in self.forces_and_moments.iter() {
            let color = colors.next().unwrap();
            let rgb = RGBColor(color.r, color.g, color.b);
            chart
                .draw_series(LineSeries::new(
                    self.time
                        .iter()
                        .zip(values.iter())
                        //.skip(10 * 20)
                        .map(|(&x, y)| (x - self.time[0], y.force.magnitude().unwrap())),
                    &rgb,
                ))
                .unwrap()
                .label(key)
                .legend(move |(x, y)| PathElement::new(vec![(x, y), (x + 20, y)], &rgb));
        }
        chart
            .configure_series_labels()
            .border_style(&BLACK)
            .background_style(&WHITE.mix(0.8))
            .position(SeriesLabelPosition::UpperRight)
            .draw()
            .unwrap();
        Ok(())
    }
    #[cfg(feature = "plot")]
    pub fn plot_this_forces(values: &[Vector], config: Option<complot::Config>) {
        /*fn minmax<'a>(x: impl Iterator<Item = &'a f64>) -> (f64, f64) {
                    x.cloned()
                        .fold((std::f64::NEG_INFINITY, std::f64::INFINITY), |(a, b), x| {
                            (f64::max(a, x), f64::min(b, x))
                        })
                }
                let max_value =
                    |x: &[f64]| -> f64 { x.iter().cloned().fold(std::f64::NEG_INFINITY, f64::max) };
                let min_value = |x: &[f64]| -> f64 { x.iter().cloned().fold(std::f64::INFINITY, f64::min) };
        */
        let (fx, (fy, fz)): (Vec<_>, (Vec<_>, Vec<_>)) = values
            .iter()
            .filter_map(|v| {
                if let Vector {
                    x: Some(x),
                    y: Some(y),
                    z: Some(z),
                } = v
                {
                    Some((x, (y, z)))
                } else {
                    None
                }
            })
            .unzip();

        let tau = 20f64.recip();
        let _: complot::Plot = (
            (0..fx.len())
                .into_iter()
                .zip(&(*fx))
                .zip(&(*fy))
                .zip(&(*fz))
                .skip(1)
                .map(|(((i, &x), &y), &z)| (i as f64 * tau, vec![x, y, z])),
            config,
        )
            .into();
    }
    #[cfg(feature = "plot")]
    pub fn plot_this_forces_psds(values: &[Vector], config: Option<complot::Config>) {
        let (mut fx, (mut fy, mut fz)): (Vec<_>, (Vec<_>, Vec<_>)) = values
            .iter()
            .filter_map(|v| {
                if let Vector {
                    x: Some(x),
                    y: Some(y),
                    z: Some(z),
                } = v
                {
                    Some((x, (y, z)))
                } else {
                    None
                }
            })
            .unzip();
        let n = fx.len() as f64;
        let fx_mean = fx.iter().sum::<f64>() / n;
        let fy_mean = fy.iter().sum::<f64>() / n;
        let fz_mean = fz.iter().sum::<f64>() / n;
        fx.iter_mut().for_each(|x| *x -= fx_mean);
        fy.iter_mut().for_each(|x| *x -= fy_mean);
        fz.iter_mut().for_each(|x| *x -= fz_mean);
        let fs = 20f64;
        let psdx = {
            let welch: PowerSpectrum<f64> = PowerSpectrum::builder(&fx)
                .sampling_frequency(fs)
                .dft_log2_max_size(10)
                .build();
            welch.periodogram()
        };
        let psdy = {
            let welch: PowerSpectrum<f64> = PowerSpectrum::builder(&fy)
                .sampling_frequency(fs)
                .dft_log2_max_size(10)
                .build();
            welch.periodogram()
        };
        let psdz = {
            let welch: PowerSpectrum<f64> = PowerSpectrum::builder(&fz)
                .sampling_frequency(fs)
                .dft_log2_max_size(10)
                .build();
            /*let welch: SpectralDensity<f64> = SpectralDensity::builder(&fz, fs)
            .dft_log2_max_size(10)
            .build();*/
            welch.periodogram()
        };
        let _: complot::LogLog = (
            psdx.frequency()
                .into_iter()
                .zip(&(*psdx))
                .zip(&(*psdy))
                .zip(&(*psdz))
                .skip(1)
                .map(|(((t, &x), &y), &z)| (t, vec![x, y, z])),
            config,
        )
            .into();
    }
    #[cfg(feature = "plot")]
    pub fn plot_moments(&self, filename: Option<&str>) {
        if self.forces_and_moments.is_empty() {
            return;
        }

        let max_value =
            |x: &[f64]| -> f64 { x.iter().cloned().fold(std::f64::NEG_INFINITY, f64::max) };
        let min_value = |x: &[f64]| -> f64 { x.iter().cloned().fold(std::f64::INFINITY, f64::min) };

        let plot =
            BitMapBackend::new(filename.unwrap_or("MOMENTS.png"), (768, 512)).into_drawing_area();
        plot.fill(&WHITE).unwrap();

        let (min_values, max_values): (Vec<_>, Vec<_>) = self
            .forces_and_moments
            .values()
            .map(|values| {
                let force_magnitude: Option<Vec<f64>> =
                    values.iter().map(|e| e.moment.magnitude()).collect();
                (
                    min_value(force_magnitude.as_ref().unwrap()),
                    max_value(force_magnitude.as_ref().unwrap()),
                )
            })
            .unzip();
        let xrange = *self.time.last().unwrap() - self.time[0];
        let mut chart = ChartBuilder::on(&plot)
            .set_label_area_size(LabelAreaPosition::Left, 60)
            .set_label_area_size(LabelAreaPosition::Bottom, 40)
            .margin(10)
            .build_cartesian_2d(
                -xrange * 1e-2..xrange * (1. + 1e-2),
                min_value(&min_values)..max_value(&max_values),
            )
            .unwrap();
        chart
            .configure_mesh()
            .x_desc("Time [s]")
            .y_desc("Moment [N-m]")
            .draw()
            .unwrap();

        let mut colors = colorous::TABLEAU10.iter().cycle();

        for (key, values) in self.forces_and_moments.iter() {
            let color = colors.next().unwrap();
            let rgb = RGBColor(color.r, color.g, color.b);
            chart
                .draw_series(LineSeries::new(
                    self.time
                        .iter()
                        .zip(values.iter())
                        .map(|(&x, y)| (x - self.time[0], y.moment.magnitude().unwrap())),
                    &rgb,
                ))
                .unwrap()
                .label(key)
                .legend(move |(x, y)| PathElement::new(vec![(x, y), (x + 20, y)], &rgb));
        }
        chart
            .configure_series_labels()
            .border_style(&BLACK)
            .background_style(&WHITE.mix(0.8))
            .position(SeriesLabelPosition::UpperRight)
            .draw()
            .unwrap();
    }
}
impl Iterator for Monitors {
    type Item = ();

    fn next(&mut self) -> Option<Self::Item> {
        let i = self.time_idx;
        self.time_idx += 1;
        self.data = Some(Vec::new());
        for e in self.forces_and_moments.values() {
            if let (Some(mut f), Some(mut m)) = ((&e[i].force).into(), (&e[i].moment).into()) {
                if let Some(x) = self.data.as_mut() {
                    x.append(&mut f);
                    x.append(&mut m);
                }
            } else {
                return None;
            }
        }
        Some(())
    }
}

#[cfg(feature = "dosio")]
pub mod dos {
    use dosio::{ios, DOSIOSError, Dos, IO};
    impl Dos for super::Monitors {
        type Input = ();
        type Output = Vec<f64>;
        fn outputs(&mut self) -> Option<Vec<IO<Self::Output>>> {
            Some(vec![ios!(CFD2021106F(self.data.as_ref().unwrap().clone()))])
        }
        fn inputs(
            &mut self,
            _data: Option<Vec<IO<Self::Input>>>,
        ) -> Result<&mut Self, DOSIOSError> {
            unimplemented! {}
        }
    }
}

/*
#[cfg(test)]
mod tests {
    use nalgebra as na;

    #[test]
    fn test_arm() {
        let force = [100f64, -33f64, 250f64];
        let force_v = na::Vector3::from_column_slice(&force);
        //let arm = na::Vector3::<f64>::new_random() * 2f64 - na::Vector3::repeat(1f64);
        let arm = na::Vector3::<f64>::from_column_slice(&[1., 1., 1.]);
        println!("ARM: {:?}", arm);
        let moment = arm.cross(&force_v);
        println!("Moment: {:?}", moment);
        let amat = na::Matrix3::new(
            0., force[2], -force[1], -force[2], 0., force[0], force[1], -force[0], 0.,
        );
        println!("A: {:#?}", amat);
        println!("Moment: {:?}", amat * arm);
        let qr = amat.svd(true, true);
        let x = qr.solve(&moment, 1e-3).unwrap();
        println!("ARM: {:?}", x);
        println!("Moment: {:?}", x.cross(&force_v));
    }
}
*/