1use std::collections::HashMap;
18use std::sync::Mutex;
19
20use x11rb::connection::Connection;
21use x11rb::protocol::xproto::{ConnectionExt as _, ImageFormat};
22use x11rb::rust_connection::RustConnection;
23use zbus::blocking::Connection as ZbusConnection;
24use zbus::blocking::Proxy;
25use zbus::zvariant::{OwnedObjectPath, OwnedValue, Value};
26
27use xa11y_core::{Error, Point, Rect, Result, Screenshot, ScreenshotProvider};
28
29pub struct LinuxScreenshot {
31 backend: Backend,
32}
33
34enum Backend {
39 X11(Box<X11Backend>),
40 Wayland { conn: ZbusConnection },
41}
42
43struct X11Backend {
44 conn: Mutex<RustConnection>,
45 root_width: u16,
46 root_height: u16,
47 root: u32,
48}
49
50impl LinuxScreenshot {
51 pub fn new() -> Result<Self> {
52 let display_set = std::env::var_os("DISPLAY").is_some();
53 let wayland = std::env::var_os("WAYLAND_DISPLAY").is_some();
54
55 if display_set {
56 let (conn, screen_num) =
57 RustConnection::connect(None).map_err(|e| Error::Platform {
58 code: -1,
59 message: format!("X11 connect: {e}"),
60 })?;
61 let screen = conn
62 .setup()
63 .roots
64 .get(screen_num)
65 .ok_or_else(|| Error::Platform {
66 code: -1,
67 message: "X server reported no screens".into(),
68 })?;
69 let root = screen.root;
70 let root_width = screen.width_in_pixels;
71 let root_height = screen.height_in_pixels;
72 Ok(Self {
73 backend: Backend::X11(Box::new(X11Backend {
74 conn: Mutex::new(conn),
75 root,
76 root_width,
77 root_height,
78 })),
79 })
80 } else if wayland {
81 let conn = ZbusConnection::session().map_err(|e| Error::Platform {
82 code: -1,
83 message: format!("session bus connect: {e}"),
84 })?;
85 Ok(Self {
86 backend: Backend::Wayland { conn },
87 })
88 } else {
89 Err(Error::Unsupported {
90 feature: "screenshot (no DISPLAY or WAYLAND_DISPLAY set)".into(),
91 })
92 }
93 }
94
95 fn capture_x11(
96 &self,
97 conn: &Mutex<RustConnection>,
98 root: u32,
99 root_w: u16,
100 root_h: u16,
101 rect: Option<Rect>,
102 ) -> Result<Screenshot> {
103 let (x, y, w, h) = match rect {
104 None => (0_i16, 0_i16, root_w, root_h),
105 Some(r) => {
106 let x = i16::try_from(r.x).map_err(|_| Error::Platform {
107 code: -1,
108 message: "rect x out of i16 range".into(),
109 })?;
110 let y = i16::try_from(r.y).map_err(|_| Error::Platform {
111 code: -1,
112 message: "rect y out of i16 range".into(),
113 })?;
114 let w = u16::try_from(r.width).map_err(|_| Error::Platform {
115 code: -1,
116 message: "rect width out of u16 range".into(),
117 })?;
118 let h = u16::try_from(r.height).map_err(|_| Error::Platform {
119 code: -1,
120 message: "rect height out of u16 range".into(),
121 })?;
122 (x, y, w, h)
123 }
124 };
125 if w == 0 || h == 0 {
126 return Err(Error::Platform {
127 code: -1,
128 message: "zero-sized capture rect".into(),
129 });
130 }
131
132 let guard = conn.lock().unwrap_or_else(|e| e.into_inner());
133 let reply = guard
134 .get_image(ImageFormat::Z_PIXMAP, root, x, y, w, h, !0)
135 .map_err(|e| Error::Platform {
136 code: -1,
137 message: format!("GetImage: {e}"),
138 })?
139 .reply()
140 .map_err(|e| Error::Platform {
141 code: -1,
142 message: format!("GetImage reply: {e}"),
143 })?;
144
145 let bpp = (reply.data.len() / (w as usize * h as usize)) as u32;
148 if bpp != 4 {
149 return Err(Error::Platform {
150 code: -1,
151 message: format!("unsupported X11 pixmap layout: {bpp} bytes/pixel (expected 4)"),
152 });
153 }
154
155 let mut rgba = Vec::with_capacity(reply.data.len());
156 for chunk in reply.data.as_chunks::<4>().0 {
157 rgba.push(chunk[2]);
159 rgba.push(chunk[1]);
160 rgba.push(chunk[0]);
161 rgba.push(0xFF);
162 }
163
164 Ok(Screenshot::new(w as u32, h as u32, rgba, 1.0))
165 }
166
167 fn capture_wayland(&self, conn: &ZbusConnection, rect: Option<Rect>) -> Result<Screenshot> {
168 let proxy = Proxy::new(
169 conn,
170 "org.freedesktop.portal.Desktop",
171 "/org/freedesktop/portal/desktop",
172 "org.freedesktop.portal.Screenshot",
173 )
174 .map_err(|e| Error::Platform {
175 code: -1,
176 message: format!("portal Screenshot proxy: {e}"),
177 })?;
178
179 let mut options: HashMap<&str, Value> = HashMap::new();
180 options.insert("interactive", Value::Bool(false));
181 options.insert("modal", Value::Bool(false));
182
183 let request_path: OwnedObjectPath =
184 proxy
185 .call("Screenshot", &("", options))
186 .map_err(|e| Error::Platform {
187 code: -1,
188 message: format!("portal Screenshot call: {e}"),
189 })?;
190
191 let request = Proxy::new(
192 conn,
193 "org.freedesktop.portal.Desktop",
194 &request_path,
195 "org.freedesktop.portal.Request",
196 )
197 .map_err(|e| Error::Platform {
198 code: -1,
199 message: format!("portal Request proxy: {e}"),
200 })?;
201
202 let mut signals = request
204 .receive_signal("Response")
205 .map_err(|e| Error::Platform {
206 code: -1,
207 message: format!("receive_signal: {e}"),
208 })?;
209 let msg = signals.next().ok_or_else(|| Error::Platform {
210 code: -1,
211 message: "portal Response signal channel closed".into(),
212 })?;
213 let (response, results): (u32, HashMap<String, OwnedValue>) =
214 msg.body().deserialize().map_err(|e| Error::Platform {
215 code: -1,
216 message: format!("portal Response deserialize: {e}"),
217 })?;
218 if response != 0 {
219 return Err(Error::PermissionDenied {
220 instructions: format!("xdg-desktop-portal Screenshot denied (response={response})"),
221 });
222 }
223 let uri_val = results.get("uri").ok_or_else(|| Error::Platform {
224 code: -1,
225 message: "portal Response missing 'uri' key".into(),
226 })?;
227 let uri: String = uri_val
228 .downcast_ref::<String>()
229 .map_err(|_| Error::Platform {
230 code: -1,
231 message: "portal Response 'uri' is not a string".into(),
232 })?;
233 let path = uri.strip_prefix("file://").ok_or_else(|| Error::Platform {
234 code: -1,
235 message: format!("portal URI not file://: {uri}"),
236 })?;
237 let bytes = std::fs::read(path).map_err(|e| Error::Platform {
238 code: e.raw_os_error().unwrap_or(-1) as i64,
239 message: format!("read portal PNG: {e}"),
240 })?;
241 let _ = std::fs::remove_file(path);
243
244 let shot = decode_png_to_rgba(&bytes)?;
245 match rect {
246 None => Ok(shot),
247 Some(r) => crop_rgba(shot, r),
248 }
249 }
250}
251
252impl ScreenshotProvider for LinuxScreenshot {
253 fn capture_full(&self) -> Result<(Screenshot, Point)> {
254 let scale = crate::scale::screenshot_scale();
258 let mut shot = match &self.backend {
259 Backend::X11(x) => self.capture_x11(&x.conn, x.root, x.root_width, x.root_height, None),
260 Backend::Wayland { conn } => self.capture_wayland(conn, None),
261 }?;
262 shot.scale = scale as f32;
263 Ok((shot, Point::new(0, 0)))
270 }
271
272 fn capture_region(&self, rect: Rect) -> Result<Screenshot> {
273 let scale = crate::scale::screenshot_scale();
276 let phys = rect.to_physical(scale);
277 let mut shot = match &self.backend {
278 Backend::X11(x) => {
279 self.capture_x11(&x.conn, x.root, x.root_width, x.root_height, Some(phys))
280 }
281 Backend::Wayland { conn } => self.capture_wayland(conn, Some(phys)),
282 }?;
283 shot.scale = scale as f32;
284 Ok(shot)
285 }
286}
287
288fn decode_png_to_rgba(bytes: &[u8]) -> Result<Screenshot> {
289 let decoder = png::Decoder::new(std::io::Cursor::new(bytes));
290 let mut reader = decoder.read_info().map_err(|e| Error::Platform {
291 code: -1,
292 message: format!("png decode header: {e}"),
293 })?;
294 let info = reader.info().clone();
295 let buf_size = reader.output_buffer_size().ok_or_else(|| Error::Platform {
296 code: -1,
297 message: "png decode: output buffer size overflowed usize".to_string(),
298 })?;
299 let mut buf = vec![0u8; buf_size];
300 let frame = reader.next_frame(&mut buf).map_err(|e| Error::Platform {
301 code: -1,
302 message: format!("png decode frame: {e}"),
303 })?;
304 buf.truncate(frame.buffer_size());
305
306 let rgba = match (info.color_type, info.bit_depth) {
307 (png::ColorType::Rgba, png::BitDepth::Eight) => buf,
308 (png::ColorType::Rgb, png::BitDepth::Eight) => {
309 let mut out = Vec::with_capacity((info.width * info.height * 4) as usize);
310 for px in buf.as_chunks::<3>().0 {
311 out.extend_from_slice(&[px[0], px[1], px[2], 0xFF]);
312 }
313 out
314 }
315 (ct, bd) => {
316 return Err(Error::Platform {
317 code: -1,
318 message: format!("unsupported portal PNG format: {ct:?} @ {bd:?}"),
319 });
320 }
321 };
322
323 Ok(Screenshot::new(info.width, info.height, rgba, 1.0))
324}
325
326fn crop_rgba(shot: Screenshot, rect: Rect) -> Result<Screenshot> {
327 let (sw, sh, pixels, scale) = (shot.width, shot.height, shot.pixels, shot.scale);
328 let x = rect.x.max(0) as u32;
329 let y = rect.y.max(0) as u32;
330 if x >= sw || y >= sh {
331 return Err(Error::Platform {
332 code: -1,
333 message: "crop rect outside captured image".into(),
334 });
335 }
336 let w = rect.width.min(sw - x);
337 let h = rect.height.min(sh - y);
338 if w == 0 || h == 0 {
339 return Err(Error::Platform {
340 code: -1,
341 message: "crop rect has zero size".into(),
342 });
343 }
344 let mut out = Vec::with_capacity((w * h * 4) as usize);
345 for row in 0..h {
346 let start = ((y + row) * sw + x) as usize * 4;
347 let end = start + (w as usize) * 4;
348 out.extend_from_slice(&pixels[start..end]);
349 }
350 Ok(Screenshot::new(w, h, out, scale))
351}