storm/barnard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Test local Mumble TCP audio fallback

Browse Source
This commit is contained in:
Brandon McGinty (chatgpt)
2026-08-09 20:51:44 -04:00
committed by Brandon McGinty
parent c9c6d6bab1
commit 5cd23f5df8
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
gumble/gumble/integration_audio_test.go
+13 -3
View File
@@ -27,7 +27,13 @@ func (l *integrationAudioListener) OnAudioStream(e *gumble.AudioStreamEvent) {
// TestLocalMumbleAudioRoundTrip sends generated 440 Hz audio through a real // TestLocalMumbleAudioRoundTrip sends generated 440 Hz audio through a real
// local Mumble server and requires the other client to decode non-silent PCM. // local Mumble server and requires the other client to decode non-silent PCM.
func TestLocalMumbleAudioRoundTrip(t *testing.T) { func TestLocalMumbleAudioRoundTrip(t *testing.T) { testLocalMumbleAudioRoundTrip(t, false) }
// Regression: TCP tunnel fallback must remain usable when UDP is deliberately
// disabled or blocked, rather than silently dropping valid audio.
func TestLocalMumbleTCPAudioFallback(t *testing.T) { testLocalMumbleAudioRoundTrip(t, true) }
func testLocalMumbleAudioRoundTrip(t *testing.T, disableUDP bool) {
if os.Getenv("BARNARD_MUMBLE_INTEGRATION") != "1" { if os.Getenv("BARNARD_MUMBLE_INTEGRATION") != "1" {
t.Skip("set BARNARD_MUMBLE_INTEGRATION=1") t.Skip("set BARNARD_MUMBLE_INTEGRATION=1")
} }
@@ -35,7 +41,7 @@ func TestLocalMumbleAudioRoundTrip(t *testing.T) {
c := gumble.NewConfig() c := gumble.NewConfig()
c.Address = "localhost:64738" c.Address = "localhost:64738"
c.Username = name c.Username = name
c.DisableUDP = false c.DisableUDP = disableUDP
return c return c
} }
tlsConfig := &tls.Config{InsecureSkipVerify: true} tlsConfig := &tls.Config{InsecureSkipVerify: true}
@@ -57,7 +63,11 @@ func TestLocalMumbleAudioRoundTrip(t *testing.T) {
t.Fatal("no negotiated audio encoder") t.Fatal("no negotiated audio encoder")
} }
time.Sleep(1500 * time.Millisecond) time.Sleep(1500 * time.Millisecond)
if !sender.UDPActive() || !receiver.UDPActive() { if disableUDP {
if sender.UDPActive() || receiver.UDPActive() {
t.Fatal("UDP activated despite TCP-only configuration")
}
} else if !sender.UDPActive() || !receiver.UDPActive() {
t.Fatalf("native UDP did not become active: sender=%v receiver=%v", sender.UDPActive(), receiver.UDPActive()) t.Fatalf("native UDP did not become active: sender=%v receiver=%v", sender.UDPActive(), receiver.UDPActive())
} }
frame := make([]int16, sendConfig.AudioFrameSize()) frame := make([]int16, sendConfig.AudioFrameSize())