diff --git a/backend/app.go b/backend/app.go
index 4a3cca4..31a8970 100644
--- a/backend/app.go
+++ b/backend/app.go
@@ -378,7 +378,7 @@ func (a *App) LoadSavedPlayQueue() error {
if err := a.PlaybackManager.LoadTracks(queue.Tracks, Replace, false); err != nil {
return err
}
- if queue.TrackIndex >= 0 {
+ if queue.TrackIndex >= 0 && queue.TrackIndex < len(queue.Tracks) {
// TODO: This isn't ideal but doesn't seem to cause an audible play-for-a-split-second artifact
a.PlaybackManager.PlayTrackAt(queue.TrackIndex)
a.PlaybackManager.Pause()
diff --git a/backend/imagemanager.go b/backend/imagemanager.go
index f8102ee..e9050ce 100644
--- a/backend/imagemanager.go
+++ b/backend/imagemanager.go
@@ -120,15 +120,6 @@ func (i *ImageManager) GetCoverThumbnail(coverID string) (image.Image, error) {
return i.fetchAndCacheCoverFromDiskOrServer(context.Background(), coverID, i.thumbnailCache.DefaultTTL, nil)
}
-// GetCoverThumbnailWithTTL fetches the cover for the given coverID and updates the TTL
-// in the in-memory image cache. It blocks until the image fetch is complete.
-func (i *ImageManager) GetCoverThumbnailWithTTL(coverID string, ttl time.Duration) (image.Image, error) {
- if img, err := i.thumbnailCache.GetWithNewTTL(coverID, ttl); err == nil {
- return img, nil
- }
- return i.fetchAndCacheCoverFromDiskOrServer(context.Background(), coverID, ttl, nil)
-}
-
// GetFullSizeCoverArt fetches the full size cover image for the given coverID.
// It blocks until the fetch is complete.
func (i *ImageManager) GetFullSizeCoverArt(coverID string) (image.Image, error) {
diff --git a/backend/mediaprovider/jellyfin/jellyfinmediaprovider.go b/backend/mediaprovider/jellyfin/jellyfinmediaprovider.go
index 9386052..a303e69 100644
--- a/backend/mediaprovider/jellyfin/jellyfinmediaprovider.go
+++ b/backend/mediaprovider/jellyfin/jellyfinmediaprovider.go
@@ -395,7 +395,7 @@ func toTrack(ch *jellyfin.Song) *mediaprovider.Track {
ID: ch.Id,
CoverArtID: coverArtID,
ParentID: ch.AlbumID,
- Name: ch.Name,
+ Title: ch.Name,
Duration: int(ch.RunTimeTicks / runTimeTicksPerSecond),
TrackNumber: ch.IndexNumber,
DiscNumber: ch.DiscNumber,
diff --git a/backend/mediaprovider/mediaprovider.go b/backend/mediaprovider/mediaprovider.go
index 648a363..c3d97d7 100644
--- a/backend/mediaprovider/mediaprovider.go
+++ b/backend/mediaprovider/mediaprovider.go
@@ -267,6 +267,10 @@ type LyricsProvider interface {
GetLyrics(track *Track) (*Lyrics, error)
}
+type RadioProvider interface {
+ GetRadioStations() ([]*RadioStation, error)
+}
+
type JukeboxProvider interface {
JukeboxStart() error
JukeboxStop() error
diff --git a/backend/mediaprovider/model.go b/backend/mediaprovider/model.go
index c865bce..51c7525 100644
--- a/backend/mediaprovider/model.go
+++ b/backend/mediaprovider/model.go
@@ -86,7 +86,7 @@ type Track struct {
ID string
CoverArtID string
ParentID string
- Name string
+ Title string
Duration int
TrackNumber int
DiscNumber int
@@ -139,6 +139,74 @@ type SavedPlayQueue struct {
TimePos int // seconds
}
+type RadioStation struct {
+ Name string
+ ID string
+ HomePageURL string
+ StreamURL string
+}
+
+type MediaItemType int
+
+const (
+ MediaItemTypeTrack MediaItemType = iota
+ MediaItemTypeRadioStation
+)
+
+type MediaItemMetadata struct {
+ Type MediaItemType
+ ID string
+ Name string
+ Artists []string
+ ArtistIDs []string
+ Album string
+ AlbumID string
+ CoverArtID string
+ Duration int
+}
+
+type MediaItem interface {
+ Metadata() MediaItemMetadata
+ Copy() MediaItem
+}
+
+func (t *Track) Metadata() MediaItemMetadata {
+ if t == nil {
+ return MediaItemMetadata{}
+ }
+ return MediaItemMetadata{
+ Type: MediaItemTypeTrack,
+ ID: t.ID,
+ Name: t.Title,
+ Artists: t.ArtistNames,
+ ArtistIDs: t.ArtistIDs,
+ Album: t.Album,
+ AlbumID: t.AlbumID,
+ CoverArtID: t.CoverArtID,
+ Duration: t.Duration,
+ }
+}
+
+func (t *Track) Copy() MediaItem {
+ new := *t
+ return &new
+}
+
+func (r *RadioStation) Metadata() MediaItemMetadata {
+ if r == nil {
+ return MediaItemMetadata{}
+ }
+ return MediaItemMetadata{
+ Type: MediaItemTypeRadioStation,
+ ID: r.ID,
+ Name: r.Name,
+ }
+}
+
+func (r *RadioStation) Copy() MediaItem {
+ return r // no need to copy since RadioStations are immutable
+}
+
type ContentType int
const (
diff --git a/backend/mediaprovider/subsonic/subsonicmediaprovider.go b/backend/mediaprovider/subsonic/subsonicmediaprovider.go
index 98b95db..fbef25c 100644
--- a/backend/mediaprovider/subsonic/subsonicmediaprovider.go
+++ b/backend/mediaprovider/subsonic/subsonicmediaprovider.go
@@ -367,7 +367,7 @@ func (s *subsonicMediaProvider) GetLyrics(track *mediaprovider.Track) (*mediapro
return mpLyrics, nil
}
// fallback to legacy getLyrics endpoint
- lyrics, err := s.client.GetLyrics(track.Name, track.ArtistNames[0])
+ lyrics, err := s.client.GetLyrics(track.Title, track.ArtistNames[0])
if err != nil || lyrics == nil || lyrics.Text == "" {
return nil, err
}
@@ -386,6 +386,7 @@ func (s *subsonicMediaProvider) GetLyrics(track *mediaprovider.Track) (*mediapro
}
// CanSavePlayQueue interface
+var _ mediaprovider.CanSavePlayQueue = (*subsonicMediaProvider)(nil)
func (s *subsonicMediaProvider) SavePlayQueue(trackIDs []string, currentTrackIdx int, timeSeconds int) error {
if len(trackIDs) == 0 {
@@ -413,6 +414,25 @@ func (s *subsonicMediaProvider) GetPlayQueue() (*mediaprovider.SavedPlayQueue, e
return savedQueue, nil
}
+// RadioProvider interface
+var _ mediaprovider.RadioProvider = (*subsonicMediaProvider)(nil)
+
+func (s *subsonicMediaProvider) GetRadioStations() ([]*mediaprovider.RadioStation, error) {
+ rs, err := s.client.GetInternetRadioStations()
+ if err != nil {
+ return nil, err
+ }
+ return sharedutil.MapSlice(rs, func(rs *subsonic.InternetRadioStation) *mediaprovider.RadioStation {
+ return &mediaprovider.RadioStation{
+ // TODO - subsonic library is missing ID in its radiostation object. add it
+ ID: "radio-" + strings.ReplaceAll(rs.Name, " ", ""),
+ Name: rs.Name,
+ HomePageURL: rs.HomePageUrl,
+ StreamURL: rs.StreamUrl,
+ }
+ }), nil
+}
+
func toTrack(ch *subsonic.Child) *mediaprovider.Track {
if ch == nil {
return nil
@@ -433,7 +453,7 @@ func toTrack(ch *subsonic.Child) *mediaprovider.Track {
ID: ch.ID,
CoverArtID: ch.CoverArt,
ParentID: ch.Parent,
- Name: ch.Title,
+ Title: ch.Title,
Duration: ch.Duration,
TrackNumber: ch.Track,
DiscNumber: ch.DiscNumber,
diff --git a/backend/mpmedia_mac.go b/backend/mpmedia_mac.go
index 9e59056..dff1fcc 100644
--- a/backend/mpmedia_mac.go
+++ b/backend/mpmedia_mac.go
@@ -69,9 +69,14 @@ func InitMPMediaHandler(playbackManager *PlaybackManager, artURLLookup func(trac
mpMediaEventRecipient = mp
C.register_os_remote_commands()
- mp.playbackManager.OnSongChange(func(track, _ *mediaprovider.Track) {
+ mp.playbackManager.OnSongChange(func(track mediaprovider.MediaItem, _ *mediaprovider.Track) {
// Asynchronously because artwork fetching can take time
- go mp.updateMetadata(track)
+ var meta *mediaprovider.MediaItemMetadata
+ if track != nil {
+ m := track.Metadata()
+ meta = &m
+ }
+ go mp.updateMetadata(meta)
})
mp.playbackManager.OnStopped(func() {
@@ -95,17 +100,19 @@ func InitMPMediaHandler(playbackManager *PlaybackManager, artURLLookup func(trac
return nil
}
-func (mp *MPMediaHandler) updateMetadata(track *mediaprovider.Track) {
+func (mp *MPMediaHandler) updateMetadata(meta *mediaprovider.MediaItemMetadata) {
var title, artist, artURL string
var duration int
- if track != nil && track.ID != "" {
+ if meta != nil && meta.ID != "" {
+ title = meta.Name
var err error
- if artURL, err = mp.artURLLookup(track.CoverArtID); err != nil {
- log.Printf("error fetching art url: %s", err.Error())
+ if artURL, err = mp.artURLLookup(meta.CoverArtID); err != nil {
+ if meta.CoverArtID != "" {
+ log.Printf("error fetching art url: %s", err.Error())
+ }
}
- title = track.Name
- artist = strings.Join(track.ArtistNames, ", ")
- duration = track.Duration
+ artist = strings.Join(meta.Artists, ", ")
+ duration = meta.Duration
}
cTitle := C.CString(title)
diff --git a/backend/mpris.go b/backend/mpris.go
index 58a9260..440747c 100644
--- a/backend/mpris.go
+++ b/backend/mpris.go
@@ -58,11 +58,11 @@ func NewMPRISHandler(playerName string, pm *PlaybackManager) *MPRISHandler {
m.evt.Player.OnSeek(pos)
}
})
- pm.OnSongChange(func(tr, _ *mediaprovider.Track) {
+ pm.OnSongChange(func(tr mediaprovider.MediaItem, _ *mediaprovider.Track) {
if tr == nil {
m.curTrackPath = ""
} else {
- m.curTrackPath = dbusTrackIDPrefix + encodeTrackId(tr.ID)
+ m.curTrackPath = dbusTrackIDPrefix + encodeTrackId(tr.Metadata().ID)
}
if m.connErr == nil {
m.evt.Player.OnTitle()
@@ -251,30 +251,48 @@ func (m *MPRISHandler) Metadata() (types.Metadata, error) {
trackObjPath = m.curTrackPath
}
status := m.pm.PlayerStatus()
- var tr mediaprovider.Track
+
+ var meta mediaprovider.MediaItemMetadata
+ // metadata that can come only from tracks
+ var discNumber, trackNumber, userRating, playCount, year int
+ var genre string
+
if np := m.pm.NowPlaying(); np != nil && status.State != player.Stopped {
- tr = *np
+ meta = np.Metadata()
+ if track, ok := np.(*mediaprovider.Track); ok {
+ discNumber = track.DiscNumber
+ trackNumber = track.TrackNumber
+ userRating = track.Rating
+ playCount = track.PlayCount
+ year = track.Year
+ genre = track.Genre
+ }
}
var artURL string
- if tr.ID != "" && m.ArtURLLookup != nil {
- if u, err := m.ArtURLLookup(tr.CoverArtID); err == nil {
+ if meta.ID != "" && m.ArtURLLookup != nil {
+ if u, err := m.ArtURLLookup(meta.CoverArtID); err == nil {
artURL = u
}
}
- return types.Metadata{
- TrackId: dbus.ObjectPath(trackObjPath),
- Length: secondsToMicroseconds(status.Duration),
- Title: tr.Name,
- Album: tr.Album,
- Artist: tr.ArtistNames,
- DiscNumber: tr.DiscNumber,
- TrackNumber: tr.TrackNumber,
- Genre: []string{tr.Genre},
- UserRating: float64(tr.Rating) / 5,
- ContentCreated: strconv.Itoa(tr.Year),
- UseCount: tr.PlayCount,
- ArtUrl: artURL,
- }, nil
+ mprisMeta := types.Metadata{
+ TrackId: dbus.ObjectPath(trackObjPath),
+ Length: secondsToMicroseconds(status.Duration),
+ Title: meta.Name,
+ Album: meta.Album,
+ Artist: meta.Artists,
+ DiscNumber: discNumber,
+ TrackNumber: trackNumber,
+ UserRating: float64(userRating) / 5,
+ UseCount: playCount,
+ ArtUrl: artURL,
+ }
+ if genre != "" {
+ mprisMeta.Genre = []string{genre}
+ }
+ if year != 0 {
+ mprisMeta.ContentCreated = strconv.Itoa(year)
+ }
+ return mprisMeta, nil
}
func (m *MPRISHandler) Volume() (float64, error) {
diff --git a/backend/playbackengine.go b/backend/playbackengine.go
index 3a089d4..37f315d 100644
--- a/backend/playbackengine.go
+++ b/backend/playbackengine.go
@@ -44,12 +44,13 @@ type playbackEngine struct {
player player.BasePlayer
playTimeStopwatch util.Stopwatch
- curTrackTime float64
+ curTrackDuration float64
latestTrackPosition float64 // cleared by checkScrobble
callbacksDisabled bool
- playQueue []*mediaprovider.Track
+ playQueue []mediaprovider.MediaItem
nowPlayingIdx int
+ isRadio bool
wasStopped bool // true iff player was stopped before handleOnTrackChange invocation
loopMode LoopMode
@@ -60,7 +61,7 @@ type playbackEngine struct {
replayGainCfg ReplayGainConfig
// registered callbacks
- onSongChange []func(nowPlaying, justScrobbledIfAny *mediaprovider.Track)
+ onSongChange []func(nowPlaying mediaprovider.MediaItem, justScrobbledIfAny *mediaprovider.Track)
onPlayTimeUpdate []func(float64, float64, bool)
onLoopModeChange []func(LoopMode)
onVolumeChange []func(int)
@@ -122,8 +123,8 @@ func (p *playbackEngine) PlayTrackAt(idx int) error {
return p.setTrack(idx, false)
}
-// Gets the curently playing song, if any.
-func (p *playbackEngine) NowPlaying() *mediaprovider.Track {
+// Gets the curently playing media item, if any.
+func (p *playbackEngine) NowPlaying() mediaprovider.MediaItem {
if p.nowPlayingIdx < 0 || len(p.playQueue) == 0 || p.player.GetStatus().State == player.Stopped {
return nil
}
@@ -184,6 +185,9 @@ func (p *playbackEngine) SeekBackOrPrevious() error {
// Seek to given absolute position in the current track by seconds.
func (p *playbackEngine) SeekSeconds(sec float64) error {
+ if p.isRadio {
+ return nil // can't seek radio stations
+ }
return p.player.SeekSeconds(sec)
}
@@ -216,7 +220,7 @@ func (p *playbackEngine) LoadTracks(tracks []*mediaprovider.Track, insertQueueMo
}
needToSetNext := len(tracks) > 0 && (insertQueueMode == InsertNext || (insertQueueMode == Append && p.nowPlayingIdx == len(p.playQueue)-1))
- newTracks := p.deepCopyTrackSlice(tracks)
+ newTracks := p.copyTrackSliceToMediaItemSlice(tracks)
if shuffle {
rand.Shuffle(len(newTracks), func(i, j int) { newTracks[i], newTracks[j] = newTracks[j], newTracks[i] })
}
@@ -235,6 +239,31 @@ func (p *playbackEngine) LoadTracks(tracks []*mediaprovider.Track, insertQueueMo
return nil
}
+func (p *playbackEngine) LoadRadioStation(radio *mediaprovider.RadioStation, insertMode InsertQueueMode) {
+ if insertMode == Replace {
+ p.player.Stop()
+ p.nowPlayingIdx = -1
+ p.playQueue = nil
+ }
+ needToSetNext := insertMode == InsertNext || (insertMode == Append && p.nowPlayingIdx == len(p.playQueue)-1)
+ insertIdx := len(p.playQueue)
+ if insertMode == InsertNext {
+ insertIdx = p.nowPlayingIdx + 1
+ }
+ new := make([]mediaprovider.MediaItem, len(p.playQueue)+1)
+ firstHalf := p.playQueue[:insertIdx]
+ copy(new, firstHalf)
+ new[len(firstHalf)] = radio
+ copy(new[len(firstHalf)+1:], p.playQueue[insertIdx:])
+ p.playQueue = new
+
+ if needToSetNext {
+ p.setNextTrack(p.nowPlayingIdx + 1)
+ }
+
+ p.invokeNoArgCallbacks(p.onQueueChange)
+}
+
// Stop playback and clear the play queue.
func (p *playbackEngine) StopAndClearPlayQueue() {
changed := len(p.playQueue) > 0
@@ -247,36 +276,40 @@ func (p *playbackEngine) StopAndClearPlayQueue() {
}
}
-func (p *playbackEngine) GetPlayQueue() []*mediaprovider.Track {
- return p.deepCopyTrackSlice(p.playQueue)
+func (p *playbackEngine) GetPlayQueue() []mediaprovider.MediaItem {
+ return p.deepCopyMediaItemSlice(p.playQueue)
}
// Any time the user changes the favorite status of a track elsewhere in the app,
// this should be called to ensure the in-memory track model is updated.
func (p *playbackEngine) OnTrackFavoriteStatusChanged(id string, fav bool) {
- if tr := sharedutil.FindTrackByID(id, p.playQueue); tr != nil {
- tr.Favorite = fav
+ if item := sharedutil.FindMediaItemByID(id, p.playQueue); item != nil {
+ if tr, ok := item.(*mediaprovider.Track); ok {
+ tr.Favorite = fav
+ }
}
}
// Any time the user changes the rating of a track elsewhere in the app,
// this should be called to ensure the in-memory track model is updated.
func (p *playbackEngine) OnTrackRatingChanged(id string, rating int) {
- if tr := sharedutil.FindTrackByID(id, p.playQueue); tr != nil {
- tr.Rating = rating
+ if item := sharedutil.FindMediaItemByID(id, p.playQueue); item != nil {
+ if tr, ok := item.(*mediaprovider.Track); ok {
+ tr.Rating = rating
+ }
}
}
// Replaces the play queue with the given set of tracks.
// Does not stop playback if the currently playing track is in the new queue,
// but updates the now playing index to point to the first instance of the track in the new queue.
-func (p *playbackEngine) UpdatePlayQueue(tracks []*mediaprovider.Track) error {
- newQueue := p.deepCopyTrackSlice(tracks)
+func (p *playbackEngine) UpdatePlayQueue(items []mediaprovider.MediaItem) error {
+ newQueue := p.deepCopyMediaItemSlice(items)
newNowPlayingIdx := -1
if p.nowPlayingIdx >= 0 {
- nowPlayingID := p.playQueue[p.nowPlayingIdx].ID
+ nowPlayingID := p.playQueue[p.nowPlayingIdx].Metadata().ID
for i, tr := range newQueue {
- if tr.ID == nowPlayingID {
+ if tr.Metadata().ID == nowPlayingID {
newNowPlayingIdx = i
break
}
@@ -298,14 +331,14 @@ func (p *playbackEngine) UpdatePlayQueue(tracks []*mediaprovider.Track) error {
}
func (p *playbackEngine) RemoveTracksFromQueue(trackIDs []string) {
- newQueue := make([]*mediaprovider.Track, 0, len(p.playQueue)-len(trackIDs))
+ newQueue := make([]mediaprovider.MediaItem, 0, len(p.playQueue)-len(trackIDs))
idSet := sharedutil.ToSet(trackIDs)
isPlayingTrackRemoved := false
isNextPlayingTrackremoved := false
nowPlaying := p.NowPlayingIndex()
newNowPlaying := nowPlaying
for i, tr := range p.playQueue {
- if _, ok := idSet[tr.ID]; ok {
+ if _, ok := idSet[tr.Metadata().ID]; ok {
if i < nowPlaying {
// if removing a track earlier than the currently playing one (if any),
// decrement new now playing index by one to account for new position in queue
@@ -395,8 +428,11 @@ func (p *playbackEngine) handleOnTrackChange() {
p.nowPlayingIdx = 0 // wrapped around
}
}
+ nowPlaying := p.playQueue[p.nowPlayingIdx]
+ _, isRadio := nowPlaying.(*mediaprovider.RadioStation)
+ p.isRadio = isRadio
p.wasStopped = false
- p.curTrackTime = float64(p.playQueue[p.nowPlayingIdx].Duration)
+ p.curTrackDuration = float64(nowPlaying.Metadata().Duration)
p.sendNowPlayingScrobble() // Must come before invokeOnChangeCallbacks b/c track may immediately be scrobbled
p.invokeOnSongChangeCallbacks()
p.doUpdateTimePos(false)
@@ -460,7 +496,12 @@ func (p *playbackEngine) setTrack(idx int, next bool) error {
url := ""
if idx >= 0 {
var err error
- url, err = p.sm.Server.GetStreamURL(p.playQueue[idx].ID, p.transcodeCfg.ForceRawFile)
+ item := p.playQueue[idx]
+ if tr, ok := item.(*mediaprovider.Track); ok {
+ url, err = p.sm.Server.GetStreamURL(tr.ID, p.transcodeCfg.ForceRawFile)
+ } else {
+ url = item.(*mediaprovider.RadioStation).StreamURL
+ }
if err != nil {
return err
}
@@ -472,7 +513,10 @@ func (p *playbackEngine) setTrack(idx int, next bool) error {
} else if trP, ok := p.player.(player.TrackPlayer); ok {
var track *mediaprovider.Track
if idx >= 0 {
- track = p.playQueue[idx]
+ track, ok = p.playQueue[idx].(*mediaprovider.Track)
+ if !ok {
+ return errors.New("cannot play non-Track media item with TrackPlayer")
+ }
}
if next {
return trP.SetNextTrack(track)
@@ -491,15 +535,19 @@ func (p *playbackEngine) checkScrobble() {
if !p.scrobbleCfg.Enabled || len(p.playQueue) == 0 || p.nowPlayingIdx < 0 {
return
}
+ track, ok := p.playQueue[p.nowPlayingIdx].(*mediaprovider.Track)
+ if !ok {
+ return // radio stations are not scrobbled
+ }
+
playDur := p.playTimeStopwatch.Elapsed()
- if playDur.Seconds() < 0.1 || p.curTrackTime < 0.1 {
+ if playDur.Seconds() < 0.1 || p.curTrackDuration < 0.1 {
return
}
- pcnt := playDur.Seconds() / p.curTrackTime * 100
+ pcnt := playDur.Seconds() / p.curTrackDuration * 100
timeThresholdMet := p.scrobbleCfg.ThresholdTimeSeconds >= 0 &&
playDur.Seconds() >= float64(p.scrobbleCfg.ThresholdTimeSeconds)
- track := p.playQueue[p.nowPlayingIdx]
var submission bool
server := p.sm.Server
if server.ClientDecidesScrobble() && (timeThresholdMet || pcnt >= float64(p.scrobbleCfg.ThresholdPercent)) {
@@ -516,7 +564,11 @@ func (p *playbackEngine) sendNowPlayingScrobble() {
if !p.scrobbleCfg.Enabled || len(p.playQueue) == 0 || p.nowPlayingIdx < 0 {
return
}
- track := p.playQueue[p.nowPlayingIdx]
+ track, ok := p.playQueue[p.nowPlayingIdx].(*mediaprovider.Track)
+ if !ok {
+ return // radio stations are not scrobbled
+ }
+
server := p.sm.Server
if !server.ClientDecidesScrobble() {
// server will count track as scrobbled as soon as it starts playing
@@ -528,11 +580,18 @@ func (p *playbackEngine) sendNowPlayingScrobble() {
// creates a deep copy of the track info so that we can maintain our own state
// (play count increases, favorite, and rating) without messing up other views' track models
-func (p *playbackEngine) deepCopyTrackSlice(tracks []*mediaprovider.Track) []*mediaprovider.Track {
- newTracks := make([]*mediaprovider.Track, len(tracks))
+func (p *playbackEngine) deepCopyMediaItemSlice(tracks []mediaprovider.MediaItem) []mediaprovider.MediaItem {
+ newTracks := make([]mediaprovider.MediaItem, len(tracks))
for i, tr := range tracks {
- copy := *tr
- newTracks[i] = ©
+ newTracks[i] = tr.Copy()
+ }
+ return newTracks
+}
+
+func (p *playbackEngine) copyTrackSliceToMediaItemSlice(tracks []*mediaprovider.Track) []mediaprovider.MediaItem {
+ newTracks := make([]mediaprovider.MediaItem, len(tracks))
+ for i, tr := range tracks {
+ newTracks[i] = tr.Copy()
}
return newTracks
}
@@ -589,7 +648,12 @@ func (p *playbackEngine) doUpdateTimePos(seeked bool) {
if s.TimePos > p.latestTrackPosition {
p.latestTrackPosition = s.TimePos
}
+ duration := s.Duration
+ if p.isRadio {
+ // MPV reports buffered duration - we don't want to show this
+ duration = 0
+ }
for _, cb := range p.onPlayTimeUpdate {
- cb(s.TimePos, s.Duration, seeked)
+ cb(s.TimePos, duration, seeked)
}
}
diff --git a/backend/playbackmanager.go b/backend/playbackmanager.go
index 2fdab18..9d06e67 100644
--- a/backend/playbackmanager.go
+++ b/backend/playbackmanager.go
@@ -45,8 +45,8 @@ func (p *PlaybackManager) DisableCallbacks() {
p.engine.callbacksDisabled = true
}
-// Gets the curently playing song, if any.
-func (p *PlaybackManager) NowPlaying() *mediaprovider.Track {
+// Gets the now playing media item, if any.
+func (p *PlaybackManager) NowPlaying() mediaprovider.MediaItem {
return p.engine.NowPlaying()
}
@@ -55,7 +55,7 @@ func (p *PlaybackManager) NowPlayingIndex() int {
}
// Sets a callback that is notified whenever a new song begins playing.
-func (p *PlaybackManager) OnSongChange(cb func(nowPlaying *mediaprovider.Track, justScrobbledIfAny *mediaprovider.Track)) {
+func (p *PlaybackManager) OnSongChange(cb func(nowPlaying mediaprovider.MediaItem, justScrobbledIfAny *mediaprovider.Track)) {
p.engine.onSongChange = append(p.engine.onSongChange, cb)
}
@@ -126,8 +126,8 @@ func (p *PlaybackManager) LoadTracks(tracks []*mediaprovider.Track, insertQueueM
// Replaces the play queue with the given set of tracks.
// Does not stop playback if the currently playing track is in the new queue,
// but updates the now playing index to point to the first instance of the track in the new queue.
-func (p *PlaybackManager) UpdatePlayQueue(tracks []*mediaprovider.Track) error {
- return p.engine.UpdatePlayQueue(tracks)
+func (p *PlaybackManager) UpdatePlayQueue(items []mediaprovider.MediaItem) error {
+ return p.engine.UpdatePlayQueue(items)
}
func (p *PlaybackManager) PlayAlbum(albumID string, firstTrack int, shuffle bool) error {
@@ -182,6 +182,10 @@ func (p *PlaybackManager) PlaySimilarSongs(id string) {
})
}
+func (p *PlaybackManager) LoadRadioStation(station *mediaprovider.RadioStation, queueMode InsertQueueMode) {
+ p.engine.LoadRadioStation(station, queueMode)
+}
+
func (p *PlaybackManager) fetchAndPlayTracks(fetchFn func() ([]*mediaprovider.Track, error)) {
if songs, err := fetchFn(); err != nil {
log.Printf("error fetching tracks: %s", err.Error())
@@ -194,7 +198,7 @@ func (p *PlaybackManager) fetchAndPlayTracks(fetchFn func() ([]*mediaprovider.Tr
}
}
-func (p *PlaybackManager) GetPlayQueue() []*mediaprovider.Track {
+func (p *PlaybackManager) GetPlayQueue() []mediaprovider.MediaItem {
return p.engine.GetPlayQueue()
}
@@ -281,7 +285,7 @@ func (p *PlaybackManager) SeekFraction(fraction float64) error {
} else if fraction > 1 {
fraction = 1
}
- target := p.engine.curTrackTime * fraction
+ target := p.engine.curTrackDuration * fraction
return p.engine.SeekSeconds(target)
}
diff --git a/backend/savedplayqueue.go b/backend/savedplayqueue.go
index a0baf41..fd6e025 100644
--- a/backend/savedplayqueue.go
+++ b/backend/savedplayqueue.go
@@ -29,9 +29,19 @@ func SavePlayQueue(serverID string, pm *PlaybackManager, filepath string, server
stats := pm.PlayerStatus()
trackIdx := pm.NowPlayingIndex()
- trackIDs := make([]string, len(queue))
- for i, tr := range queue {
- trackIDs[i] = tr.ID
+ trackIDs := make([]string, 0, len(queue))
+ for _, item := range queue {
+ if _, ok := item.(*mediaprovider.Track); ok {
+ // don't save radio stations in play queue
+ trackIDs = append(trackIDs, item.Metadata().ID)
+ }
+ }
+ if l := len(trackIDs); trackIdx >= l {
+ if l == 0 {
+ trackIdx = 0
+ } else {
+ trackIdx = l - 1
+ }
}
saved := serializedSavedPlayQueue{
diff --git a/res/bundled.go b/res/bundled.go
index d284ce7..3e1b5d0 100644
--- a/res/bundled.go
+++ b/res/bundled.go
@@ -88,7 +88,7 @@ var ResFilterSvg = &fyne.StaticResource{
var ResBroadcastSvg = &fyne.StaticResource{
StaticName: "broadcast.svg",
StaticContent: []byte(
- "\n"),
+ "\n"),
}
var ResRepeatSvg = &fyne.StaticResource{
StaticName: "repeat.svg",
diff --git a/res/icons/remix_design/broadcast.svg b/res/icons/remix_design/broadcast.svg
index ff53661..ab4b918 100644
--- a/res/icons/remix_design/broadcast.svg
+++ b/res/icons/remix_design/broadcast.svg
@@ -1,4 +1,4 @@
-