tao 0.35.2

Cross-platform window manager library.
Documentation 
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

#[cfg(feature = "dbus")]
use dbus::{
  arg::Variant,
  blocking::{Connection, SyncConnection},
  message::MatchRule,
  Error,
};
use gtk::glib::{ControlFlow, MainContext, Priority, Sender};
use log::warn;
use std::{thread, time::Duration};

use crate::{
  platform_impl::{platform::window::WindowRequest, WindowId},
  window::Theme,
};

pub fn theme() -> Result<Theme, Error> {
  let conn = Connection::new_session()?;
  let proxy = conn.with_proxy(
    "org.freedesktop.portal.Desktop",
    "/org/freedesktop/portal/desktop",
    Duration::from_secs(5),
  );

  let result: (Variant<Variant<u32>>,) = proxy.method_call(
    "org.freedesktop.portal.Settings",
    "Read",
    ("org.freedesktop.appearance", "color-scheme"),
  )?;

  Ok(color_scheme_to_theme(result.0 .0 .0))
}

pub fn receive_theme_changed(window_tx: Sender<(WindowId, WindowRequest)>) -> Result<(), Error> {
  let conn = SyncConnection::new_session()?;
  let match_rule = MatchRule::new_signal("org.freedesktop.portal.Settings", "SettingChanged");
  let (tx, rx) = MainContext::channel(Priority::DEFAULT);

  conn.add_match(match_rule, move |_: (), _, msg| {
    let mut iter = msg.iter_init();
    if let (Ok("org.freedesktop.appearance"), Ok("color-scheme"), Ok(value)) = (
      iter.read::<&str>(),         // Namespace
      iter.read::<&str>(),         // Key
      iter.read::<Variant<u32>>(), // Value
    ) {
      if let Err(e) = tx.send(color_scheme_to_theme(value.0)) {
        warn!("Failed to send theme change via channel: {}", e);
      }
    }
    true
  })?;

  rx.attach(None, move |theme| {
    if let Err(e) = window_tx.send((WindowId::dummy(), WindowRequest::SetTheme(Some(theme)))) {
      warn!("Failed to send theme change request: {}", e);
      ControlFlow::Break
    } else {
      ControlFlow::Continue
    }
  });

  thread::spawn(move || loop {
    if let Err(e) = conn.process(Duration::from_secs(5)) {
      warn!("D-Bus message processing error: {}", e);
      break;
    }
  });

  Ok(())
}

fn color_scheme_to_theme(color_scheme: u32) -> Theme {
  match color_scheme {
    1 => Theme::Dark,  // Prefer Dark
    2 => Theme::Light, // Prefer Light
    _ => Theme::Light, // No Preference, default to Light
  }
}