1#![allow(clippy::too_many_arguments)]
7
8#[allow(unused_imports)]
9use std::borrow::Cow;
10#[allow(unused_imports)]
11use std::convert::TryInto;
12#[allow(unused_imports)]
13use crate::utils::RawFdContainer;
14#[allow(unused_imports)]
15use crate::x11_utils::{Request, RequestHeader, Serialize, TryParse, TryParseFd};
16use std::io::IoSlice;
17use crate::connection::RequestConnection;
18#[allow(unused_imports)]
19use crate::connection::Connection as X11Connection;
20#[allow(unused_imports)]
21use crate::cookie::{Cookie, CookieWithFds, VoidCookie};
22use crate::errors::ConnectionError;
23#[allow(unused_imports)]
24use crate::errors::ReplyOrIdError;
25use std::future::Future;
26use std::pin::Pin;
27#[allow(unused_imports)]
28use super::xproto;
29
30pub use x11rb_protocol::protocol::xtest::*;
31
32async fn major_opcode<Conn: RequestConnection + ?Sized>(conn: &Conn) -> Result<u8, ConnectionError> {
34 let info = conn.extension_information(X11_EXTENSION_NAME).await?;
35 let info = info.ok_or(ConnectionError::UnsupportedExtension)?;
36 Ok(info.major_opcode)
37}
38
39pub async fn get_version<Conn>(conn: &Conn, major_version: u8, minor_version: u16) -> Result<Cookie<'_, Conn, GetVersionReply>, ConnectionError>
40where
41 Conn: RequestConnection + ?Sized,
42{
43 let request0 = GetVersionRequest {
44 major_version,
45 minor_version,
46 };
47 let (bytes, fds) = request0.serialize(major_opcode(conn).await?);
48 let slices = [IoSlice::new(&bytes[0])];
49 assert_eq!(slices.len(), bytes.len());
50 conn.send_request_with_reply(&slices, fds).await
51}
52pub async fn compare_cursor<Conn>(conn: &Conn, window: xproto::Window, cursor: xproto::Cursor) -> Result<Cookie<'_, Conn, CompareCursorReply>, ConnectionError>
53where
54 Conn: RequestConnection + ?Sized,
55{
56 let request0 = CompareCursorRequest {
57 window,
58 cursor,
59 };
60 let (bytes, fds) = request0.serialize(major_opcode(conn).await?);
61 let slices = [IoSlice::new(&bytes[0])];
62 assert_eq!(slices.len(), bytes.len());
63 conn.send_request_with_reply(&slices, fds).await
64}
65pub async fn fake_input<Conn>(conn: &Conn, type_: u8, detail: u8, time: u32, root: xproto::Window, root_x: i16, root_y: i16, deviceid: u8) -> Result<VoidCookie<'_, Conn>, ConnectionError>
66where
67 Conn: RequestConnection + ?Sized,
68{
69 let request0 = FakeInputRequest {
70 type_,
71 detail,
72 time,
73 root,
74 root_x,
75 root_y,
76 deviceid,
77 };
78 let (bytes, fds) = request0.serialize(major_opcode(conn).await?);
79 let slices = [IoSlice::new(&bytes[0])];
80 assert_eq!(slices.len(), bytes.len());
81 conn.send_request_without_reply(&slices, fds).await
82}
83pub async fn grab_control<Conn>(conn: &Conn, impervious: bool) -> Result<VoidCookie<'_, Conn>, ConnectionError>
84where
85 Conn: RequestConnection + ?Sized,
86{
87 let request0 = GrabControlRequest {
88 impervious,
89 };
90 let (bytes, fds) = request0.serialize(major_opcode(conn).await?);
91 let slices = [IoSlice::new(&bytes[0])];
92 assert_eq!(slices.len(), bytes.len());
93 conn.send_request_without_reply(&slices, fds).await
94}
95pub trait ConnectionExt: RequestConnection {
97 fn xtest_get_version(&self, major_version: u8, minor_version: u16) -> Pin<Box<dyn Future<Output = Result<Cookie<'_, Self, GetVersionReply>, ConnectionError>> + Send + '_>>
98 {
99 Box::pin(get_version(self, major_version, minor_version))
100 }
101 fn xtest_compare_cursor(&self, window: xproto::Window, cursor: xproto::Cursor) -> Pin<Box<dyn Future<Output = Result<Cookie<'_, Self, CompareCursorReply>, ConnectionError>> + Send + '_>>
102 {
103 Box::pin(compare_cursor(self, window, cursor))
104 }
105 fn xtest_fake_input(&self, type_: u8, detail: u8, time: u32, root: xproto::Window, root_x: i16, root_y: i16, deviceid: u8) -> Pin<Box<dyn Future<Output = Result<VoidCookie<'_, Self>, ConnectionError>> + Send + '_>>
106 {
107 Box::pin(fake_input(self, type_, detail, time, root, root_x, root_y, deviceid))
108 }
109 fn xtest_grab_control(&self, impervious: bool) -> Pin<Box<dyn Future<Output = Result<VoidCookie<'_, Self>, ConnectionError>> + Send + '_>>
110 {
111 Box::pin(grab_control(self, impervious))
112 }
113}
114
115impl<C: RequestConnection + ?Sized> ConnectionExt for C {}