flexaudio-os-linux 0.8.0

Linux system and per-process audio capture backend (PipeWire) for flexaudio.
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

// Convert a completed PipeWire inventory without querying native objects.
use super::{NATIVE_CHANNELS, NATIVE_RATE};
use flexaudio_core::{DeviceIdNamespace, DeviceInfo, NamespacedDevice, SourceKind};

/// Raw node properties collected by registry callbacks.
pub(super) struct NodeRecord {
    pub(super) node_name: String,
    pub(super) description: String,
    pub(super) media_class: String,
    pub(super) rate: Option<u32>,
    pub(super) channels: Option<u16>,
}

/// Collector confined to the enumeration loop's thread.
#[derive(Default)]
pub(super) struct EnumState {
    pub(super) nodes: Vec<NodeRecord>,
    pub(super) default_sink: Option<String>,
    pub(super) default_source: Option<String>,
}

pub(super) fn namespaced_devices(state: &EnumState) -> Vec<NamespacedDevice> {
    let mut out = Vec::with_capacity(state.nodes.len());
    for n in &state.nodes {
        let is_loopback = n.media_class == "Audio/Sink";
        let source_kind = if is_loopback {
            SourceKind::SystemLoopback
        } else {
            SourceKind::Mic
        };
        let is_default = if is_loopback {
            state.default_sink.as_deref() == Some(n.node_name.as_str())
        } else {
            state.default_source.as_deref() == Some(n.node_name.as_str())
        };
        let (sample_rate, channels, format_available) =
            flexaudio_core::inventory::device_format(Ok((
                n.rate.unwrap_or(NATIVE_RATE),
                n.channels.unwrap_or(NATIVE_CHANNELS),
            )));
        out.push(NamespacedDevice::new(
            DeviceInfo {
                id: n.node_name.clone(),
                name: n.description.clone(),
                source_kind,
                sample_rate,
                channels,
                format_available,
                is_loopback,
                is_default,
            },
            DeviceIdNamespace::PipeWireNodeName,
        ));
    }
    out
}