use std::fmt; use std::error; extern crate serde; use self::serde::Serialize; use self::serde::bytes::{ByteBuf, Bytes}; /////////////////////////////////////////////////////////////////////////////// #[derive(Debug, PartialEq)] struct Error; impl serde::ser::Error for Error { fn custom>(_: T) -> Error { Error } } impl serde::de::Error for Error { fn custom>(_: T) -> Error { Error } fn end_of_stream() -> Error { Error } } impl fmt::Display for Error { fn fmt(&self, formatter: &mut fmt::Formatter) -> Result<(), fmt::Error> { formatter.write_str(format!("{:?}", self).as_ref()) } } impl error::Error for Error { fn description(&self) -> &str { "Serde Deserialization Error" } fn cause(&self) -> Option<&error::Error> { None } } /////////////////////////////////////////////////////////////////////////////// struct BytesSerializer { bytes: Vec, } impl BytesSerializer { fn new(bytes: Vec) -> Self { BytesSerializer { bytes: bytes, } } } impl serde::Serializer for BytesSerializer { type Error = Error; fn serialize_unit(&mut self) -> Result<(), Error> { Err(Error) } fn serialize_bool(&mut self, _v: bool) -> Result<(), Error> { Err(Error) } fn serialize_i64(&mut self, _v: i64) -> Result<(), Error> { Err(Error) } fn serialize_u64(&mut self, _v: u64) -> Result<(), Error> { Err(Error) } fn serialize_f32(&mut self, _v: f32) -> Result<(), Error> { Err(Error) } fn serialize_f64(&mut self, _v: f64) -> Result<(), Error> { Err(Error) } fn serialize_char(&mut self, _v: char) -> Result<(), Error> { Err(Error) } fn serialize_str(&mut self, _v: &str) -> Result<(), Error> { Err(Error) } fn serialize_none(&mut self) -> Result<(), Error> { Err(Error) } fn serialize_some(&mut self, _value: V) -> Result<(), Error> where V: serde::Serialize, { Err(Error) } fn serialize_seq(&mut self, _visitor: V) -> Result<(), Error> where V: serde::ser::SeqVisitor, { Err(Error) } fn serialize_seq_elt(&mut self, _value: T) -> Result<(), Error> where T: serde::Serialize { Err(Error) } fn serialize_map(&mut self, _visitor: V) -> Result<(), Error> where V: serde::ser::MapVisitor, { Err(Error) } fn serialize_map_elt(&mut self, _key: K, _value: V) -> Result<(), Error> where K: serde::Serialize, V: serde::Serialize, { Err(Error) } fn serialize_bytes(&mut self, bytes: &[u8]) -> Result<(), Error> { assert_eq!(self.bytes, bytes); Ok(()) } } /////////////////////////////////////////////////////////////////////////////// struct BytesDeserializer { bytes: Option>, } impl BytesDeserializer { fn new(bytes: Vec) -> Self { BytesDeserializer { bytes: Some(bytes), } } } impl serde::Deserializer for BytesDeserializer { type Error = Error; fn deserialize(&mut self, _visitor: V) -> Result where V: serde::de::Visitor, { Err(Error) } fn deserialize_bytes(&mut self, mut visitor: V) -> Result where V: serde::de::Visitor, { visitor.visit_byte_buf(self.bytes.take().unwrap()) } } /////////////////////////////////////////////////////////////////////////////// #[test] fn test_bytes_ser_bytes() { let buf = vec![]; let bytes = Bytes::from(&buf); let mut ser = BytesSerializer::new(vec![]); bytes.serialize(&mut ser).unwrap(); let buf = vec![1, 2, 3]; let bytes = Bytes::from(&buf); let mut ser = BytesSerializer::new(vec![1, 2, 3]); bytes.serialize(&mut ser).unwrap(); } /////////////////////////////////////////////////////////////////////////////// #[test] fn test_byte_buf_de_bytes() { let mut de = BytesDeserializer::new(vec![]); let bytes = serde::Deserialize::deserialize(&mut de); assert_eq!(bytes, Ok(ByteBuf::new())); let mut de = BytesDeserializer::new(vec![1, 2, 3]); let bytes = serde::Deserialize::deserialize(&mut de); assert_eq!(bytes, Ok(ByteBuf::from(vec![1, 2, 3]))); }