serde-indexed 0.2.0

use serde_indexed::{DeserializeIndexed, SerializeIndexed};
use serde_test::{assert_tokens, Token};

/// buffer should be big enough to hold serialized object.
fn cbor_serialize<T: serde::Serialize>(
    object: &T,
    buffer: &mut [u8],
) -> Result<usize, serde_cbor::Error> {
    let writer = serde_cbor::ser::SliceWrite::new(buffer);
    let mut ser = serde_cbor::Serializer::new(writer);

    object.serialize(&mut ser)?;

    let writer = ser.into_inner();
    let size = writer.bytes_written();

    Ok(size)
}

/// may or may not modify buffer to hold temporary data.
/// buffer may be longer than serialized T.
fn cbor_deserialize<'de, T: serde::Deserialize<'de>>(
    buffer: &'de mut [u8],
) -> Result<T, serde_cbor::Error> {
    let mut deserializer = serde_cbor::de::Deserializer::from_mut_slice(buffer);
    serde::Deserialize::deserialize(&mut deserializer)
}

/// scratch should be big enough to hold temporary data.
/// buffer must not have trailing data.
fn cbor_deserialize_with_scratch<'de, T: serde::Deserialize<'de>>(
    buffer: &'de [u8],
    scratch: &'de mut [u8],
) -> Result<T, serde_cbor::Error> {
    serde_cbor::de::from_slice_with_scratch(buffer, scratch)
}

mod some_keys {
    use super::*;

    use hex_literal::hex;
    use serde_bytes::{ByteArray, Bytes};
    use serde_test::assert_de_tokens;

    #[derive(Clone, Debug, PartialEq, SerializeIndexed, DeserializeIndexed)]
    #[serde_indexed(auto_index, offset = 1)]
    pub struct SomeKeys {
        pub number: i32,
        pub bytes: [u8; 7],
        pub string: heapless::String<10>,
        #[serde(skip_serializing_if = "Option::is_none")]
        pub option: Option<u8>,
        pub vector: heapless::Vec<u8, 16>,
    }

