quintodrome/server/subsonic/radio.go

package subsonic

import (
	"net/http"
	"strings"

	"github.com/navidrome/navidrome/conf"
	"github.com/navidrome/navidrome/model"
	"github.com/navidrome/navidrome/model/request"
	"github.com/navidrome/navidrome/server/subsonic/responses"
	"github.com/navidrome/navidrome/utils/req"
)

func (api *Router) CreateInternetRadio(r *http.Request) (*responses.Subsonic, error) {
	p := req.Params(r)
	streamUrl, err := p.String("streamUrl")
	if err != nil {
		return nil, err
	}

	name, err := p.String("name")
	if err != nil {
		return nil, err
	}

	homepageUrl, _ := p.String("homepageUrl")
	ctx := r.Context()

	radio := &model.Radio{
		StreamUrl:   streamUrl,
		HomePageUrl: homepageUrl,
		Name:        name,
	}

	err = api.ds.Radio(ctx).Put(radio)
	if err != nil {
		return nil, err
	}
	return newResponse(), nil
}

func (api *Router) DeleteInternetRadio(r *http.Request) (*responses.Subsonic, error) {
	p := req.Params(r)
	id, err := p.String("id")

	if err != nil {
		return nil, err
	}

	err = api.ds.Radio(r.Context()).Delete(id)
	if err != nil {
		return nil, err
	}
	return newResponse(), nil
}

func (api *Router) GetInternetRadios(r *http.Request) (*responses.Subsonic, error) {
	ctx := r.Context()
	radios, err := api.ds.Radio(ctx).GetAll(model.QueryOptions{Sort: "name"})
	if err != nil {
		return nil, err
	}

	res := make([]responses.Radio, len(radios))
	for i, g := range radios {
		res[i] = responses.Radio{
			ID:          g.ID,
			Name:        g.Name,
			StreamUrl:   g.StreamUrl,
			HomepageUrl: g.HomePageUrl,
		}

		player, _ := request.PlayerFrom(ctx)
		if strings.Contains(conf.Server.Subsonic.LegacyClients, player.Client) {
			continue
		}
		// Add coverArt if not legacy client
		var coverArt string
		if g.UploadedImage != "" {
			coverArt = g.CoverArtID().String()
		}
		res[i].OpenSubsonicRadio = &responses.OpenSubsonicRadio{
			CoverArt: coverArt,
		}
	}

	response := newResponse()
	response.InternetRadioStations = &responses.InternetRadioStations{
		Radios: res,
	}

	return response, nil
}

func (api *Router) UpdateInternetRadio(r *http.Request) (*responses.Subsonic, error) {
	p := req.Params(r)
	id, err := p.String("id")
	if err != nil {
		return nil, err
	}

	streamUrl, err := p.String("streamUrl")
	if err != nil {
		return nil, err
	}

	name, err := p.String("name")
	if err != nil {
		return nil, err
	}

	homepageUrl, _ := p.String("homepageUrl")
	ctx := r.Context()

	radio := &model.Radio{
		ID:          id,
		StreamUrl:   streamUrl,
		HomePageUrl: homepageUrl,
		Name:        name,
	}

	err = api.ds.Radio(ctx).Put(radio, "StreamUrl", "HomePageUrl", "Name")
	if err != nil {
		return nil, err
	}
	return newResponse(), nil
}