rusty-tracks 0.0.11

Rust client to connect to DataTracks.
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
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

use flatbuffers::{FlatBufferBuilder, WIPOffset};
use track_rails::message_generated::protocol;
use track_rails::message_generated::protocol::{Bool, BoolArgs, Float, FloatArgs, Integer, IntegerArgs, Null, NullArgs, Text, TextArgs, ValueWrapper, ValueWrapperArgs};

#[derive(Debug)]
pub enum Value {
    Text(String),
    Number(i64),
    Float(f64),
    Bool(bool),
    Null,
}

impl Value{
    pub fn flatternize<'b>(&self, builder: & mut FlatBufferBuilder<'b>) -> WIPOffset<ValueWrapper<'b>> {
        match self {
            Value::Text(t) => {
                let text = builder.create_string(t.as_str());
                let text = Text::create(builder, &TextArgs{data: Some(text)}).as_union_value();
                ValueWrapper::create(builder, &ValueWrapperArgs{ data_type: protocol::Value::Text, data: Some(text) })
            }
            Value::Number(n) => {
                let number = Integer::create(builder, &IntegerArgs{data: *n }).as_union_value();
                ValueWrapper::create(builder, &ValueWrapperArgs{ data_type: protocol::Value::Integer, data: Some(number) })
            }
            Value::Float(f) => {
                let float = Float::create(builder, &FloatArgs{data: *f as f32 }).as_union_value();
                ValueWrapper::create(builder, &ValueWrapperArgs{ data_type: protocol::Value::Float, data: Some(float) })
            }
            Value::Bool(b) => {
                let bool = Bool::create(builder, &BoolArgs{data: *b}).as_union_value();
                ValueWrapper::create(builder, &ValueWrapperArgs{ data_type: protocol::Value::Bool, data: Some(bool) })
            }
            Value::Null => {
                let null = Null::create(builder, &NullArgs{}).as_union_value();
                ValueWrapper::create(builder, &ValueWrapperArgs{ data_type: protocol::Value::Null, data: Some(null) })
            }
        }

    }
}

impl From<i64> for Value {
    fn from(value: i64) -> Self {
        Value::Number(value)
    }
}

impl From<f64> for Value {
    fn from(value: f64) -> Self {
        Value::Float(value)
    }
}

impl From<bool> for Value {
    fn from(value: bool) -> Self {
        Value::Bool(value)
    }
}

impl From<String> for Value {
    fn from(value: String) -> Self {
        Value::Text(value)
    }
}

impl From<&str> for Value {
    fn from(value: &str) -> Self {
        Value::Text(value.to_string())
    }
}

impl<'a> From<ValueWrapper<'a>> for Value {
    fn from(value: ValueWrapper<'a>) -> Self {
        match value.data_type() {
            protocol::Value::Integer => {
                let int = value.data_as_integer().unwrap();
                Value::Number(int.data() as i64)
            }
            protocol::Value::Float => {
                let float = value.data_as_float().unwrap();
                Value::Float(float.data() as f64)
            }
            protocol::Value::Bool => {
                let bool = value.data_as_bool().unwrap();
                Value::Bool(bool.data())
            }
            protocol::Value::Text => {
                let text = value.data_as_text().unwrap();
                Value::Text(text.data().to_string())
            }
            protocol::Value::Null => {
                Value::Null
            },
            _ => todo!()
        }
    }
}