tycho 0.1.2

A minimal, self-describing and traversable binary data format designed around rust and the serde data model.
Documentation 
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

use tokio::io::AsyncRead;

use crate::error::{TychoError, TychoResult};
use crate::ident::ValueIdent;
use crate::read::async_::func::{read_byte_async, read_bytes_async};
use crate::read::async_::length::read_length_async;
use crate::read::async_::number::{read_number_async, read_number_ident_async};
use crate::read::async_::string::{read_char_async, read_string_async};
use crate::{Value, Uuid};

pub(crate) async fn read_value_ident_async<R: AsyncRead + Unpin>(reader: &mut R) -> TychoResult<ValueIdent> {
    let byte = read_byte_async(reader).await?;

    match byte {
        0x00 => Ok(ValueIdent::Null),
        0x01 => Ok(ValueIdent::Boolean),
        0x02 => Ok(ValueIdent::String),
        0x03 => Ok(ValueIdent::Char),
        0x04 => Ok(ValueIdent::Number(read_number_ident_async(reader).await?)),
        0x05 => Ok(ValueIdent::Bytes),
        0x06 => Ok(ValueIdent::UUID),

        _ => Err(TychoError::InvalidIdent { found: byte, expecting: "value ident".to_string() })
    }
}

pub(crate) async fn read_value_async<R: AsyncRead + Unpin>(reader: &mut R, ident: &ValueIdent) -> TychoResult<Value> {
    match ident {
        ValueIdent::Null => Ok(Value::Null),
        ValueIdent::Boolean => Ok(Value::Boolean(read_byte_async(reader).await? == 0x01)),
        ValueIdent::String => Ok(Value::String(read_string_async(reader).await?)),
        ValueIdent::Char => Ok(Value::Char(read_char_async(reader).await?)),
        ValueIdent::Number(n) => Ok(Value::Number(read_number_async(reader, n).await?)),
        ValueIdent::Bytes => {
            let length = read_length_async(reader).await?;
            Ok(Value::Bytes(read_bytes_async(reader, length).await?))
        }
        ValueIdent::UUID => {
            // suffering
            let bytes = [
                read_byte_async(reader).await?, read_byte_async(reader).await?,
                read_byte_async(reader).await?, read_byte_async(reader).await?,
                read_byte_async(reader).await?, read_byte_async(reader).await?,
                read_byte_async(reader).await?, read_byte_async(reader).await?,
                read_byte_async(reader).await?, read_byte_async(reader).await?,
                read_byte_async(reader).await?, read_byte_async(reader).await?,
                read_byte_async(reader).await?, read_byte_async(reader).await?,
                read_byte_async(reader).await?, read_byte_async(reader).await?,
            ];
            Ok(Value::UUID(Uuid::from_slice(bytes)))
        }
    }
}