    #[derive(Clone, Debug, PartialEq, SerializeIndexed, DeserializeIndexed)]
    #[serde_indexed(auto_index, offset = 1)]
    pub struct SomeRefKeys<'a, 'b, 'c> {
        pub number: i32,
        #[serde(skip)]
        pub ignored: i32,
        #[serde(skip(no_increment))]
        pub ignored2: i32,
        pub bytes: &'a ByteArray<7>,
        pub string: &'b str,
        #[serde(skip_serializing_if = "Option::is_none")]
        pub option: Option<u8>,
        pub vector: &'c Bytes,
    }

    #[derive(Clone, Debug, PartialEq, SerializeIndexed, DeserializeIndexed)]
    // #[serde_indexed(offset = 1)]
    #[serde_indexed(auto_index)]
    pub struct NakedOption {
        pub option: Option<SomeKeys>,
        pub num: usize,
        pub key: bool,
    }

    #[derive(Clone, Debug, PartialEq, SerializeIndexed, DeserializeIndexed)]
    // #[serde_indexed(offset = 1)]
    #[serde_indexed(auto_index)]
    pub struct NakedRefOption<'a, 'b, 'c> {
        pub option: Option<SomeRefKeys<'a, 'b, 'c>>,
        pub num: usize,
        pub key: bool,
    }

    #[derive(Clone, Debug, PartialEq, SerializeIndexed, DeserializeIndexed)]
    // #[serde_indexed(offset = 1)]
    #[serde_indexed(auto_index)]
    pub struct EmptyStruct {}

    fn an_example() -> (&'static [u8], SomeKeys) {
        let mut string = heapless::String::new();
        string.push_str("so serde").unwrap();

        let mut vector = heapless::Vec::<u8, 16>::new();
        vector.push(42).unwrap();

        let value = SomeKeys {
            number: -7,
            bytes: [37u8; 7],
            string,
            option: None,
            vector,
        };
        // in Python: cbor2.dumps({1: -7, 2: [37]*7, 3: "so serde", 5: [42]*1})
        let serialized: &[u8] =
            &hex!("a40126028718251825182518251825182518250368736f2073657264650581182a");
        (serialized, value)
    }

    fn a_ref_example() -> (&'static [u8], SomeRefKeys<'static, 'static, 'static>) {
        const BYTE_ARRAY: ByteArray<7> = ByteArray::new([37u8; 7]);
        let value = SomeRefKeys {
            number: -7,
            ignored: 0,
            ignored2: 0,
            bytes: &BYTE_ARRAY,
            string: "so serde",
            option: None,
            vector: Bytes::new(&[42]),
        };
        // in Python: cbor2.dumps({1: -7, 3: bytes([37]*7), 4: "so serde", 6: bytes([42]*1)}).
        let serialized: &[u8] = &hex!("a401260347252525252525250468736f20736572646506412a");
        (serialized, value)
    }

    fn another_example() -> (&'static [u8], SomeKeys) {
        let (_, mut an_example) = an_example();
        an_example.option = Some(0xff);
        // in Python: cbor2.dumps({1: -7, 2: [37]*7, 3: "so serde", 4: 0xff, 5: [42]*1})
        let serialized: &[u8] =
            &hex!("a50126028718251825182518251825182518250368736f2073657264650418ff0581182a");
        (serialized, an_example)
    }

    fn another_ref_example() -> (&'static [u8], SomeRefKeys<'static, 'static, 'static>) {
        let (_, mut an_example) = a_ref_example();
        an_example.option = Some(0xff);
        // in Python: cbor2.dumps({1: -7, 3: bytes([37]*7), 4: "so serde", 5: 0xff,  6: bytes([42]*1)}).hex()
        let serialized: &[u8] = &hex!("a501260347252525252525250468736f2073657264650518ff06412a");
        (serialized, an_example)
    }

    #[test]
    fn tokens() {
        assert_tokens(
            &an_example().1,
            &[
                Token::Map { len: Some(4) },
                Token::U64(1),
                Token::I32(-7),
                Token::U64(2),
                Token::Tuple { len: 7 },
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::TupleEnd,
                Token::U64(3),
                Token::Str("so serde"),
                Token::U64(5),
                Token::Seq { len: Some(1) },
                Token::U8(42),
                Token::SeqEnd,
                Token::MapEnd,
            ],
        );
        assert_tokens(
            &another_example().1,
            &[
                Token::Map { len: Some(5) },
                Token::U64(1),
                Token::I32(-7),
                Token::U64(2),
                Token::Tuple { len: 7 },
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::TupleEnd,
                Token::U64(3),
                Token::Str("so serde"),
                Token::U64(4),
                Token::Some,
                Token::U8(0xFF),
                Token::U64(5),
                Token::Seq { len: Some(1) },
                Token::U8(42),
                Token::SeqEnd,
                Token::MapEnd,
            ],
        );
        assert_tokens(
            &a_ref_example().1,
            &[
                Token::Map { len: Some(4) },
                Token::U64(1),
                Token::I32(-7),
                Token::U64(3),
                Token::BorrowedBytes(&[37; 7]),
                Token::U64(4),
                Token::BorrowedStr("so serde"),
                Token::U64(6),
                Token::BorrowedBytes(&[42]),
                Token::MapEnd,
            ],
        );
        assert_tokens(
            &another_ref_example().1,
            &[
                Token::Map { len: Some(5) },
                Token::U64(1),
                Token::I32(-7),
                Token::U64(3),
                Token::BorrowedBytes(&[37; 7]),
                Token::U64(4),
                Token::BorrowedStr("so serde"),
                Token::U64(5),
                Token::Some,
                Token::U8(0xFF),
                Token::U64(6),
                Token::BorrowedBytes(&[42]),
                Token::MapEnd,
            ],
        )
    }

    #[test]
    fn serialize() {
        let (serialized_value, example) = an_example();

        let mut buffer = [0u8; 64];
        let size = cbor_serialize(&example, &mut buffer).unwrap();

        assert_eq!(&buffer[..size], serialized_value);
    }

    #[test]
    fn deserialize() {
        let (serialized_value, example) = an_example();

        // no allocations need in this case.
        let maybe_example: SomeKeys =
            cbor_deserialize_with_scratch(serialized_value, &mut []).unwrap();

        assert_eq!(maybe_example, example);
    }

    #[test]
    fn serialize_ref() {
        let (serialized_value, example) = a_ref_example();

        let mut buffer = [0u8; 64];
        let size = cbor_serialize(&example, &mut buffer).unwrap();

        assert_eq!(&buffer[..size], serialized_value);
    }

    #[test]
    fn deserialize_ref() {
        let (serialized_value, example) = a_ref_example();

        // no allocations need in this case.
        let maybe_example: SomeRefKeys =
            cbor_deserialize_with_scratch(serialized_value, &mut []).unwrap();

        assert_eq!(maybe_example, example);
    }

    #[test]
    fn another_serialize() {
        let (serialized_value, example) = another_example();

        let mut buffer = [0u8; 64];
        let size = cbor_serialize(&example, &mut buffer).unwrap();

        assert_eq!(&buffer[..size], serialized_value);
    }

    #[test]
    fn another_deserialize() {
        let (serialized_value, example) = another_example();
        // could also use `cbor_deserialize_with_scratch` in this case,
        // demonstrating the `cbor_deserialize` function.
        let mut buffer = serialized_value.to_owned();

        let maybe_example: SomeKeys = cbor_deserialize(&mut buffer).unwrap();

        assert_eq!(maybe_example, example);
    }

    #[test]
    fn another_ref_serialize() {
        let (serialized_value, example) = another_ref_example();

        let mut buffer = [0u8; 64];
        let size = cbor_serialize(&example, &mut buffer).unwrap();

        assert_eq!(&buffer[..size], serialized_value);
    }

    #[test]
    fn another_ref_deserialize() {
        let (serialized_value, example) = another_ref_example();
        // could also use `cbor_deserialize_with_scratch` in this case,
        // demonstrating the `cbor_deserialize` function.
        let mut buffer = serialized_value.to_owned();

        let maybe_example: SomeRefKeys = cbor_deserialize(&mut buffer).unwrap();

        assert_eq!(maybe_example, example);
    }

    #[test]
    fn test_unknown_fields() {
        let value = an_example().1;
        assert_de_tokens(
            &value,
            &[
                Token::Map { len: Some(5) },
                Token::U64(1),
                Token::I32(-7),
                Token::U64(2),
                Token::Tuple { len: 7 },
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::U8(37),
                Token::TupleEnd,
                Token::U64(3),
                Token::Str("so serde"),
                Token::U64(5),
                Token::Seq { len: Some(1) },
                Token::U8(42),
                Token::SeqEnd,
                Token::U64(6),
                Token::U8(42),
                Token::MapEnd,
            ],
        );
    }
}

