//! Serialize structured data. //! //! # Overview //! //! Provides traits and implementations for efficient and safe binary serialization and //! deserialization of structured data. The library focuses on: //! //! - **Performance:** Uses the [bytes] crate and aims to minimize allocations. //! - **Safety:** Deserialization of untrusted data is made safer via the `Cfg` associated type in //! the [Read] trait, allowing users to impose limits (like maximum lengths) or other strict //! constraints on the data. //! - **Ease of Use:** Provides implementations for common Rust types and uses extension traits //! ([ReadExt], [DecodeExt], etc.) for ergonomic usage. //! //! # Core Concepts //! //! The library revolves around a few core traits: //! //! - [Write]: Implement this to define how your type is written to a byte buffer. //! - [Read]: Implement this to define how your type is read from a byte buffer. //! It has an associated `Cfg` type, primarily used to enforce constraints (e.g., size limits) //! when reading untrusted data. Use `()` if no config is needed. //! - [EncodeSize]: Implement this to calculate the exact encoded byte size of a value. //! Required for efficient buffer pre-allocation. //! - [FixedSize]: Marker trait for types whose encoded size is constant. Automatically //! implements [EncodeSize]. //! //! Helper traits combine these for convenience: //! //! - [Encode]: Combines [Write] + [EncodeSize]. Provides [Encode::encode()] method. //! - [Decode]: Requires [Read]. Provides [Decode::decode_cfg()] method that ensures //! that the entire buffer is consumed. //! - [Codec]: Combines [Encode] + [Decode]. //! //! # Supported Types //! //! Natively supports encoding/decoding for: //! - Primitives: [bool], //! [u8], [u16], [u32], [u64], [u128], //! [i8], [i16], [i32], [i64], [i128], //! [f32], [f64], [u8; N], //! and [usize] (must fit within a [u32] for cross-platform compatibility). //! - Collections: [`Vec`], [`Option`], `BTreeMap`, `BTreeSet` //! - Tuples: `(T1, T2, ...)` (up to 12 elements) //! - Common External Types: [::bytes::Bytes] //! //! With the `std` feature (enabled by default): //! - Networking: //! [`std::net::Ipv4Addr`], //! [`std::net::Ipv6Addr`], //! [`std::net::SocketAddrV4`], //! [`std::net::SocketAddrV6`], //! [`std::net::IpAddr`], //! [`std::net::SocketAddr`] //! - Collections: //! [`std::collections::HashMap`], //! [`std::collections::HashSet`] //! //! # Implementing for Custom Types //! //! You typically need to implement [Write], [EncodeSize] (unless [FixedSize]), and [Read] //! for your custom structs and enums. //! //! ## Example 1. Fixed-Size Type //! //! ``` //! use bytes::{Buf, BufMut}; //! use commonware_codec::{Error, FixedSize, Read, ReadExt, Write, Encode, DecodeExt}; //! //! // Define a custom struct //! #[derive(Debug, Clone, PartialEq)] //! struct Point { //! x: u32, // FixedSize //! y: u32, // FixedSize //! } //! //! // 1. Implement Write: How to serialize the struct //! impl Write for Point { //! fn write(&self, buf: &mut impl BufMut) { //! // u32 implements Write //! self.x.write(buf); //! self.y.write(buf); //! } //! } //! //! // 2. Implement FixedSize (provides EncodeSize automatically) //! impl FixedSize for Point { //! // u32 implements FixedSize //! const SIZE: usize = u32::SIZE + u32::SIZE; //! } //! //! // 3. Implement Read: How to deserialize the struct (uses default Cfg = ()) //! impl Read for Point { //! type Cfg = (); //! fn read_cfg(buf: &mut impl Buf, _: &()) -> Result { //! // Use ReadExt::read for ergonomic reading when Cfg is () //! let x = u32::read(buf)?; //! let y = u32::read(buf)?; //! Ok(Self { x, y }) //! } //! } //! //! // Point now automatically implements Encode, Decode, Codec //! let point = Point { x: 1, y: 2 }; //! //! // Encode is available via FixedSize + Write //! let bytes = point.encode(); //! assert_eq!(bytes.len(), Point::SIZE); //! //! // Decode is available via Read, use DecodeExt //! let decoded_point = Point::decode(bytes).unwrap(); //! assert_eq!(point, decoded_point); //! ``` //! //! ## Example 2. Variable-Size Type //! //! ``` //! use bytes::{Buf, BufMut}; //! use commonware_codec::{ //! Decode, Encode, EncodeSize, Error, FixedSize, Read, ReadExt, //! ReadRangeExt, Write, RangeCfg //! }; //! use core::ops::RangeInclusive; // Example RangeCfg //! //! // Define a simple configuration for reading Item //! // Here, it just specifies the maximum allowed metadata length. //! #[derive(Clone)] //! pub struct ItemConfig { //! max_metadata_len: usize, //! } //! //! // Define a custom struct //! #[derive(Debug, Clone, PartialEq)] //! struct Item { //! id: u64, // FixedSize //! name: Option, // EncodeSize (depends on Option) //! metadata: Vec, // EncodeSize (variable) //! } //! //! // 1. Implement Write //! impl Write for Item { //! fn write(&self, buf: &mut impl BufMut) { //! self.id.write(buf); // u64 implements Write //! self.name.write(buf); // Option implements Write //! self.metadata.write(buf); // Vec implements Write //! } //! } //! //! // 2. Implement EncodeSize //! impl EncodeSize for Item { //! fn encode_size(&self) -> usize { //! // Sum the sizes of the parts //! self.id.encode_size() // u64 implements EncodeSize (via FixedSize) //! + self.name.encode_size() // Option implements EncodeSize //! + self.metadata.encode_size() // Vec implements EncodeSize //! } //! } //! //! // 3. Implement Read //! impl Read for Item { //! type Cfg = ItemConfig; //! fn read_cfg(buf: &mut impl Buf, cfg: &ItemConfig) -> Result { //! // u64 requires Cfg = (), uses ReadExt::read //! let id = ::read(buf)?; //! //! // Option requires Cfg = (), uses ReadExt::read //! let name = >::read(buf)?; //! //! // For Vec, the required config is (RangeCfg, InnerConfig) //! // InnerConfig for u8 is (), so we need (RangeCfg, ()) //! // We use ReadRangeExt::read_range which handles the () for us. //! // The RangeCfg limits the vector length using our ItemConfig. //! let metadata_range = 0..=cfg.max_metadata_len; // Create the RangeCfg //! let metadata = >::read_range(buf, metadata_range)?; //! //! Ok(Self { id, name, metadata }) //! } //! } //! //! // Now you can use Encode and Decode: //! let item = Item { id: 101, name: None, metadata: vec![1, 2, 3] }; //! let config = ItemConfig { max_metadata_len: 1024 }; //! //! // Encode the item (uses Write + EncodeSize) //! let bytes = item.encode(); // Returns BytesMut //! //! // Decode the item //! // decode_cfg ensures all bytes are consumed. //! let decoded_item = Item::decode_cfg(bytes, &config).unwrap(); //! assert_eq!(item, decoded_item); //! ``` #![doc( html_logo_url = "https://commonware.xyz/imgs/rustdoc_logo.svg", html_favicon_url = "https://commonware.xyz/favicon.ico" )] #![cfg_attr(not(feature = "std"), no_std)] #[cfg(not(feature = "std"))] extern crate alloc; pub mod codec; pub mod config; pub mod error; pub mod extensions; pub mod types; pub mod util; pub mod varint; // Re-export main types and traits pub use codec::*; pub use config::RangeCfg; pub use error::Error; pub use extensions::*; #[cfg(feature = "arbitrary")] pub mod conformance; // Re-export paste for use in conformance macros #[cfg(feature = "arbitrary")] #[doc(hidden)] pub use paste;