aboutsummaryrefslogtreecommitdiff
path: root/internal/mpd/mpd.go
diff options
context:
space:
mode:
authorFranck Cuny <franck@fcuny.net>2025-08-29 09:23:18 -0700
committerFranck Cuny <franck@fcuny.net>2025-08-29 09:23:18 -0700
commit91ead5e4493bb459ea537ad204e7e6b3d15a220b (patch)
treef712f9d75a969479bda177bc439918ed2a1008f0 /internal/mpd/mpd.go
parentfix readme for x509-info project (diff)
parentprepare the migration (diff)
downloadx-91ead5e4493bb459ea537ad204e7e6b3d15a220b.tar.gz
Merge remote-tracking branch 'import/main'
Diffstat (limited to 'internal/mpd/mpd.go')
-rw-r--r--internal/mpd/mpd.go48
1 files changed, 48 insertions, 0 deletions
diff --git a/internal/mpd/mpd.go b/internal/mpd/mpd.go
new file mode 100644
index 0000000..5b57ee4
--- /dev/null
+++ b/internal/mpd/mpd.go
@@ -0,0 +1,48 @@
+package mpd
+
+import (
+ "log"
+ "time"
+
+ "github.com/fhs/gompd/v2/mpd"
+)
+
+type Player struct {
+ Watcher *mpd.Watcher
+ Client *mpd.Client
+}
+
+func NewPlayer(net string, addr string) (*Player, error) {
+ var (
+ p Player
+ err error
+ )
+
+ p.Watcher, err = mpd.NewWatcher(net, addr, "", "player")
+ if err != nil {
+ log.Fatalf("failed to create a watcher: %v", err)
+ }
+
+ p.Client, err = mpd.Dial(net, addr)
+ if err != nil {
+ log.Fatalf("failed to start mpd client: %v", err)
+ }
+
+ go func() {
+ for range time.Tick(30 * time.Second) {
+ p.Client.Ping()
+ }
+ }()
+
+ return &p, nil
+}
+
+func (p *Player) Close() error {
+ if err := p.Watcher.Close(); err != nil {
+ return err
+ }
+ if err := p.Client.Close(); err != nil {
+ return err
+ }
+ return nil
+}