aboutsummaryrefslogtreecommitdiffhomepage
path: root/internal/pipewire/pipewire_test.go
diff options
context:
space:
mode:
authorOphestra <cat@gensokyo.uk>2025-12-03 03:52:17 +0900
committerOphestra <cat@gensokyo.uk>2025-12-03 03:52:17 +0900
commit2c0b92771a95693af7f14a70ddeddc5371e73996 (patch)
tree38c5e3cf06ecdee79db7d373c68dfbd4fe3b7e6b /internal/pipewire/pipewire_test.go
parent054c91879fccc22466da942462497e048c057a54 (diff)
internal/pipewire: relocate constants
This should make things easier to navigate, and possible to fully automatically generate the constants in the future. Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'internal/pipewire/pipewire_test.go')
-rw-r--r--internal/pipewire/pipewire_test.go53
1 files changed, 0 insertions, 53 deletions
diff --git a/internal/pipewire/pipewire_test.go b/internal/pipewire/pipewire_test.go
index f7df3ab1..f819dff8 100644
--- a/internal/pipewire/pipewire_test.go
+++ b/internal/pipewire/pipewire_test.go
@@ -1,8 +1,6 @@
package pipewire_test
import (
- _ "embed"
- "encoding/binary"
"fmt"
"net"
"reflect"
@@ -813,57 +811,6 @@ func (conn *stubUnixConn) Close() error {
return nil
}
-var (
- //go:embed testdata/pw-container-00-sendmsg
- samplePWContainer00 string
- //go:embed testdata/pw-container-01-recvmsg
- samplePWContainer01 string
- //go:embed testdata/pw-container-03-sendmsg
- samplePWContainer03 string
- //go:embed testdata/pw-container-04-recvmsg
- samplePWContainer04 string
- //go:embed testdata/pw-container-06-sendmsg
- samplePWContainer06 string
- //go:embed testdata/pw-container-07-recvmsg
- samplePWContainer07 string
-
- // samplePWContainer is a collection of messages from the pw-container sample.
- samplePWContainer = [...][][3][]byte{
- splitMessages(samplePWContainer00),
- splitMessages(samplePWContainer01),
- nil,
- splitMessages(samplePWContainer03),
- splitMessages(samplePWContainer04),
- nil,
- splitMessages(samplePWContainer06),
- splitMessages(samplePWContainer07),
- nil,
- }
-)
-
-// splitMessages splits concatenated messages into groups of
-// header, payload, footer of each individual message.
-// splitMessages panics on any decoding error.
-func splitMessages(iovec string) (messages [][3][]byte) {
- data := []byte(iovec)
- messages = make([][3][]byte, 0, 1<<7)
-
- var header pipewire.Header
- for len(data) != 0 {
- if err := header.UnmarshalBinary(data[:pipewire.SizeHeader]); err != nil {
- panic(err)
- }
- size := pipewire.SizePrefix + binary.NativeEndian.Uint32(data[pipewire.SizeHeader:])
- messages = append(messages, [3][]byte{
- data[:pipewire.SizeHeader],
- data[pipewire.SizeHeader : pipewire.SizeHeader+size],
- data[pipewire.SizeHeader+size : pipewire.SizeHeader+header.Size],
- })
- data = data[pipewire.SizeHeader+header.Size:]
- }
- return
-}
-
func TestContextErrors(t *testing.T) {
t.Parallel()