omnimesh 1.0.1

Zero-allocation mesh networking middleware for autonomous robot fleets, edge-AI swarms, and multi-agent systems
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 super::header::{PayloadType, Priority};

#[repr(C, packed)]
pub struct RawEnvelopeHeader {
    pub magic: u32,
    pub version: u32,
    pub message_id: [u8; 16],
    pub sequence: u64,
    pub sender_did: [u8; 32],
    pub recipient_did: [u8; 32],
    pub timestamp_us: u64,
    pub priority: u8,
    pub payload_type: u8,
}

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum ParseError {
    Truncated,
    InvalidMagic(u32),
    InvalidPriority(u8),
    InvalidPayloadType(u8),
    PayloadOverflow,
}

impl RawEnvelopeHeader {
    pub const MAGIC: u32 = 0x4F4D4E49;
    pub const SIZE: usize = 106;

    pub fn size() -> usize {
        Self::SIZE
    }

    pub fn from_bytes(buf: &[u8]) -> Result<&Self, ParseError> {
        if buf.len() < Self::SIZE {
            return Err(ParseError::Truncated);
        }

        let ptr = buf.as_ptr() as *const Self;
        unsafe { Ok(&*ptr) }
    }
}

impl TryFrom<u8> for Priority {
    type Error = ParseError;

    fn try_from(value: u8) -> Result<Self, Self::Error> {
        match value {
            0 => Ok(Priority::Low),
            1 => Ok(Priority::Normal),
            2 => Ok(Priority::High),
            3 => Ok(Priority::Critical),
            invalid => Err(ParseError::InvalidPriority(invalid)),
        }
    }
}

impl TryFrom<u8> for PayloadType {
    type Error = ParseError;

    fn try_from(value: u8) -> Result<Self, Self::Error> {
        match value {
            0 => Ok(PayloadType::Raw),
            1 => Ok(PayloadType::RobotCommand),
            2 => Ok(PayloadType::ModelWeights),
            3 => Ok(PayloadType::InferenceResult),
            4 => Ok(PayloadType::SensorFusion),
            invalid => Err(ParseError::InvalidPayloadType(invalid)),
        }
    }
}