1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111

pub mod ser;
pub mod de;

mod code_page;
pub use code_page::*;

use serde::de::DeserializeSeed;
use crate::code::de::*;
use serde::{Deserialize, Serialize};
use std::io::{Read, Write};
use crate::code::ser::*;

pub fn deserialize_from<'de, T: Deserialize<'de>>(reader: &'de mut (impl Read + ?Sized), code_page: CodePage, isolated: Option<u32>)
    -> Result<T, de::Error> {

    let mut reader = GenericReader::new(reader);
    let deserializer = EslDeserializer::new(isolated, code_page, &mut reader);
    T::deserialize(deserializer)
}

pub fn deserialize_from_seed<'de, T: DeserializeSeed<'de>>(seed: T, reader: &'de mut (impl Read + ?Sized), code_page: CodePage, isolated: Option<u32>)
    -> Result<T::Value, de::Error> {

    let mut reader = GenericReader::new(reader);
    let deserializer = EslDeserializer::new(isolated, code_page, &mut reader);
    seed.deserialize(deserializer)
}

pub fn deserialize_from_slice<'a, 'de, T: Deserialize<'de>>(bytes: &'a mut &'de [u8], code_page: CodePage, isolated: bool)
    -> Result<T, de::Error> {

    let deserializer = bytes_deserializer(bytes, code_page, isolated);
    T::deserialize(deserializer)
}

pub fn deserialize_from_slice_seed<'a, 'de, T: DeserializeSeed<'de>>(seed: T, bytes: &'a mut &'de [u8], code_page: CodePage, isolated: bool)
    -> Result<T::Value, de::Error> {

    let deserializer = bytes_deserializer(bytes, code_page, isolated);
    seed.deserialize(deserializer)
}

pub fn deserialize<'de, T: Deserialize<'de>>(mut bytes: &'de [u8], code_page: CodePage, isolated: bool)
    -> Result<T, de::ExtError> {

    let deserializer = bytes_deserializer(&mut bytes, code_page, isolated);
    let res = T::deserialize(deserializer)?;
    if !bytes.is_empty() {
        Err(de::ExtError::Unread(bytes))
    } else {
        Ok(res)
    }
}

pub fn deserialize_seed<'de, T: DeserializeSeed<'de>>(seed: T, mut bytes: &'de [u8], code_page: CodePage, isolated: bool)
    -> Result<T::Value, de::ExtError> {
    
    let deserializer = bytes_deserializer(&mut bytes, code_page, isolated);
    let res = seed.deserialize(deserializer)?;
    if !bytes.is_empty() {
        Err(de::ExtError::Unread(bytes))
    } else {
        Ok(res)
    }
}

fn bytes_deserializer<'a, 'de>(bytes: &'a mut &'de [u8], code_page: CodePage, isolated: bool) -> EslDeserializer<'static, 'a, 'de, &'de [u8]> {
    assert!(!isolated || bytes.len() <= u32::max_value() as usize);
    EslDeserializer::new(if isolated { Some(bytes.len() as u32) } else { None }, code_page, bytes)
}

pub fn serialized_size<T: Serialize + ?Sized>(v: &T, code_page: CodePage, isolated: bool) -> Result<usize, ser::IoError> {
    let mut writer = Size(0);
    let serializer = EslSerializer::new(isolated, code_page, &mut writer);
    v.serialize(serializer)?;
    Ok(writer.0)
}

pub fn serialize_into<T: Serialize + ?Sized>(v: &T, writer: &mut (impl Write + ?Sized), code_page: CodePage, isolated: bool) -> Result<(), ser::IoError> {
    let mut writer = GenericWriter::new(writer);
    let serializer = EslSerializer::new(isolated, code_page, &mut writer);
    v.serialize(serializer)
}

pub fn serialize_into_slice<'a, 'b: 'a, T: Serialize + ?Sized>(v: &T, bytes: &'b mut &'a mut [u8], code_page: CodePage, isolated: bool) -> Result<(), ser::IoError> {
    let mut writer = SliceWriter::new(*bytes);
    let serializer = EslSerializer::new(isolated, code_page, &mut writer);
    v.serialize(serializer)?;
    let written = writer.written();
    *bytes = &mut (*bytes)[written ..];
    Ok(())
}

fn no_io_error(e: ser::IoError) -> ser::Error {
    match e {
        ser::IoError::Other(e) => e,
        ser::IoError::Io(_) => unreachable!()
    }
}

pub fn serialize_into_vec<T: Serialize + ?Sized>(v: &T, bytes: &mut Vec<u8>, code_page: CodePage, isolated: bool) -> Result<(), ser::Error> {
    let serializer = EslSerializer::new(isolated, code_page, bytes);
    v.serialize(serializer).map_err(no_io_error)
}

pub fn serialize<T: Serialize + ?Sized>(v: &T, code_page: CodePage, isolated: bool) -> Result<Vec<u8>, ser::Error> {
    let mut bytes = Vec::new();
    let serializer = EslSerializer::new(isolated, code_page, &mut bytes);
    v.serialize(serializer).map_err(no_io_error)?;
    Ok(bytes)
}