Marvin Preuss
40071a52f9
All checks were successful
continuous-integration/drone/push Build is passing
139 lines
2.5 KiB
Go
139 lines
2.5 KiB
Go
package mpc
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/fhs/gompd/v2/mpd"
|
|
"github.com/rs/zerolog"
|
|
"github.com/rs/zerolog/log"
|
|
"go.xsfx.dev/schnutibox/internal/config"
|
|
"go.xsfx.dev/schnutibox/internal/metrics"
|
|
)
|
|
|
|
const (
|
|
timeout = 5 * time.Second
|
|
timeoutWait = time.Second / 2
|
|
)
|
|
|
|
var errTimeout = errors.New("timeout")
|
|
|
|
func Conn() (*mpd.Client, error) {
|
|
t := time.NewTimer(timeout)
|
|
|
|
for {
|
|
select {
|
|
case <-t.C:
|
|
return nil, errTimeout
|
|
default:
|
|
c, err := mpd.Dial("tcp", fmt.Sprintf("%s:%d", config.Cfg.MPD.Hostname, config.Cfg.MPD.Port))
|
|
if err != nil {
|
|
log.Error().Err(err).Msg("could not connect")
|
|
|
|
time.Sleep(timeoutWait)
|
|
|
|
continue
|
|
}
|
|
|
|
if !t.Stop() {
|
|
go func() {
|
|
<-t.C
|
|
}()
|
|
}
|
|
|
|
return c, nil
|
|
}
|
|
}
|
|
}
|
|
|
|
// PlaylistURIS extracts uris from MPD playlist.
|
|
func PlaylistURIS(m *mpd.Client) ([]string, error) {
|
|
attrs, err := m.PlaylistInfo(-1, -1)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("could not get playlist: %w", err)
|
|
}
|
|
|
|
// Stores the tracklist it got from the MPD server.
|
|
uris := []string{}
|
|
|
|
// Builds uri list.
|
|
for _, a := range attrs {
|
|
uris = append(uris, a["file"])
|
|
}
|
|
|
|
return uris, nil
|
|
}
|
|
|
|
func Stop(logger zerolog.Logger) error {
|
|
logger.Info().Msg("trying to stop playback")
|
|
|
|
m, err := Conn()
|
|
if err != nil {
|
|
return fmt.Errorf("could not connect: %w", err)
|
|
}
|
|
|
|
// nolint:wrapcheck
|
|
return m.Stop()
|
|
}
|
|
|
|
func Clear(logger zerolog.Logger) error {
|
|
logger.Info().Msg("trying to clear playlist")
|
|
|
|
m, err := Conn()
|
|
if err != nil {
|
|
return fmt.Errorf("could not connect: %w", err)
|
|
}
|
|
|
|
// nolint:wrapcheck
|
|
return m.Clear()
|
|
}
|
|
|
|
func Play(logger zerolog.Logger, rfid string, name string, uris []string) error {
|
|
logger.Info().Msg("trying to add tracks")
|
|
|
|
m, err := Conn()
|
|
if err != nil {
|
|
return fmt.Errorf("could not connect: %w", err)
|
|
}
|
|
|
|
// Stop playing track.
|
|
if err := Stop(logger); err != nil {
|
|
metrics.BoxErrors.Inc()
|
|
|
|
return err
|
|
}
|
|
|
|
// Clear playlist.
|
|
if err := Clear(logger); err != nil {
|
|
metrics.BoxErrors.Inc()
|
|
|
|
return err
|
|
}
|
|
|
|
// Adding every single uri to playlist
|
|
for _, i := range uris {
|
|
logger.Debug().Str("uri", i).Msg("add track")
|
|
|
|
if err := m.Add(i); err != nil {
|
|
metrics.BoxErrors.Inc()
|
|
|
|
return fmt.Errorf("could not add track: %w", err)
|
|
}
|
|
}
|
|
|
|
// Getting playlist uris from MPD server.
|
|
// This is needed to identify the right metric to use.
|
|
mpdURIS, err := PlaylistURIS(m)
|
|
if err != nil {
|
|
metrics.BoxErrors.Inc()
|
|
|
|
return err
|
|
}
|
|
|
|
metrics.NewPlay(rfid, name, mpdURIS)
|
|
|
|
// nolint:wrapcheck
|
|
return m.Play(-1)
|
|
}
|