wiremix 0.11.0

A TUI mixer for PipeWire
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

use std::rc::Rc;

use pipewire::{
    link::{Link, LinkChangeMask, LinkInfoRef},
    proxy::Listener,
    registry::{GlobalObject, Registry},
};

use libspa::utils::dict::DictRef;

use crate::wirehose::event_sender::EventSender;
use crate::wirehose::StateEvent;

pub fn monitor_link(
    registry: &Registry,
    object: &GlobalObject<&DictRef>,
    sender: &Rc<EventSender>,
) -> Option<(Rc<Link>, Box<dyn Listener>)> {
    let link: Link = registry.bind(object).ok()?;
    let link = Rc::new(link);

    let listener = link
        .add_listener_local()
        .info({
            let sender_weak = Rc::downgrade(sender);
            move |info| {
                let Some(sender) = sender_weak.upgrade() else {
                    return;
                };
                for change in info.change_mask().iter() {
                    if change == LinkChangeMask::PROPS {
                        link_info_props(&sender, info);
                    }
                }
            }
        })
        .register();

    Some((link, Box::new(listener)))
}

fn link_info_props(sender: &EventSender, link_info: &LinkInfoRef) {
    // Ignore props and get the nodes directly from the link info.
    sender.send(StateEvent::from(link_info));
}