Version bump for dep updates

rust/cargo is also needed

See merge request asus-linux/asusctl!140

.gitlab-ci.yml

@@ -1,7 +1,7 @@
 image: rust:latest
 
 before_script:
-  - apt-get update -qq && apt-get install -y -qq libdbus-1-dev libclang-dev libudev-dev libfontconfig1-dev
+  - apt-get update -qq && apt-get install -y -qq libudev-dev libgtk-3-dev
 
 stages:
     - test
@@ -26,4 +26,3 @@ build:
 
 variables:
   GIT_SUBMODULE_STRATEGY: normal
-

CHANGELOG.md

@@ -4,7 +4,22 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
-## [Unreleased - 4.5.0-RC5]
+## [Unreleased]
+## [v4.5.2]
+### Changed
+- Update dependencies and bump version
+
+## [v4.5.1]
+### Added
+- Support for FA506IE LED modes (Author: Herohtar)
+### Changed
+- Add a basic system tray with dGPU status and gpu mode switch actions
+- Fixup some notifications in ROGCC
+- Add config options for notifications for ROGCC
+- Share states with tray process in ROGCC
+- Share tates with tray process in ROGCC
+
+## [v4.5.0]
 ### Added
 - intofy watches on:
   - `charge_control_end_threshold`

Cargo.toml

@@ -2,20 +2,17 @@
 members = ["asusctl", "daemon", "daemon-user", "rog-platform", "rog-dbus", "rog-anime", "rog-aura", "rog-profiles", "rog-control-center"]
 
 [workspace.package]
-version = "4.5.0-rc5"
+version = "4.5.2"
 
 [workspace.dependencies]
 async-trait = "^0.1"
-tokio = { version = "^1.21.2", features = ["macros", "rt-multi-thread", "time"]}
+tokio = { version = "^1.21.2", features = ["macros", "rt-multi-thread", "time", "sync"]}
 concat-idents = "^1.1"
 dirs = "^4.0"
 smol = "^1.2"
 
-zbus = "^3.4"
+zbus = "^3.5"
-zbus_macros = "^3.4"
+logind-zbus = { version = "^3.0.3" } #, default-features = false, features = ["non_blocking"] }
-zvariant = "^3.7"
-zvariant_derive = "^3.7"
-logind-zbus = { version = "^3.0" } #, default-features = false, features = ["non_blocking"] }
 
 serde = "^1.0"
 serde_derive = "^1.0"
@@ -23,7 +20,7 @@ serde_json = "^1.0"
 toml = "^0.5.9"
 
 log = "^0.4"
-env_logger = "^0.9"
+env_logger = "^0.9.3"
 
 glam = { version = "^0.22", features = ["serde"] }
 gumdrop = "^0.8"

Makefile

@@ -57,7 +57,10 @@ install:
 
 	$(INSTALL_DATA) "./data/icons/asus_notif_yellow.png" "$(DESTDIR)$(datarootdir)/icons/hicolor/512x512/apps/asus_notif_yellow.png"
 	$(INSTALL_DATA) "./data/icons/asus_notif_green.png" "$(DESTDIR)$(datarootdir)/icons/hicolor/512x512/apps/asus_notif_green.png"
+	$(INSTALL_DATA) "./data/icons/asus_notif_blue.png" "$(DESTDIR)$(datarootdir)/icons/hicolor/512x512/apps/asus_notif_blue.png"
 	$(INSTALL_DATA) "./data/icons/asus_notif_red.png" "$(DESTDIR)$(datarootdir)/icons/hicolor/512x512/apps/asus_notif_red.png"
+	$(INSTALL_DATA) "./data/icons/asus_notif_orange.png" "$(DESTDIR)$(datarootdir)/icons/hicolor/512x512/apps/asus_notif_orange.png"
+	$(INSTALL_DATA) "./data/icons/asus_notif_white.png" "$(DESTDIR)$(datarootdir)/icons/hicolor/512x512/apps/asus_notif_white.png"
 
 	$(INSTALL_DATA) "./data/icons/scalable/gpu-compute.svg" "$(DESTDIR)$(datarootdir)/icons/hicolor/scalable/status/gpu-compute.svg"
 	$(INSTALL_DATA) "./data/icons/scalable/gpu-hybrid.svg" "$(DESTDIR)$(datarootdir)/icons/hicolor/scalable/status/gpu-hybrid.svg"

README.md

