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

use {
    crate::{
        client::ClientId,
        it::{
            test_error::{TestError, TestResult},
            test_ifs::test_screenshot::TestJayScreenshot,
            test_object::TestObject,
            test_transport::TestTransport,
            testrun::ParseFull,
        },
        utils::{buffd::MsgParser, cell_ext::CellExt},
        video::dmabuf::DmaBuf,
        wire::{
            JayCompositorId,
            jay_compositor::{self, *},
        },
    },
    std::{cell::Cell, rc::Rc},
    uapi::OwnedFd,
};

pub struct TestJayCompositor {
    pub id: JayCompositorId,
    pub tran: Rc<TestTransport>,
    pub client_id: Cell<Option<ClientId>>,
}

impl TestJayCompositor {
    pub fn new(tran: &Rc<TestTransport>) -> Self {
        Self {
            id: tran.id(),
            tran: tran.clone(),
            client_id: Cell::new(None),
        }
    }

    pub async fn get_client_id(&self) -> Result<ClientId, TestError> {
        if self.client_id.is_none() {
            self.tran.send(GetClientId { self_id: self.id })?;
        }
        self.tran.sync().await;
        match self.client_id.get() {
            Some(c) => Ok(c),
            _ => bail!("Compositor did not send a client id"),
        }
    }

    pub fn enable_symmetric_delete(&self) -> TestResult {
        self.tran.send(EnableSymmetricDelete { self_id: self.id })?;
        Ok(())
    }

    pub async fn take_screenshot(
        &self,
        include_cursor: bool,
    ) -> Result<(DmaBuf, Option<Rc<OwnedFd>>), TestError> {
        self.tran.sync().await;
        self.tran.run.state.idle().await;
        let js = Rc::new(TestJayScreenshot {
            id: self.tran.id(),
            state: self.tran.run.state.clone(),
            drm_dev: Default::default(),
            planes: Default::default(),
            result: Default::default(),
        });
        self.tran.send(TakeScreenshot2 {
            self_id: self.id,
            id: js.id,
            include_cursor: include_cursor as _,
        })?;
        self.tran.add_obj(js.clone())?;
        self.tran.sync().await;
        match js.result.take() {
            Some(Ok(res)) => Ok((res, js.drm_dev.take())),
            Some(Err(res)) => bail!("Compositor could not take a screenshot: {}", res),
            None => bail!("Compositor did not send a screenshot"),
        }
    }

    fn handle_client_id(&self, parser: MsgParser<'_, '_>) -> Result<(), TestError> {
        let ev = jay_compositor::ClientId::parse_full(parser)?;
        self.client_id.set(Some(ClientId::from_raw(ev.client_id)));
        self.tran.client_id.set(ClientId::from_raw(ev.client_id));
        Ok(())
    }

    fn handle_seat(&self, parser: MsgParser<'_, '_>) -> Result<(), TestError> {
        let _ev = Seat::parse_full(parser)?;
        Ok(())
    }

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

test_object! {
    TestJayCompositor, JayCompositor;

    CLIENT_ID => handle_client_id,
    SEAT => handle_seat,
    CAPABILITIES => handle_capabilities,
}

impl TestObject for TestJayCompositor {}