sealrs 0.13.2

Set of classic asynchronous primitives (Actors, Executors, Futures / Promises)
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

// This struct describes how to serialize and deserialize messages. For simplification reasons,
// serde_json is used for generating and parsing binary data. This struct represents server
// side serializer, he may serialize Data message and deserialize SendData message.

use crate::actors::prelude::*;
use super::storage;
use std::sync::{Arc, Mutex};
use bytes::{BytesMut, Bytes, Buf, BufMut, BigEndian};

pub struct MsgSerializer {}

impl MsgSerializer {
    pub fn new() -> MsgSerializer {
        MsgSerializer {}
    }
}

impl MessagesSerializer for MsgSerializer {
    fn to_binary(&mut self, msg: Message) -> Result<SerializedMessage, SerializationError> {
        let msg = msg.get();
        match_downcast_ref!(msg, {
            m: storage::responses::Data => {
                let s = serde_json::to_string(&m).unwrap();
                let mut buf = Vec::new();
                buf.put(s.as_bytes());
                Ok(SerializedMessage { marker: 2, blob: buf })
            },
            _ => Err(SerializationError::UnsupportedMessage)
        })
    }

    fn from_binary(&mut self, marker: u32, blob: Vec<u8>) -> Result<Message, SerializationError> {
        match marker {
            1 => {
                let string = std::str::from_utf8(&blob);
                if string.is_ok() {
                    let m: Result<storage::commands::GetData, serde_json::Error> = serde_json::from_str(string.unwrap());
                    if m.is_ok() {
                        Ok(msg!(m.ok().unwrap()))
                    } else {
                        Err(SerializationError::DamagedBlob)
                    }
                } else {
                    Err(SerializationError::DamagedBlob)
                }
            },
            _ => Err(SerializationError::UnsupportedMessage)
        }
    }
}