@@ -2,7 +2,7 @@
 
 [![](https://www.paypalobjects.com/en_US/i/btn/btn_donate_LG.gif)](https://www.paypal.com/donate/?hosted_button_id=4V2DEPS7K6APC) - [Asus Linux Website](https://asus-linux.org/)
 
-**WARNING:** Do not run the main branch of this repo unless you have all the asus-wmi kernel patches. You should use stable kernels + tagged releases.
+**WARNING:** Many features are developed in tandem with kernel patches. If you see a feature is missing you either need a patched kernel, or v6.1 which has all my work merged upstream.
 
 `asusd` is a utility for Linux to control many aspects of various ASUS laptops
 but can also be used with non-asus laptops with reduced features.
@@ -81,7 +81,16 @@ Requirements are rust >= 1.57 installed from rustup.io if the distro provided ve
 
 **fedora:**
 
-    dnf install clang-devel systemd-devel cargo
+    dnf install cmake clang-devel systemd-devel gtk3-devel cargo
+    make
+    sudo make install
+
+**openSUSE:**
+
+Works with KDE Plasma (without GTK packages)
+
+    zypper in -t pattern devel_basis
+    zypper in rustup cmake clang-devel systemd-devel glib2-devel cairo-devel atkmm-devel pangomm-devel gdk-pixbuf-devel gtk3-devel
     make
     sudo make install
 

asusctl/src/main.rs

@@ -539,7 +539,6 @@ fn handle_led_power_1_do_tuf(
         x19b6: vec![],
         tuf: enabled,
     };
-    dbg!(&data);
     dbus.proxies().led().set_leds_power(data, true)?;
 
     let data = AuraPowerDev {

daemon-user/Cargo.toml

@@ -27,6 +27,4 @@ rog_aura = { path = "../rog-aura" }
 rog_dbus = { path = "../rog-dbus" }
 rog_platform = { path = "../rog-platform" }
 
-zbus.workspace = true
+zbus.workspace = true
-zvariant.workspace = true
-zvariant_derive.workspace = true

daemon-user/src/ctrl_anime.rs

@@ -11,9 +11,10 @@ use std::{
     },
 };
 use std::{sync::Arc, thread::sleep, time::Instant};
-use zbus::dbus_interface;
+use zbus::{
-use zvariant::ObjectPath;
+    dbus_interface,
-use zvariant_derive::Type;
+    zvariant::{ObjectPath, Type},
+};
 
 use crate::user_config::ConfigLoadSave;
 use crate::{error::Error, user_config::UserAnimeConfig};

daemon/Cargo.toml

@@ -32,7 +32,6 @@ log.workspace = true
 env_logger.workspace = true
 
 zbus.workspace = true
-zvariant.workspace = true
 logind-zbus.workspace = true
 
 # serialisation

daemon/src/config.rs

@@ -61,7 +61,7 @@ impl Config {
     pub fn read(&mut self) {
         let mut file = OpenOptions::new()
             .read(true)
-            .open(&CONFIG_PATH)
+            .open(CONFIG_PATH)
             .unwrap_or_else(|err| panic!("Error reading {}: {}", CONFIG_PATH, err));
         let mut buf = String::new();
         if let Ok(l) = file.read_to_string(&mut buf) {

daemon/src/ctrl_anime/config.rs

@@ -145,7 +145,7 @@ impl AnimeConfig {
             .read(true)
             .write(true)
             .create(true)
-            .open(&ANIME_CONFIG_PATH)
+            .open(ANIME_CONFIG_PATH)
             .unwrap_or_else(|_| {
                 panic!(
                     "The file {} or directory /etc/asusd/ is missing",
@@ -249,7 +249,7 @@ impl AnimeConfig {
     pub fn read(&mut self) {
         let mut file = OpenOptions::new()
             .read(true)
-            .open(&ANIME_CONFIG_PATH)
+            .open(ANIME_CONFIG_PATH)
             .unwrap_or_else(|err| panic!("Error reading {}: {}", ANIME_CONFIG_PATH, err));
         let mut buf = String::new();
         if let Ok(l) = file.read_to_string(&mut buf) {

daemon/src/ctrl_aura/config.rs

@@ -192,7 +192,7 @@ impl AuraConfig {
             .read(true)
             .write(true)
             .create(true)
-            .open(&AURA_CONFIG_PATH)
+            .open(AURA_CONFIG_PATH)
             .unwrap_or_else(|_| {
                 panic!(
                     "The file {} or directory /etc/asusd/ is missing",
@@ -264,7 +264,7 @@ impl AuraConfig {
     pub fn read(&mut self) {
         let mut file = OpenOptions::new()
             .read(true)
-            .open(&AURA_CONFIG_PATH)
+            .open(AURA_CONFIG_PATH)
             .unwrap_or_else(|err| panic!("Error reading {}: {}", AURA_CONFIG_PATH, err));
         let mut buf = String::new();
         if let Ok(l) = file.read_to_string(&mut buf) {

daemon/src/ctrl_supported.rs

@@ -1,8 +1,6 @@
 use async_trait::async_trait;
 use serde_derive::{Deserialize, Serialize};
-use zbus::dbus_interface;
+use zbus::{dbus_interface, zvariant::Type, Connection};
-use zbus::Connection;
-use zvariant::Type;
 
 use crate::{
     ctrl_anime::CtrlAnime, ctrl_aura::controller::CtrlKbdLed, ctrl_platform::CtrlPlatform,

daemon/src/laptops.rs

@@ -90,7 +90,7 @@ impl LedSupportFile {
         let mut loaded = false;
         let mut data = LedSupportFile::default();
         // Load user configs first so they are first to be checked
-        if let Ok(mut file) = OpenOptions::new().read(true).open(&ASUS_LED_MODE_USER_CONF) {
+        if let Ok(mut file) = OpenOptions::new().read(true).open(ASUS_LED_MODE_USER_CONF) {
             let mut buf = String::new();
             if let Ok(l) = file.read_to_string(&mut buf) {
                 if l == 0 {
@@ -107,7 +107,7 @@ impl LedSupportFile {
             }
         }
         // Load and append the default LED support data
-        if let Ok(mut file) = OpenOptions::new().read(true).open(&ASUS_LED_MODE_CONF) {
+        if let Ok(mut file) = OpenOptions::new().read(true).open(ASUS_LED_MODE_CONF) {
             let mut buf = String::new();
             if let Ok(l) = file.read_to_string(&mut buf) {
                 if l == 0 {

daemon/src/lib.rs

@@ -25,8 +25,7 @@ use crate::error::RogError;
 use async_trait::async_trait;
 use log::warn;
 use logind_zbus::manager::ManagerProxy;
-use zbus::{export::futures_util::StreamExt, Connection, SignalContext};
+use zbus::{export::futures_util::StreamExt, zvariant::ObjectPath, Connection, SignalContext};
-use zvariant::ObjectPath;
 
 /// This macro adds a function which spawns an `inotify` task on the passed in `Executor`.
 ///
@@ -64,7 +63,6 @@ macro_rules! task_watch_item {
                             let mut buffer = [0; 32];
                             watch.event_stream(&mut buffer).unwrap().for_each(|_| async {
                                 let value = ctrl.$name();
-                                dbg!(&value);
                                 concat_idents::concat_idents!(notif_fn = notify_, $name {
                                     Self::notif_fn(&signal_ctxt, value).await.ok();
                                 });

data/asusd-ledmodes.toml

@@ -12,6 +12,13 @@ standard = ["Static", "Breathe", "Strobe", "Rainbow", "Pulse"]
 multizone = []
 per_key = false
 
+[[led_data]]
+prod_family = "ASUS TUF Gaming A15"
+board_names = ["FA506I"]
+standard = ["Static", "Breathe", "Strobe", "Pulse"]
+multizone = []
+per_key = false
+
 [[led_data]]
 prod_family = "Zephyrus S"
 board_names = ["GX502", "GX701", "G531", "GL531", "G532"]

data/asusd.rules

@@ -9,6 +9,7 @@ ENV{DMI_FAMILY}=="*TUF*", GOTO="asusd_start"
 ENV{DMI_FAMILY}=="*ROG*", GOTO="asusd_start"
 ENV{DMI_FAMILY}=="*Zephyrus*", GOTO="asusd_start"
 ENV{DMI_FAMILY}=="*Strix*", GOTO="asusd_start"
+ENV{DMI_FAMILY}=="*Vivo*ook*", GOTO="asusd_start"
 # No match so
 GOTO="asusd_end"
 
@@ -16,4 +17,4 @@ LABEL="asusd_start"
 ACTION=="add|change", DRIVER=="asus-nb-wmi", TAG+="systemd", ENV{SYSTEMD_WANTS}="asusd.service"
 ACTION=="add|remove", DRIVER=="asus-nb-wmi", TAG+="systemd", RUN+="systemctl restart asusd.service"
 
-LABEL="asusd_end"
+LABEL="asusd_end"

rog-anime/Cargo.toml

@@ -14,7 +14,7 @@ exclude = ["data"]
 
 [features]
 default = ["dbus", "detect"]
-dbus = ["zvariant", "zbus"]
+dbus = ["zbus"]
 detect = ["sysfs-class"]
 
 [dependencies]
@@ -28,7 +28,6 @@ serde_derive.workspace = true
 
 glam.workspace = true
 
-zvariant = { workspace = true, optional = true }
 zbus = { workspace = true, optional = true }
 
 sysfs-class = { workspace = true, optional = true }

rog-anime/src/data.rs

@@ -7,7 +7,7 @@ use std::{
 use log::info;
 use serde_derive::{Deserialize, Serialize};
 #[cfg(feature = "dbus")]
-use zvariant::Type;
+use zbus::zvariant::Type;
 
 use crate::{
     error::{AnimeError, Result},

rog-aura/Cargo.toml

@@ -14,13 +14,13 @@ exclude = ["data"]
 
 [features]
 default = ["dbus", "toml"]
-dbus = ["zvariant"]
+dbus = ["zbus"]
 
 [dependencies]
 serde.workspace = true
 serde_derive.workspace = true
 toml = { workspace = true, optional = true }
-zvariant = { workspace = true, optional = true }
+zbus = { workspace = true, optional = true }
 
 [dev-dependencies]
 serde_json.workspace = true

rog-aura/src/builtin_modes.rs

@@ -5,9 +5,9 @@ pub const LED_INIT4: &str = "^ASUS Tech.Inc."; // ^ == 0x5e
 pub const LED_INIT5: [u8; 6] = [0x5e, 0x05, 0x20, 0x31, 0, 0x08];
 
 use serde_derive::{Deserialize, Serialize};
-use std::str::FromStr;
+use std::{fmt::Display, str::FromStr};
 #[cfg(feature = "dbus")]
-use zvariant::Type;
+use zbus::zvariant::Type;
 
 use crate::{error::Error, LED_MSG_LEN};
 
@@ -171,6 +171,12 @@ pub enum AuraModeNum {
     Flash = 12,
 }
 
+impl Display for AuraModeNum {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        write!(f, "{}", <&str>::from(self))
+    }
+}
+
 impl From<AuraModeNum> for String {
     fn from(mode: AuraModeNum) -> Self {
         match mode {

rog-aura/src/per_key_rgb.rs

@@ -1,7 +1,7 @@
 use crate::keys::Key;
 use serde_derive::{Deserialize, Serialize};
 #[cfg(feature = "dbus")]
-use zvariant::Type;
+use zbus::zvariant::Type;
 
 /// Represents the per-key raw USB packets
 pub type PerKeyRaw = Vec<Vec<u8>>;

rog-aura/src/per_zone.rs

@@ -1,6 +1,6 @@
 use serde_derive::{Deserialize, Serialize};
 #[cfg(feature = "dbus")]
-use zvariant::Type;
+use zbus::zvariant::Type;
 
 /// Represents the zoned raw USB packets
 pub type ZonedRaw = Vec<u8>;

rog-aura/src/usb.rs

@@ -1,7 +1,7 @@
 use serde::{Deserialize, Serialize};
 use std::ops::{BitAnd, BitOr};
 #[cfg(feature = "dbus")]
-use zvariant::Type;
+use zbus::zvariant::Type;
 
 pub const LED_INIT1: [u8; 2] = [0x5d, 0xb9];
 pub const LED_INIT2: &str = "]ASUS Tech.Inc."; // ] == 0x5d

rog-control-center/Cargo.toml

@@ -12,14 +12,20 @@ egui = { git = "https://github.com/flukejones/egui" }
 eframe= { git = "https://github.com/flukejones/egui" }
 #eframe= { git = "https://github.com/emilk/egui", default-features = false, features = ["dark-light", "default_fonts", "wgpu"] }
 
+libappindicator = "0.7" # Tray icon
+gtk = "0.15"
+
 daemon = { path = "../daemon" }
 rog_anime = { path = "../rog-anime" }
 rog_dbus = { path = "../rog-dbus" }
 rog_aura = { path = "../rog-aura" }
 rog_profiles = { path = "../rog-profiles" }
 rog_platform = { path = "../rog-platform" }
-supergfxctl = { git = "https://gitlab.com/asus-linux/supergfxctl.git" }
+supergfxctl = { git = "https://gitlab.com/asus-linux/supergfxctl.git", default-features = false }
-#supergfxctl = { path = "../../supergfxctl" }
+#supergfxctl = { path = "../../supergfxctl", default-features = false }
+
+log.workspace = true
+env_logger.workspace = true
 
 tokio.workspace = true
 serde.workspace = true
@@ -30,5 +36,7 @@ zbus.workspace = true
 dirs.workspace = true
 notify-rust.workspace = true
 
-nix = "^0.20.0"
+png_pong.workspace = true
+
+nix = "^0.25"
 tempfile = "3.2.0"

rog-control-center/src/app.rs

@@ -2,7 +2,7 @@ use std::{
     f64::consts::PI,
     sync::{
         atomic::{AtomicBool, AtomicU8, Ordering},
-        Arc,
+        Arc, Mutex,
     },
     time::{Duration, Instant},
 };
@@ -11,16 +11,15 @@ use egui::{Button, RichText};
 use rog_platform::supported::SupportedFunctions;
 
 use crate::{
-    config::Config, error::Result, page_states::PageDataStates, Page, RogDbusClientBlocking,
+    config::Config, error::Result, system_state::SystemState, Page, RogDbusClientBlocking,
 };
 
-pub struct RogApp<'a> {
+pub struct RogApp {
     pub page: Page,
-    pub states: PageDataStates,
+    pub states: Arc<Mutex<SystemState>>,
     pub supported: SupportedFunctions,
     // TODO: can probably just open and read whenever
     pub config: Config,
-    pub asus_dbus: RogDbusClientBlocking<'a>,
     /// Oscillator in percentage
     pub oscillator1: Arc<AtomicU8>,
     pub oscillator2: Arc<AtomicU8>,
@@ -31,11 +30,11 @@ pub struct RogApp<'a> {
     pub oscillator_toggle: Arc<AtomicBool>,
 }
 
-impl<'a> RogApp<'a> {
+impl RogApp {
     /// Called once before the first frame.
     pub fn new(
         config: Config,
-        states: PageDataStates,
+        states: Arc<Mutex<SystemState>>,
         _cc: &eframe::CreationContext<'_>,
     ) -> Result<Self> {
         let (dbus, _) = RogDbusClientBlocking::new()?;
@@ -55,6 +54,7 @@ impl<'a> RogApp<'a> {
         let oscillator_freq1 = oscillator_freq.clone();
         let oscillator_toggle = Arc::new(AtomicBool::new(false));
         let oscillator_toggle1 = oscillator_toggle.clone();
+
         std::thread::spawn(move || {
             let started = Instant::now();
             let mut toggled = false;
@@ -83,6 +83,7 @@ impl<'a> RogApp<'a> {
                 oscillator1_1.store(tmp1, Ordering::SeqCst);
                 oscillator1_2.store(tmp2, Ordering::SeqCst);
                 oscillator1_3.store(tmp3, Ordering::SeqCst);
+
                 std::thread::sleep(Duration::from_millis(33));
             }
         });
@@ -92,7 +93,6 @@ impl<'a> RogApp<'a> {
             states,
             page: Page::System,
             config,
-            asus_dbus: dbus,
             oscillator1,
             oscillator2,
             oscillator3,
@@ -102,60 +102,63 @@ impl<'a> RogApp<'a> {
     }
 }
 
-impl<'a> eframe::App for RogApp<'a> {
+impl eframe::App for RogApp {
     /// Called each time the UI needs repainting, which may be many times per second.
     /// Put your widgets into a `SidePanel`, `TopPanel`, `CentralPanel`, `Window` or `Area`.
     fn update(&mut self, ctx: &egui::Context, frame: &mut eframe::Frame) {
-        let Self {
+        let states = self.states.clone();
-            supported,
+
-            asus_dbus: dbus,
+        if let Ok(mut states) = states.try_lock() {
-            states,
+            if states.app_should_update {
-            ..
+                states.app_should_update = false;
-        } = self;
+                ctx.request_repaint();
-        states
+            }
-            .refresh_if_notfied(supported, dbus)
+        }
-            .map(|repaint| {
-                if repaint {
-                    ctx.request_repaint();
-                }
-            })
-            .map_err(|e| self.states.error = Some(e.to_string()))
-            .ok();
 
         let page = self.page;
 
         self.top_bar(ctx, frame);
         self.side_panel(ctx);
 
-        if let Some(err) = self.states.error.clone() {
+        let mut was_error = false;
-            egui::CentralPanel::default().show(ctx, |ui| {
-                ui.heading(RichText::new("Error!").size(28.0));
 
-                ui.centered_and_justified(|ui| {
+        if let Ok(mut states) = states.try_lock() {
-                    ui.label(RichText::new(format!("The error was: {:?}", err)).size(22.0));
+            if let Some(err) = states.error.clone() {
-                });
+                was_error = true;
-            });
+                egui::CentralPanel::default().show(ctx, |ui| {
-            egui::TopBottomPanel::bottom("error_bar")
+                    ui.heading(RichText::new("Error!").size(28.0));
-                .default_height(26.0)
+
-                .show(ctx, |ui| {
+                    ui.centered_and_justified(|ui| {
-                    ui.with_layout(egui::Layout::right_to_left(egui::Align::TOP), |ui| {
+                        ui.label(RichText::new(format!("The error was: {:?}", err)).size(22.0));
-                        if ui
-                            .add(Button::new(RichText::new("Okay").size(20.0)))
-                            .clicked()
-                        {
-                            self.states.error = None;
-                        }
                     });
                 });
-        } else if page == Page::System {
+                egui::TopBottomPanel::bottom("error_bar")
-            self.system_page(ctx);
+                    .default_height(26.0)
-        } else if page == Page::AuraEffects {
+                    .show(ctx, |ui| {
-            self.aura_page(ctx);
+                        ui.with_layout(egui::Layout::right_to_left(egui::Align::TOP), |ui| {
-        // TODO: Anime page is not complete
+                            if ui
-        // } else if page == Page::AnimeMatrix {
+                                .add(Button::new(RichText::new("Okay").size(20.0)))
-        //     self.anime_page(ctx);
+                                .clicked()
-        } else if page == Page::FanCurves {
+                            {
-            self.fan_curve_page(ctx);
+                                states.error = None;
+                            }
+                        });
+                    });
+            }
+        }
+        if !was_error {
+            if let Ok(mut states) = states.try_lock() {
+                if page == Page::System {
+                    self.system_page(&mut states, ctx);
+                } else if page == Page::AuraEffects {
+                    self.aura_page(&mut states, ctx);
+                // TODO: Anime page is not complete
+                // } else if page == Page::AnimeMatrix {
+                //     self.anime_page(ctx);
+                } else if page == Page::FanCurves {
+                    self.fan_curve_page(&mut states, ctx);
+                }
+            }
         }
     }
 }

rog-control-center/src/config.rs

@@ -1,22 +1,23 @@
+use log::{error, info, warn};
+use serde_derive::{Deserialize, Serialize};
 use std::{
     fs::{create_dir, OpenOptions},
     io::{Read, Write},
 };
-
-use serde_derive::{Deserialize, Serialize};
 //use log::{error, info, warn};
 
-use crate::error::Error;
+use crate::{error::Error, notify::EnabledNotifications};
 
 const CFG_DIR: &str = "rog";
 const CFG_FILE_NAME: &str = "rog-control-center.cfg";
 
-#[derive(Debug, Deserialize, Serialize)]
+#[derive(Debug, Clone, Deserialize, Serialize)]
 #[serde(default)]
 pub struct Config {
     pub run_in_background: bool,
     pub startup_in_background: bool,
     pub enable_notifications: bool,
+    pub enabled_notifications: EnabledNotifications,
 }
 
 impl Default for Config {
@@ -25,6 +26,7 @@ impl Default for Config {
             run_in_background: true,
             startup_in_background: false,
             enable_notifications: true,
+            enabled_notifications: EnabledNotifications::default(),
         }
     }
 }
@@ -32,14 +34,17 @@ impl Default for Config {
 impl Config {
     pub fn load() -> Result<Config, Error> {
         let mut path = if let Some(dir) = dirs::config_dir() {
+            info!("Found XDG config dir {dir:?}");
             dir
         } else {
+            error!("Could not get XDG config dir");
             return Err(Error::XdgVars);
         };
 
         path.push(CFG_DIR);
         if !path.exists() {
             create_dir(path.clone())?;
+            info!("Created {path:?}");
         }
 
         path.push(CFG_FILE_NAME);
@@ -54,18 +59,20 @@ impl Config {
 
         if let Ok(read_len) = file.read_to_string(&mut buf) {
             if read_len == 0 {
+                warn!("Zero len read of Config file");
                 let default = Config::default();
                 let t = toml::to_string_pretty(&default).unwrap();
                 file.write_all(t.as_bytes())?;
                 return Ok(default);
             } else if let Ok(data) = toml::from_str::<Config>(&buf) {
+                info!("Loaded config file {path:?}");
                 return Ok(data);
             }
         }
         Err(Error::ConfigLoadFail)
     }
 
-    pub fn save(&self) -> Result<(), Error> {
+    pub fn save(&mut self, enabled_notifications: &EnabledNotifications) -> Result<(), Error> {
         let mut path = if let Some(dir) = dirs::config_dir() {
             dir
         } else {
@@ -75,6 +82,7 @@ impl Config {
         path.push(CFG_DIR);
         if !path.exists() {
             create_dir(path.clone())?;
+            info!("Created {path:?}");
         }
 
         path.push(CFG_FILE_NAME);
@@ -85,8 +93,10 @@ impl Config {
             .truncate(true)
             .open(&path)?;
 
+        self.enabled_notifications = enabled_notifications.clone();
         let t = toml::to_string_pretty(&self).unwrap();
         file.write_all(t.as_bytes())?;
+        info!("Saved config file {path:?}");
         Ok(())
     }
 }

rog-control-center/src/lib.rs

@@ -14,9 +14,10 @@ pub mod error;
 #[cfg(feature = "mocking")]
 pub mod mocking;
 pub mod notify;
-pub mod page_states;
 pub mod pages;
 pub mod startup_error;
+pub mod system_state;
+pub mod tray;
 pub mod widgets;
 
 #[cfg(feature = "mocking")]
@@ -96,7 +97,7 @@ pub fn get_ipc_file() -> Result<File, crate::error::Error> {
     let tmp_dir = std::env::temp_dir().join("rog-gui");
     let fifo_path = tmp_dir.join("ipc.pipe");
     if let Err(e) = unistd::mkfifo(&fifo_path, stat::Mode::S_IRWXU) {
-        if !matches!(e, nix::Error::Sys(nix::errno::Errno::EEXIST)) {
+        if !matches!(e, nix::errno::Errno::EEXIST) {
             return Err(e)?;
         }
     }

rog-control-center/src/main.rs

@@ -1,28 +1,38 @@
-use eframe::NativeOptions;
+use eframe::{IconData, NativeOptions};
+use log::{error, info, LevelFilter};
 use rog_aura::layouts::KeyLayout;
+use rog_control_center::notify::EnabledNotifications;
+use rog_control_center::tray::init_tray;
 use rog_control_center::{
     config::Config, error::Result, get_ipc_file, notify::start_notifications, on_tmp_dir_exists,
-    page_states::PageDataStates, print_versions, startup_error::AppErrorShow, RogApp,
+    print_versions, startup_error::AppErrorShow, system_state::SystemState, RogApp,
     RogDbusClientBlocking, SHOWING_GUI, SHOW_GUI,
 };
 use rog_platform::supported::SupportedFunctions;
-use tokio::runtime::Runtime;
+use std::sync::Mutex;
-
 use std::{
     fs::OpenOptions,
     io::{Read, Write},
     path::PathBuf,
-    sync::{atomic::AtomicBool, Arc},
+    sync::Arc,
 };
+use tokio::runtime::Runtime;
 
 #[cfg(not(feature = "mocking"))]
 const DATA_DIR: &str = "/usr/share/rog-gui/";
 #[cfg(feature = "mocking")]
 const DATA_DIR: &str = env!("CARGO_MANIFEST_DIR");
 const BOARD_NAME: &str = "/sys/class/dmi/id/board_name";
+const APP_ICON_PATH: &str = "/usr/share/icons/hicolor/512x512/apps/rog-control-center.png";
 
 fn main() -> Result<()> {
     print_versions();
+    let mut logger = env_logger::Builder::new();
+    logger
+        .target(env_logger::Target::Stdout)
+        .format(|buf, record| writeln!(buf, "{}: {}", record.level(), record.args()))
+        .filter(None, LevelFilter::Info)
+        .init();
 
     // start tokio
     let rt = Runtime::new().expect("Unable to create Runtime");
@@ -36,6 +46,7 @@ fn main() -> Result<()> {
         min_window_size: Some(egui::vec2(840.0, 600.0)),
         max_window_size: Some(egui::vec2(840.0, 600.0)),
         run_and_return: true,
+        icon_data: Some(load_icon()),
         ..Default::default()
     };
 
@@ -49,14 +60,28 @@ fn main() -> Result<()> {
         })
         .unwrap();
 
+    let supported = match dbus.proxies().supported().supported_functions() {
+        Ok(s) => s,
+        Err(e) => {
+            eframe::run_native(
+                "ROG Control Center",
+                native_options.clone(),
+                Box::new(move |_| Box::new(AppErrorShow::new(e.to_string()))),
+            );
+            SupportedFunctions::default()
+        }
+    };
+
     // Startup
     let mut config = Config::load()?;
     let mut start_closed = config.startup_in_background;
 
     if config.startup_in_background {
         config.run_in_background = true;
-        config.save()?;
+        let tmp = config.enabled_notifications.clone(); // ends up being a double clone, oh well.
+        config.save(&tmp)?;
     }
+    let enabled_notifications = EnabledNotifications::tokio_mutex(&config);
 
     // Find and load a matching layout for laptop
     let mut file = OpenOptions::new()
@@ -93,16 +118,16 @@ fn main() -> Result<()> {
         Err(_) => on_tmp_dir_exists().unwrap(),
     };
 
-    let states =
+    let states = setup_page_state_and_notifs(layout, enabled_notifications, &supported)?;
-        setup_page_state_and_notifs(layout.clone(), &config, native_options.clone(), &dbus)
+
-            .unwrap();
+    init_tray(supported, states.clone());
 
     loop {
         if !start_closed {
             start_app(states.clone(), native_options.clone())?;
         }
 
-        let config = Config::load().unwrap();
+        let config = Config::load()?;
         if !config.run_in_background {
             break;
         }
@@ -111,7 +136,7 @@ fn main() -> Result<()> {
             let mut buf = [0u8; 4];
             // blocks until it is read, typically the read will happen after a second
             // process writes to the IPC (so there is data to actually read)
-            if get_ipc_file().unwrap().read(&mut buf).is_ok() && buf[0] == SHOW_GUI {
+            if get_ipc_file()?.read(&mut buf).is_ok() && buf[0] == SHOW_GUI {
                 start_closed = false;
                 continue;
             }
@@ -127,59 +152,23 @@ fn main() -> Result<()> {
 
 fn setup_page_state_and_notifs(
     keyboard_layout: KeyLayout,
-    config: &Config,
+    enabled_notifications: Arc<Mutex<EnabledNotifications>>,
-    native_options: NativeOptions,
+    supported: &SupportedFunctions,
-    dbus: &RogDbusClientBlocking,
+) -> Result<Arc<Mutex<SystemState>>> {
-) -> Result<PageDataStates> {
+    let page_states = Arc::new(Mutex::new(SystemState::new(
-    // Cheap method to alert to notifications rather than spinning a thread for each
-    // This is quite different when done in a retained mode app
-    let charge_notified = Arc::new(AtomicBool::new(false));
-    let bios_notified = Arc::new(AtomicBool::new(false));
-    let aura_notified = Arc::new(AtomicBool::new(false));
-    let anime_notified = Arc::new(AtomicBool::new(false));
-    let profiles_notified = Arc::new(AtomicBool::new(false));
-    let fans_notified = Arc::new(AtomicBool::new(false));
-    let notifs_enabled = Arc::new(AtomicBool::new(config.enable_notifications));
-
-    start_notifications(
-        charge_notified.clone(),
-        bios_notified.clone(),
-        aura_notified.clone(),
-        anime_notified.clone(),
-        profiles_notified.clone(),
-        fans_notified.clone(),
-        notifs_enabled.clone(),
-    )?;
-
-    let supported = match dbus.proxies().supported().supported_functions() {
-        Ok(s) => s,
-        Err(e) => {
-            eframe::run_native(
-                "ROG Control Center",
-                native_options,
-                Box::new(move |_| Box::new(AppErrorShow::new(e.to_string()))),
-            );
-            SupportedFunctions::default()
-        }
-    };
-
-    PageDataStates::new(
         keyboard_layout,
-        notifs_enabled.clone(),
+        enabled_notifications.clone(),
-        charge_notified.clone(),
+        supported,
-        bios_notified.clone(),
+    )?));
-        aura_notified.clone(),
+
-        anime_notified.clone(),
+    start_notifications(page_states.clone(), enabled_notifications)?;
-        profiles_notified.clone(),
+
-        fans_notified.clone(),
+    Ok(page_states)
-        &supported,
-        &dbus,
-    )
 }
 
-fn start_app(states: PageDataStates, native_options: NativeOptions) -> Result<()> {
+fn start_app(states: Arc<Mutex<SystemState>>, native_options: NativeOptions) -> Result<()> {
-    let mut ipc_file = get_ipc_file().unwrap();
+    let mut ipc_file = get_ipc_file()?;
-    ipc_file.write_all(&[SHOWING_GUI]).unwrap();
+    ipc_file.write_all(&[SHOWING_GUI])?;
     eframe::run_native(
         "ROG Control Center",
         native_options,
@@ -187,3 +176,42 @@ fn start_app(states: PageDataStates, native_options: NativeOptions) -> Result<()
     );
     Ok(())
 }
+
+/// Bah.. the icon dosn't work on wayland anyway, but we'll leave it in for now.
+fn load_icon() -> IconData {
+    let path = PathBuf::from(APP_ICON_PATH);
+    let mut buf = Vec::new();
+    let mut rgba = Vec::new();
+    let mut height = 512;
+    let mut width = 512;
+    if path.exists() {
+        if let Ok(mut file) = OpenOptions::new()
+            .read(true)
+            .open(path)
+            .map_err(|e| error!("Error opening app icon: {e:?}"))
+        {
+            file.read_to_end(&mut buf)
+                .map_err(|e| error!("Error reading app icon: {e:?}"))
+                .ok();
+
+            let data = std::io::Cursor::new(buf);
+            let decoder = png_pong::Decoder::new(data).unwrap().into_steps();
+            let png_pong::Step { raster, delay: _ } = decoder.last().unwrap().unwrap();
+
+            if let png_pong::PngRaster::Rgba8(ras) = raster {
+                rgba = ras.as_u8_slice().to_vec();
+                width = ras.width();
+                height = ras.height();
+                info!("Loaded app icon. Not actually supported in Wayland yet");
+            }
+        }
+    } else {
+        error!("Missing {APP_ICON_PATH}")
+    }
+
+    IconData {
+        height,
+        width,
+        rgba,
+    }
+}

rog-control-center/src/notify.rs

@@ -1,23 +1,68 @@
-use crate::error::Result;
+use crate::{config::Config, error::Result, system_state::SystemState};
-use notify_rust::{Hint, Notification, NotificationHandle};
+use log::{error, info, trace};
+use notify_rust::{Hint, Notification, NotificationHandle, Urgency};
 use rog_dbus::{
     zbus_anime::AnimeProxy, zbus_led::LedProxy, zbus_platform::RogBiosProxy,
     zbus_power::PowerProxy, zbus_profile::ProfileProxy,
 };
 use rog_platform::platform::GpuMode;
 use rog_profiles::Profile;
+use serde::{Deserialize, Serialize};
 use std::{
     fmt::Display,
-    sync::{
+    process::Command,
-        atomic::{AtomicBool, Ordering},
+    sync::{Arc, Mutex},
-        Arc, Mutex,
-    },
 };
-use supergfxctl::pci_device::GfxPower;
+use supergfxctl::{pci_device::GfxPower, zbus_proxy::DaemonProxy as SuperProxy};
 use zbus::export::futures_util::{future, StreamExt};
 
 const NOTIF_HEADER: &str = "ROG Control";
 
+#[derive(Debug, Clone, Deserialize, Serialize)]
+#[serde(default)]
+pub struct EnabledNotifications {
+    pub receive_notify_post_boot_sound: bool,
+    pub receive_notify_panel_od: bool,
+    pub receive_notify_dgpu_disable: bool,
+    pub receive_notify_egpu_enable: bool,
+    pub receive_notify_gpu_mux_mode: bool,
+    pub receive_notify_charge_control_end_threshold: bool,
+    pub receive_notify_mains_online: bool,
+    pub receive_notify_profile: bool,
+    pub receive_notify_led: bool,
+    /// Anime
+    pub receive_power_states: bool,
+    pub receive_notify_gfx: bool,
+    pub receive_notify_gfx_status: bool,
+    pub all_enabled: bool,
+}
+
+impl Default for EnabledNotifications {
+    fn default() -> Self {
+        Self {
+            receive_notify_post_boot_sound: false,
+            receive_notify_panel_od: true,
+            receive_notify_dgpu_disable: true,
+            receive_notify_egpu_enable: true,
+            receive_notify_gpu_mux_mode: true,
+            receive_notify_charge_control_end_threshold: true,
+            receive_notify_mains_online: false,
+            receive_notify_profile: true,
+            receive_notify_led: false,
+            receive_power_states: false,
+            receive_notify_gfx: false,
+            receive_notify_gfx_status: false,
+            all_enabled: false,
+        }
+    }
+}
+
+impl EnabledNotifications {
+    pub fn tokio_mutex(config: &Config) -> Arc<Mutex<Self>> {
+        Arc::new(Mutex::new(config.enabled_notifications.clone()))
+    }
+}
+
 macro_rules! notify {
     ($notifier:expr, $last_notif:ident) => {
         if let Some(notif) = $last_notif.take() {
@@ -29,35 +74,49 @@ macro_rules! notify {
     };
 }
 
+// TODO: drop the macro and use generics plus closure
 macro_rules! recv_notif {
     ($proxy:ident,
         $signal:ident,
-        $was_notified:ident,
         $last_notif:ident,
         $notif_enabled:ident,
-        [$($out_arg:ident)+],
+        $page_states:ident,
+        ($($args: tt)*),
+        ($($out_arg:tt)+),
         $msg:literal,
         $notifier:ident) => {
+
         let last_notif = $last_notif.clone();
         let notifs_enabled1 = $notif_enabled.clone();
-        let notified = $was_notified.clone();
+        let page_states1 = $page_states.clone();
-        // TODO: make a macro or generic function or something...
+
         tokio::spawn(async move {
-                let conn = zbus::Connection::system().await.unwrap();
+                let conn = zbus::Connection::system().await.map_err(|e| {
-                let proxy = $proxy::new(&conn).await.unwrap();
+                        log::error!("zbus signal: {}: {e}", stringify!($signal));
-                if let Ok(p) = proxy.$signal().await {
+                        e
-                    p.for_each(|e| {
+                    }).unwrap();
+                let proxy = $proxy::new(&conn).await.map_err(|e| {
+                        log::error!("zbus signal: {}: {e}", stringify!($signal));
+                        e
+                    }).unwrap();
+                if let Ok(mut p) = proxy.$signal().await {
+                    info!("Started zbus signal thread: {}", stringify!($signal));
+                    while let Some(e) = p.next().await {
                         if let Ok(out) = e.args() {
-                            if notifs_enabled1.load(Ordering::SeqCst) {
+                            if let Ok(config) = notifs_enabled1.lock() {
-                                if let Ok(ref mut lock) = last_notif.try_lock() {
+                                if config.all_enabled && config.$signal {
-                                    notify!($notifier($msg, &out$(.$out_arg)+()), lock);
+                                    if let Ok(ref mut lock) = last_notif.lock() {
+                                        trace!("zbus signal {} locked last_notif", stringify!($signal));
+                                        notify!($notifier($msg, &out.$($out_arg)+()), lock);
+                                    }
                                 }
                             }
-                            notified.store(true, Ordering::SeqCst);
+                            if let Ok(mut lock) = page_states1.lock() {
+                                lock.$($args)+ = *out.$($out_arg)+();
+                                lock.set_notified();
+                            }
                         }
-                        future::ready(())
+                    }
-                    })
-                    .await;
                 };
             });
     };
@@ -66,13 +125,8 @@ macro_rules! recv_notif {
 type SharedHandle = Arc<Mutex<Option<NotificationHandle>>>;
 
 pub fn start_notifications(
-    charge_notified: Arc<AtomicBool>,
+    page_states: Arc<Mutex<SystemState>>,
-    bios_notified: Arc<AtomicBool>,
+    enabled_notifications: Arc<Mutex<EnabledNotifications>>,
-    aura_notified: Arc<AtomicBool>,
-    anime_notified: Arc<AtomicBool>,
-    profiles_notified: Arc<AtomicBool>,
-    _fans_notified: Arc<AtomicBool>,
-    notifs_enabled: Arc<AtomicBool>,
 ) -> Result<()> {
     let last_notification: SharedHandle = Arc::new(Mutex::new(None));
 
@@ -80,10 +134,11 @@ pub fn start_notifications(
     recv_notif!(
         RogBiosProxy,
         receive_notify_post_boot_sound,
-        bios_notified,
         last_notification,
-        notifs_enabled,
+        enabled_notifications,
-        [on],
+        page_states,
+        (bios.post_sound),
+        (on),
         "BIOS Post sound",
         do_notification
     );
@@ -91,10 +146,11 @@ pub fn start_notifications(
     recv_notif!(
         RogBiosProxy,
         receive_notify_panel_od,
-        bios_notified,
         last_notification,
-        notifs_enabled,
+        enabled_notifications,
-        [overdrive],
+        page_states,
+        (bios.panel_overdrive),
+        (overdrive),
         "Panel Overdrive enabled:",
         do_notification
     );
@@ -102,10 +158,11 @@ pub fn start_notifications(
     recv_notif!(
         RogBiosProxy,
         receive_notify_dgpu_disable,
-        bios_notified,
         last_notification,
-        notifs_enabled,
+        enabled_notifications,
-        [disable],
+        page_states,
+        (bios.dgpu_disable),
+        (disable),
         "BIOS dGPU disabled",
         do_notification
     );
@@ -113,10 +170,11 @@ pub fn start_notifications(
     recv_notif!(
         RogBiosProxy,
         receive_notify_egpu_enable,
-        bios_notified,
         last_notification,
-        notifs_enabled,
+        enabled_notifications,
-        [enable],
+        page_states,
+        (bios.egpu_enable),
+        (enable),
         "BIOS eGPU enabled",
         do_notification
     );
@@ -124,22 +182,24 @@ pub fn start_notifications(
     recv_notif!(
         RogBiosProxy,
         receive_notify_gpu_mux_mode,
-        bios_notified,
         last_notification,
-        notifs_enabled,
+        enabled_notifications,
-        [mode],
+        page_states,
-        "BIOS GPU MUX mode (reboot required)",
+        (bios.dedicated_gfx),
-        mux_notification
+        (mode),
+        "Reboot required. BIOS GPU MUX mode set to",
+        do_mux_notification
     );
 
     // Charge notif
     recv_notif!(
         PowerProxy,
         receive_notify_charge_control_end_threshold,
-        charge_notified,
         last_notification,
-        notifs_enabled,
+        enabled_notifications,
-        [limit],
+        page_states,
+        (power_state.charge_limit),
+        (limit),
         "Battery charge limit changed to",
         do_notification
     );
@@ -147,10 +207,11 @@ pub fn start_notifications(
     recv_notif!(
         PowerProxy,
         receive_notify_mains_online,
-        bios_notified,
         last_notification,
-        notifs_enabled,
+        enabled_notifications,
-        [on],
+        page_states,
+        (power_state.ac_power),
+        (on),
         "AC Power power is",
         ac_power_notification
     );
@@ -159,10 +220,11 @@ pub fn start_notifications(
     recv_notif!(
         ProfileProxy,
         receive_notify_profile,
-        profiles_notified,
         last_notification,
-        notifs_enabled,
+        enabled_notifications,
-        [profile],
+        page_states,
+        (profiles.current),
+        (profile),
         "Profile changed to",
         do_thermal_notif
     );
@@ -172,69 +234,138 @@ pub fn start_notifications(
     recv_notif!(
         LedProxy,
         receive_notify_led,
-        aura_notified,
         last_notification,
-        notifs_enabled,
+        enabled_notifications,
-        [data mode_name],
+        page_states,
+        (aura.current_mode),
+        (data.mode),
         "Keyboard LED mode changed to",
         do_notification
     );
 
+    let page_states1 = page_states.clone();
     tokio::spawn(async move {
-        let conn = zbus::Connection::system().await.unwrap();
+        let conn = zbus::Connection::system()
-        let proxy = LedProxy::new(&conn).await.unwrap();
-        if let Ok(p) = proxy.receive_all_signals().await {
-            p.for_each(|_| {
-                aura_notified.store(true, Ordering::SeqCst);
-                future::ready(())
-            })
-            .await;
-        };
-    });
-
-    tokio::spawn(async move {
-        let conn = zbus::Connection::system().await.unwrap();
-        let proxy = AnimeProxy::new(&conn).await.unwrap();
-        if let Ok(p) = proxy.receive_power_states().await {
-            p.for_each(|_| {
-                anime_notified.store(true, Ordering::SeqCst);
-                future::ready(())
-            })
-            .await;
-        };
-    });
-
-    let notifs_enabled1 = notifs_enabled.clone();
-    let last_notif = last_notification.clone();
-    let bios_notified1 = bios_notified.clone();
-    tokio::spawn(async move {
-        let conn = zbus::Connection::system().await.unwrap();
-        let proxy = supergfxctl::zbus_proxy::DaemonProxy::new(&conn)
             .await
+            .map_err(|e| {
+                error!("zbus signal: receive_power_states: {e}");
+                e
+            })
             .unwrap();
-        if let Ok(p) = proxy.receive_notify_gfx_status().await {
+        let proxy = AnimeProxy::new(&conn)
-            p.for_each(|e| {
+            .await
+            .map_err(|e| {
+                error!("zbus signal: receive_power_states: {e}");
+                e
+            })
+            .unwrap();
+        if let Ok(p) = proxy.receive_power_states().await {
+            info!("Started zbus signal thread: receive_power_states");
+            p.for_each(|_| {
+                if let Ok(_lock) = page_states1.lock() {
+                    // TODO: lock.anime.
+                }
+                future::ready(())
+            })
+            .await;
+        };
+    });
+
+    recv_notif!(
+        SuperProxy,
+        receive_notify_gfx,
+        last_notification,
+        enabled_notifications,
+        page_states,
+        (gfx_state.mode),
+        (mode),
+        "Gfx mode changed to",
+        do_notification
+    );
+
+    // recv_notif!(
+    //     SuperProxy,
+    //     receive_notify_action,
+    //     bios_notified,
+    //     last_gfx_action_notif,
+    //     enabled_notifications,
+    //     [action],
+    //     "Gfx mode change requires",
+    //     do_gfx_action_notif
+    // );
+
+    tokio::spawn(async move {
+        let conn = zbus::Connection::system()
+            .await
+            .map_err(|e| {
+                error!("zbus signal: receive_notify_action: {e}");
+                e
+            })
+            .unwrap();
+        let proxy = SuperProxy::new(&conn)
+            .await
+            .map_err(|e| {
+                error!("zbus signal: receive_notify_action: {e}");
+                e
+            })
+            .unwrap();
+        if let Ok(mut p) = proxy.receive_notify_action().await {
+            info!("Started zbus signal thread: receive_notify_action");
+            while let Some(e) = p.next().await {
                 if let Ok(out) = e.args() {
-                    if notifs_enabled1.load(Ordering::SeqCst) {
+                    let action = out.action();
-                        let status = out.status();
+                    do_gfx_action_notif("Gfx mode change requires", &format!("{action:?}",))
-                        if *status != GfxPower::Unknown {
+                        .map_err(|e| {
-                            // Required check because status cycles through active/unknown/suspended
+                            error!("zbus signal: do_gfx_action_notif: {e}");
-                            if let Ok(ref mut lock) = last_notif.try_lock() {
+                            e
-                                notify!(
+                        })
-                                    do_notification(
+                        .unwrap();
-                                        "dGPU status changed:",
+                }
-                                        &format!("{status:?}",)
+            }
-                                    ),
+        };
-                                    lock
+    });
-                                );
+
+    let notifs_enabled1 = enabled_notifications;
+    let last_notif = last_notification;
+    tokio::spawn(async move {
+        let conn = zbus::Connection::system()
+            .await
+            .map_err(|e| {
+                error!("zbus signal: receive_notify_gfx_status: {e}");
+                e
+            })
+            .unwrap();
+        let proxy = SuperProxy::new(&conn)
+            .await
+            .map_err(|e| {
+                error!("zbus signal: receive_notify_gfx_status: {e}");
+                e
+            })
+            .unwrap();
+        if let Ok(mut p) = proxy.receive_notify_gfx_status().await {
+            info!("Started zbus signal thread: receive_notify_gfx_status");
+            while let Some(e) = p.next().await {
+                if let Ok(out) = e.args() {
+                    let status = out.status;
+                    if status != GfxPower::Unknown {
+                        if let Ok(config) = notifs_enabled1.lock() {
+                            if config.all_enabled && config.receive_notify_gfx_status {
+                                // Required check because status cycles through active/unknown/suspended
+                                if let Ok(ref mut lock) = last_notif.lock() {
+                                    notify!(
+                                        do_gpu_status_notif("dGPU status changed:", &status),
+                                        lock
+                                    );
+                                }
                             }
                         }
+                        if let Ok(mut lock) = page_states.lock() {
+                            lock.gfx_state.power_status = status;
+                            lock.set_notified();
+                        }
                     }
                 }
-                bios_notified1.store(true, Ordering::SeqCst);
+            }
-                future::ready(())
-            })
-            .await;
         };
     });
 
@@ -273,11 +404,6 @@ fn ac_power_notification(message: &str, on: &bool) -> Result<NotificationHandle>
     Ok(base_notification(message, &data).show()?)
 }
 
-/// Actual GpuMode unused as data is never correct until switched by reboot
-fn mux_notification(message: &str, _: &GpuMode) -> Result<NotificationHandle> {
-    Ok(base_notification(message, &"").show()?)
-}
-
 fn do_thermal_notif(message: &str, profile: &Profile) -> Result<NotificationHandle> {
     let icon = match profile {
         Profile::Balanced => "asus_notif_yellow",
@@ -288,3 +414,49 @@ fn do_thermal_notif(message: &str, profile: &Profile) -> Result<NotificationHand
     let mut notif = base_notification(message, &profile.to_uppercase());
     Ok(notif.icon(icon).show()?)
 }
+
+fn do_gpu_status_notif(message: &str, data: &GfxPower) -> Result<NotificationHandle> {
+    // eww
+    let mut notif = base_notification(message, &<&str>::from(data).to_string());
+    let icon = match data {
+        GfxPower::Active => "asus_notif_red",
+        GfxPower::Suspended => "asus_notif_blue",
+        GfxPower::Off => "asus_notif_green",
+        GfxPower::AsusDisabled => "asus_notif_white",
+        GfxPower::AsusMuxDiscreet => "asus_notif_red",
+        GfxPower::Unknown => "gpu-integrated",
+    };
+    notif.icon(icon);
+    Ok(Notification::show(&notif)?)
+}
+
+fn do_gfx_action_notif<T>(message: &str, data: &T) -> Result<()>
+where
+    T: Display,
+{
+    let mut notif = base_notification(message, data);
+    notif.action("gnome-session-quit", "Logout");
+    notif.urgency(Urgency::Critical);
+    notif.timeout(3000);
+    notif.icon("dialog-warning");
+    notif.hint(Hint::Transient(true));
+    let handle = notif.show()?;
+    handle.wait_for_action(|id| {
+        if id == "gnome-session-quit" {
+            let mut cmd = Command::new("gnome-session-quit");
+            cmd.spawn().ok();
+        } else if id == "__closed" {
+            // TODO: cancel the switching
+        }
+    });
+    Ok(())
+}
+
+/// Actual GpuMode unused as data is never correct until switched by reboot
+fn do_mux_notification(message: &str, _: &GpuMode) -> Result<NotificationHandle> {
+    let mut notif = base_notification(message, &"");
+    notif.urgency(Urgency::Critical);
+    notif.icon("system-reboot-symbolic");
+    notif.hint(Hint::Transient(true));
+    Ok(notif.show()?)
+}

rog-control-center/src/pages/anime_page.rs

@@ -1,6 +1,6 @@
 use crate::RogApp;
 
-impl<'a> RogApp<'a> {
+impl RogApp {
     pub fn anime_page(&mut self, ctx: &egui::Context) {
         egui::CentralPanel::default().show(ctx, |ui| {
             ui.label("In progress");

rog-control-center/src/pages/aura_page.rs

@@ -4,16 +4,15 @@ use egui::Color32;
 use rog_aura::{AuraEffect, AuraModeNum};
 
 use crate::{
+    system_state::SystemState,
     widgets::{aura_modes_group, keyboard},
     RogApp,
 };
 
-impl<'a> RogApp<'a> {
+impl RogApp {
-    pub fn aura_page(&mut self, ctx: &egui::Context) {
+    pub fn aura_page(&mut self, states: &mut SystemState, ctx: &egui::Context) {
         let Self {
             supported,
-            states,
-            asus_dbus: dbus,
             oscillator1,
             oscillator2,
             oscillator3,
@@ -26,7 +25,6 @@ impl<'a> RogApp<'a> {
         let blue = oscillator3.load(Ordering::SeqCst) as u32;
         states.aura.nudge_wave(red as u8, green as u8, blue as u8);
         // let osc = c.0 * 255 / osc;
-        // dbg!(osc);
         let c1 = states
             .aura
             .modes
@@ -72,7 +70,7 @@ impl<'a> RogApp<'a> {
 
         // TODO: animation of colour changes/periods/blending
         egui::CentralPanel::default().show(ctx, |ui| {
-            aura_modes_group(supported, states, oscillator_freq, dbus, ui);
+            aura_modes_group(supported, states, oscillator_freq, ui);
 
             keyboard(ui, &states.keyboard_layout, &mut states.aura, colour);
         });

rog-control-center/src/pages/fan_curve_page.rs

@@ -1,5 +1,5 @@
 use crate::{
-    page_states::{FanCurvesState, ProfilesState},
+    system_state::{FanCurvesState, ProfilesState, SystemState},
     widgets::fan_graphs,
     RogApp, RogDbusClientBlocking,
 };
@@ -7,14 +7,9 @@ use egui::Ui;
 use rog_platform::supported::SupportedFunctions;
 use rog_profiles::Profile;
 
-impl<'a> RogApp<'a> {
+impl RogApp {
-    pub fn fan_curve_page(&mut self, ctx: &egui::Context) {
+    pub fn fan_curve_page(&mut self, states: &mut SystemState, ctx: &egui::Context) {
-        let Self {
+        let Self { supported, .. } = self;
-            supported,
-            states,
-            asus_dbus: dbus,
-            ..
-        } = self;
 
         egui::CentralPanel::default().show(ctx, |ui| {
             ui.heading("Custom fan curves");
@@ -23,11 +18,11 @@ impl<'a> RogApp<'a> {
                 supported,
                 &mut states.profiles,
                 &mut states.fan_curves,
-                dbus, &mut states.error,
+                &states.asus_dbus, &mut states.error,
                 ui,
             );
 
-            fan_graphs(supported, &mut states.profiles, &mut states.fan_curves, dbus, &mut states.error, ui);
+            fan_graphs(supported, &mut states.profiles, &mut states.fan_curves, &states.asus_dbus, &mut states.error, ui);
         });
     }
 
@@ -76,8 +71,7 @@ impl<'a> RogApp<'a> {
             let selected_profile = curves.show_curve;
             let selected_pu = curves.show_graph;
 
-            let notif = curves.was_notified.clone();
+            match FanCurvesState::new(supported, dbus) {
-            match FanCurvesState::new(notif, supported, dbus) {
                 Ok(f) => *curves = f,
                 Err(e) => *do_error = Some(e.to_string()),
             }

rog-control-center/src/pages/system_page.rs

@@ -1,18 +1,15 @@
 use crate::{
+    system_state::SystemState,
     widgets::{
         anime_power_group, app_settings, aura_power_group, platform_profile, rog_bios_group,
     },
     RogApp,
 };
 
-impl<'a> RogApp<'a> {
+impl RogApp {
-    pub fn system_page(&mut self, ctx: &egui::Context) {
+    pub fn system_page(&mut self, states: &mut SystemState, ctx: &egui::Context) {
         let Self {
-            config,
+            config, supported, ..
-            supported,
-            states,
-            asus_dbus: dbus,
-            ..
         } = self;
 
         egui::CentralPanel::default().show(ctx, |ui| {
@@ -27,26 +24,24 @@ impl<'a> RogApp<'a> {
                         /******************************************************/
                         ui.vertical(|ui| {
                             ui.separator();
-                            app_settings(config, states, ui);
+                            if supported.platform_profile.platform_profile {
+                                platform_profile(states, ui);
+                            }
                         });
-
                         ui.vertical(|ui| {
                             ui.separator();
-                            if supported.platform_profile.platform_profile {
+                            aura_power_group(supported, states, ui);
-                                platform_profile(states, dbus, ui);
-                            }
                         });
                         ui.end_row();
 
                         /******************************************************/
                         ui.vertical(|ui| {
                             ui.separator();
-                            aura_power_group(supported, states, dbus, ui);
+                            app_settings(config, states, ui);
                         });
-
                         ui.vertical(|ui| {
                             ui.separator();
-                            rog_bios_group(supported, states, dbus, ui);
+                            rog_bios_group(supported, states, ui);
                         });
                         ui.end_row();
 
@@ -54,7 +49,7 @@ impl<'a> RogApp<'a> {
                         ui.vertical(|ui| {
                             ui.separator();
                             if supported.anime_ctrl.0 {
-                                anime_power_group(supported, states, dbus, ui);
+                                anime_power_group(supported, states, ui);
                             }
                         });
                         ui.vertical(|ui| {

rog-control-center/src/system_state.rs

@@ -1,24 +1,24 @@
 use std::{
     collections::{BTreeMap, HashSet},
-    sync::{
+    sync::{Arc, Mutex},
-        atomic::{AtomicBool, Ordering},
-        Arc,
-    },
 };
 
 use egui::Vec2;
 use rog_aura::{layouts::KeyLayout, usb::AuraPowerDev, AuraEffect, AuraModeNum};
 use rog_platform::{platform::GpuMode, supported::SupportedFunctions};
 use rog_profiles::{fan_curve_set::FanCurveSet, FanCurvePU, Profile};
+use supergfxctl::{
+    pci_device::{GfxMode, GfxPower},
+    zbus_proxy::DaemonProxyBlocking as GfxProxyBlocking,
+};
 
-use crate::{error::Result, RogDbusClientBlocking};
+use crate::{error::Result, notify::EnabledNotifications, RogDbusClientBlocking};
 
 #[derive(Clone, Debug)]
 pub struct BiosState {
     /// To be shared to a thread that checks notifications.
     /// It's a bit general in that it won't provide *what* was
     /// updated, so the full state needs refresh
-    pub was_notified: Arc<AtomicBool>,
     pub post_sound: bool,
     pub dedicated_gfx: GpuMode,
     pub panel_overdrive: bool,
@@ -27,13 +27,8 @@ pub struct BiosState {
 }
 
 impl BiosState {
-    pub fn new(
+    pub fn new(supported: &SupportedFunctions, dbus: &RogDbusClientBlocking) -> Result<Self> {
-        was_notified: Arc<AtomicBool>,
-        supported: &SupportedFunctions,
-        dbus: &RogDbusClientBlocking,
-    ) -> Result<Self> {
         Ok(Self {
-            was_notified,
             post_sound: if supported.rog_bios_ctrl.post_sound {
                 dbus.proxies().rog_bios().post_boot_sound()? != 0
             } else {
@@ -58,19 +53,13 @@ impl BiosState {
 
 #[derive(Clone, Debug)]
 pub struct ProfilesState {
-    pub was_notified: Arc<AtomicBool>,
     pub list: Vec<Profile>,
     pub current: Profile,
 }
 
 impl ProfilesState {
-    pub fn new(
+    pub fn new(supported: &SupportedFunctions, dbus: &RogDbusClientBlocking) -> Result<Self> {
-        was_notified: Arc<AtomicBool>,
-        supported: &SupportedFunctions,
-        dbus: &RogDbusClientBlocking,
-    ) -> Result<Self> {
         Ok(Self {
-            was_notified,
             list: if supported.platform_profile.platform_profile {
                 let mut list = dbus.proxies().profile().profiles()?;
                 list.sort();
@@ -89,7 +78,6 @@ impl ProfilesState {
 
 #[derive(Clone, Debug)]
 pub struct FanCurvesState {
-    pub was_notified: Arc<AtomicBool>,
     pub show_curve: Profile,
     pub show_graph: FanCurvePU,
     pub enabled: HashSet<Profile>,
@@ -98,11 +86,7 @@ pub struct FanCurvesState {
 }
 
 impl FanCurvesState {
-    pub fn new(
+    pub fn new(supported: &SupportedFunctions, dbus: &RogDbusClientBlocking) -> Result<Self> {
-        was_notified: Arc<AtomicBool>,
-        supported: &SupportedFunctions,
-        dbus: &RogDbusClientBlocking,
-    ) -> Result<Self> {
         let profiles = if supported.platform_profile.platform_profile {
             dbus.proxies().profile().profiles()?
         } else {
@@ -143,7 +127,6 @@ impl FanCurvesState {
         };
 
         Ok(Self {
-            was_notified,
             show_curve,
             show_graph: FanCurvePU::CPU,
             enabled,
@@ -155,7 +138,6 @@ impl FanCurvesState {
 
 #[derive(Clone, Debug)]
 pub struct AuraState {
-    pub was_notified: Arc<AtomicBool>,
     pub current_mode: AuraModeNum,
     pub modes: BTreeMap<AuraModeNum, AuraEffect>,
     pub enabled: AuraPowerDev,
@@ -167,13 +149,8 @@ pub struct AuraState {
 }
 
 impl AuraState {
-    pub fn new(
+    pub fn new(supported: &SupportedFunctions, dbus: &RogDbusClientBlocking) -> Result<Self> {
-        was_notified: Arc<AtomicBool>,
-        supported: &SupportedFunctions,
-        dbus: &RogDbusClientBlocking,
-    ) -> Result<Self> {
         Ok(Self {
-            was_notified,
             current_mode: if !supported.keyboard_led.stock_led_modes.is_empty() {
                 dbus.proxies().led().led_mode().unwrap_or_default()
             } else {
@@ -214,7 +191,6 @@ impl AuraState {
 
 #[derive(Clone, Debug)]
 pub struct AnimeState {
-    pub was_notified: Arc<AtomicBool>,
     pub bright: u8,
     pub boot: bool,
     pub awake: bool,
@@ -222,13 +198,8 @@ pub struct AnimeState {
 }
 
 impl AnimeState {
-    pub fn new(
+    pub fn new(supported: &SupportedFunctions, dbus: &RogDbusClientBlocking) -> Result<Self> {
-        was_notified: Arc<AtomicBool>,
-        supported: &SupportedFunctions,
-        dbus: &RogDbusClientBlocking,
-    ) -> Result<Self> {
         Ok(Self {
-            was_notified,
             boot: if supported.anime_ctrl.0 {
                 dbus.proxies().anime().boot_enabled()?
             } else {
@@ -246,11 +217,41 @@ impl AnimeState {
     }
 }
 
-#[derive(Debug, Clone)]
+#[derive(Clone, Debug)]
-pub struct PageDataStates {
+pub struct GfxState {
+    pub mode: GfxMode,
+    pub power_status: GfxPower,
+}
+
+impl GfxState {
+    pub fn new(_supported: &SupportedFunctions, dbus: &GfxProxyBlocking) -> Result<Self> {
+        Ok(Self {
+            mode: dbus.mode()?,
+            power_status: dbus.power()?,
+        })
+    }
+}
+
+#[derive(Clone, Debug)]
+pub struct PowerState {
+    pub charge_limit: u8,
+    pub ac_power: bool,
+}
+
+impl PowerState {
+    pub fn new(_supported: &SupportedFunctions, dbus: &RogDbusClientBlocking) -> Result<Self> {
+        Ok(Self {
+            charge_limit: dbus.proxies().charge().charge_control_end_threshold()?,
+            ac_power: dbus.proxies().charge().mains_online()?,
+        })
+    }
+}
+
+///  State stored from system daemons. This is shared with: tray, zbus notifications thread
+/// and the GUI app thread.
+pub struct SystemState {
     pub keyboard_layout: KeyLayout,
-    pub notifs_enabled: Arc<AtomicBool>,
+    pub enabled_notifications: Arc<Mutex<EnabledNotifications>>,
-    pub was_notified: Arc<AtomicBool>,
     /// Because much of the app state here is the same as `RogBiosSupportedFunctions`
     /// we can re-use that structure.
     pub bios: BiosState,
@@ -258,87 +259,59 @@ pub struct PageDataStates {
     pub anime: AnimeState,
     pub profiles: ProfilesState,
     pub fan_curves: FanCurvesState,
-    pub charge_limit: u8,
+    pub gfx_state: GfxState,
+    pub power_state: PowerState,
     pub error: Option<String>,
+    /// Specific field for the tray only so that we can know when it does need update.
+    /// The tray should set this to false when done.
+    pub tray_should_update: bool,
+    pub app_should_update: bool,
+    pub asus_dbus: RogDbusClientBlocking<'static>,
+    pub gfx_dbus: GfxProxyBlocking<'static>,
 }
 
-#[allow(clippy::too_many_arguments)]
+impl SystemState {
-impl PageDataStates {
+    /// Creates self, including the relevant dbus connections and proixies for internal use
     pub fn new(
         keyboard_layout: KeyLayout,
-        notifs_enabled: Arc<AtomicBool>,
+        enabled_notifications: Arc<Mutex<EnabledNotifications>>,
-        charge_notified: Arc<AtomicBool>,
-        bios_notified: Arc<AtomicBool>,
-        aura_notified: Arc<AtomicBool>,
-        anime_notified: Arc<AtomicBool>,
-        profiles_notified: Arc<AtomicBool>,
-        fans_notified: Arc<AtomicBool>,
         supported: &SupportedFunctions,
-        dbus: &RogDbusClientBlocking,
     ) -> Result<Self> {
+        let (asus_dbus, conn) = RogDbusClientBlocking::new().unwrap();
+        let gfx_dbus = GfxProxyBlocking::new(&conn).unwrap();
         Ok(Self {
             keyboard_layout,
-            notifs_enabled,
+            enabled_notifications,
-            was_notified: charge_notified,
+            power_state: PowerState::new(supported, &asus_dbus)?,
-            charge_limit: dbus.proxies().charge().charge_control_end_threshold()?,
+            bios: BiosState::new(supported, &asus_dbus)?,
-            bios: BiosState::new(bios_notified, supported, dbus)?,
+            aura: AuraState::new(supported, &asus_dbus)?,
-            aura: AuraState::new(aura_notified, supported, dbus)?,
+            anime: AnimeState::new(supported, &asus_dbus)?,
-            anime: AnimeState::new(anime_notified, supported, dbus)?,
+            profiles: ProfilesState::new(supported, &asus_dbus)?,
-            profiles: ProfilesState::new(profiles_notified, supported, dbus)?,
+            fan_curves: FanCurvesState::new(supported, &asus_dbus)?,
-            fan_curves: FanCurvesState::new(fans_notified, supported, dbus)?,
+            gfx_state: GfxState::new(supported, &gfx_dbus)?,
             error: None,
+            tray_should_update: true,
+            app_should_update: true,
+            asus_dbus,
+            gfx_dbus,
         })
     }
 
-    pub fn refresh_if_notfied(
+    pub fn set_notified(&mut self) {
-        &mut self,
+        self.tray_should_update = true;
-        supported: &SupportedFunctions,
+        self.app_should_update = true;
-        dbus: &RogDbusClientBlocking,
-    ) -> Result<bool> {
-        let mut notified = false;
-        if self.was_notified.load(Ordering::SeqCst) {
-            self.charge_limit = dbus.proxies().charge().charge_control_end_threshold()?;
-            self.was_notified.store(false, Ordering::SeqCst);
-            notified = true;
-        }
-
-        if self.aura.was_notified.load(Ordering::SeqCst) {
-            self.aura = AuraState::new(self.aura.was_notified.clone(), supported, dbus)?;
-            self.aura.was_notified.store(false, Ordering::SeqCst);
-            notified = true;
-        }
-
-        if self.bios.was_notified.load(Ordering::SeqCst) {
-            self.bios = BiosState::new(self.bios.was_notified.clone(), supported, dbus)?;
-            self.bios.was_notified.store(false, Ordering::SeqCst);
-            notified = true;
-        }
-
-        if self.profiles.was_notified.load(Ordering::SeqCst) {
-            self.profiles =
-                ProfilesState::new(self.profiles.was_notified.clone(), supported, dbus)?;
-            self.profiles.was_notified.store(false, Ordering::SeqCst);
-            notified = true;
-        }
-
-        if self.fan_curves.was_notified.load(Ordering::SeqCst) {
-            self.fan_curves =
-                FanCurvesState::new(self.fan_curves.was_notified.clone(), supported, dbus)?;
-            self.fan_curves.was_notified.store(false, Ordering::SeqCst);
-            notified = true;
-        }
-        Ok(notified)
     }
 }
 
-impl Default for PageDataStates {
+impl Default for SystemState {
     fn default() -> Self {
+        let (asus_dbus, conn) = RogDbusClientBlocking::new().unwrap();
+        let gfx_dbus = GfxProxyBlocking::new(&conn).unwrap();
+
         Self {
             keyboard_layout: KeyLayout::ga401_layout(),
-            notifs_enabled: Default::default(),
+            enabled_notifications: Default::default(),
-            was_notified: Default::default(),
             bios: BiosState {
-                was_notified: Default::default(),
                 post_sound: Default::default(),
                 dedicated_gfx: GpuMode::NotSupported,
                 panel_overdrive: Default::default(),
@@ -346,7 +319,6 @@ impl Default for PageDataStates {
                 egpu_enable: Default::default(),
             },
             aura: AuraState {
-                was_notified: Default::default(),
                 current_mode: AuraModeNum::Static,
                 modes: Default::default(),
                 enabled: AuraPowerDev {
@@ -360,27 +332,35 @@ impl Default for PageDataStates {
                 wave_blue: Default::default(),
             },
             anime: AnimeState {
-                was_notified: Default::default(),
                 bright: Default::default(),
                 boot: Default::default(),
                 awake: Default::default(),
                 sleep: Default::default(),
             },
             profiles: ProfilesState {
-                was_notified: Default::default(),
                 list: Default::default(),
                 current: Default::default(),
             },
             fan_curves: FanCurvesState {
-                was_notified: Default::default(),
                 show_curve: Default::default(),
                 show_graph: Default::default(),
                 enabled: Default::default(),
                 curves: Default::default(),
                 drag_delta: Default::default(),
             },
-            charge_limit: Default::default(),
+            gfx_state: GfxState {
+                mode: GfxMode::None,
+                power_status: GfxPower::Unknown,
+            },
+            power_state: PowerState {
+                charge_limit: 99,
+                ac_power: false,
+            },
             error: Default::default(),
+            tray_should_update: true,
+            app_should_update: true,
+            asus_dbus,
+            gfx_dbus,
         }
     }
 }

rog-control-center/src/tray.rs

@@ -0,0 +1,433 @@
+//! A seld-contained tray icon with menus. The control of app<->tray is done via
+//! commands over an MPSC channel.
+
+use std::{
+    io::Write,
+    sync::{
+        mpsc::{channel, Receiver},
+        Arc, Mutex,
+    },
+    time::Duration,
+};
+
+use gtk::{gio::Icon, prelude::*};
+use rog_dbus::zbus_platform::RogBiosProxyBlocking;
+use rog_platform::{platform::GpuMode, supported::SupportedFunctions};
+
+use crate::{error::Result, get_ipc_file, system_state::SystemState, SHOW_GUI};
+use libappindicator::{AppIndicator, AppIndicatorStatus};
+use supergfxctl::{
+    pci_device::{GfxMode, GfxPower},
+    zbus_proxy::DaemonProxyBlocking as GfxProxyBlocking,
+};
+
+use log::{debug, error, info, trace};
+
+const TRAY_APP_ICON: &str = "rog-control-center";
+const TRAY_LABEL: &str = "ROG Control Center";
+
+pub enum AppToTray {
+    DgpuStatus(GfxPower),
+}
+
+pub enum TrayToApp {
+    Open,
+    Quit,
+}
+
+pub struct RadioGroup(Vec<gtk::RadioMenuItem>);
+
+impl RadioGroup {
+    /// Add new radio menu item. `set_no_show_all()` is true until added to menu
+    /// to prevent teh callback from running
+    pub fn new<F>(first_label: &str, cb: F) -> Self
+    where
+        F: Fn(&gtk::RadioMenuItem) + Send + 'static,
+    {
+        let item = gtk::RadioMenuItem::with_label(first_label);
+        item.set_active(false);
+        item.set_no_show_all(true);
+        item.connect_activate(move |this| {
+            if this.is_active() && !this.is_no_show_all() {
+                cb(this);
+            }
+        });
+        Self(vec![item])
+    }
+
+    /// Add new radio menu item. `set_no_show_all()` is true until added to menu
+    /// to prevent teh callback from running
+    pub fn add<F>(&mut self, label: &str, cb: F)
+    where
+        F: Fn(&gtk::RadioMenuItem) + Send + 'static,
+    {
+        debug_assert!(!self.0.is_empty());
+        let group = self.0[0].group();
+
+        let item = gtk::RadioMenuItem::with_label_from_widget(&group[0], Some(label));
+        item.set_active(false);
+        item.set_no_show_all(true);
+        item.connect_activate(move |this| {
+            if this.is_active() && !this.is_no_show_all() {
+                cb(this);
+            }
+        });
+        self.0.push(item);
+    }
+}
+
+pub struct ROGTray {
+    tray: AppIndicator,
+    menu: gtk::Menu,
+    icon: &'static str,
+    bios_proxy: RogBiosProxyBlocking<'static>,
+    gfx_proxy: GfxProxyBlocking<'static>,
+}
+
+impl ROGTray {
+    pub fn new() -> Result<Self> {
+        let conn = zbus::blocking::Connection::system().map_err(|e| {
+            error!("ROGTray: {e}");
+            e
+        })?;
+        let rog_tray = Self {
+            tray: AppIndicator::new(TRAY_LABEL, TRAY_APP_ICON),
+            menu: gtk::Menu::new(),
+            icon: TRAY_APP_ICON,
+            bios_proxy: RogBiosProxyBlocking::new(&conn).map_err(|e| {
+                error!("ROGTray: {e}");
+                e
+            })?,
+            gfx_proxy: GfxProxyBlocking::new(&conn).map_err(|e| {
+                error!("ROGTray: {e}");
+                e
+            })?,
+        };
+        Ok(rog_tray)
+    }
+
+    pub fn set_icon(&mut self, icon: &'static str) {
+        self.icon = icon;
+        self.tray.set_icon(self.icon);
+        self.tray.set_status(AppIndicatorStatus::Active);
+    }
+
+    /// Add a non-interactive label
+    fn add_inactive_label(&mut self, label: &str) {
+        let item = gtk::MenuItem::with_label(label);
+        item.set_sensitive(false);
+        self.menu.append(&item);
+        self.menu.show_all();
+    }
+
+    /// Add a separator
+    fn add_separator(&mut self) {
+        let item = gtk::SeparatorMenuItem::new();
+        item.set_sensitive(false);
+        self.menu.append(&item);
+        self.menu.show_all();
+    }
+
+    fn add_radio_sub_menu(&mut self, header_label: &str, active_label: &str, sub_menu: RadioGroup) {
+        let header_item = gtk::MenuItem::with_label(header_label);
+        header_item.show_all();
+        self.menu.add(&header_item);
+
+        let menu = gtk::Menu::new();
+        for item in sub_menu.0.iter() {
+            if let Some(label) = item.label() {
+                item.set_active(label == active_label);
+            } else {
+                item.set_active(false);
+            }
+            item.set_no_show_all(false);
+            item.show_all();
+            menu.add(item);
+        }
+        menu.show_all();
+        header_item.set_submenu(Some(&menu));
+    }
+
+    fn _add_menu_item<F>(&mut self, label: &str, cb: F)
+    where
+        F: Fn() + Send + 'static,
+    {
+        let item = gtk::MenuItem::with_label(label);
+        item.connect_activate(move |_| {
+            cb();
+        });
+        self.menu.append(&item);
+        self.menu.show_all();
+    }
+
+    fn add_check_menu_item<F>(&mut self, label: &str, is_active: bool, cb: F)
+    where
+        F: Fn(&gtk::CheckMenuItem) + Send + 'static,
+    {
+        let item = gtk::CheckMenuItem::with_label(label);
+        item.set_active(is_active);
+        item.connect_activate(move |this| {
+            cb(this);
+        });
+        self.menu.append(&item);
+        self.menu.show_all();
+    }
+
+    /// Add a menu item with an icon to the right
+    fn add_icon_menu_item<F>(&mut self, label: &str, icon: &str, cb: F)
+    where
+        F: Fn() + Send + 'static,
+    {
+        let g_box = gtk::Box::new(gtk::Orientation::Horizontal, 6);
+        let icon = gtk::Image::from_gicon(&Icon::for_string(icon).unwrap(), gtk::IconSize::Menu);
+        let label = gtk::Label::new(Some(label));
+        let item = gtk::MenuItem::new();
+        g_box.add(&icon);
+        g_box.add(&label);
+
+        item.add(&g_box);
+        item.show_all();
+
+        item.connect_activate(move |_| {
+            cb();
+        });
+        self.menu.append(&item);
+        self.menu.show_all();
+        self.tray.set_menu(&mut self.menu);
+    }
+
+    fn _set_status(&mut self, status: AppIndicatorStatus) {
+        self.tray.set_status(status)
+    }
+
+    fn menu_add_base(&mut self) {
+        self.add_icon_menu_item("Open app", "asus_notif_red", move || {
+            if let Ok(mut ipc) = get_ipc_file().map_err(|e| {
+                error!("ROGTray: get_ipc_file: {}", e);
+            }) {
+                ipc.write_all(&[SHOW_GUI]).ok();
+            }
+        });
+
+        self.add_separator();
+        debug!("ROGTray: built base menu");
+    }
+
+    fn menu_add_charge_limit(&mut self, supported: &SupportedFunctions, limit: u8) {
+        if supported.charge_ctrl.charge_level_set {
+            self.add_inactive_label(&format!("Charge limit: {limit}"));
+            debug!("ROGTray: appended charge limit menu");
+        }
+    }
+
+    fn menu_add_panel_od(&mut self, supported: &SupportedFunctions, panel_od: bool) {
+        if supported.rog_bios_ctrl.panel_overdrive {
+            let bios = self.bios_proxy.clone();
+            self.add_check_menu_item("Panel Overdrive", panel_od, move |this| {
+                bios.set_panel_od(this.is_active())
+                    .map_err(|e| {
+                        error!("ROGTray: set_panel_od: {e}");
+                        e
+                    })
+                    .ok();
+            });
+            debug!("ROGTray: appended panel overdrive menu");
+        }
+    }
+
+    fn menu_add_gpu(&mut self, supported: &SupportedFunctions, current_mode: GfxMode) {
+        let gfx_dbus = self.gfx_proxy.clone();
+        let mut gpu_menu = RadioGroup::new("Integrated", move |_| {
+            let mode = gfx_dbus
+                .mode()
+                .map_err(|e| {
+                    error!("ROGTray: mode: {e}");
+                    e
+                })
+                .unwrap_or(GfxMode::None);
+            if mode != GfxMode::Integrated {
+                gfx_dbus
+                    .set_mode(&GfxMode::Integrated)
+                    .map_err(|e| {
+                        error!("ROGTray: srt_mode: {e}");
+                        e
+                    })
+                    .ok();
+            }
+        });
+
+        let gfx_dbus = self.gfx_proxy.clone();
+        gpu_menu.add("Hybrid", move |_| {
+            let mode = gfx_dbus
+                .mode()
+                .map_err(|e| {
+                    error!("ROGTray: mode: {e}");
+                    e
+                })
+                .unwrap_or(GfxMode::None);
+            if mode != GfxMode::Hybrid {
+                gfx_dbus
+                    .set_mode(&GfxMode::Hybrid)
+                    .map_err(|e| {
+                        error!("ROGTray: set_mode: {e}");
+                        e
+                    })
+                    .ok();
+            }
+        });
+        if supported.rog_bios_ctrl.gpu_mux {
+            let gfx_dbus = self.bios_proxy.clone();
+            gpu_menu.add("Ultimate (Reboot required)", move |_| {
+                let mode = gfx_dbus
+                    .gpu_mux_mode()
+                    .map_err(|e| {
+                        error!("ROGTray: mode: {e}");
+                        e
+                    })
+                    .unwrap_or(GpuMode::Error);
+                if mode != GpuMode::Discrete {
+                    gfx_dbus
+                        .set_gpu_mux_mode(GpuMode::Discrete)
+                        .map_err(|e| {
+                            error!("ROGTray: set_mode: {e}");
+                            e
+                        })
+                        .ok();
+                }
+            });
+        }
+        if supported.rog_bios_ctrl.egpu_enable {
+            let gfx_dbus = self.gfx_proxy.clone();
+            gpu_menu.add("eGPU", move |_| {
+                let mode = gfx_dbus
+                    .mode()
+                    .map_err(|e| {
+                        error!("ROGTray: mode: {e}");
+                        e
+                    })
+                    .unwrap_or(GfxMode::None);
+                if mode != GfxMode::Egpu {
+                    gfx_dbus
+                        .set_mode(&GfxMode::Egpu)
+                        .map_err(|e| {
+                            error!("ROGTray: set_mode: {e}");
+                            e
+                        })
+                        .ok();
+                }
+            });
+        }
+
+        let active = match current_mode {
+            GfxMode::AsusMuxDiscreet => "Discreet".to_string(),
+            _ => current_mode.to_string(),
+        };
+        self.add_radio_sub_menu(
+            &format!("GPU Mode: {current_mode}"),
+            active.as_str(),
+            gpu_menu,
+        );
+
+        debug!("ROGTray: appended gpu menu");
+    }
+
+    fn menu_clear(&mut self) {
+        self.menu = gtk::Menu::new();
+        debug!("ROGTray: cleared self");
+    }
+
+    /// Reset GTK menu to internal state, this can be called after clearing and rebuilding the menu too.
+    fn menu_update(&mut self) {
+        self.tray.set_menu(&mut self.menu);
+        self.set_icon(self.icon);
+    }
+
+    /// Do a flush, build, and update of the tray menu
+    fn rebuild_and_update(
+        &mut self,
+        supported: &SupportedFunctions,
+        current_gfx_mode: GfxMode,
+        charge_limit: u8,
+        panel_od: bool,
+    ) {
+        self.menu_clear();
+        self.menu_add_base();
+        self.menu_add_charge_limit(supported, charge_limit);
+        self.menu_add_panel_od(supported, panel_od);
+        self.menu_add_gpu(supported, current_gfx_mode);
+        self.menu_update();
+    }
+}
+
+pub fn init_tray(
+    supported: SupportedFunctions,
+    states: Arc<Mutex<SystemState>>,
+) -> Receiver<TrayToApp> {
+    let (send, recv) = channel();
+    let _send = Arc::new(Mutex::new(send));
+
+    std::thread::spawn(move || {
+        if gtk::init()
+            .map_err(|e| {
+                error!("ROGTray: gtk init {e}");
+                e
+            })
+            .is_err()
+        {
+            return;
+        } // Make this the main thread for gtk
+        debug!("init_tray gtk");
+
+        let mut tray = match ROGTray::new() {
+            Ok(t) => {
+                info!("init_tray: built menus");
+                t
+            }
+            Err(e) => {
+                error!("ROGTray: tray init {e}");
+                if let Ok(mut states) = states.lock() {
+                    states.error = Some(format!("Could not start tray: {e}"));
+                }
+                return;
+            }
+        };
+        tray.rebuild_and_update(&supported, GfxMode::Hybrid, 100, false);
+        tray.set_icon(TRAY_APP_ICON);
+        info!("Started ROGTray");
+
+        loop {
+            if let Ok(mut lock) = states.lock() {
+                if lock.tray_should_update {
+                    tray.rebuild_and_update(
+                        &supported,
+                        lock.gfx_state.mode,
+                        lock.power_state.charge_limit,
+                        lock.bios.panel_overdrive,
+                    );
+                    lock.tray_should_update = false;
+                    debug!("ROGTray: rebuilt menus due to state change");
+
+                    match lock.gfx_state.power_status {
+                        GfxPower::Active => tray.set_icon("asus_notif_red"),
+                        GfxPower::Suspended => tray.set_icon("asus_notif_blue"),
+                        GfxPower::Off => tray.set_icon("asus_notif_green"),
+                        GfxPower::AsusDisabled => tray.set_icon("asus_notif_white"),
+                        GfxPower::AsusMuxDiscreet => tray.set_icon("asus_notif_red"),
+                        GfxPower::Unknown => tray.set_icon("gpu-integrated"),
+                    };
+                }
+            }
+
+            if gtk::events_pending() {
+                // This is blocking until any events are available
+                gtk::main_iteration();
+                continue;
+            }
+            // Don't spool at max speed if no gtk events
+            std::thread::sleep(Duration::from_millis(300));
+            trace!("Tray loop ticked");
+        }
+    });
+
+    recv
+}

rog-control-center/src/widgets/anime_power.rs

@@ -1,14 +1,9 @@
 use egui::{RichText, Ui};
 use rog_platform::supported::SupportedFunctions;
 
-use crate::{page_states::PageDataStates, RogDbusClientBlocking};
+use crate::system_state::SystemState;
 
-pub fn anime_power_group(
+pub fn anime_power_group(_supported: &SupportedFunctions, states: &mut SystemState, ui: &mut Ui) {
-    _supported: &SupportedFunctions,
-    states: &mut PageDataStates,
-    dbus: &mut RogDbusClientBlocking,
-    ui: &mut Ui,
-) {
     ui.heading("AniMe Matrix Settings");
     ui.label("Options are incomplete. Awake + Boot should work");
 
@@ -43,7 +38,9 @@ pub fn anime_power_group(
             });
             ui.horizontal_wrapped(|ui| {
                 if ui.checkbox(&mut states.anime.boot, "Enable").changed() {
-                    dbus.proxies()
+                    states
+                        .asus_dbus
+                        .proxies()
                         .anime()
                         .set_boot_on_off(states.anime.boot)
                         .map_err(|err| {
@@ -54,7 +51,9 @@ pub fn anime_power_group(
             });
             ui.horizontal_wrapped(|ui| {
                 if ui.checkbox(&mut states.anime.awake, "Enable").changed() {
-                    dbus.proxies()
+                    states
+                        .asus_dbus
+                        .proxies()
                         .anime()
                         .set_on_off(states.anime.awake)
                         .map_err(|err| {

rog-control-center/src/widgets/app_settings.rs

@@ -1,13 +1,17 @@
-use std::sync::atomic::Ordering;
-
 use egui::Ui;
 
-use crate::{config::Config, page_states::PageDataStates};
+use crate::{config::Config, system_state::SystemState};
 
-pub fn app_settings(config: &mut Config, states: &mut PageDataStates, ui: &mut Ui) {
+pub fn app_settings(config: &mut Config, states: &mut SystemState, ui: &mut Ui) {
     ui.heading("ROG GUI Settings");
     // ui.label("Options are incomplete. Awake + Boot should work");
 
+    let mut enabled_notifications = if let Ok(lock) = states.enabled_notifications.lock() {
+        lock.clone()
+    } else {
+        Default::default()
+    };
+
     if ui
         .checkbox(&mut config.run_in_background, "Run in Background")
         .clicked()
@@ -15,17 +19,70 @@ pub fn app_settings(config: &mut Config, states: &mut PageDataStates, ui: &mut U
             .checkbox(&mut config.startup_in_background, "Startup Hidden")
             .clicked()
         || ui
-            .checkbox(&mut config.enable_notifications, "Enable Notifications")
+            .checkbox(
+                &mut enabled_notifications.all_enabled,
+                "Enable Notifications",
+            )
+            .clicked()
+        || ui
+            .checkbox(
+                &mut enabled_notifications.receive_notify_gfx_status,
+                "Enable dGPU status notification",
+            )
+            .clicked()
+        || ui
+            .checkbox(
+                &mut enabled_notifications.receive_notify_dgpu_disable,
+                "Enable dGPU disablement notification",
+            )
+            .clicked()
+        || ui
+            .checkbox(
+                &mut enabled_notifications.receive_notify_egpu_enable,
+                "Enable eGPU enablement notification",
+            )
+            .clicked()
+        || ui
+            .checkbox(
+                &mut enabled_notifications.receive_notify_mains_online,
+                "Enable mains (AC) power notification",
+            )
+            .clicked()
+        || ui
+            .checkbox(
+                &mut enabled_notifications.receive_notify_charge_control_end_threshold,
+                "Enable charge threshold notification",
+            )
+            .clicked()
+        || ui
+            .checkbox(
+                &mut enabled_notifications.receive_notify_profile,
+                "Enable profile change notification",
+            )
+            .clicked()
+        || ui
+            .checkbox(
+                &mut enabled_notifications.receive_notify_panel_od,
+                "Enable panel overdrive notification",
+            )
+            .clicked()
+        || ui
+            .checkbox(
+                &mut enabled_notifications.receive_notify_post_boot_sound,
+                "Enable BIOS post sound notification",
+            )
             .clicked()
     {
-        states
+        if let Ok(mut lock) = states.enabled_notifications.lock() {
-            .notifs_enabled
+            // Replace inner content before save
-            .store(config.enable_notifications, Ordering::SeqCst);
+            *lock = enabled_notifications;
-        config
+
-            .save()
+            config
-            .map_err(|err| {
+                .save(&lock)
-                states.error = Some(err.to_string());
+                .map_err(|err| {
-            })
+                    states.error = Some(err.to_string());
-            .ok();
+                })
+                .ok();
+        }
     }
 }

rog-control-center/src/widgets/aura_modes.rs

@@ -7,16 +7,12 @@ use egui::{RichText, Ui};
 use rog_aura::{AuraEffect, AuraModeNum, AuraZone, Colour, Speed};
 use rog_platform::supported::SupportedFunctions;
 
-use crate::{
+use crate::system_state::{AuraState, SystemState};
-    page_states::{AuraState, PageDataStates},
-    RogDbusClientBlocking,
-};
 
 pub fn aura_modes_group(
     supported: &SupportedFunctions,
-    states: &mut PageDataStates,
+    states: &mut SystemState,
     freq: &mut Arc<AtomicU8>,
-    dbus: &mut RogDbusClientBlocking,
     ui: &mut Ui,
 ) {
     let mut changed = false;
@@ -172,8 +168,7 @@ pub fn aura_modes_group(
     ui.separator();
     ui.with_layout(egui::Layout::right_to_left(egui::Align::TOP), |ui| {
         if ui.add(egui::Button::new("Cancel")).clicked() {
-            let notif = states.aura.was_notified.clone();
+            match AuraState::new(supported, &states.asus_dbus) {
-            match AuraState::new(notif, supported, dbus) {
                 Ok(a) => states.aura.modes = a.modes,
                 Err(e) => states.error = Some(e.to_string()),
             }
@@ -202,7 +197,9 @@ pub fn aura_modes_group(
     if changed {
         states.aura.current_mode = selected;
 
-        dbus.proxies()
+        states
+            .asus_dbus
+            .proxies()
             .led()
             .set_led_mode(states.aura.modes.get(&selected).unwrap())
             .map_err(|err| {

rog-control-center/src/widgets/aura_power.rs

@@ -5,32 +5,22 @@ use rog_aura::{
 };
 use rog_platform::supported::SupportedFunctions;
 
-use crate::{page_states::PageDataStates, RogDbusClientBlocking};
+use crate::system_state::SystemState;
 
-pub fn aura_power_group(
+pub fn aura_power_group(supported: &SupportedFunctions, states: &mut SystemState, ui: &mut Ui) {
-    supported: &SupportedFunctions,
-    states: &mut PageDataStates,
-    dbus: &mut RogDbusClientBlocking,
-    ui: &mut Ui,
-) {
     ui.heading("LED settings");
 
     match supported.keyboard_led.prod_id {
         AuraDevice::X1854 | AuraDevice::X1869 | AuraDevice::X1866 => {
-            aura_power1(supported, states, dbus, ui)
+            aura_power1(supported, states, ui)
         }
-        AuraDevice::X19B6 => aura_power2(supported, states, dbus, ui),
+        AuraDevice::X19B6 => aura_power2(supported, states, ui),
-        AuraDevice::Tuf => aura_power1(supported, states, dbus, ui),
+        AuraDevice::Tuf => aura_power1(supported, states, ui),
         AuraDevice::Unknown => {}
     }
 }
 
-fn aura_power1(
+fn aura_power1(supported: &SupportedFunctions, states: &mut SystemState, ui: &mut Ui) {
-    supported: &SupportedFunctions,
-    states: &mut PageDataStates,
-    dbus: &mut RogDbusClientBlocking,
-    ui: &mut Ui,
-) {
     let enabled_states = &mut states.aura.enabled;
     let mut boot = enabled_states.x1866.contains(&AuraDev1866::Boot);
     let mut sleep = enabled_states.x1866.contains(&AuraDev1866::Sleep);
@@ -144,7 +134,9 @@ fn aura_power1(
                     x19b6: vec![],
                 };
                 // build data to send
-                dbus.proxies()
+                states
+                    .asus_dbus
+                    .proxies()
                     .led()
                     .set_leds_power(options, enable)
                     .map_err(|err| {
@@ -193,7 +185,9 @@ fn aura_power1(
                     x19b6: vec![],
                 };
                 // build data to send
-                dbus.proxies()
+                states
+                    .asus_dbus
+                    .proxies()
                     .led()
                     .set_leds_power(options, enable)
                     .map_err(|err| {
@@ -207,12 +201,7 @@ fn aura_power1(
     }
 }
 
-fn aura_power2(
+fn aura_power2(supported: &SupportedFunctions, states: &mut SystemState, ui: &mut Ui) {
-    supported: &SupportedFunctions,
-    states: &mut PageDataStates,
-    dbus: &mut RogDbusClientBlocking,
-    ui: &mut Ui,
-) {
     let enabled_states = &mut states.aura.enabled;
     let has_logo = supported
         .keyboard_led
@@ -331,7 +320,9 @@ fn aura_power2(
                 x19b6: data,
             };
             // build data to send
-            dbus.proxies()
+            states
+                .asus_dbus
+                .proxies()
                 .led()
                 .set_leds_power(options, enable)
                 .map_err(|err| {

rog-control-center/src/widgets/fan_graph.rs

@@ -3,7 +3,7 @@ use rog_platform::supported::SupportedFunctions;
 use rog_profiles::{FanCurvePU, Profile};
 
 use crate::{
-    page_states::{FanCurvesState, ProfilesState},
+    system_state::{FanCurvesState, ProfilesState},
     RogDbusClientBlocking,
 };
 
@@ -136,8 +136,7 @@ pub fn fan_graphs(
             })
             .ok();
 
-        let notif = curves.was_notified.clone();
+        match FanCurvesState::new(supported, dbus) {
-        match FanCurvesState::new(notif, supported, dbus) {
             Ok(f) => *curves = f,
             Err(e) => *do_error = Some(e.to_string()),
         }

rog-control-center/src/widgets/keyboard_layout.rs

@@ -1,7 +1,7 @@
 use egui::{Align, Color32, Vec2};
 use rog_aura::{keys::KeyShape, layouts::KeyLayout, AuraModeNum};
 
-use crate::page_states::AuraState;
+use crate::system_state::AuraState;
 
 pub fn keyboard(
     ui: &mut egui::Ui,

rog-control-center/src/widgets/rog_bios.rs

@@ -1,9 +1,9 @@
-use crate::{page_states::PageDataStates, RogDbusClientBlocking};
+use crate::system_state::SystemState;
 use egui::Ui;
 use rog_platform::{platform::GpuMode, supported::SupportedFunctions};
 use rog_profiles::Profile;
 
-pub fn platform_profile(states: &mut PageDataStates, dbus: &RogDbusClientBlocking, ui: &mut Ui) {
+pub fn platform_profile(states: &mut SystemState, ui: &mut Ui) {
     ui.heading("Platform profile");
 
     let mut changed = false;
@@ -23,7 +23,9 @@ pub fn platform_profile(states: &mut PageDataStates, dbus: &RogDbusClientBlockin
     });
 
     if changed {
-        dbus.proxies()
+        states
+            .asus_dbus
+            .proxies()
             .profile()
             .set_active_profile(states.profiles.current)
             .map_err(|err| {
@@ -33,21 +35,18 @@ pub fn platform_profile(states: &mut PageDataStates, dbus: &RogDbusClientBlockin
     };
 }
 
-pub fn rog_bios_group(
+pub fn rog_bios_group(supported: &SupportedFunctions, states: &mut SystemState, ui: &mut Ui) {
-    supported: &SupportedFunctions,
-    states: &mut PageDataStates,
-    dbus: &mut RogDbusClientBlocking,
-    ui: &mut Ui,
-) {
     ui.heading("Bios options");
 
-    let slider = egui::Slider::new(&mut states.charge_limit, 20..=100)
+    let slider = egui::Slider::new(&mut states.power_state.charge_limit, 20..=100)
         .text("Charging limit")
         .step_by(1.0);
     if ui.add(slider).drag_released() {
-        dbus.proxies()
+        states
+            .asus_dbus
+            .proxies()
             .charge()
-            .set_charge_control_end_threshold(states.charge_limit as u8)
+            .set_charge_control_end_threshold(states.power_state.charge_limit as u8)
             .map_err(|err| {
                 states.error = Some(err.to_string());
             })
@@ -62,7 +61,9 @@ pub fn rog_bios_group(
             ))
             .changed()
     {
-        dbus.proxies()
+        states
+            .asus_dbus
+            .proxies()
             .rog_bios()
             .set_post_boot_sound(states.bios.post_sound)
             .map_err(|err| {
@@ -79,7 +80,9 @@ pub fn rog_bios_group(
             ))
             .changed()
     {
-        dbus.proxies()
+        states
+            .asus_dbus
+            .proxies()
             .rog_bios()
             .set_panel_od(states.bios.panel_overdrive)
             .map_err(|err| {
@@ -114,7 +117,9 @@ pub fn rog_bios_group(
         });
 
         if changed {
-            dbus.proxies()
+            states
+                .asus_dbus
+                .proxies()
                 .rog_bios()
                 .set_gpu_mux_mode(states.bios.dedicated_gfx)
                 .map_err(|err| {

rog-control-center/src/widgets/side_panel.rs

@@ -1,6 +1,6 @@
 use crate::{Page, RogApp};
 
-impl<'a> RogApp<'a> {
+impl RogApp {
     pub fn side_panel(&mut self, ctx: &egui::Context) {
         egui::SidePanel::left("side_panel")
             .resizable(false)

rog-control-center/src/widgets/top_bar.rs

@@ -2,7 +2,7 @@ use egui::{vec2, Align2, FontId, Id, Sense};
 
 use crate::{RogApp, VERSION};
 
-impl<'a> RogApp<'a> {
+impl RogApp {
     pub fn top_bar(&mut self, ctx: &egui::Context, frame: &mut eframe::Frame) {
         egui::TopBottomPanel::top("top_panel").show(ctx, |ui| {
             // The top panel is often a good place for a menu bar:

rog-dbus/Cargo.toml

@@ -15,5 +15,3 @@ rog_aura = { path = "../rog-aura" }
 rog_profiles = { path = "../rog-profiles" }
 rog_platform = { path = "../rog-platform" }
 zbus.workspace = true
-zbus_macros.workspace = true
-zvariant.workspace = true

rog-dbus/src/zbus_anime.rs

@@ -1,5 +1,5 @@
 use rog_anime::{AnimeDataBuffer, AnimePowerStates};
-use zbus_macros::dbus_proxy;
+use zbus::dbus_proxy;
 
 #[dbus_proxy(
     interface = "org.asuslinux.Daemon",
@@ -7,33 +7,26 @@ use zbus_macros::dbus_proxy;
 )]
 trait Anime {
     /// Set whether the AniMe will show boot, suspend, or off animations
-    #[inline]
     fn set_boot_on_off(&self, status: bool) -> zbus::Result<()>;
 
     /// Set the global AniMe brightness
-    #[inline]
     fn set_brightness(&self, bright: f32) -> zbus::Result<()>;
 
     /// Set whether the AniMe is displaying images/data
-    #[inline]
     fn set_on_off(&self, status: bool) -> zbus::Result<()>;
 
     /// Writes a data stream of length. Will force system thread to exit until it is restarted
-    #[inline]
     fn write(&self, input: AnimeDataBuffer) -> zbus::Result<()>;
 
     /// Get status of if the AniMe LEDs are on
-    #[inline]
     #[dbus_proxy(property)]
     fn awake_enabled(&self) -> zbus::Result<bool>;
 
     /// Get the status of if factory system-status animations are enabled
-    #[inline]
     #[dbus_proxy(property)]
     fn boot_enabled(&self) -> zbus::Result<bool>;
 
     /// Notify listeners of the status of AniMe LED power and factory system-status animations
-    #[inline]
     #[dbus_proxy(signal)]
     fn power_states(&self, data: AnimePowerStates) -> zbus::Result<()>;
 }

rog-dbus/src/zbus_led.rs

@@ -21,8 +21,8 @@
 
 use std::collections::BTreeMap;
 
+use zbus::dbus_proxy;
 use zbus::{blocking::Connection, Result};
-use zbus_macros::dbus_proxy;
 
 use rog_aura::{usb::AuraPowerDev, AuraEffect, AuraModeNum, LedBrightness, PerKeyRaw};
 
@@ -34,60 +34,46 @@ const BLOCKING_TIME: u64 = 40; // 100ms = 10 FPS, max 50ms = 20 FPS, 40ms = 25 F
 )]
 trait Led {
     /// NextLedMode method
-    #[inline]
     fn next_led_mode(&self) -> zbus::Result<()>;
 
     /// PrevLedMode method
-    #[inline]
     fn prev_led_mode(&self) -> zbus::Result<()>;
 
     /// Toggle to next led brightness
-    #[inline]
     fn next_led_brightness(&self) -> zbus::Result<()>;
 
     /// Toggle to previous led brightness
-    #[inline]
     fn prev_led_brightness(&self) -> zbus::Result<()>;
 
     /// SetBrightness method
-    #[inline]
     fn set_brightness(&self, brightness: LedBrightness) -> zbus::Result<()>;
 
     /// SetLedMode method
-    #[inline]
     fn set_led_mode(&self, effect: &AuraEffect) -> zbus::Result<()>;
 
-    #[inline]
     fn set_leds_power(&self, options: AuraPowerDev, enabled: bool) -> zbus::Result<()>;
 
-    #[inline]
     fn per_key_raw(&self, data: PerKeyRaw) -> zbus::fdo::Result<()>;
 
     /// NotifyLed signal
-    #[inline]
     #[dbus_proxy(signal)]
     fn notify_led(&self, data: AuraEffect) -> zbus::Result<()>;
 
     #[dbus_proxy(signal)]
-    #[inline]
     fn notify_power_states(&self, data: AuraPowerDev) -> zbus::Result<()>;
 
     /// LedBrightness property
-    #[inline]
     #[dbus_proxy(property)]
     fn led_brightness(&self) -> zbus::Result<i16>;
 
     /// LedMode property
-    #[inline]
     fn led_mode(&self) -> zbus::Result<AuraModeNum>;
 
     /// LedModes property
-    #[inline]
     fn led_modes(&self) -> zbus::Result<BTreeMap<AuraModeNum, AuraEffect>>;
 
     // As property doesn't work for AuraPowerDev (complexity of serialization?)
     // #[dbus_proxy(property)]
-    #[inline]
     fn leds_enabled(&self) -> zbus::Result<AuraPowerDev>;
 }
 

rog-dbus/src/zbus_platform.rs

@@ -20,7 +20,7 @@
 //! …consequently `zbus-xmlgen` did not generate code for the above interfaces.
 
 use rog_platform::platform::GpuMode;
-use zbus_macros::dbus_proxy;
+use zbus::dbus_proxy;
 
 #[dbus_proxy(
     interface = "org.asuslinux.Daemon",
@@ -28,62 +28,48 @@ use zbus_macros::dbus_proxy;
 )]
 trait RogBios {
     /// DgpuDisable method
-    #[inline]
     fn dgpu_disable(&self) -> zbus::Result<bool>;
 
     /// EgpuEnable method
-    #[inline]
     fn egpu_enable(&self) -> zbus::Result<bool>;
 
     /// GpuMuxMode method
-    #[inline]
     fn gpu_mux_mode(&self) -> zbus::Result<GpuMode>;
 
     /// PanelOd method
-    #[inline]
     fn panel_od(&self) -> zbus::Result<bool>;
 
     /// PostBootSound method
-    #[inline]
     fn post_boot_sound(&self) -> zbus::Result<i16>;
 
     /// SetDgpuDisable method
-    #[inline]
     fn set_dgpu_disable(&self, disable: bool) -> zbus::Result<()>;
 
     /// SetEgpuEnable method
-    #[inline]
     fn set_egpu_enable(&self, enable: bool) -> zbus::Result<()>;
 
     /// SetGpuMuxMode method
-    #[inline]
     fn set_gpu_mux_mode(&self, mode: GpuMode) -> zbus::Result<()>;
 
     /// SetPanelOd method
-    #[inline]
     fn set_panel_od(&self, overdrive: bool) -> zbus::Result<()>;
 
     /// SetPostBootSound method
-    #[inline]
     fn set_post_boot_sound(&self, on: bool) -> zbus::Result<()>;
 
     /// NotifyDgpuDisable signal
-    #[inline]
     #[dbus_proxy(signal)]
     fn notify_dgpu_disable(&self, disable: bool) -> zbus::Result<()>;
 
     /// NotifyEgpuEnable signal
-    #[inline]
     #[dbus_proxy(signal)]
     fn notify_egpu_enable(&self, enable: bool) -> zbus::Result<()>;
 
     /// NotifyGpuMuxMode signal
-    #[inline]
     #[dbus_proxy(signal)]
     fn notify_gpu_mux_mode(&self, mode: GpuMode) -> zbus::Result<()>;
 
     /// NotifyPanelOd signal
-    #[inline]
     #[dbus_proxy(signal)]
     fn notify_panel_od(&self, overdrive: bool) -> zbus::Result<()>;
 

rog-dbus/src/zbus_power.rs

@@ -19,7 +19,7 @@
 //!
 //! …consequently `zbus-xmlgen` did not generate code for the above interfaces.
 
-use zbus_macros::dbus_proxy;
+use zbus::dbus_proxy;
 
 #[dbus_proxy(
     interface = "org.asuslinux.Daemon",
@@ -27,24 +27,19 @@ use zbus_macros::dbus_proxy;
 )]
 trait Power {
     /// charge_control_end_threshold method
-    #[inline]
     fn charge_control_end_threshold(&self) -> zbus::Result<u8>;
 
     /// MainsOnline method
-    #[inline]
     fn mains_online(&self) -> zbus::Result<bool>;
 
     /// set_charge_control_end_threshold method
-    #[inline]
     fn set_charge_control_end_threshold(&self, limit: u8) -> zbus::Result<()>;
 
     /// NotifyCharge signal
-    #[inline]
     #[dbus_proxy(signal)]
     fn notify_charge_control_end_threshold(&self, limit: u8) -> zbus::Result<u8>;
 
     /// NotifyMainsOnline signal
-    #[inline]
     #[dbus_proxy(signal)]
     fn notify_mains_online(&self, on: bool) -> zbus::Result<()>;
 }

rog-dbus/src/zbus_profile.rs

@@ -23,7 +23,7 @@ use rog_profiles::{
     fan_curve_set::{CurveData, FanCurveSet},
     Profile,
 };
-use zbus_macros::dbus_proxy;
+use zbus::dbus_proxy;
 
 #[dbus_proxy(
     interface = "org.asuslinux.Daemon",
@@ -31,55 +31,44 @@ use zbus_macros::dbus_proxy;
 )]
 trait Profile {
     /// Get the fan-curve data for the currently active Profile
-    #[inline]
     fn fan_curve_data(&self, profile: Profile) -> zbus::Result<FanCurveSet>;
 
     /// Fetch the active profile name
-    #[inline]
     fn active_profile(&self) -> zbus::Result<Profile>;
 
     /// Get a list of profiles that have fan-curves enabled.
-    #[inline]
     fn enabled_fan_profiles(&self) -> zbus::Result<Vec<Profile>>;
 
     /// Toggle to next platform_profile. Names provided by `Profiles`.
     /// If fan-curves are supported will also activate a fan curve for profile.
-    #[inline]
     fn next_profile(&self) -> zbus::Result<()>;
 
     /// Fetch profile names
-    #[inline]
     fn profiles(&self) -> zbus::Result<Vec<Profile>>;
 
     /// Set this platform_profile name as active
-    #[inline]
     fn set_active_profile(&self, profile: Profile) -> zbus::Result<()>;
 
     /// Set a profile fan curve enabled status. Will also activate a fan curve.
-    #[inline]
     fn set_fan_curve_enabled(&self, profile: Profile, enabled: bool) -> zbus::Result<()>;
 
     /// Set the fan curve for the specified profile, or the profile the user is
     /// currently in if profile == None. Will also activate the fan curve.
-    #[inline]
     fn set_fan_curve(&self, profile: Profile, curve: CurveData) -> zbus::Result<()>;
 
     /// Reset the stored (self) and device curve to the defaults of the platform.
     ///
     /// Each platform_profile has a different default and the defualt can be read
     /// only for the currently active profile.
-    #[inline]
     fn set_active_curve_to_defaults(&self) -> zbus::Result<()>;
 
     /// Reset the stored (self) and device curve to the defaults of the platform.
     ///
     /// Each platform_profile has a different default and the defualt can be read
     /// only for the currently active profile.
-    #[inline]
     fn reset_profile_curves(&self, profile: Profile) -> zbus::fdo::Result<()>;
 
     /// NotifyProfile signal
-    #[inline]
     #[dbus_proxy(signal)]
     async fn notify_profile(&self, profile: Profile) -> zbus::Result<Profile>;
 }

rog-dbus/src/zbus_supported.rs

@@ -20,7 +20,7 @@
 //! …consequently `zbus-xmlgen` did not generate code for the above interfaces.
 
 use rog_platform::supported::SupportedFunctions;
-use zbus_macros::dbus_proxy;
+use zbus::dbus_proxy;
 
 #[dbus_proxy(
     interface = "org.asuslinux.Daemon",
@@ -28,6 +28,5 @@ use zbus_macros::dbus_proxy;
 )]
 trait Supported {
     /// SupportedFunctions method
-    #[inline]
     fn supported_functions(&self) -> zbus::Result<SupportedFunctions>;
 }

rog-platform/Cargo.toml

@@ -8,8 +8,7 @@ log.workspace = true
 rog_aura = { path = "../rog-aura" }
 serde.workspace = true
 serde_derive.workspace = true
-zvariant.workspace = true
+zbus.workspace = true
-zvariant_derive.workspace = true
 sysfs-class.workspace = true
 concat-idents.workspace = true
 udev.workspace = true

rog-platform/src/lib.rs

@@ -78,7 +78,7 @@ pub fn write_attr_u8_array(device: &mut Device, attr: &str, values: &[u8]) -> Re
     let tmp: String = values.iter().map(|v| format!("{} ", v)).collect();
     let tmp = tmp.trim();
     device
-        .set_attribute_value(attr, &tmp)
+        .set_attribute_value(attr, tmp)
         .map_err(|e| PlatformError::IoPath(attr.into(), e))
 }
 

rog-platform/src/platform.rs

@@ -2,7 +2,7 @@ use std::{fmt::Display, path::PathBuf, str::FromStr};
 
 use log::{info, warn};
 use serde::{Deserialize, Serialize};
-use zvariant::Type;
+use zbus::zvariant::Type;
 
 use crate::{
     attr_bool, attr_u8,

rog-platform/src/supported.rs

@@ -1,7 +1,7 @@
 use rog_aura::{usb::AuraDevice, AuraModeNum, AuraZone};
 use serde_derive::{Deserialize, Serialize};
 use std::fmt;
-use zvariant_derive::Type;
+use zbus::zvariant::Type;
 
 #[derive(Serialize, Deserialize, Type, Debug, Default, Clone)]
 pub struct SupportedFunctions {

rog-profiles/Cargo.toml

@@ -6,12 +6,11 @@ edition = "2021"
 
 [features]
 default = ["dbus"]
-dbus = ["zvariant", "zvariant_derive"]
+dbus = ["zbus"]
 
 [dependencies]
 udev.workspace = true
 serde.workspace = true
 serde_derive.workspace = true
 
-zvariant = { workspace = true, optional = true }
+zbus = { workspace = true, optional = true }
-zvariant_derive = { workspace = true, optional = true }

rog-profiles/src/fan_curve_set.rs

@@ -2,7 +2,7 @@ use serde_derive::{Deserialize, Serialize};
 
 use udev::Device;
 #[cfg(feature = "dbus")]
-use zvariant_derive::Type;
+use zbus::zvariant::Type;
 
 use crate::{error::ProfileError, FanCurvePU};
 

rog-profiles/src/lib.rs

@@ -14,7 +14,7 @@ use serde_derive::{Deserialize, Serialize};
 
 use udev::Device;
 #[cfg(feature = "dbus")]
-use zvariant_derive::Type;
+use zbus::zvariant::Type;
 
 pub const PLATFORM_PROFILE: &str = "/sys/firmware/acpi/platform_profile";
 pub const PLATFORM_PROFILES: &str = "/sys/firmware/acpi/platform_profile_choices";
@@ -52,7 +52,7 @@ impl Profile {
     }
 
     pub fn get_active_profile() -> Result<Profile, ProfileError> {
-        let mut file = OpenOptions::new().read(true).open(&PLATFORM_PROFILE)?;
+        let mut file = OpenOptions::new().read(true).open(PLATFORM_PROFILE)?;
 
         let mut buf = String::new();
         file.read_to_string(&mut buf)?;
@@ -60,7 +60,7 @@ impl Profile {
     }
 
     pub fn get_profile_names() -> Result<Vec<Profile>, ProfileError> {
-        let mut file = OpenOptions::new().read(true).open(&PLATFORM_PROFILES)?;
+        let mut file = OpenOptions::new().read(true).open(PLATFORM_PROFILES)?;
 
         let mut buf = String::new();
         file.read_to_string(&mut buf)?;