dwelling-radio/internal/radio/icecast.go

package radio

import (
	"encoding/json"
	"fmt"
	"net/http"
	"os/exec"
	"strings"
	"time"
)

type IcecastStatusDTO struct {
	Icestats struct {
		ServerStartISO8601 string `json:"server_start_iso8601"`
		ServerStartDate    string `json:"server_start"`
		Source             struct {
			Artist       string `json:"artist"`
			Title        string `json:"title"`
			ListenerPeak int    `json:"listener_peak"`
			Listeners    int    `json:"listeners"`
		} `json:"source"`
	} `json:"icestats"`
}

func (is *IcecastStatusDTO) Song() string {
	return fmt.Sprintf("%s - %s", is.Icestats.Source.Artist, is.Icestats.Source.Title)
}

type IcecastStatus struct {
	ServerStartISO8601 string `json:"server_start_iso8601"`
	ServerStartDate    string `json:"server_start_date"`
	SongName           string `json:"song"`
	ListenerPeak       int    `json:"listener_peak"`
	Listeners          int    `json:"listeners"`
}

type Song struct {
	Time   string `json:"time"`
	Artist string `json:"artist"`
	Title  string `json:"title"`
}

func IcecastGetStatus(icecastURL string) (*IcecastStatus, error) {
	resp, err := http.Get(icecastURL)
	if err != nil {
		return nil, err
	}

	iceStatDTO := &IcecastStatusDTO{}

	if err := json.NewDecoder(resp.Body).Decode(iceStatDTO); err != nil {
		return nil, err
	}

	iceStat := &IcecastStatus{
		ServerStartISO8601: iceStatDTO.Icestats.ServerStartISO8601,
		ServerStartDate:    iceStatDTO.Icestats.ServerStartDate,
		SongName:           iceStatDTO.Song(),
		ListenerPeak:       iceStatDTO.Icestats.Source.ListenerPeak,
		Listeners:          iceStatDTO.Icestats.Source.Listeners,
	}

	return iceStat, nil
}

func IcecastLastPlayedSongs(lastNSongs int, playlistPath string) ([]Song, error) {
	songs := make([]Song, 0)

	cmd := fmt.Sprintf("tail -n%d %s | head -n-1 | cut -d'|' -f1,4", lastNSongs+1, playlistPath)
	out, err := exec.Command("bash", "-c", cmd).CombinedOutput()
	if err != nil {
		return songs, err
	}

	if len(out) == 0 {
		return songs, nil
	}

	songs_ := strings.Split(string(out), "\n")

	for _, song := range songs_ {
		ts := strings.Split(song, "|")
		if len(ts) <= 1 {
			continue
		}
		tim, _ := time.Parse("02/Jan/2006:15:04:05 -0700", ts[0])
		at := strings.Split(ts[1], " - ")
		songs = append(songs, Song{
			Time:   tim.UTC().Format("15:04"),
			Artist: at[0],
			Title:  at[1]})
	}

	return songs, nil
}