check library scan state for supported clients

Author: LumePart

src/client/client.go

@@ -24,6 +24,7 @@ type APIClient interface {
 	AddLibrary() error
 	SearchSongs([]*models.Track) error
 	RefreshLibrary() error
+	CheckRefreshState() bool
 	CreatePlaylist([]*models.Track) error
 	SearchPlaylist() error
 	UpdatePlaylist() error
@@ -142,9 +143,11 @@ func (c *Client) CreatePlaylist(tracks []*models.Track) error {
 	if err := c.API.RefreshLibrary(); err != nil {
 		return fmt.Errorf("[%s] failed to schedule a library scan: %s", c.System, err.Error())
 	}
-
 	slog.Info("Refreshing library...", "system", c.System)
-	time.Sleep(time.Duration(c.Cfg.Sleep) * time.Minute)
+	if !c.API.CheckRefreshState() {
+		time.Sleep(time.Duration(c.Cfg.Sleep) * time.Minute)
+	}
+
 	if err := c.API.SearchSongs(tracks); err != nil { // search newly added songs
 		slog.Warn("SearchSongs failed", "context", err)
 	}

src/client/emby.go

@@ -120,6 +120,10 @@ func (c *Emby) RefreshLibrary() error {
 	return nil
 }
 
+func (c *Emby) CheckRefreshState() bool {
+	return false
+}
+
 func (c *Emby) SearchSongs(tracks []*models.Track) error {
 	for _, track := range tracks {
 		reqParam := fmt.Sprintf("/emby/Items?IncludeMediaTypes=Audio&SearchTerm=%s&Recursive=true&Fields=Path", url.QueryEscape(track.CleanTitle))

src/client/jellyfin.go

@@ -130,6 +130,10 @@ func (c *Jellyfin) RefreshLibrary() error {
 	return nil
 }
 
+func (c *Jellyfin) CheckRefreshState() bool {
+	return false
+}
+
 func (c *Jellyfin) SearchSongs(tracks []*models.Track) error {
 	for _, track := range tracks {
 		reqParam := fmt.Sprintf("/Items?IncludeMediaTypes=Audio&SearchTerm=%s&Recursive=true&Fields=Path", url.QueryEscape(track.CleanTitle))

src/client/mpd.go

@@ -59,6 +59,10 @@ func (c *MPD) RefreshLibrary() error {
 	return nil
 }
 
+func (c *MPD) CheckRefreshState() bool {
+	return true
+}
+
 func (c *MPD) CreatePlaylist(tracks []*models.Track) error {
 	f, err := os.OpenFile(c.Cfg.PlaylistDir+c.Cfg.PlaylistName+".m3u", os.O_APPEND|os.O_WRONLY|os.O_CREATE, 0666)
 	if err != nil {

src/client/plex.go

@@ -223,6 +223,10 @@ func (c *Plex) RefreshLibrary() error {
 	return nil
 }
 
+func (c *Plex) CheckRefreshState() bool {
+	return false
+}
+
 func (c *Plex) SearchSongs(tracks []*models.Track) error {
 	for _, track := range tracks {
 		params := fmt.Sprintf("/library/search?query=%s", url.QueryEscape(track.CleanTitle))

src/client/subsonic.go

@@ -180,6 +180,10 @@ func (c *Subsonic) startScan() error {
 	return nil
 }
 
+func (c *Subsonic) CheckRefreshState() bool {
+	return false
+}
+
 func (c *Subsonic) CreatePlaylist(tracks []*models.Track) error {
 	var trackIDs strings.Builder
 	for _, track := range tracks { // build songID parameters