mod cow {
    use super::*;
    use std::borrow::Cow;

    #[derive(PartialEq, Debug, SerializeIndexed, DeserializeIndexed)]
    #[serde_indexed(auto_index, offset = 1)]
    struct WithLifetimes<'a> {
        data: Cow<'a, [u8]>,
        #[serde(skip_serializing_if = "Option::is_none")]
        option: Option<u8>,
    }

    fn lifetime_example<'a>() -> WithLifetimes<'a> {
        WithLifetimes {
            data: Cow::Borrowed(&[1, 2, 3]),
            option: None,
        }
    }

    const SERIALIZED_LIFETIME_EXAMPLE: &[u8] = b"\xa1\x01\x83\x01\x02\x03";

    #[test]
    fn tokens() {
        assert_tokens(
            &lifetime_example(),
            &[
                Token::Map { len: Some(1) },
                Token::U64(1),
                Token::Seq { len: Some(3) },
                Token::U8(1),
                Token::U8(2),
                Token::U8(3),
                Token::SeqEnd,
                Token::MapEnd,
            ],
        );
    }

    #[test]
    fn serialize() {
        let data = lifetime_example();
        let mut buf = [0u8; 64];

        let size = cbor_serialize(&data, &mut buf).unwrap();

        assert_eq!(&buf[..size], SERIALIZED_LIFETIME_EXAMPLE);
    }

    #[test]
    fn deserialize() {
        let example = lifetime_example();

        let deserialized: WithLifetimes<'_> =
            cbor_deserialize_with_scratch(SERIALIZED_LIFETIME_EXAMPLE, &mut []).unwrap();

        assert_eq!(deserialized, example);
        let Cow::Owned(_) = deserialized.data else {
            panic!("Expected deserialized data Cow::Owned");
        };
    }
}

