diff options
author | xegineering <me@xegineering.eu> | 2024-11-17 12:45:35 +0100 |
---|---|---|
committer | xegineering <me@xegineering.eu> | 2024-11-17 12:48:00 +0100 |
commit | d4cf5ed8e38d1e5d0b8110e8959e002c216f073f (patch) | |
tree | 4565ee3c50e6de74b6ce65c615ac71dcf8378a7f /soundbox/url.go | |
parent | a95013aa0813d1644aa15780f360fa4dad2223a8 (diff) | |
download | soundbox-go-d4cf5ed8e38d1e5d0b8110e8959e002c216f073f.tar soundbox-go-d4cf5ed8e38d1e5d0b8110e8959e002c216f073f.tar.zst soundbox-go-d4cf5ed8e38d1e5d0b8110e8959e002c216f073f.zip |
Fix streaming only via first interface candidate
Diffstat (limited to 'soundbox/url.go')
-rw-r--r-- | soundbox/url.go | 80 |
1 files changed, 80 insertions, 0 deletions
diff --git a/soundbox/url.go b/soundbox/url.go new file mode 100644 index 0000000..4ad9908 --- /dev/null +++ b/soundbox/url.go @@ -0,0 +1,80 @@ +package soundbox + +import ( + "context" + "errors" + "io" + "net" + "os/exec" + "time" +) + +// streamingPort is the default network port a soundbox is listening to for +// incoming audio stream data. +const streamingPort = 5316 + +const bufferSize = 20 + +const writeTimeout = 1 * time.Second + +// StreamURLContext streams audio from a given URL to one or multiple soundbox +// devices. The devices are referenced via their MAC addresses given by the +// targets argument. The ctx argument is passed to cancel the streaming. +func StreamURLContext(ctx context.Context, url string, targets []net.HardwareAddr) error { + conns := make([]net.Conn, 0) + for _, target := range targets { + conn, err := dialContext(ctx, target) + if err != nil { + return err + } + conns = append(conns, conn) + } + defer func() { + for _, conn := range conns { + conn.Close() + } + }() + + cmd := exec.CommandContext( + ctx, + "ffmpeg", + "-re", + "-i", + url, + "-acodec", + "flac", + "-f", + "ogg", + "-", + ) + stdout, err := cmd.StdoutPipe() + if err != nil { + return err + } + + err = cmd.Start() + if err != nil { + return err + } + + for { + buffer := make([]byte, bufferSize) + i, err := stdout.Read(buffer) + if err != nil { + if errors.Is(err, io.EOF) { + break + } else { + return err + } + } + for _, conn := range conns { + conn.SetDeadline(time.Now().Add(writeTimeout)) + _, err = conn.Write(buffer[:i]) + if err != nil { + return err + } + } + } + + return cmd.Wait() +} |