path: root/tools/mpd-stats/internal/mpd/mpd.go

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
}