rosidl_runtime_rs 0.6.1

use serde::{de::Error, ser::SerializeSeq, Deserialize, Deserializer, Serialize, Serializer};

use super::{BoundedSequence, Sequence};
use crate::traits::SequenceAlloc;

impl<'de, T: Deserialize<'de> + SequenceAlloc> Deserialize<'de> for Sequence<T> {
    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
    where
        D: Deserializer<'de>,
    {
        let v: Vec<_> = Deserialize::deserialize(deserializer)?;
        Ok(Self::from(v))
    }
}

impl<T: Serialize + SequenceAlloc> Serialize for Sequence<T> {
    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
    where
        S: Serializer,
    {
        let mut seq = serializer.serialize_seq(Some(self.len()))?;
        for element in self.iter() {
            seq.serialize_element(element)?;
        }
        seq.end()
    }
}

impl<'de, T: Deserialize<'de> + SequenceAlloc, const N: usize> Deserialize<'de>
    for BoundedSequence<T, N>
{
    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
    where
        D: Deserializer<'de>,
    {
        let v: Vec<_> = Deserialize::deserialize(deserializer)?;
        Self::try_from(v).map_err(D::Error::custom)
    }
}

impl<T: Serialize + SequenceAlloc, const N: usize> Serialize for BoundedSequence<T, N> {
    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
    where
        S: Serializer,
    {
        self.inner.serialize(serializer)
    }
}

#[cfg(test)]
mod tests {
    use quickcheck::quickcheck;

    use crate::{BoundedSequence, Sequence};

    quickcheck! {
        fn test_json_roundtrip_sequence(xs: Sequence<i32>) -> bool {
            let value = serde_json::to_value(xs.clone()).unwrap();
            let recovered = serde_json::from_value(value).unwrap();
            xs == recovered
        }
    }

    quickcheck! {
        fn test_json_roundtrip_bounded_sequence(xs: BoundedSequence<i32, 256>) -> bool {
            let value = serde_json::to_value(xs.clone()).unwrap();
            let recovered = serde_json::from_value(value).unwrap();
            xs == recovered
        }
    }
}