jay-compositor 1.13.0

The Jay compositor
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

use {
    crate::{
        ifs::wl_seat::WlSeat,
        it::{
            test_error::{TestError, TestResult},
            test_ifs::{test_keyboard::TestKeyboard, test_pointer::TestPointer},
            test_object::TestObject,
            test_transport::TestTransport,
            testrun::ParseFull,
        },
        utils::{buffd::MsgParser, clonecell::CloneCell, once::Once},
        wire::{WlSeatId, wl_seat::*},
    },
    std::{cell::Cell, rc::Rc},
};

pub struct TestSeat {
    pub id: WlSeatId,
    pub tran: Rc<TestTransport>,
    pub server: CloneCell<Option<Rc<WlSeat>>>,
    pub destroyed: Once,
    pub caps: Cell<u32>,
    pub name: CloneCell<Option<Rc<String>>>,
}

impl TestSeat {
    pub fn destroy(&self) -> Result<(), TestError> {
        if self.destroyed.set() {
            self.tran.send(Release { self_id: self.id })?;
        }
        Ok(())
    }

    pub async fn get_keyboard(&self) -> TestResult<Rc<TestKeyboard>> {
        let id = self.tran.id();
        self.tran.send(GetKeyboard {
            self_id: self.id,
            id,
        })?;
        let kb = Rc::new(TestKeyboard {
            id,
            tran: self.tran.clone(),
            server: Default::default(),
            destroyed: Default::default(),
            keymap: Default::default(),
            key: Default::default(),
            modifiers: Default::default(),
            enter: Default::default(),
            leave: Default::default(),
            event_id: Default::default(),
        });
        self.tran.add_obj(kb.clone())?;
        self.tran.sync().await;
        let server = self.tran.get_server_obj(id)?;
        kb.server.set(Some(server));
        Ok(kb)
    }

    pub async fn get_pointer(&self) -> TestResult<Rc<TestPointer>> {
        let id = self.tran.id();
        self.tran.send(GetPointer {
            self_id: self.id,
            id,
        })?;
        let pointer = Rc::new(TestPointer {
            id,
            tran: self.tran.clone(),
            server: Default::default(),
            destroyed: Default::default(),
            leave: Rc::new(Default::default()),
            enter: Rc::new(Default::default()),
            motion: Rc::new(Default::default()),
            button: Rc::new(Default::default()),
            axis_relative_direction: Rc::new(Default::default()),
        });
        self.tran.add_obj(pointer.clone())?;
        self.tran.sync().await;
        let server = self.tran.get_server_obj(id)?;
        pointer.server.set(Some(server));
        Ok(pointer)
    }

    fn handle_capabilities(&self, parser: MsgParser<'_, '_>) -> Result<(), TestError> {
        let ev = Capabilities::parse_full(parser)?;
        self.caps.set(ev.capabilities);
        Ok(())
    }

    fn handle_name(&self, parser: MsgParser<'_, '_>) -> Result<(), TestError> {
        let ev = Name::parse_full(parser)?;
        self.name.set(Some(Rc::new(ev.name.to_string())));
        Ok(())
    }
}

impl Drop for TestSeat {
    fn drop(&mut self) {
        let _ = self.destroy();
    }
}

test_object! {
    TestSeat, WlSeat;

    CAPABILITIES => handle_capabilities,
    NAME => handle_name,
}

impl TestObject for TestSeat {}