116 lines
3.8 KiB
Rust
116 lines
3.8 KiB
Rust
//! # DBus interface proxy for: `org.freedesktop.UPower.KbdBacklight`
|
|
//!
|
|
//! This code was generated by `zbus-xmlgen` `2.0.1` from DBus introspection data.
|
|
//! Source: `Interface '/org/freedesktop/UPower/KbdBacklight' from service 'org.freedesktop.UPower' on system bus`.
|
|
|
|
use cosmic::iced::{self, futures::SinkExt, subscription};
|
|
use std::{fmt::Debug, hash::Hash};
|
|
use tokio::sync::mpsc::{unbounded_channel, UnboundedReceiver, UnboundedSender};
|
|
use zbus::dbus_proxy;
|
|
|
|
#[dbus_proxy(
|
|
default_service = "org.freedesktop.UPower",
|
|
interface = "org.freedesktop.UPower.KbdBacklight",
|
|
default_path = "/org/freedesktop/UPower/KbdBacklight"
|
|
)]
|
|
trait KbdBacklight {
|
|
/// GetBrightness method
|
|
fn get_brightness(&self) -> zbus::Result<i32>;
|
|
|
|
/// GetMaxBrightness method
|
|
fn get_max_brightness(&self) -> zbus::Result<i32>;
|
|
|
|
/// SetBrightness method
|
|
fn set_brightness(&self, value: i32) -> zbus::Result<()>;
|
|
|
|
/// BrightnessChanged signal
|
|
#[dbus_proxy(signal)]
|
|
fn brightness_changed(&self, value: i32) -> zbus::Result<()>;
|
|
|
|
/// BrightnessChangedWithSource signal
|
|
#[dbus_proxy(signal)]
|
|
fn brightness_changed_with_source(&self, value: i32, source: &str) -> zbus::Result<()>;
|
|
}
|
|
|
|
pub fn kbd_backlight_subscription<I: 'static + Hash + Copy + Send + Sync + Debug>(
|
|
id: I,
|
|
) -> iced::Subscription<KeyboardBacklightUpdate> {
|
|
subscription::channel(id, 50, move |mut output| async move {
|
|
let mut state = State::Ready;
|
|
|
|
loop {
|
|
state = start_listening(state, &mut output).await;
|
|
}
|
|
})
|
|
}
|
|
|
|
#[derive(Debug)]
|
|
pub enum State {
|
|
Ready,
|
|
Waiting(
|
|
KbdBacklightProxy<'static>,
|
|
UnboundedReceiver<KeyboardBacklightRequest>,
|
|
),
|
|
Finished,
|
|
}
|
|
|
|
async fn get_brightness(kbd_proxy: &KbdBacklightProxy<'_>) -> zbus::Result<f64> {
|
|
Ok(kbd_proxy.get_brightness().await? as f64 / kbd_proxy.get_max_brightness().await? as f64)
|
|
}
|
|
|
|
async fn start_listening(
|
|
state: State,
|
|
output: &mut futures::channel::mpsc::Sender<KeyboardBacklightUpdate>,
|
|
) -> State {
|
|
match state {
|
|
State::Ready => {
|
|
let conn = match zbus::Connection::system().await {
|
|
Ok(conn) => conn,
|
|
Err(_) => return State::Finished,
|
|
};
|
|
let kbd_proxy = match KbdBacklightProxy::builder(&conn).build().await {
|
|
Ok(p) => p,
|
|
Err(_) => return State::Finished,
|
|
};
|
|
let (tx, rx) = unbounded_channel();
|
|
|
|
let b = get_brightness(&kbd_proxy).await.ok();
|
|
_ = output.send(KeyboardBacklightUpdate::Sender(tx)).await;
|
|
_ = output.send(KeyboardBacklightUpdate::Brightness(b)).await;
|
|
|
|
State::Waiting(kbd_proxy, rx)
|
|
}
|
|
State::Waiting(proxy, mut rx) => match rx.recv().await {
|
|
Some(req) => match req {
|
|
KeyboardBacklightRequest::Get => {
|
|
let b = get_brightness(&proxy).await.ok();
|
|
_ = output.send(KeyboardBacklightUpdate::Brightness(b)).await;
|
|
State::Waiting(proxy, rx)
|
|
}
|
|
KeyboardBacklightRequest::Set(value) => {
|
|
if let Ok(max_brightness) = proxy.get_max_brightness().await {
|
|
let value = value.clamp(0., 1.) * (max_brightness as f64);
|
|
let value = value.round() as i32;
|
|
let _ = proxy.set_brightness(value).await;
|
|
}
|
|
|
|
State::Waiting(proxy, rx)
|
|
}
|
|
},
|
|
None => State::Finished,
|
|
},
|
|
State::Finished => iced::futures::future::pending().await,
|
|
}
|
|
}
|
|
|
|
#[derive(Debug, Clone)]
|
|
pub enum KeyboardBacklightUpdate {
|
|
Sender(UnboundedSender<KeyboardBacklightRequest>),
|
|
Brightness(Option<f64>),
|
|
}
|
|
|
|
#[derive(Debug, Clone)]
|
|
pub enum KeyboardBacklightRequest {
|
|
Get,
|
|
Set(f64),
|
|
}
|