lxmf-wire 0.2.0

Core LXMF wire format, message primitives, and identity helpers for LXMF-rs.
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

use serde::{Deserialize, Serialize};
use serde_bytes::ByteBuf;

use crate::error::LxmfError;
use crate::message::{MessageState, TransportMethod};
use alloc::string::String;
use alloc::string::ToString;
use alloc::vec::Vec;

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct MessageContainer {
    pub state: u8,
    pub lxmf_bytes: ByteBuf,
    pub transport_encrypted: bool,
    pub transport_encryption: Option<String>,
    pub method: u8,
}

impl MessageContainer {
    pub fn from_msgpack(bytes: &[u8]) -> Result<Self, LxmfError> {
        rmp_serde::from_slice(bytes).map_err(|e| LxmfError::Decode(e.to_string()))
    }

    pub fn to_msgpack(&self) -> Result<Vec<u8>, LxmfError> {
        let mut out = Vec::new();
        let mut serializer = rmp_serde::Serializer::new(&mut out).with_struct_map();
        self.serialize(&mut serializer).map_err(|e| LxmfError::Encode(e.to_string()))?;
        Ok(out)
    }

    pub fn state_enum(&self) -> Result<MessageState, LxmfError> {
        MessageState::try_from(self.state)
            .map_err(|_| LxmfError::Decode("unknown message state".into()))
    }

    pub fn method_enum(&self) -> Result<TransportMethod, LxmfError> {
        TransportMethod::try_from(self.method)
            .map_err(|_| LxmfError::Decode("unknown transport method".into()))
    }
}