mod generics {
    use super::*;
    use heapless::String;
    use serde_bytes::{ByteArray, Bytes};
    use serde_test::{assert_de_tokens, assert_ser_tokens};

    #[derive(PartialEq, Debug, SerializeIndexed, DeserializeIndexed)]
    #[serde_indexed(auto_index, offset = 1)]
    struct WithGeneric<T> {
        data: T,
        #[serde(skip_serializing_if = "Option::is_none")]
        option: Option<u8>,
    }

    fn generics_example<'a>() -> WithGeneric<&'a Bytes> {
        WithGeneric {
            data: Bytes::new(&[1, 2, 3]),
            option: None,
        }
    }

    #[derive(PartialEq, Debug, SerializeIndexed, DeserializeIndexed)]
    #[serde_indexed(auto_index, offset = 1)]
    struct WithConstGeneric<const N: usize> {
        data: ByteArray<N>,
        #[serde(skip_serializing_if = "Option::is_none")]
        option: Option<u8>,
    }

    fn const_generics_example() -> WithConstGeneric<3> {
        WithConstGeneric {
            data: ByteArray::new([1, 2, 3]),
            option: None,
        }
    }

    #[test]
    fn tokens() {
        let tokens = &[
            Token::Map { len: Some(1) },
            Token::U64(1),
            Token::BorrowedBytes(&[1, 2, 3]),
            Token::MapEnd,
        ];
        assert_tokens(&generics_example(), tokens);
        assert_tokens(&const_generics_example(), tokens);
        assert_tokens(
            &all_generics_example(),
            &[
                Token::Map { len: Some(4) },
                Token::U64(1),
                Token::Seq { len: Some(2) },
                Token::Str("abc"),
                Token::Str("acdef"),
                Token::SeqEnd,
                Token::U64(2),
                Token::Seq { len: Some(3) },
                Token::U8(1),
                Token::U8(2),
                Token::U8(3),
                Token::SeqEnd,
                Token::U64(3),
                Token::BorrowedBytes(b"bytes"),
                Token::U64(4),
                Token::BorrowedBytes(b"123"),
                Token::MapEnd,
            ],
        );
    }

    #[derive(PartialEq, Debug, SerializeIndexed, DeserializeIndexed)]
    #[serde_indexed(auto_index, offset = 1)]
    struct WithAllGenerics<'a, 'b, T, I, const N: usize, const Z: usize> {
        data1: heapless::Vec<T, N>,
        data2: heapless::Vec<I, Z>,
        data3: &'a Bytes,
        data4: &'b ByteArray<Z>,
    }

    fn all_generics_example<'a, 'b>() -> WithAllGenerics<'a, 'b, String<5>, u8, 10, 3> {
        let data1 = heapless::Vec::from_slice(&["abc".into(), "acdef".into()]).unwrap();
        let data2 = heapless::Vec::from_slice(&[1, 2, 3]).unwrap();

        const BYTES: ByteArray<3> = ByteArray::new(*b"123");
        WithAllGenerics {
            data1,
            data2,
            data3: Bytes::new(b"bytes"),
            data4: &BYTES,
        }
    }

