queen 0.26.0

message queue
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

use crate::crypto::Crypto;
use crate::error::{Result, Error};
use crate::nson::Message;

pub trait Codec: Send + 'static {
    fn new() -> Self;

    fn decode(&mut self, crypto: &Option<Crypto>, bytes: Vec<u8>) -> Result<Message>;

    fn encode(&mut self, crypto: &Option<Crypto>, message: Message) -> Result<Vec<u8>>;
}

pub struct NsonCodec;

impl Codec for NsonCodec {
    fn new() -> Self {
        NsonCodec
    }

    fn decode(&mut self, crypto: &Option<Crypto>, mut bytes: Vec<u8>) -> Result<Message> {
        if let Some(crypto) = &crypto {
            crypto.decrypt(&mut bytes).map_err(|err|
                Error::InvalidData(format!("{}", err))
            )?;
        }

        let recv = Message::from_bytes(&bytes);

        recv.map_err(|err| Error::InvalidData(format!("{}", err)))
    }

    fn encode(&mut self, crypto: &Option<Crypto>, message: Message) -> Result<Vec<u8>> {
        let mut bytes = message.to_bytes().map_err(|err| Error::InvalidData(format!("{}", err)) )?;

        if let Some(crypto) = &crypto {
            crypto.encrypt(&mut bytes).map_err(|err|
                Error::InvalidData(format!("{}", err))
            )?;
        }

        Ok(bytes)
    }
}