#![cfg(any(feature = "std", feature = "arrayvec"))] use core::ops::Deref; use mqtt_tiny::{packets::TryFromIterator, Disconnect}; // Select an appropriate vector type #[cfg(feature = "std")] type Vec = std::vec::Vec; #[cfg(all(not(feature = "std"), feature = "arrayvec"))] type Vec = arrayvec::ArrayVec; /// A test vector for encoded/decoded pairs #[derive(Debug, Clone)] pub struct Good { /// The encoded representation encoded: &'static [u8], /// The decoded representation decoded: Disconnect, } impl Good { /// Good encoded/decoded pairs pub const fn all() -> [Self; 1] { [ // The DISCONNECT packet does not carry any configurable data Self { encoded: b"\xE0\x00", decoded: Disconnect::new() }, ] } } /// A test vector for known-bad encoded encoded fields #[derive(Debug)] pub struct BadEncoded { /// The invalid encoded representation encoded: &'static [u8], } impl BadEncoded { /// Good encoded/decoded pairs pub const fn all() -> &'static [Self] { &[ // Packet with invalid packet type Self { encoded: b"\xF0\x00" }, ] } } /// Tests successful decoding #[test] pub fn decode() { for test_vector in Good::all() { // Decode and validate let encoded = test_vector.encoded.iter().copied(); let decoded = Disconnect::try_from_iter(encoded).expect("Failed to decode valid packet"); assert_eq!(decoded, test_vector.decoded, "Invalid decoded packet") } } /// Tests successful encoding #[test] pub fn encode() { for test_vector in Good::all() { // Encode and validate let decoded = test_vector.decoded.clone(); let encoded: Vec = decoded.into_iter().collect(); assert_eq!(encoded.deref(), test_vector.encoded, "Invalid encoded packet"); } } /// Tests failing decoding #[test] pub fn decode_invalid() { for test_vector in BadEncoded::all() { // Decode and validate let encoded = test_vector.encoded.iter().copied(); let decoded = Disconnect::try_from_iter(encoded); assert!(decoded.is_err(), "Unexpected success when decoding invalid packet"); } }