hyprwire 0.2.8

A fast and consistent wire protocol for IPC
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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

use crate::message;
use libffi::low;
use std::sync::Arc;

#[repr(u8)]
#[derive(Debug, Copy, Clone, PartialEq, Eq)]
pub enum MessageMagic {
    /// Signifies an end of a message
    End = 0x0,

    /// Primitive type identifiers
    TypeUint = 0x10,
    TypeInt = 0x11,
    TypeF32 = 0x12,
    TypeSeq = 0x13,
    TypeObjectId = 0x14,

    /// Variable length types
    /// [magic : 1B][len : VLQ][data : len B]
    TypeVarchar = 0x20,

    /// [magic : 1B][type : 1B][`n_els` : VLQ]{ [data...] }
    TypeArray = 0x21,

    /// [magic : 1B][id : UINT][`name_len` : VLQ][object name ...]
    TypeObject = 0x22,

    /// Special types
    /// FD has size 0. It's passed via control.
    TypeFd = 0x40,
}

impl MessageMagic {
    pub(crate) fn to_ffi_type(self) -> *mut low::ffi_type {
        match self {
            Self::TypeUint | Self::TypeObject | Self::TypeSeq | Self::TypeObjectId => {
                &raw mut low::types::uint32
            }
            Self::TypeInt | Self::TypeFd => &raw mut low::types::sint32,
            Self::TypeVarchar | Self::TypeArray => &raw mut low::types::pointer,
            Self::TypeF32 => &raw mut low::types::float,
            Self::End => &raw mut low::types::void,
        }
    }
}

impl TryFrom<u8> for MessageMagic {
    type Error = message::Error;

    fn try_from(value: u8) -> Result<Self, Self::Error> {
        match value {
            0x00 => Ok(Self::End),
            0x10 => Ok(Self::TypeUint),
            0x11 => Ok(Self::TypeInt),
            0x12 => Ok(Self::TypeF32),
            0x13 => Ok(Self::TypeSeq),
            0x14 => Ok(Self::TypeObjectId),
            0x20 => Ok(Self::TypeVarchar),
            0x21 => Ok(Self::TypeArray),
            0x22 => Ok(Self::TypeObject),
            0x40 => Ok(Self::TypeFd),
            _ => Err(message::Error::MalformedMessage),
        }
    }
}

pub enum CallArg<'a> {
    Uint(u32),
    Int(i32),
    F32(f32),
    Object(u32),
    Varchar(&'a [u8]),
    Fd(i32),
    UintArray(&'a [u32]),
    IntArray(&'a [i32]),
    F32Array(&'a [f32]),
    ObjectArray(&'a [u32]),
    FdArray(&'a [i32]),
    VarcharArray(&'a [&'a [u8]]),
}

pub struct Method {
    pub idx: u32,
    pub params: &'static [u8],
    pub returns_type: &'static str,
    pub since: u32,
    pub destructor: bool,
}

pub trait ProtocolObjectSpec: Send + Sync {
    fn object_name(&self) -> &str;

    fn c2s(&self) -> &[Method];

    fn s2c(&self) -> &[Method];
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn message_magic_known_values_try_from() {
        let known: &[u8] = &[0x00, 0x10, 0x11, 0x12, 0x13, 0x14, 0x20, 0x21, 0x22, 0x40];
        for &byte in known {
            assert!(
                MessageMagic::try_from(byte).is_ok(),
                "expected Ok for byte={byte:#04x}"
            );
        }
    }

    #[test]
    fn message_magic_unknown_value_fails() {
        assert!(MessageMagic::try_from(0xFF_u8).is_err());
    }
}

pub trait ProtocolSpec {
    fn spec_name(&self) -> &str;

    fn spec_ver(&self) -> u32;

    fn objects(&self) -> &[Arc<dyn ProtocolObjectSpec>];
}