sonet-rs 1.0.0

Lightweight TCP Communication Library
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

use crate::buffer::read::SonetReadBuf;
use crate::buffer::write::SonetWriteBuf;
use crate::packet::{Packet, PacketRegistry};

/// The Serializer & Deserializer for a pack
pub struct Codec {

    /// The packet registry
    pub registry: PacketRegistry,
}

impl Codec {

    /// Creates a new Codec instance
    pub fn new(registry: PacketRegistry) -> Codec {
        Codec { registry }
    }

    /// Serializes the packet object into a ReadBuffer
    pub fn serialize(&self, packet: &Box<dyn Packet>) -> SonetReadBuf {
        // Name of the packet
        let name = packet.get_name();

        // The types of the packet struct fields
        let types = packet.object_type_names();

        // The packet struct field values
        let data = packet.get_values();

        // New WriteBuf
        let mut buf = SonetWriteBuf::new();

        // Write the name to buffer
        buf.write_string(&name.to_string());

        // Write the values automatically
        buf.parse_types(types, data);

        // Convert WriteBuf -> ReadBuf
        let read_buf = buf.readable();

        let len = read_buf.data.len();

        let mut buf = SonetWriteBuf::new();
        
        buf.write_int(len as u32);

        buf.write_raw(read_buf.data.as_slice());

        buf.readable()
    }

    /// Deserializes the ReadBuffer into a packet instance
    pub fn deserialize(&self, buffer: &mut SonetReadBuf) -> Box<dyn Packet + Send + Sync> {
        // Read the packet's name
        let packet_name = buffer.read_string();

        // Get the instance-creation supplier from the registry.
        let packet_wrapper = self.registry.get(&packet_name);

        // Get the packet's struct field types
        let types = packet_wrapper.get_types();

        // Read the struct field values from ReadBuf
        let data = buffer.parse_types(types);

        // Create instance with the value given
        packet_wrapper.create_instance_box(data)
    }
}