platform.rs

   1use std::{
   2    env,
   3    path::{Path, PathBuf},
   4    process::Command,
   5    rc::Rc,
   6    sync::Arc,
   7};
   8#[cfg(any(feature = "wayland", feature = "x11"))]
   9use std::{
  10    ffi::OsString,
  11    fs::File,
  12    io::Read as _,
  13    os::fd::{AsFd, AsRawFd, FromRawFd},
  14    time::Duration,
  15};
  16
  17use anyhow::{Context as _, anyhow};
  18use async_task::Runnable;
  19use calloop::{LoopSignal, channel::Channel};
  20use futures::channel::oneshot;
  21use util::ResultExt as _;
  22#[cfg(any(feature = "wayland", feature = "x11"))]
  23use xkbcommon::xkb::{self, Keycode, Keysym, State};
  24
  25use crate::{
  26    Action, AnyWindowHandle, BackgroundExecutor, ClipboardItem, CursorStyle, DisplayId,
  27    ForegroundExecutor, Keymap, LinuxDispatcher, Menu, MenuItem, OwnedMenu, PathPromptOptions,
  28    Pixels, Platform, PlatformDisplay, PlatformKeyboardLayout, PlatformTextSystem, PlatformWindow,
  29    Point, Result, Task, WindowAppearance, WindowParams, px,
  30};
  31
  32#[cfg(any(feature = "wayland", feature = "x11"))]
  33pub(crate) const SCROLL_LINES: f32 = 3.0;
  34
  35// Values match the defaults on GTK.
  36// Taken from https://github.com/GNOME/gtk/blob/main/gtk/gtksettings.c#L320
  37#[cfg(any(feature = "wayland", feature = "x11"))]
  38pub(crate) const DOUBLE_CLICK_INTERVAL: Duration = Duration::from_millis(400);
  39pub(crate) const DOUBLE_CLICK_DISTANCE: Pixels = px(5.0);
  40pub(crate) const KEYRING_LABEL: &str = "zed-github-account";
  41
  42#[cfg(any(feature = "wayland", feature = "x11"))]
  43const FILE_PICKER_PORTAL_MISSING: &str =
  44    "Couldn't open file picker due to missing xdg-desktop-portal implementation.";
  45
  46pub trait LinuxClient {
  47    fn compositor_name(&self) -> &'static str;
  48    fn with_common<R>(&self, f: impl FnOnce(&mut LinuxCommon) -> R) -> R;
  49    fn keyboard_layout(&self) -> Box<dyn PlatformKeyboardLayout>;
  50    fn displays(&self) -> Vec<Rc<dyn PlatformDisplay>>;
  51    #[allow(unused)]
  52    fn display(&self, id: DisplayId) -> Option<Rc<dyn PlatformDisplay>>;
  53    fn primary_display(&self) -> Option<Rc<dyn PlatformDisplay>>;
  54    #[cfg(feature = "screen-capture")]
  55    fn is_screen_capture_supported(&self) -> bool;
  56    #[cfg(feature = "screen-capture")]
  57    fn screen_capture_sources(
  58        &self,
  59    ) -> oneshot::Receiver<Result<Vec<Rc<dyn crate::ScreenCaptureSource>>>>;
  60
  61    fn open_window(
  62        &self,
  63        handle: AnyWindowHandle,
  64        options: WindowParams,
  65    ) -> anyhow::Result<Box<dyn PlatformWindow>>;
  66    fn set_cursor_style(&self, style: CursorStyle);
  67    fn open_uri(&self, uri: &str);
  68    fn reveal_path(&self, path: PathBuf);
  69    fn write_to_primary(&self, item: ClipboardItem);
  70    fn write_to_clipboard(&self, item: ClipboardItem);
  71    fn read_from_primary(&self) -> Option<ClipboardItem>;
  72    fn read_from_clipboard(&self) -> Option<ClipboardItem>;
  73    fn active_window(&self) -> Option<AnyWindowHandle>;
  74    fn window_stack(&self) -> Option<Vec<AnyWindowHandle>>;
  75    fn run(&self);
  76}
  77
  78#[derive(Default)]
  79pub(crate) struct PlatformHandlers {
  80    pub(crate) open_urls: Option<Box<dyn FnMut(Vec<String>)>>,
  81    pub(crate) quit: Option<Box<dyn FnMut()>>,
  82    pub(crate) reopen: Option<Box<dyn FnMut()>>,
  83    pub(crate) app_menu_action: Option<Box<dyn FnMut(&dyn Action)>>,
  84    pub(crate) will_open_app_menu: Option<Box<dyn FnMut()>>,
  85    pub(crate) validate_app_menu_command: Option<Box<dyn FnMut(&dyn Action) -> bool>>,
  86    pub(crate) keyboard_layout_change: Option<Box<dyn FnMut()>>,
  87}
  88
  89pub(crate) struct LinuxCommon {
  90    pub(crate) background_executor: BackgroundExecutor,
  91    pub(crate) foreground_executor: ForegroundExecutor,
  92    pub(crate) text_system: Arc<dyn PlatformTextSystem>,
  93    pub(crate) appearance: WindowAppearance,
  94    pub(crate) auto_hide_scrollbars: bool,
  95    pub(crate) callbacks: PlatformHandlers,
  96    pub(crate) signal: LoopSignal,
  97    pub(crate) menus: Vec<OwnedMenu>,
  98}
  99
 100impl LinuxCommon {
 101    pub fn new(signal: LoopSignal) -> (Self, Channel<Runnable>) {
 102        let (main_sender, main_receiver) = calloop::channel::channel::<Runnable>();
 103
 104        #[cfg(any(feature = "wayland", feature = "x11"))]
 105        let text_system = Arc::new(crate::CosmicTextSystem::new());
 106        #[cfg(not(any(feature = "wayland", feature = "x11")))]
 107        let text_system = Arc::new(crate::NoopTextSystem::new());
 108
 109        let callbacks = PlatformHandlers::default();
 110
 111        let dispatcher = Arc::new(LinuxDispatcher::new(main_sender.clone()));
 112
 113        let background_executor = BackgroundExecutor::new(dispatcher.clone());
 114
 115        let common = LinuxCommon {
 116            background_executor,
 117            foreground_executor: ForegroundExecutor::new(dispatcher.clone()),
 118            text_system,
 119            appearance: WindowAppearance::Light,
 120            auto_hide_scrollbars: false,
 121            callbacks,
 122            signal,
 123            menus: Vec::new(),
 124        };
 125
 126        (common, main_receiver)
 127    }
 128}
 129
 130impl<P: LinuxClient + 'static> Platform for P {
 131    fn background_executor(&self) -> BackgroundExecutor {
 132        self.with_common(|common| common.background_executor.clone())
 133    }
 134
 135    fn foreground_executor(&self) -> ForegroundExecutor {
 136        self.with_common(|common| common.foreground_executor.clone())
 137    }
 138
 139    fn text_system(&self) -> Arc<dyn PlatformTextSystem> {
 140        self.with_common(|common| common.text_system.clone())
 141    }
 142
 143    fn keyboard_layout(&self) -> Box<dyn PlatformKeyboardLayout> {
 144        self.keyboard_layout()
 145    }
 146
 147    fn on_keyboard_layout_change(&self, callback: Box<dyn FnMut()>) {
 148        self.with_common(|common| common.callbacks.keyboard_layout_change = Some(callback));
 149    }
 150
 151    fn run(&self, on_finish_launching: Box<dyn FnOnce()>) {
 152        on_finish_launching();
 153
 154        LinuxClient::run(self);
 155
 156        let quit = self.with_common(|common| common.callbacks.quit.take());
 157        if let Some(mut fun) = quit {
 158            fun();
 159        }
 160    }
 161
 162    fn quit(&self) {
 163        self.with_common(|common| common.signal.stop());
 164    }
 165
 166    fn compositor_name(&self) -> &'static str {
 167        self.compositor_name()
 168    }
 169
 170    fn restart(&self, binary_path: Option<PathBuf>) {
 171        use std::os::unix::process::CommandExt as _;
 172
 173        // get the process id of the current process
 174        let app_pid = std::process::id().to_string();
 175        // get the path to the executable
 176        let app_path = if let Some(path) = binary_path {
 177            path
 178        } else {
 179            match self.app_path() {
 180                Ok(path) => path,
 181                Err(err) => {
 182                    log::error!("Failed to get app path: {:?}", err);
 183                    return;
 184                }
 185            }
 186        };
 187
 188        log::info!("Restarting process, using app path: {:?}", app_path);
 189
 190        // Script to wait for the current process to exit and then restart the app.
 191        let script = format!(
 192            r#"
 193            while kill -0 {pid} 2>/dev/null; do
 194                sleep 0.1
 195            done
 196
 197            {app_path}
 198            "#,
 199            pid = app_pid,
 200            app_path = app_path.display()
 201        );
 202
 203        let restart_process = Command::new("/usr/bin/env")
 204            .arg("bash")
 205            .arg("-c")
 206            .arg(script)
 207            .process_group(0)
 208            .spawn();
 209
 210        match restart_process {
 211            Ok(_) => self.quit(),
 212            Err(e) => log::error!("failed to spawn restart script: {:?}", e),
 213        }
 214    }
 215
 216    fn activate(&self, _ignoring_other_apps: bool) {
 217        log::info!("activate is not implemented on Linux, ignoring the call")
 218    }
 219
 220    fn hide(&self) {
 221        log::info!("hide is not implemented on Linux, ignoring the call")
 222    }
 223
 224    fn hide_other_apps(&self) {
 225        log::info!("hide_other_apps is not implemented on Linux, ignoring the call")
 226    }
 227
 228    fn unhide_other_apps(&self) {
 229        log::info!("unhide_other_apps is not implemented on Linux, ignoring the call")
 230    }
 231
 232    fn primary_display(&self) -> Option<Rc<dyn PlatformDisplay>> {
 233        self.primary_display()
 234    }
 235
 236    fn displays(&self) -> Vec<Rc<dyn PlatformDisplay>> {
 237        self.displays()
 238    }
 239
 240    #[cfg(feature = "screen-capture")]
 241    fn is_screen_capture_supported(&self) -> bool {
 242        self.is_screen_capture_supported()
 243    }
 244
 245    #[cfg(feature = "screen-capture")]
 246    fn screen_capture_sources(
 247        &self,
 248    ) -> oneshot::Receiver<Result<Vec<Rc<dyn crate::ScreenCaptureSource>>>> {
 249        self.screen_capture_sources()
 250    }
 251
 252    fn active_window(&self) -> Option<AnyWindowHandle> {
 253        self.active_window()
 254    }
 255
 256    fn window_stack(&self) -> Option<Vec<AnyWindowHandle>> {
 257        self.window_stack()
 258    }
 259
 260    fn open_window(
 261        &self,
 262        handle: AnyWindowHandle,
 263        options: WindowParams,
 264    ) -> anyhow::Result<Box<dyn PlatformWindow>> {
 265        self.open_window(handle, options)
 266    }
 267
 268    fn open_url(&self, url: &str) {
 269        self.open_uri(url);
 270    }
 271
 272    fn on_open_urls(&self, callback: Box<dyn FnMut(Vec<String>)>) {
 273        self.with_common(|common| common.callbacks.open_urls = Some(callback));
 274    }
 275
 276    fn prompt_for_paths(
 277        &self,
 278        options: PathPromptOptions,
 279    ) -> oneshot::Receiver<Result<Option<Vec<PathBuf>>>> {
 280        let (done_tx, done_rx) = oneshot::channel();
 281
 282        #[cfg(not(any(feature = "wayland", feature = "x11")))]
 283        let _ = (done_tx.send(Ok(None)), options);
 284
 285        #[cfg(any(feature = "wayland", feature = "x11"))]
 286        self.foreground_executor()
 287            .spawn(async move {
 288                let title = if options.directories {
 289                    "Open Folder"
 290                } else {
 291                    "Open File"
 292                };
 293
 294                let request = match ashpd::desktop::file_chooser::OpenFileRequest::default()
 295                    .modal(true)
 296                    .title(title)
 297                    .multiple(options.multiple)
 298                    .directory(options.directories)
 299                    .send()
 300                    .await
 301                {
 302                    Ok(request) => request,
 303                    Err(err) => {
 304                        let result = match err {
 305                            ashpd::Error::PortalNotFound(_) => anyhow!(FILE_PICKER_PORTAL_MISSING),
 306                            err => err.into(),
 307                        };
 308                        let _ = done_tx.send(Err(result));
 309                        return;
 310                    }
 311                };
 312
 313                let result = match request.response() {
 314                    Ok(response) => Ok(Some(
 315                        response
 316                            .uris()
 317                            .iter()
 318                            .filter_map(|uri| uri.to_file_path().ok())
 319                            .collect::<Vec<_>>(),
 320                    )),
 321                    Err(ashpd::Error::Response(_)) => Ok(None),
 322                    Err(e) => Err(e.into()),
 323                };
 324                let _ = done_tx.send(result);
 325            })
 326            .detach();
 327        done_rx
 328    }
 329
 330    fn prompt_for_new_path(&self, directory: &Path) -> oneshot::Receiver<Result<Option<PathBuf>>> {
 331        let (done_tx, done_rx) = oneshot::channel();
 332
 333        #[cfg(not(any(feature = "wayland", feature = "x11")))]
 334        let _ = (done_tx.send(Ok(None)), directory);
 335
 336        #[cfg(any(feature = "wayland", feature = "x11"))]
 337        self.foreground_executor()
 338            .spawn({
 339                let directory = directory.to_owned();
 340
 341                async move {
 342                    let request = match ashpd::desktop::file_chooser::SaveFileRequest::default()
 343                        .modal(true)
 344                        .title("Save File")
 345                        .current_folder(directory)
 346                        .expect("pathbuf should not be nul terminated")
 347                        .send()
 348                        .await
 349                    {
 350                        Ok(request) => request,
 351                        Err(err) => {
 352                            let result = match err {
 353                                ashpd::Error::PortalNotFound(_) => {
 354                                    anyhow!(FILE_PICKER_PORTAL_MISSING)
 355                                }
 356                                err => err.into(),
 357                            };
 358                            let _ = done_tx.send(Err(result));
 359                            return;
 360                        }
 361                    };
 362
 363                    let result = match request.response() {
 364                        Ok(response) => Ok(response
 365                            .uris()
 366                            .first()
 367                            .and_then(|uri| uri.to_file_path().ok())),
 368                        Err(ashpd::Error::Response(_)) => Ok(None),
 369                        Err(e) => Err(e.into()),
 370                    };
 371                    let _ = done_tx.send(result);
 372                }
 373            })
 374            .detach();
 375
 376        done_rx
 377    }
 378
 379    fn can_select_mixed_files_and_dirs(&self) -> bool {
 380        // org.freedesktop.portal.FileChooser only supports "pick files" and "pick directories".
 381        false
 382    }
 383
 384    fn reveal_path(&self, path: &Path) {
 385        self.reveal_path(path.to_owned());
 386    }
 387
 388    fn open_with_system(&self, path: &Path) {
 389        let path = path.to_owned();
 390        self.background_executor()
 391            .spawn(async move {
 392                let _ = std::process::Command::new("xdg-open")
 393                    .arg(path)
 394                    .spawn()
 395                    .context("invoking xdg-open")
 396                    .log_err();
 397            })
 398            .detach();
 399    }
 400
 401    fn on_quit(&self, callback: Box<dyn FnMut()>) {
 402        self.with_common(|common| {
 403            common.callbacks.quit = Some(callback);
 404        });
 405    }
 406
 407    fn on_reopen(&self, callback: Box<dyn FnMut()>) {
 408        self.with_common(|common| {
 409            common.callbacks.reopen = Some(callback);
 410        });
 411    }
 412
 413    fn on_app_menu_action(&self, callback: Box<dyn FnMut(&dyn Action)>) {
 414        self.with_common(|common| {
 415            common.callbacks.app_menu_action = Some(callback);
 416        });
 417    }
 418
 419    fn on_will_open_app_menu(&self, callback: Box<dyn FnMut()>) {
 420        self.with_common(|common| {
 421            common.callbacks.will_open_app_menu = Some(callback);
 422        });
 423    }
 424
 425    fn on_validate_app_menu_command(&self, callback: Box<dyn FnMut(&dyn Action) -> bool>) {
 426        self.with_common(|common| {
 427            common.callbacks.validate_app_menu_command = Some(callback);
 428        });
 429    }
 430
 431    fn app_path(&self) -> Result<PathBuf> {
 432        // get the path of the executable of the current process
 433        let app_path = env::current_exe()?;
 434        return Ok(app_path);
 435    }
 436
 437    fn set_menus(&self, menus: Vec<Menu>, _keymap: &Keymap) {
 438        self.with_common(|common| {
 439            common.menus = menus.into_iter().map(|menu| menu.owned()).collect();
 440        })
 441    }
 442
 443    fn get_menus(&self) -> Option<Vec<OwnedMenu>> {
 444        self.with_common(|common| Some(common.menus.clone()))
 445    }
 446
 447    fn set_dock_menu(&self, _menu: Vec<MenuItem>, _keymap: &Keymap) {
 448        // todo(linux)
 449    }
 450
 451    fn path_for_auxiliary_executable(&self, _name: &str) -> Result<PathBuf> {
 452        Err(anyhow::Error::msg(
 453            "Platform<LinuxPlatform>::path_for_auxiliary_executable is not implemented yet",
 454        ))
 455    }
 456
 457    fn set_cursor_style(&self, style: CursorStyle) {
 458        self.set_cursor_style(style)
 459    }
 460
 461    fn should_auto_hide_scrollbars(&self) -> bool {
 462        self.with_common(|common| common.auto_hide_scrollbars)
 463    }
 464
 465    fn write_credentials(&self, url: &str, username: &str, password: &[u8]) -> Task<Result<()>> {
 466        let url = url.to_string();
 467        let username = username.to_string();
 468        let password = password.to_vec();
 469        self.background_executor().spawn(async move {
 470            let keyring = oo7::Keyring::new().await?;
 471            keyring.unlock().await?;
 472            keyring
 473                .create_item(
 474                    KEYRING_LABEL,
 475                    &vec![("url", &url), ("username", &username)],
 476                    password,
 477                    true,
 478                )
 479                .await?;
 480            Ok(())
 481        })
 482    }
 483
 484    fn read_credentials(&self, url: &str) -> Task<Result<Option<(String, Vec<u8>)>>> {
 485        let url = url.to_string();
 486        self.background_executor().spawn(async move {
 487            let keyring = oo7::Keyring::new().await?;
 488            keyring.unlock().await?;
 489
 490            let items = keyring.search_items(&vec![("url", &url)]).await?;
 491
 492            for item in items.into_iter() {
 493                if item.label().await.is_ok_and(|label| label == KEYRING_LABEL) {
 494                    let attributes = item.attributes().await?;
 495                    let username = attributes
 496                        .get("username")
 497                        .context("Cannot find username in stored credentials")?;
 498                    item.unlock().await?;
 499                    let secret = item.secret().await?;
 500
 501                    // we lose the zeroizing capabilities at this boundary,
 502                    // a current limitation GPUI's credentials api
 503                    return Ok(Some((username.to_string(), secret.to_vec())));
 504                } else {
 505                    continue;
 506                }
 507            }
 508            Ok(None)
 509        })
 510    }
 511
 512    fn delete_credentials(&self, url: &str) -> Task<Result<()>> {
 513        let url = url.to_string();
 514        self.background_executor().spawn(async move {
 515            let keyring = oo7::Keyring::new().await?;
 516            keyring.unlock().await?;
 517
 518            let items = keyring.search_items(&vec![("url", &url)]).await?;
 519
 520            for item in items.into_iter() {
 521                if item.label().await.is_ok_and(|label| label == KEYRING_LABEL) {
 522                    item.delete().await?;
 523                    return Ok(());
 524                }
 525            }
 526
 527            Ok(())
 528        })
 529    }
 530
 531    fn window_appearance(&self) -> WindowAppearance {
 532        self.with_common(|common| common.appearance)
 533    }
 534
 535    fn register_url_scheme(&self, _: &str) -> Task<anyhow::Result<()>> {
 536        Task::ready(Err(anyhow!("register_url_scheme unimplemented")))
 537    }
 538
 539    fn write_to_primary(&self, item: ClipboardItem) {
 540        self.write_to_primary(item)
 541    }
 542
 543    fn write_to_clipboard(&self, item: ClipboardItem) {
 544        self.write_to_clipboard(item)
 545    }
 546
 547    fn read_from_primary(&self) -> Option<ClipboardItem> {
 548        self.read_from_primary()
 549    }
 550
 551    fn read_from_clipboard(&self) -> Option<ClipboardItem> {
 552        self.read_from_clipboard()
 553    }
 554
 555    fn add_recent_document(&self, _path: &Path) {}
 556}
 557
 558#[cfg(any(feature = "wayland", feature = "x11"))]
 559pub(super) fn open_uri_internal(
 560    executor: BackgroundExecutor,
 561    uri: &str,
 562    activation_token: Option<String>,
 563) {
 564    if let Some(uri) = ashpd::url::Url::parse(uri).log_err() {
 565        executor
 566            .spawn(async move {
 567                match ashpd::desktop::open_uri::OpenFileRequest::default()
 568                    .activation_token(activation_token.clone().map(ashpd::ActivationToken::from))
 569                    .send_uri(&uri)
 570                    .await
 571                {
 572                    Ok(_) => return,
 573                    Err(e) => log::error!("Failed to open with dbus: {}", e),
 574                }
 575
 576                for mut command in open::commands(uri.to_string()) {
 577                    if let Some(token) = activation_token.as_ref() {
 578                        command.env("XDG_ACTIVATION_TOKEN", token);
 579                    }
 580                    match command.spawn() {
 581                        Ok(_) => return,
 582                        Err(e) => {
 583                            log::error!("Failed to open with {:?}: {}", command.get_program(), e)
 584                        }
 585                    }
 586                }
 587            })
 588            .detach();
 589    }
 590}
 591
 592#[cfg(any(feature = "x11", feature = "wayland"))]
 593pub(super) fn reveal_path_internal(
 594    executor: BackgroundExecutor,
 595    path: PathBuf,
 596    activation_token: Option<String>,
 597) {
 598    executor
 599        .spawn(async move {
 600            if let Some(dir) = File::open(path.clone()).log_err() {
 601                match ashpd::desktop::open_uri::OpenDirectoryRequest::default()
 602                    .activation_token(activation_token.map(ashpd::ActivationToken::from))
 603                    .send(&dir.as_fd())
 604                    .await
 605                {
 606                    Ok(_) => return,
 607                    Err(e) => log::error!("Failed to open with dbus: {}", e),
 608                }
 609                if path.is_dir() {
 610                    open::that_detached(path).log_err();
 611                } else {
 612                    open::that_detached(path.parent().unwrap_or(Path::new(""))).log_err();
 613                }
 614            }
 615        })
 616        .detach();
 617}
 618
 619#[allow(unused)]
 620pub(super) fn is_within_click_distance(a: Point<Pixels>, b: Point<Pixels>) -> bool {
 621    let diff = a - b;
 622    diff.x.abs() <= DOUBLE_CLICK_DISTANCE && diff.y.abs() <= DOUBLE_CLICK_DISTANCE
 623}
 624
 625#[cfg(any(feature = "wayland", feature = "x11"))]
 626pub(super) fn get_xkb_compose_state(cx: &xkb::Context) -> Option<xkb::compose::State> {
 627    let mut locales = Vec::default();
 628    if let Some(locale) = env::var_os("LC_CTYPE") {
 629        locales.push(locale);
 630    }
 631    locales.push(OsString::from("C"));
 632    let mut state: Option<xkb::compose::State> = None;
 633    for locale in locales {
 634        if let Ok(table) =
 635            xkb::compose::Table::new_from_locale(&cx, &locale, xkb::compose::COMPILE_NO_FLAGS)
 636        {
 637            state = Some(xkb::compose::State::new(
 638                &table,
 639                xkb::compose::STATE_NO_FLAGS,
 640            ));
 641            break;
 642        }
 643    }
 644    state
 645}
 646
 647#[cfg(any(feature = "wayland", feature = "x11"))]
 648pub(super) unsafe fn read_fd(mut fd: filedescriptor::FileDescriptor) -> Result<Vec<u8>> {
 649    let mut file = unsafe { File::from_raw_fd(fd.as_raw_fd()) };
 650    let mut buffer = Vec::new();
 651    file.read_to_end(&mut buffer)?;
 652    Ok(buffer)
 653}
 654
 655#[cfg(any(feature = "wayland", feature = "x11"))]
 656pub(super) const DEFAULT_CURSOR_ICON_NAME: &str = "left_ptr";
 657
 658impl CursorStyle {
 659    #[cfg(any(feature = "wayland", feature = "x11"))]
 660    pub(super) fn to_icon_names(&self) -> &'static [&'static str] {
 661        // Based on cursor names from chromium:
 662        // https://github.com/chromium/chromium/blob/d3069cf9c973dc3627fa75f64085c6a86c8f41bf/ui/base/cursor/cursor_factory.cc#L113
 663        match self {
 664            CursorStyle::Arrow => &[DEFAULT_CURSOR_ICON_NAME],
 665            CursorStyle::IBeam => &["text", "xterm"],
 666            CursorStyle::Crosshair => &["crosshair", "cross"],
 667            CursorStyle::ClosedHand => &["closedhand", "grabbing", "hand2"],
 668            CursorStyle::OpenHand => &["openhand", "grab", "hand1"],
 669            CursorStyle::PointingHand => &["pointer", "hand", "hand2"],
 670            CursorStyle::ResizeLeft => &["w-resize", "left_side"],
 671            CursorStyle::ResizeRight => &["e-resize", "right_side"],
 672            CursorStyle::ResizeLeftRight => &["ew-resize", "sb_h_double_arrow"],
 673            CursorStyle::ResizeUp => &["n-resize", "top_side"],
 674            CursorStyle::ResizeDown => &["s-resize", "bottom_side"],
 675            CursorStyle::ResizeUpDown => &["sb_v_double_arrow", "ns-resize"],
 676            CursorStyle::ResizeUpLeftDownRight => &["size_fdiag", "bd_double_arrow", "nwse-resize"],
 677            CursorStyle::ResizeUpRightDownLeft => &["size_bdiag", "nesw-resize", "fd_double_arrow"],
 678            CursorStyle::ResizeColumn => &["col-resize", "sb_h_double_arrow"],
 679            CursorStyle::ResizeRow => &["row-resize", "sb_v_double_arrow"],
 680            CursorStyle::IBeamCursorForVerticalLayout => &["vertical-text"],
 681            CursorStyle::OperationNotAllowed => &["not-allowed", "crossed_circle"],
 682            CursorStyle::DragLink => &["alias"],
 683            CursorStyle::DragCopy => &["copy"],
 684            CursorStyle::ContextualMenu => &["context-menu"],
 685            CursorStyle::None => {
 686                #[cfg(debug_assertions)]
 687                panic!("CursorStyle::None should be handled separately in the client");
 688                #[cfg(not(debug_assertions))]
 689                &[DEFAULT_CURSOR_ICON_NAME]
 690            }
 691        }
 692    }
 693}
 694
 695#[cfg(any(feature = "wayland", feature = "x11"))]
 696pub(super) fn log_cursor_icon_warning(message: impl std::fmt::Display) {
 697    if let Ok(xcursor_path) = env::var("XCURSOR_PATH") {
 698        log::warn!(
 699            "{:#}\ncursor icon loading may be failing if XCURSOR_PATH environment variable is invalid. \
 700                    XCURSOR_PATH overrides the default icon search. Its current value is '{}'",
 701            message,
 702            xcursor_path
 703        );
 704    } else {
 705        log::warn!("{:#}", message);
 706    }
 707}
 708
 709#[cfg(any(feature = "wayland", feature = "x11"))]
 710fn guess_ascii(keycode: Keycode, shift: bool) -> Option<char> {
 711    let c = match (keycode.raw(), shift) {
 712        (24, _) => 'q',
 713        (25, _) => 'w',
 714        (26, _) => 'e',
 715        (27, _) => 'r',
 716        (28, _) => 't',
 717        (29, _) => 'y',
 718        (30, _) => 'u',
 719        (31, _) => 'i',
 720        (32, _) => 'o',
 721        (33, _) => 'p',
 722        (34, false) => '[',
 723        (34, true) => '{',
 724        (35, false) => ']',
 725        (35, true) => '}',
 726        (38, _) => 'a',
 727        (39, _) => 's',
 728        (40, _) => 'd',
 729        (41, _) => 'f',
 730        (42, _) => 'g',
 731        (43, _) => 'h',
 732        (44, _) => 'j',
 733        (45, _) => 'k',
 734        (46, _) => 'l',
 735        (47, false) => ';',
 736        (47, true) => ':',
 737        (48, false) => '\'',
 738        (48, true) => '"',
 739        (49, false) => '`',
 740        (49, true) => '~',
 741        (51, false) => '\\',
 742        (51, true) => '|',
 743        (52, _) => 'z',
 744        (53, _) => 'x',
 745        (54, _) => 'c',
 746        (55, _) => 'v',
 747        (56, _) => 'b',
 748        (57, _) => 'n',
 749        (58, _) => 'm',
 750        (59, false) => ',',
 751        (59, true) => '>',
 752        (60, false) => '.',
 753        (60, true) => '<',
 754        (61, false) => '/',
 755        (61, true) => '?',
 756
 757        _ => return None,
 758    };
 759
 760    Some(c)
 761}
 762
 763#[cfg(any(feature = "wayland", feature = "x11"))]
 764impl crate::Keystroke {
 765    pub(super) fn from_xkb(
 766        state: &State,
 767        mut modifiers: crate::Modifiers,
 768        keycode: Keycode,
 769    ) -> Self {
 770        let key_utf32 = state.key_get_utf32(keycode);
 771        let key_utf8 = state.key_get_utf8(keycode);
 772        let key_sym = state.key_get_one_sym(keycode);
 773
 774        let key = match key_sym {
 775            Keysym::Return => "enter".to_owned(),
 776            Keysym::Prior => "pageup".to_owned(),
 777            Keysym::Next => "pagedown".to_owned(),
 778            Keysym::ISO_Left_Tab => "tab".to_owned(),
 779            Keysym::KP_Prior => "pageup".to_owned(),
 780            Keysym::KP_Next => "pagedown".to_owned(),
 781            Keysym::XF86_Back => "back".to_owned(),
 782            Keysym::XF86_Forward => "forward".to_owned(),
 783            Keysym::XF86_Cut => "cut".to_owned(),
 784            Keysym::XF86_Copy => "copy".to_owned(),
 785            Keysym::XF86_Paste => "paste".to_owned(),
 786            Keysym::XF86_New => "new".to_owned(),
 787            Keysym::XF86_Open => "open".to_owned(),
 788            Keysym::XF86_Save => "save".to_owned(),
 789
 790            Keysym::comma => ",".to_owned(),
 791            Keysym::period => ".".to_owned(),
 792            Keysym::less => "<".to_owned(),
 793            Keysym::greater => ">".to_owned(),
 794            Keysym::slash => "/".to_owned(),
 795            Keysym::question => "?".to_owned(),
 796
 797            Keysym::semicolon => ";".to_owned(),
 798            Keysym::colon => ":".to_owned(),
 799            Keysym::apostrophe => "'".to_owned(),
 800            Keysym::quotedbl => "\"".to_owned(),
 801
 802            Keysym::bracketleft => "[".to_owned(),
 803            Keysym::braceleft => "{".to_owned(),
 804            Keysym::bracketright => "]".to_owned(),
 805            Keysym::braceright => "}".to_owned(),
 806            Keysym::backslash => "\\".to_owned(),
 807            Keysym::bar => "|".to_owned(),
 808
 809            Keysym::grave => "`".to_owned(),
 810            Keysym::asciitilde => "~".to_owned(),
 811            Keysym::exclam => "!".to_owned(),
 812            Keysym::at => "@".to_owned(),
 813            Keysym::numbersign => "#".to_owned(),
 814            Keysym::dollar => "$".to_owned(),
 815            Keysym::percent => "%".to_owned(),
 816            Keysym::asciicircum => "^".to_owned(),
 817            Keysym::ampersand => "&".to_owned(),
 818            Keysym::asterisk => "*".to_owned(),
 819            Keysym::parenleft => "(".to_owned(),
 820            Keysym::parenright => ")".to_owned(),
 821            Keysym::minus => "-".to_owned(),
 822            Keysym::underscore => "_".to_owned(),
 823            Keysym::equal => "=".to_owned(),
 824            Keysym::plus => "+".to_owned(),
 825            Keysym::space => "space".to_owned(),
 826            Keysym::BackSpace => "backspace".to_owned(),
 827            Keysym::Tab => "tab".to_owned(),
 828            Keysym::Delete => "delete".to_owned(),
 829            Keysym::Escape => "escape".to_owned(),
 830
 831            Keysym::Left => "left".to_owned(),
 832            Keysym::Right => "right".to_owned(),
 833            Keysym::Up => "up".to_owned(),
 834            Keysym::Down => "down".to_owned(),
 835            Keysym::Home => "home".to_owned(),
 836            Keysym::End => "end".to_owned(),
 837
 838            _ => {
 839                let name = xkb::keysym_get_name(key_sym).to_lowercase();
 840                if key_sym.is_keypad_key() {
 841                    name.replace("kp_", "")
 842                } else if let Some(key) = key_utf8.chars().next()
 843                    && key_utf8.len() == 1
 844                    && key.is_ascii()
 845                {
 846                    if key.is_ascii_graphic() {
 847                        key_utf8.to_lowercase()
 848                    // map ctrl-a to `a`
 849                    // ctrl-0..9 may emit control codes like ctrl-[, but
 850                    // we don't want to map them to `[`
 851                    } else if key_utf32 <= 0x1f
 852                        && !name.chars().next().is_some_and(|c| c.is_ascii_digit())
 853                    {
 854                        ((key_utf32 as u8 + 0x40) as char)
 855                            .to_ascii_lowercase()
 856                            .to_string()
 857                    } else {
 858                        name
 859                    }
 860                } else if let Some(key_en) = guess_ascii(keycode, modifiers.shift) {
 861                    String::from(key_en)
 862                } else {
 863                    name
 864                }
 865            }
 866        };
 867
 868        if modifiers.shift {
 869            // we only include the shift for upper-case letters by convention,
 870            // so don't include for numbers and symbols, but do include for
 871            // tab/enter, etc.
 872            if key.chars().count() == 1 && key.to_lowercase() == key.to_uppercase() {
 873                modifiers.shift = false;
 874            }
 875        }
 876
 877        // Ignore control characters (and DEL) for the purposes of key_char
 878        let key_char =
 879            (key_utf32 >= 32 && key_utf32 != 127 && !key_utf8.is_empty()).then_some(key_utf8);
 880
 881        Self {
 882            modifiers,
 883            key,
 884            key_char,
 885        }
 886    }
 887
 888    /**
 889     * Returns which symbol the dead key represents
 890     * <https://developer.mozilla.org/en-US/docs/Web/API/UI_Events/Keyboard_event_key_values#dead_keycodes_for_linux>
 891     */
 892    pub fn underlying_dead_key(keysym: Keysym) -> Option<String> {
 893        match keysym {
 894            Keysym::dead_grave => Some("`".to_owned()),
 895            Keysym::dead_acute => Some("´".to_owned()),
 896            Keysym::dead_circumflex => Some("^".to_owned()),
 897            Keysym::dead_tilde => Some("~".to_owned()),
 898            Keysym::dead_macron => Some("¯".to_owned()),
 899            Keysym::dead_breve => Some("˘".to_owned()),
 900            Keysym::dead_abovedot => Some("˙".to_owned()),
 901            Keysym::dead_diaeresis => Some("¨".to_owned()),
 902            Keysym::dead_abovering => Some("˚".to_owned()),
 903            Keysym::dead_doubleacute => Some("˝".to_owned()),
 904            Keysym::dead_caron => Some("ˇ".to_owned()),
 905            Keysym::dead_cedilla => Some("¸".to_owned()),
 906            Keysym::dead_ogonek => Some("˛".to_owned()),
 907            Keysym::dead_iota => Some("ͅ".to_owned()),
 908            Keysym::dead_voiced_sound => Some("".to_owned()),
 909            Keysym::dead_semivoiced_sound => Some("".to_owned()),
 910            Keysym::dead_belowdot => Some("̣̣".to_owned()),
 911            Keysym::dead_hook => Some("̡".to_owned()),
 912            Keysym::dead_horn => Some("̛".to_owned()),
 913            Keysym::dead_stroke => Some("̶̶".to_owned()),
 914            Keysym::dead_abovecomma => Some("̓̓".to_owned()),
 915            Keysym::dead_abovereversedcomma => Some("ʽ".to_owned()),
 916            Keysym::dead_doublegrave => Some("̏".to_owned()),
 917            Keysym::dead_belowring => Some("˳".to_owned()),
 918            Keysym::dead_belowmacron => Some("̱".to_owned()),
 919            Keysym::dead_belowcircumflex => Some("".to_owned()),
 920            Keysym::dead_belowtilde => Some("̰".to_owned()),
 921            Keysym::dead_belowbreve => Some("̮".to_owned()),
 922            Keysym::dead_belowdiaeresis => Some("̤".to_owned()),
 923            Keysym::dead_invertedbreve => Some("̯".to_owned()),
 924            Keysym::dead_belowcomma => Some("̦".to_owned()),
 925            Keysym::dead_currency => None,
 926            Keysym::dead_lowline => None,
 927            Keysym::dead_aboveverticalline => None,
 928            Keysym::dead_belowverticalline => None,
 929            Keysym::dead_longsolidusoverlay => None,
 930            Keysym::dead_a => None,
 931            Keysym::dead_A => None,
 932            Keysym::dead_e => None,
 933            Keysym::dead_E => None,
 934            Keysym::dead_i => None,
 935            Keysym::dead_I => None,
 936            Keysym::dead_o => None,
 937            Keysym::dead_O => None,
 938            Keysym::dead_u => None,
 939            Keysym::dead_U => None,
 940            Keysym::dead_small_schwa => Some("ə".to_owned()),
 941            Keysym::dead_capital_schwa => Some("Ə".to_owned()),
 942            Keysym::dead_greek => None,
 943            _ => None,
 944        }
 945    }
 946}
 947
 948#[cfg(any(feature = "wayland", feature = "x11"))]
 949impl crate::Modifiers {
 950    pub(super) fn from_xkb(keymap_state: &State) -> Self {
 951        let shift = keymap_state.mod_name_is_active(xkb::MOD_NAME_SHIFT, xkb::STATE_MODS_EFFECTIVE);
 952        let alt = keymap_state.mod_name_is_active(xkb::MOD_NAME_ALT, xkb::STATE_MODS_EFFECTIVE);
 953        let control =
 954            keymap_state.mod_name_is_active(xkb::MOD_NAME_CTRL, xkb::STATE_MODS_EFFECTIVE);
 955        let platform =
 956            keymap_state.mod_name_is_active(xkb::MOD_NAME_LOGO, xkb::STATE_MODS_EFFECTIVE);
 957        Self {
 958            shift,
 959            alt,
 960            control,
 961            platform,
 962            function: false,
 963        }
 964    }
 965}
 966
 967#[cfg(any(feature = "wayland", feature = "x11"))]
 968impl crate::Capslock {
 969    pub(super) fn from_xkb(keymap_state: &State) -> Self {
 970        let on = keymap_state.mod_name_is_active(xkb::MOD_NAME_CAPS, xkb::STATE_MODS_EFFECTIVE);
 971        Self { on }
 972    }
 973}
 974
 975#[cfg(test)]
 976mod tests {
 977    use super::*;
 978    use crate::{Point, px};
 979
 980    #[test]
 981    fn test_is_within_click_distance() {
 982        let zero = Point::new(px(0.0), px(0.0));
 983        assert_eq!(
 984            is_within_click_distance(zero, Point::new(px(5.0), px(5.0))),
 985            true
 986        );
 987        assert_eq!(
 988            is_within_click_distance(zero, Point::new(px(-4.9), px(5.0))),
 989            true
 990        );
 991        assert_eq!(
 992            is_within_click_distance(Point::new(px(3.0), px(2.0)), Point::new(px(-2.0), px(-2.0))),
 993            true
 994        );
 995        assert_eq!(
 996            is_within_click_distance(zero, Point::new(px(5.0), px(5.1))),
 997            false
 998        );
 999    }
1000}