wehub-resource-sync
133 lines
3.6 KiB
Go
133 lines
3.6 KiB
Go
//go:build linux
|
|
|
|
package player
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
"os/exec"
|
|
"strconv"
|
|
"strings"
|
|
)
|
|
|
|
// ListAudioDevices returns available output sinks via pactl.
|
|
// Works on PulseAudio and PipeWire (via pipewire-pulse).
|
|
func ListAudioDevices() ([]AudioDevice, error) {
|
|
defaultSink := ""
|
|
if out, err := exec.Command("pactl", "get-default-sink").Output(); err == nil {
|
|
defaultSink = strings.TrimSpace(string(out))
|
|
}
|
|
|
|
out, err := exec.Command("pactl", "list", "sinks").Output()
|
|
if err != nil {
|
|
return nil, fmt.Errorf("pactl: %w (is PulseAudio/PipeWire running?)", err)
|
|
}
|
|
|
|
var devices []AudioDevice
|
|
var cur *AudioDevice
|
|
|
|
for _, line := range strings.Split(string(out), "\n") {
|
|
line = strings.TrimSpace(line)
|
|
if strings.HasPrefix(line, "Sink #") {
|
|
idx, _ := strconv.Atoi(strings.TrimPrefix(line, "Sink #"))
|
|
devices = append(devices, AudioDevice{Index: idx})
|
|
cur = &devices[len(devices)-1]
|
|
} else if cur != nil {
|
|
if key, val, ok := strings.Cut(line, ": "); ok {
|
|
switch key {
|
|
case "Name":
|
|
cur.Name = val
|
|
cur.Active = val == defaultSink
|
|
case "Description":
|
|
cur.Description = val
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return devices, nil
|
|
}
|
|
|
|
// PrepareAudioDevice sets PIPEWIRE_NODE so the PipeWire ALSA plugin
|
|
// routes this process's audio to the named device.
|
|
// Must be called before player.New(). Returns a cleanup that restores the env.
|
|
func PrepareAudioDevice(device string) func() {
|
|
prev, hadPrev := os.LookupEnv("PIPEWIRE_NODE")
|
|
os.Setenv("PIPEWIRE_NODE", device)
|
|
return func() {
|
|
if hadPrev {
|
|
os.Setenv("PIPEWIRE_NODE", prev)
|
|
} else {
|
|
os.Unsetenv("PIPEWIRE_NODE")
|
|
}
|
|
}
|
|
}
|
|
|
|
// SwitchAudioDevice moves cliamp's audio stream to a different sink.
|
|
// Falls back to changing the system default if the stream can't be found.
|
|
func SwitchAudioDevice(deviceName string) error {
|
|
out, err := exec.Command("pactl", "list", "sink-inputs").Output()
|
|
if err != nil {
|
|
return fmt.Errorf("pactl: %w", err)
|
|
}
|
|
|
|
pidStr := strconv.Itoa(os.Getpid())
|
|
sinkInputIdx := -1
|
|
currentIdx := 0
|
|
props := map[string]string{}
|
|
|
|
// Parse all sink-inputs, collecting properties per entry.
|
|
lines := strings.Split(string(out), "\n")
|
|
for _, line := range lines {
|
|
line = strings.TrimSpace(line)
|
|
if strings.HasPrefix(line, "Sink Input #") {
|
|
// Check previous entry before moving on.
|
|
if sinkInputIdx < 0 {
|
|
sinkInputIdx = matchCliamp(props, pidStr, currentIdx)
|
|
}
|
|
if sinkInputIdx >= 0 {
|
|
break
|
|
}
|
|
currentIdx, _ = strconv.Atoi(strings.TrimPrefix(line, "Sink Input #"))
|
|
props = map[string]string{}
|
|
continue
|
|
}
|
|
if key, val, ok := strings.Cut(line, "="); ok {
|
|
props[strings.TrimSpace(key)] = strings.Trim(strings.TrimSpace(val), `"`)
|
|
}
|
|
}
|
|
// Check the last entry.
|
|
if sinkInputIdx < 0 {
|
|
sinkInputIdx = matchCliamp(props, pidStr, currentIdx)
|
|
}
|
|
|
|
if sinkInputIdx >= 0 {
|
|
cmd := exec.Command("pactl", "move-sink-input",
|
|
strconv.Itoa(sinkInputIdx), deviceName)
|
|
if out, err := cmd.CombinedOutput(); err != nil {
|
|
return fmt.Errorf("move-sink-input: %s (%w)", strings.TrimSpace(string(out)), err)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Fallback: change the system default sink.
|
|
if out, err := exec.Command("pactl", "set-default-sink", deviceName).CombinedOutput(); err != nil {
|
|
return fmt.Errorf("set-default-sink: %s (%w)", strings.TrimSpace(string(out)), err)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// matchCliamp checks if a sink-input's properties belong to cliamp.
|
|
func matchCliamp(props map[string]string, pidStr string, idx int) int {
|
|
if props["application.process.id"] == pidStr {
|
|
return idx
|
|
}
|
|
if strings.EqualFold(props["application.process.binary"], "cliamp") {
|
|
return idx
|
|
}
|
|
if strings.Contains(strings.ToLower(props["application.name"]), "cliamp") {
|
|
return idx
|
|
}
|
|
return -1
|
|
}
|