summaryrefslogtreecommitdiff
path: root/soundbox/stream.go
diff options
context:
space:
mode:
authorxegineering <me@xegineering.eu>2024-10-31 22:10:36 +0100
committerxegineering <me@xegineering.eu>2024-10-31 22:10:36 +0100
commit79eeb90079e417f0a9d040c1de8f3278c628810f (patch)
tree0745023fcbeb97faedefa216394fc228bbcf9443 /soundbox/stream.go
parentcbcebb47e515f900f2505098f0ce87697e2fe283 (diff)
downloadsoundbox-go-79eeb90079e417f0a9d040c1de8f3278c628810f.tar
soundbox-go-79eeb90079e417f0a9d040c1de8f3278c628810f.tar.zst
soundbox-go-79eeb90079e417f0a9d040c1de8f3278c628810f.zip
Change module name and restructure contentv0.1.2
The repository names for soundbox are named as below: - app: soundbox-app - Go library module: soundbox-go - Device: soundbox The Go module names were: - app: xengineering.eu/soundbox/app - Go library module: xengineering.eu/soundbox This does not make clear which module is related to which repository since the names are different. Thus it should be changed to: - app: xengineering.eu/soundbox-app - Go library module: xengineering.eu/soundbox-go The import statement for the library is then: import "xengineering.eu/soundbox-go/soundbox" This is a bit longer but it keeps the property that the library is referenced inside the code by the simple name `soundbox`.
Diffstat (limited to 'soundbox/stream.go')
-rw-r--r--soundbox/stream.go48
1 files changed, 48 insertions, 0 deletions
diff --git a/soundbox/stream.go b/soundbox/stream.go
new file mode 100644
index 0000000..cc8fcea
--- /dev/null
+++ b/soundbox/stream.go
@@ -0,0 +1,48 @@
+package soundbox
+
+import (
+ "context"
+ "fmt"
+ "os/exec"
+ "net"
+)
+
+// streamingPort is the default network port a soundbox is listening to for
+// incoming audio stream data.
+const streamingPort = 5316
+
+// 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 {
+ iface, err := getInterface()
+ if err != nil {
+ return err
+ }
+
+ cmd := []string{
+ "-re",
+ "-i",
+ url,
+ }
+
+ for _, target := range targets {
+ ip, err := toLinkLocal(target)
+ if err != nil {
+ return err
+ }
+
+ cmd = append(cmd, "-acodec")
+ cmd = append(cmd, "flac")
+ cmd = append(cmd, "-f")
+ cmd = append(cmd, "ogg")
+ cmd = append(cmd, fmt.Sprintf(
+ "tcp://[%s%%%s]:%d",
+ ip,
+ iface.Name,
+ streamingPort,
+ ))
+ }
+
+ return exec.CommandContext(ctx, "ffmpeg", cmd...).Run()
+}