autd3-protobuf 25.1.0

Protocol Buffer
Documentation
use autd3_gain_holo::{LinAlgBackend, NalgebraBackend};

use crate::{
    pb::*,
    to_holo,
    traits::{FromMessage, ToMessage},
};

impl ToMessage
    for autd3_gain_holo::SDP<
        autd3_driver::acoustics::directivity::Sphere,
        NalgebraBackend<autd3_driver::acoustics::directivity::Sphere>,
    >
{
    type Message = DatagramLightweight;

    #[allow(clippy::unnecessary_cast)]
    fn to_msg(&self, _: Option<&autd3_driver::geometry::Geometry>) -> Self::Message {
        Self::Message {
            datagram: Some(datagram_lightweight::Datagram::Gain(Gain {
                gain: Some(gain::Gain::Sdp(Sdp {
                    holo: to_holo!(self),
                    alpha: self.alpha() as _,
                    lambda: self.lambda() as _,
                    repeat: self.repeat() as _,
                    constraint: Some(self.constraint().to_msg(None)),
                })),
                segment: Segment::S0 as _,
                transition: true,
            })),
        }
    }
}

impl ToMessage
    for autd3_driver::datagram::DatagramWithSegment<
        autd3_gain_holo::SDP<
            autd3_driver::acoustics::directivity::Sphere,
            NalgebraBackend<autd3_driver::acoustics::directivity::Sphere>,
        >,
    >
{
    type Message = DatagramLightweight;

    #[allow(clippy::unnecessary_cast)]
    fn to_msg(&self, _: Option<&autd3_driver::geometry::Geometry>) -> Self::Message {
        Self::Message {
            datagram: Some(datagram_lightweight::Datagram::Gain(Gain {
                gain: Some(gain::Gain::Sdp(Sdp {
                    holo: to_holo!(self),
                    alpha: self.alpha() as _,
                    lambda: self.lambda() as _,
                    repeat: self.repeat() as _,
                    constraint: Some(self.constraint().to_msg(None)),
                })),
                segment: self.segment() as _,
                transition: true,
            })),
        }
    }
}

impl FromMessage<Sdp>
    for autd3_gain_holo::SDP<
        autd3_driver::acoustics::directivity::Sphere,
        NalgebraBackend<autd3_driver::acoustics::directivity::Sphere>,
    >
{
    #[allow(clippy::unnecessary_cast)]
    fn from_msg(msg: &Sdp) -> Option<Self> {
        Some(
            Self::new(
                NalgebraBackend::new().ok()?,
                msg.holo
                    .iter()
                    .map(|h| {
                        Some((
                            autd3_driver::geometry::Vector3::from_msg(h.pos.as_ref()?)?,
                            h.amp.as_ref()?.value as f32 * autd3_gain_holo::Pa,
                        ))
                    })
                    .collect::<Option<Vec<_>>>()?,
            )
            .with_alpha(msg.alpha as _)
            .with_lambda(msg.lambda as _)
            .with_repeat(msg.repeat as _)
            .with_constraint(autd3_gain_holo::EmissionConstraint::from_msg(
                msg.constraint.as_ref()?,
            )?),
        )
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use autd3_driver::geometry::Vector3;
    use rand::Rng;

    #[test]
    fn test_holo_sdp() {
        let mut rng = rand::thread_rng();

        let holo = autd3_gain_holo::SDP::new(
            NalgebraBackend::new().unwrap(),
            [
                (
                    Vector3::new(rng.gen(), rng.gen(), rng.gen()),
                    rng.gen::<f32>() * autd3_gain_holo::Pa,
                ),
                (
                    Vector3::new(rng.gen(), rng.gen(), rng.gen()),
                    rng.gen::<f32>() * autd3_gain_holo::Pa,
                ),
            ],
        )
        .with_alpha(rng.gen())
        .with_lambda(rng.gen())
        .with_repeat(rng.gen());
        let msg = holo.to_msg(None);

        match msg.datagram {
            Some(datagram_lightweight::Datagram::Gain(Gain {
                gain: Some(gain::Gain::Sdp(g)),
                ..
            })) => {
                let holo2 = autd3_gain_holo::SDP::from_msg(&g).unwrap();
                assert_approx_eq::assert_approx_eq!(holo.alpha(), holo2.alpha());
                assert_approx_eq::assert_approx_eq!(holo.lambda(), holo2.lambda());
                assert_eq!(holo.repeat(), holo2.repeat());
                assert_eq!(holo.constraint(), holo2.constraint());
                holo.foci()
                    .iter()
                    .zip(holo2.foci().iter())
                    .for_each(|(f1, f2)| {
                        assert_approx_eq::assert_approx_eq!(f1.x, f2.x);
                        assert_approx_eq::assert_approx_eq!(f1.y, f2.y);
                        assert_approx_eq::assert_approx_eq!(f1.z, f2.z);
                    });
                holo.amps()
                    .iter()
                    .zip(holo2.amps().iter())
                    .for_each(|(f1, f2)| {
                        assert_approx_eq::assert_approx_eq!(f1.pascal(), f2.pascal());
                    });
            }
            _ => panic!("unexpected datagram type"),
        }
    }
}