    #[test]
    fn all_generics() {
        const SERIALIZED_ALL_GENERIC_EXAMPLE: &[u8] = b"\xa4\x01\x82\x63\x61\x62\x63\x65\x61\x63\x64\x65\x66\x02\x83\x01\x02\x03\x03\x45\x62\x79\x74\x65\x73\x04\x43\x31\x32\x33";
        let data = all_generics_example();
        let mut buf = [0u8; 64];
        let size = cbor_serialize(&data, &mut buf).unwrap();

        println!("{buf:02x?}");
        assert_eq!(&buf[..size], SERIALIZED_ALL_GENERIC_EXAMPLE);

        let example = all_generics_example();

        let deserialized: WithAllGenerics<'_, '_, String<5>, u8, 10, 3> =
            cbor_deserialize_with_scratch(SERIALIZED_ALL_GENERIC_EXAMPLE, &mut []).unwrap();

        assert_eq!(deserialized, example);
    }

    #[test]
    fn serialize_with() {
        #[derive(serde_indexed::SerializeIndexed)]
        #[serde_indexed(auto_index)]
        struct SerializeWith {
            #[serde(serialize_with = "serde_bytes::serialize")]
            data: Vec<u8>,
        }

        let value = SerializeWith { data: vec![0; 128] };

        assert_ser_tokens(
            &value,
            &[
                Token::Map { len: Some(1) },
                Token::U64(0),
                Token::Bytes(&[0; 128]),
                Token::MapEnd,
            ],
        )
    }

    #[test]
    fn deserialize_with() {
        #[derive(serde_indexed::DeserializeIndexed, PartialEq, Eq, Debug)]
        #[serde_indexed(auto_index)]
        struct DeserializeWith {
            #[serde(deserialize_with = "serde_bytes::deserialize")]
            data: Vec<u8>,
        }

        let value = DeserializeWith { data: vec![0; 128] };

        assert_de_tokens(
            &value,
            &[
                Token::Map { len: Some(1) },
                Token::U64(0),
                Token::Bytes(&[0; 128]),
                Token::MapEnd,
            ],
        )
    }

    #[test]
    fn with() {
        #[derive(
            serde_indexed::SerializeIndexed, serde_indexed::DeserializeIndexed, PartialEq, Eq, Debug,
        )]
        #[serde_indexed(auto_index)]
        struct SerializeWith {
            #[serde(with = "serde_bytes")]
            data: Vec<u8>,
        }

        let value = SerializeWith { data: vec![0; 128] };

        assert_tokens(
            &value,
            &[
                Token::Map { len: Some(1) },
                Token::U64(0),
                Token::Bytes(&[0; 128]),
                Token::MapEnd,
            ],
        )
    }

    #[test]
    fn with_lifetime() {
        #[derive(
            serde_indexed::SerializeIndexed, serde_indexed::DeserializeIndexed, PartialEq, Eq, Debug,
        )]
        #[serde_indexed(auto_index)]
        struct SerializeWith<'a> {
            #[serde(with = "serde_bytes")]
            data: &'a [u8],
        }

        let value = SerializeWith { data: &[0; 128] };

        assert_tokens(
            &value,
            &[
                Token::Map { len: Some(1) },
                Token::U64(0),
                Token::BorrowedBytes(&[0; 128]),
                Token::MapEnd,
            ],
        )
    }
}

mod index {
    use super::*;

    #[derive(PartialEq, Debug, SerializeIndexed, DeserializeIndexed)]
    struct WithIndices {
        #[serde(index = 9)]
        test1: usize,
        #[serde(index = 2)]
        test2: usize,
        #[serde(index = 0x5A)]
        test3: usize,
        #[serde(skip)]
        test4: usize,
    }

    fn indices_example() -> WithIndices {
        WithIndices {
            test1: 42,
            test2: 1,
            test3: 99,
            test4: 0,
        }
    }

    #[test]
    fn tokens() {
        assert_tokens(
            &indices_example(),
            &[
                Token::Map { len: Some(3) },
                Token::U64(9),
                Token::U64(42),
                Token::U64(2),
                Token::U64(1),
                Token::U64(0x5A),
                Token::U64(99),
                Token::MapEnd,
            ],
        );
    }
}