breadx 0.2.9

Implementation of the X Window System Protocol
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

// MIT/Apache2 License

use breadx::{auto::AsByteSequence, Connection, Fd, Setup};
use std::iter;

/// A connection that stores requests.
pub struct VoidConnection {
    requests: Vec<Box<[u8]>>,
    buffer: Vec<u8>,
}

impl Connection for VoidConnection {
    #[inline]
    fn send_packet(&mut self, bytes: &[u8], fds: &mut Vec<Fd>) -> breadx::Result {
        assert!(fds.is_empty());
        self.requests.push(bytes.into());
        Ok(())
    }

    #[inline]
    fn read_packet(&mut self, bytes: &mut [u8], _fds: &mut Vec<Fd>) -> breadx::Result {
        self.buffer
            .drain(..bytes.len())
            .enumerate()
            .for_each(|(i, b)| {
                bytes[i] = b;
            });
        Ok(())
    }
}

impl VoidConnection {
    #[inline]
    pub fn from_setup(setup: Setup) -> Self {
        let mut buffer = iter::repeat(0).take(setup.size()).collect::<Vec<u8>>();
        setup.as_bytes(&mut buffer);
        buffer[0] = 1;

        Self {
            requests: Vec::new(),
            buffer,
        }
    }

    #[inline]
    pub fn buffer(&mut self, bytes: &[u8]) {
        self.buffer.extend_from_slice(bytes);
    }

    #[inline]
    pub fn audit(&self, bytes: &[Box<[u8]>]) {
        self.requests
            .iter()
            .zip(bytes.iter())
            .for_each(|(ours, theirs)| {
                if ours != theirs {
                    panic!(
                        "Byte mismatch:\n Should've been: {:?}\n Was: {:?}",
                        theirs, ours
                    );
                }
            });
    }
}