#[cfg(feature = "bytemuck")]
use bytemuck_derive::{Pod, Zeroable};
#[cfg(feature = "serde")]
use serde_derive::{Deserialize, Serialize};
#[cfg(feature = "wincode")]
use wincode::{SchemaRead, SchemaWrite};
#[cfg(feature = "borsh")]
use {
alloc::string::ToString,
borsh::{BorshDeserialize, BorshSchema, BorshSerialize},
};
#[cfg_attr(feature = "wincode", derive(SchemaRead, SchemaWrite))]
#[cfg_attr(feature = "wincode", wincode(assert_zero_copy))]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
#[cfg_attr(feature = "serde", serde(from = "bool", into = "bool"))]
#[cfg_attr(feature = "bytemuck", derive(Pod, Zeroable))]
#[derive(Clone, Copy, Debug, Default, PartialEq)]
#[repr(transparent)]
pub struct Bool(pub u8);
impl Bool {
pub const fn from_bool(b: bool) -> Self {
Self(if b { 1 } else { 0 })
}
}
impl From<bool> for Bool {
fn from(b: bool) -> Self {
Self::from_bool(b)
}
}
impl From<&bool> for Bool {
fn from(b: &bool) -> Self {
Self(if *b { 1 } else { 0 })
}
}
impl From<&Bool> for bool {
fn from(b: &Bool) -> Self {
b.0 != 0
}
}
impl From<Bool> for bool {
fn from(b: Bool) -> Self {
b.0 != 0
}
}
#[macro_export]
macro_rules! impl_int_conversion {
($P:ty, $I:ty) => {
impl $P {
pub const fn from_primitive(n: $I) -> Self {
Self(n.to_le_bytes())
}
}
impl From<$I> for $P {
fn from(n: $I) -> Self {
Self::from_primitive(n)
}
}
impl From<$P> for $I {
fn from(unaligned: $P) -> Self {
Self::from_le_bytes(unaligned.0)
}
}
};
}
#[cfg_attr(feature = "wincode", derive(SchemaRead, SchemaWrite))]
#[cfg_attr(feature = "wincode", wincode(assert_zero_copy))]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
#[cfg_attr(feature = "serde", serde(from = "u16", into = "u16"))]
#[cfg_attr(feature = "bytemuck", derive(Pod, Zeroable))]
#[derive(Clone, Copy, Debug, Default, PartialEq)]
#[repr(transparent)]
pub struct U16(pub [u8; 2]);
impl_int_conversion!(U16, u16);
#[cfg_attr(feature = "wincode", derive(SchemaRead, SchemaWrite))]
#[cfg_attr(feature = "wincode", wincode(assert_zero_copy))]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
#[cfg_attr(feature = "serde", serde(from = "i16", into = "i16"))]
#[cfg_attr(feature = "bytemuck", derive(Pod, Zeroable))]
#[derive(Clone, Copy, Debug, Default, PartialEq)]
#[repr(transparent)]
pub struct I16(pub [u8; 2]);
impl_int_conversion!(I16, i16);
#[cfg_attr(feature = "wincode", derive(SchemaRead, SchemaWrite))]
#[cfg_attr(feature = "wincode", wincode(assert_zero_copy))]
#[cfg_attr(
feature = "borsh",
derive(BorshDeserialize, BorshSerialize, BorshSchema)
)]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
#[cfg_attr(feature = "serde", serde(from = "u32", into = "u32"))]
#[cfg_attr(feature = "bytemuck", derive(Pod, Zeroable))]
#[derive(Clone, Copy, Debug, Default, PartialEq)]
#[repr(transparent)]
pub struct U32(pub [u8; 4]);
impl_int_conversion!(U32, u32);
#[cfg_attr(feature = "wincode", derive(SchemaRead, SchemaWrite))]
#[cfg_attr(feature = "wincode", wincode(assert_zero_copy))]
#[cfg_attr(
feature = "borsh",
derive(BorshDeserialize, BorshSerialize, BorshSchema)
)]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
#[cfg_attr(feature = "serde", serde(from = "u64", into = "u64"))]
#[cfg_attr(feature = "bytemuck", derive(Pod, Zeroable))]
#[derive(Clone, Copy, Debug, Default, PartialEq)]
#[repr(transparent)]
pub struct U64(pub [u8; 8]);
impl_int_conversion!(U64, u64);
#[cfg_attr(feature = "wincode", derive(SchemaRead, SchemaWrite))]
#[cfg_attr(feature = "wincode", wincode(assert_zero_copy))]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
#[cfg_attr(feature = "serde", serde(from = "i64", into = "i64"))]
#[cfg_attr(feature = "bytemuck", derive(Pod, Zeroable))]
#[derive(Clone, Copy, Debug, Default, PartialEq)]
#[repr(transparent)]
pub struct I64([u8; 8]);
impl_int_conversion!(I64, i64);
#[cfg(not(target_arch = "bpf"))]
#[cfg_attr(feature = "wincode", derive(SchemaRead, SchemaWrite))]
#[cfg_attr(feature = "wincode", wincode(assert_zero_copy))]
#[cfg_attr(
feature = "borsh",
derive(BorshDeserialize, BorshSerialize, BorshSchema)
)]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
#[cfg_attr(feature = "serde", serde(from = "u128", into = "u128"))]
#[cfg_attr(feature = "bytemuck", derive(Pod, Zeroable))]
#[derive(Clone, Copy, Debug, Default, PartialEq)]
#[repr(transparent)]
pub struct U128(pub [u8; 16]);
#[cfg(not(target_arch = "bpf"))]
impl_int_conversion!(U128, u128);
macro_rules! impl_usize_conversion {
($UnalignedType:ty, $PrimitiveType:ty) => {
impl TryFrom<usize> for $UnalignedType {
type Error = core::num::TryFromIntError;
fn try_from(val: usize) -> Result<Self, Self::Error> {
let primitive_val = <$PrimitiveType>::try_from(val)?;
Ok(primitive_val.into())
}
}
impl From<$UnalignedType> for usize {
fn from(unaligned_val: $UnalignedType) -> Self {
let primitive_val = <$PrimitiveType>::from(unaligned_val);
Self::try_from(primitive_val)
.expect("value out of range for usize on this platform")
}
}
};
}
impl_usize_conversion!(U16, u16);
impl_usize_conversion!(U32, u32);
impl_usize_conversion!(U64, u64);
#[cfg(not(target_arch = "bpf"))]
impl_usize_conversion!(U128, u128);
#[cfg(test)]
mod tests {
use super::*;
#[cfg(feature = "bytemuck")]
#[test]
fn test_bool() {
assert!(bytemuck::try_from_bytes::<Bool>(&[]).is_err());
assert!(bytemuck::try_from_bytes::<Bool>(&[0, 0]).is_err());
for i in 0..=u8::MAX {
assert_eq!(i != 0, bool::from(*bytemuck::from_bytes::<Bool>(&[i])));
}
}
#[cfg(feature = "serde")]
#[test]
fn test_bool_serde() {
let unaligned_false: Bool = false.into();
let unaligned_true: Bool = true.into();
let serialized_false = serde_json::to_string(&unaligned_false).unwrap();
let serialized_true = serde_json::to_string(&unaligned_true).unwrap();
assert_eq!(&serialized_false, "false");
assert_eq!(&serialized_true, "true");
let deserialized_false = serde_json::from_str::<Bool>(&serialized_false).unwrap();
let deserialized_true = serde_json::from_str::<Bool>(&serialized_true).unwrap();
assert_eq!(unaligned_false, deserialized_false);
assert_eq!(unaligned_true, deserialized_true);
}
#[cfg(feature = "bytemuck")]
#[test]
fn test_u16() {
assert!(bytemuck::try_from_bytes::<U16>(&[]).is_err());
assert_eq!(1u16, u16::from(*bytemuck::from_bytes::<U16>(&[1, 0])));
}
#[cfg(feature = "serde")]
#[test]
fn test_u16_serde() {
let unaligned_u16: U16 = u16::MAX.into();
let serialized = serde_json::to_string(&unaligned_u16).unwrap();
assert_eq!(&serialized, "65535");
let deserialized = serde_json::from_str::<U16>(&serialized).unwrap();
assert_eq!(unaligned_u16, deserialized);
}
#[cfg(feature = "bytemuck")]
#[test]
fn test_i16() {
assert!(bytemuck::try_from_bytes::<I16>(&[]).is_err());
assert_eq!(-1i16, i16::from(*bytemuck::from_bytes::<I16>(&[255, 255])));
}
#[cfg(feature = "serde")]
#[test]
fn test_i16_serde() {
let unaligned_i16: I16 = i16::MAX.into();
let serialized = serde_json::to_string(&unaligned_i16).unwrap();
assert_eq!(&serialized, "32767");
let deserialized = serde_json::from_str::<I16>(&serialized).unwrap();
assert_eq!(unaligned_i16, deserialized);
}
#[cfg(feature = "bytemuck")]
#[test]
fn test_u64() {
assert!(bytemuck::try_from_bytes::<U64>(&[]).is_err());
assert_eq!(
1u64,
u64::from(*bytemuck::from_bytes::<U64>(&[1, 0, 0, 0, 0, 0, 0, 0]))
);
}
#[cfg(feature = "serde")]
#[test]
fn test_u64_serde() {
let unaligned_u64: U64 = u64::MAX.into();
let serialized = serde_json::to_string(&unaligned_u64).unwrap();
assert_eq!(&serialized, "18446744073709551615");
let deserialized = serde_json::from_str::<U64>(&serialized).unwrap();
assert_eq!(unaligned_u64, deserialized);
}
#[cfg(feature = "bytemuck")]
#[test]
fn test_i64() {
assert!(bytemuck::try_from_bytes::<I64>(&[]).is_err());
assert_eq!(
-1i64,
i64::from(*bytemuck::from_bytes::<I64>(&[
255, 255, 255, 255, 255, 255, 255, 255
]))
);
}
#[cfg(feature = "serde")]
#[test]
fn test_i64_serde() {
let unaligned_i64: I64 = i64::MAX.into();
let serialized = serde_json::to_string(&unaligned_i64).unwrap();
assert_eq!(&serialized, "9223372036854775807");
let deserialized = serde_json::from_str::<I64>(&serialized).unwrap();
assert_eq!(unaligned_i64, deserialized);
}
#[cfg(not(target_arch = "bpf"))]
#[cfg(feature = "bytemuck")]
#[test]
fn test_u128() {
assert!(bytemuck::try_from_bytes::<U128>(&[]).is_err());
assert_eq!(
1u128,
u128::from(*bytemuck::from_bytes::<U128>(&[
1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0
]))
);
}
#[cfg(not(target_arch = "bpf"))]
#[cfg(feature = "serde")]
#[test]
fn test_u128_serde() {
let unaligned_u128: U128 = u128::MAX.into();
let serialized = serde_json::to_string(&unaligned_u128).unwrap();
assert_eq!(&serialized, "340282366920938463463374607431768211455");
let deserialized = serde_json::from_str::<U128>(&serialized).unwrap();
assert_eq!(unaligned_u128, deserialized);
}
macro_rules! test_usize_roundtrip {
($test_name:ident, $UnalignedType:ty, $max:expr) => {
#[test]
fn $test_name() {
let unaligned = <$UnalignedType>::try_from(0usize).unwrap();
assert_eq!(usize::from(unaligned), 0);
let unaligned = <$UnalignedType>::try_from(42usize).unwrap();
assert_eq!(usize::from(unaligned), 42);
let max = $max as usize;
let unaligned = <$UnalignedType>::try_from(max).unwrap();
assert_eq!(usize::from(unaligned), max);
}
};
}
test_usize_roundtrip!(test_usize_roundtrip_u16, U16, u16::MAX);
test_usize_roundtrip!(test_usize_roundtrip_u32, U32, u32::MAX);
test_usize_roundtrip!(test_usize_roundtrip_u64, U64, u64::MAX);
#[cfg(not(target_arch = "bpf"))]
test_usize_roundtrip!(test_usize_roundtrip_u128, U128, u128::MAX);
#[cfg(feature = "wincode")]
mod wincode_tests {
use {super::*, test_case::test_case};
#[test_case(Bool::from_bool(true))]
#[test_case(Bool::from_bool(false))]
#[test_case(U16::from_primitive(u16::MAX))]
#[test_case(I16::from_primitive(i16::MIN))]
#[test_case(U32::from_primitive(u32::MAX))]
#[test_case(U64::from_primitive(u64::MAX))]
#[test_case(I64::from_primitive(i64::MIN))]
#[cfg(not(target_arch = "bpf"))]
#[test_case(U128::from_primitive(u128::MAX))]
fn wincode_roundtrip<
T: PartialEq
+ core::fmt::Debug
+ wincode::ZeroCopy
+ for<'de> wincode::SchemaRead<'de, wincode::config::DefaultConfig, Dst = T>
+ wincode::SchemaWrite<wincode::config::DefaultConfig, Src = T>,
>(
value: T,
) {
let size = wincode::serialized_size(&value).unwrap() as usize;
let mut bytes = [0u8; 32];
assert!(size <= bytes.len());
wincode::serialize_into(&mut bytes[..size], &value).unwrap();
let deserialized: T = wincode::deserialize(&bytes[..size]).unwrap();
assert_eq!(value, deserialized);
let zero_copy_ref = <T as wincode::ZeroCopy>::from_bytes(&bytes[..size]).unwrap();
assert_eq!(&value, zero_copy_ref);
}
}
}