tkbar 0.2.0

A minimalist, hardened status bar for Wayland.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

use {
    crate::conf::CONFIG,
    gtk::{Align, Box as GtkBox, Button, glib, prelude::*},
    gtk4 as gtk,
    std::thread,
};

#[cfg(feature = "hyprland")]
mod hypr;
#[cfg(feature = "niri")]
mod niri;
#[cfg(feature = "sway")]
mod sway;

#[derive(Clone, Debug)]
#[cfg_attr(
    feature = "hyprland",
    expect(dead_code, reason = "`idx` is not used in hyprland")
)]
struct Ws {
    id: u64,
    /// Maximum of 255 workspaces
    idx: u8,
    label: String,
    is_active: bool,
    is_focused: bool,
}

#[cfg(any(feature = "hyprland", feature = "niri", feature = "sway"))]
pub(crate) fn workspaces() -> GtkBox {
    let container = GtkBox::new(CONFIG.style.position.orientation(), 4);
    container.add_css_class("workspaces");

    let (tx, rx) = async_channel::unbounded::<Vec<Ws>>();

    thread::spawn(move || {
        #[cfg(feature = "niri")]
        if let Err(e) = niri::event_loop(&tx) {
            crate::log::warn("workspaces", &format!("niri IPC error: {e}"));
        }

        #[cfg(feature = "hyprland")]
        if let Err(e) = hypr::event_loop(&tx) {
            crate::log::warn("workspaces", &format!("hyprland IPC error: {e}"));
        }

        #[cfg(feature = "sway")]
        if let Err(e) = sway::event_loop(&tx) {
            crate::log::warn("workspaces", &format!("sway IPC error: {e}"));
        }
    });

    glib::spawn_future_local(glib::clone!(
        #[weak]
        container,
        #[upgrade_or_default]
        async move {
            while let Ok(list) = rx.recv().await {
                while let Some(child) = container.first_child() {
                    container.remove(&child);
                }

                for ws in &list {
                    if !CONFIG.behaviour.should_show_empty_workspace &&
                        !ws.is_active &&
                        !ws.is_focused
                    {
                        continue;
                    }

                    let btn = Button::with_label(&ws.label);
                    btn.add_css_class("workspace");
                    if ws.is_focused {
                        btn.add_css_class("current");
                    }
                    if !ws.is_active {
                        btn.add_css_class("inactive");
                    }
                    btn.set_valign(Align::Center);
                    btn.set_halign(Align::Center);

                    let id = ws.id;
                    btn.connect_clicked(move |_| focus_workspace(id));
                    container.append(&btn);
                }
            }
        }
    ));

    container
}

fn focus_workspace(id: u64) {
    thread::spawn(move || {
        #[cfg(feature = "niri")]
        niri::focus_workspace(id);

        #[cfg(feature = "hyprland")]
        hypr::focus_workspace(id);

        #[cfg(feature = "sway")]
        sway::focus_workspace(id);
    });
}