data-rw 1.6.4

io buffer write reader.
Documentation
use crate::serde::error::DataError;
use crate::serde::serialize_impl::{
    DataSerializeMap, DataSerializeSeq, DataSerializeTuple, DataSerializeTupleStruct,
    DataSerializeTupleVariant,
};
use crate::Data;
use anyhow::Result;
use paste::paste;
use serde::{Serialize, Serializer};

macro_rules! make_base_serialize {
    ($($type:ty)+) => {
      paste!{
        $(
        #[inline]
        fn [<serialize_ $type>] (self, v: $type) -> Result<Self::Ok, Self::Error> {
            self.write_fixed(v);
            Ok(())
        }
        )*
      }
    };
}

impl<'a> Serializer for &'a mut Data {
    type Ok = ();
    type Error = DataError;
    type SerializeSeq = DataSerializeSeq<'a>;
    type SerializeTuple = DataSerializeTuple<'a>;
    type SerializeTupleStruct = DataSerializeTupleStruct<'a>;
    type SerializeTupleVariant = DataSerializeTupleVariant<'a>;
    type SerializeMap = DataSerializeMap<'a>;
    type SerializeStruct = DataSerializeTupleStruct<'a>;
    type SerializeStructVariant = DataSerializeTupleVariant<'a>;

    make_base_serialize!(bool i8 u8 i16 u16 i32 u32 i64 u64 f32 f64 i128 u128);

    #[inline]
    fn serialize_char(self, v: char) -> Result<Self::Ok, Self::Error> {
        let mut buf = [0; 4];
        self.write_fixed(v.encode_utf8(&mut buf).as_bytes());
        Ok(())
    }

    #[inline]
    fn serialize_str(self, v: &str) -> Result<Self::Ok, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        self.write_fixed(v);
        Ok(())
    }

    #[inline]
    fn serialize_bytes(self, v: &[u8]) -> Result<Self::Ok, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        self.write_fixed(v);
        Ok(())
    }

    #[inline]
    fn serialize_none(self) -> Result<Self::Ok, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        self.write_fixed(0u8);
        Ok(())
    }

    #[inline]
    fn serialize_some<T: ?Sized>(self, value: &T) -> Result<Self::Ok, Self::Error>
    where
        T: Serialize,
    {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        self.write_fixed(1u8);
        value.serialize(self)
    }

    #[inline]
    fn serialize_unit(self) -> Result<Self::Ok, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        self.write_fixed(1u8);
        Ok(())
    }

    #[inline]
    fn serialize_unit_struct(self, _name: &'static str) -> Result<Self::Ok, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        self.write_fixed(1u8);
        Ok(())
    }

    #[inline]
    fn serialize_unit_variant(
        self,
        _name: &'static str,
        _variant_index: u32,
        variant: &'static str,
    ) -> Result<Self::Ok, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        self.write_fixed(variant);
        Ok(())
    }

    #[inline]
    fn serialize_newtype_struct<T: ?Sized>(
        self,
        _name: &'static str,
        value: &T,
    ) -> Result<Self::Ok, Self::Error>
    where
        T: Serialize,
    {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        value.serialize(self)
    }

    #[inline]
    fn serialize_newtype_variant<T: ?Sized>(
        self,
        _name: &'static str,
        _variant_index: u32,
        variant: &'static str,
        value: &T,
    ) -> Result<Self::Ok, Self::Error>
    where
        T: Serialize,
    {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        self.write_fixed(variant);
        value.serialize(self)
    }

    #[inline]
    fn serialize_seq(self, len: Option<usize>) -> Result<Self::SerializeSeq, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        Ok(DataSerializeSeq::new(self, len))
    }

    #[inline]
    fn serialize_tuple(self, len: usize) -> Result<Self::SerializeTuple, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        Ok(DataSerializeTuple::new(self, len))
    }

    #[inline]
    fn serialize_tuple_struct(
        self,
        _name: &'static str,
        len: usize,
    ) -> Result<Self::SerializeTupleStruct, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        Ok(DataSerializeTupleStruct::new(self, len))
    }

    #[inline]
    fn serialize_tuple_variant(
        self,
        _name: &'static str,
        _variant_index: u32,
        variant: &'static str,
        len: usize,
    ) -> Result<Self::SerializeTupleVariant, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        Ok(DataSerializeTupleVariant::new(self, variant, len))
    }

    #[inline]
    fn serialize_map(self, len: Option<usize>) -> Result<Self::SerializeMap, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        Ok(DataSerializeMap::new(self, len))
    }

    #[inline]
    fn serialize_struct(
        self,
        _name: &'static str,
        len: usize,
    ) -> Result<Self::SerializeStruct, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        Ok(DataSerializeTupleStruct::new(self, len))
    }

    #[inline]
    fn serialize_struct_variant(
        self,
        _name: &'static str,
        _variant_index: u32,
        variant: &'static str,
        len: usize,
    ) -> Result<Self::SerializeStructVariant, Self::Error> {
        if self.mode == 1 {
            return Err(DataError::RollBack);
        }
        Ok(DataSerializeTupleVariant::new(self, variant, len))
    }
}