Merge pull request #149 from alexballas/devel

v2.3.0

Author: alexballas

README.md

@@ -72,6 +72,21 @@ When transcoding is enabled, Go2TV probes available GPU H.264 encoders first and
 
 ---
 
+## Playlist (GUI)
+
+Go2TV GUI keeps the current selection in a **Playlist**, even for a single file.
+
+- Selecting or dropping a single local file creates a 1-item playlist
+- Selecting or dropping multiple files creates a multi-item playlist
+- The **Playlist** window lets you add, remove, reorder, and select items
+- Drag and drop on the main window replaces the current playlist
+- Drag and drop on the Playlist window appends files when a playlist already exists
+- **Next**, **Previous**, and **Auto-Play Next File** follow the playlist order
+- **Auto-Play Next File** wraps to the start of the playlist when it reaches the end
+- **Same File Types Only** is still respected for auto-play traversal
+
+---
+
 ## RTMP Streaming (Chromecast only)
 
 Go2TV can act as an RTMP server, allowing you to stream from OBS or other software directly to your Chromecast. **This feature requires FFmpeg.**
@@ -158,7 +173,8 @@ yt-dlp -o - "https://youtu.be/..." | go2tv -tc -t http://192.168.1.50:8009
 - **Transcoding** - Converts incompatible video formats on-the-fly (requires FFmpeg)
 - **Subtitles** - Supports external SRT/VTT files and embedded MKV subtitles
 - **Seek support** - Jump to any position in the video
-- **Loop and auto-play** - Loop a single file or auto-play the next file in folder
+- **Playlist playback** - Single-file and multi-file playlists with add/remove/reorder/select support
+- **Loop and auto-play** - Loop the current file or auto-play through the playlist
 - **Gapless playback** - Supported for DLNA devices
 - **RTMP Server** - Cast live streams from OBS directly to Chromecast (requires FFmpeg)
 - **Cast Desktop (experimental)** - Cast desktop as live stream to Chromecast (requires FFmpeg)
@@ -190,18 +206,13 @@ If you want tool-driven casting from MCP-compatible workflows, use mcp-beam.
 
 ## Notes
 
-**Firewall Configuration**
-
-Go2TV uses ports 3339-3438 for device discovery. If you're behind a firewall, allow inbound UDP traffic on these ports.
+**Chromecast receiver**
 
-**macOS Security**
+Go2TV uses a custom Chromecast receiver hosted at https://cast-receiver.go2tv.app/. It is not part of this open-source repository and is not currently published. Functionality matches the default receiver, with minor branding differences.
 
-If you see "cannot be opened because the developer cannot be verified":
-1. Control-click the app, then choose Open from the menu
-2. Click Open
+**Firewall Configuration**
 
-If you see "go2tv is damaged and can't be opened":
-- Run: `xattr -cr /path/to/go2tv.app`
+Go2TV uses ports 3339-3438 for device discovery. If you're behind a firewall, allow inbound UDP traffic on these ports.
 
 ---
 

assets/linux/app.go2tv.go2tv.appdata.xml

@@ -51,6 +51,18 @@
   </branding>
 
   <releases>
+      <release version="2.3.0" date="2026-04-21" type="stable">
+        <description>
+          <ul>
+            <li>Added resume playback support to continue media from the last saved position.</li>
+            <li>Added a media queue to organize and play files in sequence.</li>
+            <li>Polished the GUI with device badges, layout tuning, and small mobile cleanups.</li>
+            <li>Added better exportable diagnostics and crash reports.</li>
+            <li>Improved device discovery.</li>
+          </ul>
+        </description>
+        <url type="details">https://github.com/alexballas/go2tv/releases/tag/v2.3.0</url>
+      </release>
       <release version="2.2.0" date="2026-03-14" type="stable">
         <description>
           <ul>

castprotocol/client.go

@@ -7,6 +7,9 @@ import (
 	"io"
 	"net"
 	"net/url"
+	"path"
+	"path/filepath"
+	"strings"
 	"sync"
 	"time"
 
@@ -109,13 +112,122 @@ func isTimeoutError(err error) bool {
 	return false
 }
 
+func (c *CastClient) defaultReceiverReady() bool {
+	app := c.app.App()
+	return app != nil && app.AppId == cast.DefaultMediaReceiverAppID && app.TransportId != ""
+}
+
+func normalizeMediaTitle(title string, mediaURL string) string {
+	if normalized := deriveMediaTitle(title); normalized != "" {
+		return normalized
+	}
+	return deriveMediaTitle(mediaURL)
+}
+
+func deriveMediaTitle(value string) string {
+	value = strings.TrimSpace(value)
+	if value == "" {
+		return ""
+	}
+
+	if u, err := url.Parse(value); err == nil && u.Scheme != "" {
+		if base := path.Base(u.Path); base != "" && base != "." && base != "/" {
+			return base
+		}
+		if host := strings.TrimSpace(u.Host); host != "" {
+			return host
+		}
+	}
+
+	if base := filepath.Base(value); base != "" && base != "." && base != string(filepath.Separator) {
+		return base
+	}
+
+	return value
+}
+
+// Ensure the Default Media Receiver is running before custom media commands.
+func (c *CastClient) ensureDefaultReceiverReady() error {
+	if c.defaultReceiverReady() {
+		return nil
+	}
+
+	if err := c.app.Update(); err == nil && c.defaultReceiverReady() {
+		return nil
+	}
+
+	var lastErr error
+	for attempt := range 5 {
+		if !c.IsConnected() {
+			c.Log().Debug().Str("Method", "ensureDefaultReceiverReady").Msg("connection closed during receiver launch, aborting silently")
+			return nil
+		}
+
+		c.Log().Debug().Str("Method", "ensureDefaultReceiverReady").Int("Attempt", attempt+1).Msg("launching default receiver")
+		if err := LaunchDefaultReceiver(c.conn); err != nil {
+			lastErr = err
+			if isTimeoutError(err) && attempt < 4 {
+				c.Log().Debug().Str("Method", "ensureDefaultReceiverReady").Int("Attempt", attempt+1).Err(err).Msg("timeout, TV may be waking up, retrying...")
+				if !c.IsConnected() {
+					c.Log().Debug().Str("Method", "ensureDefaultReceiverReady").Msg("connection closed during retry wait, aborting silently")
+					return nil
+				}
+				time.Sleep(4 * time.Second)
+				continue
+			}
+			c.Log().Error().Str("Method", "ensureDefaultReceiverReady").Err(err).Msg("launch receiver failed")
+			return fmt.Errorf("launch receiver: %w", err)
+		}
+
+		for i := range 8 {
+			if !c.IsConnected() {
+				c.Log().Debug().Str("Method", "ensureDefaultReceiverReady").Msg("connection closed during app update, aborting silently")
+				return nil
+			}
+
+			if err := c.app.Update(); err != nil {
+				lastErr = err
+				c.Log().Debug().Str("Method", "ensureDefaultReceiverReady").Int("Attempt", i+1).Err(err).Msg("app.Update retry")
+				time.Sleep(time.Duration(i+1) * 500 * time.Millisecond)
+				continue
+			}
+
+			if c.defaultReceiverReady() {
+				c.Log().Debug().Str("Method", "ensureDefaultReceiverReady").Str("TransportId", c.app.App().TransportId).Msg("default receiver ready")
+				return nil
+			}
+
+			lastErr = fmt.Errorf("failed to get default receiver transport ID after retries")
+			time.Sleep(time.Duration(i+1) * 500 * time.Millisecond)
+		}
+
+		if attempt < 4 {
+			c.Log().Debug().Str("Method", "ensureDefaultReceiverReady").Int("Attempt", attempt+1).Msg("receiver not ready, retrying...")
+			if !c.IsConnected() {
+				c.Log().Debug().Str("Method", "ensureDefaultReceiverReady").Msg("connection closed during retry wait, aborting silently")
+				return nil
+			}
+			time.Sleep(4 * time.Second)
+			continue
+		}
+	}
+
+	if lastErr == nil {
+		lastErr = fmt.Errorf("failed to get default receiver transport ID after retries")
+	}
+
+	c.Log().Error().Str("Method", "ensureDefaultReceiverReady").Err(lastErr).Msg("failed to launch default receiver")
+	return lastErr
+}
+
 // Load loads media from URL onto the Chromecast.
 // startTime is the position in seconds to start playback from.
 // duration is the total media duration in seconds (0 to let Chromecast detect).
 // If subtitleURL is provided, uses custom load command with subtitle tracks.
 // If live is true, uses StreamType "LIVE" to identify as live stream.
-func (c *CastClient) Load(mediaURL string, contentType string, startTime int, duration float64, subtitleURL string, live bool) error {
-	c.Log().Debug().Str("Method", "Load").Str("URL", mediaURL).Str("ContentType", contentType).Int("StartTime", startTime).Float64("Duration", duration).Bool("HasSubs", subtitleURL != "").Bool("Live", live).Msg("loading media")
+func (c *CastClient) Load(mediaURL string, contentType string, title string, startTime int, duration float64, subtitleURL string, live bool) error {
+	mediaTitle := normalizeMediaTitle(title, mediaURL)
+	c.Log().Debug().Str("Method", "Load").Str("URL", mediaURL).Str("ContentType", contentType).Str("Title", mediaTitle).Int("StartTime", startTime).Float64("Duration", duration).Bool("HasSubs", subtitleURL != "").Bool("Live", live).Msg("loading media")
 
 	// Check if connection is still active, reconnect if needed
 	// This handles cases where Close() was called but the client is being reused
@@ -126,10 +238,10 @@ func (c *CastClient) Load(mediaURL string, contentType string, startTime int, du
 		}
 	}
 
-	// If no subtitles, no custom duration, and NOT a live stream: use standard app.Load()
+	// If no subtitles, no custom duration, no title, and NOT a live stream: use standard app.Load()
 	// For live streams, we MUST use custom LoadWithSubtitles to set StreamType "LIVE"
 	// (go-chromecast library hardcodes StreamType "BUFFERED" so we need custom path for LIVE)
-	if subtitleURL == "" && duration == 0 && !live {
+	if subtitleURL == "" && duration == 0 && mediaTitle == "" && !live {
 		// Retry loop for TV wake-up scenarios (timeout errors)
 		var lastErr error
 		for attempt := range 5 {
@@ -160,70 +272,42 @@ func (c *CastClient) Load(mediaURL string, contentType string, startTime int, du
 	// With subtitles or custom duration: launch the app first WITHOUT loading media, then send custom load
 	// This prevents double playback (first without subs, then with subs queued)
 	// Retry loop for TV wake-up scenarios
+	if err := c.ensureDefaultReceiverReady(); err != nil {
+		return err
+	}
+
 	var lastErr error
 	for attempt := range 5 {
 		if !c.IsConnected() {
 			c.Log().Debug().Str("Method", "Load").Msg("connection closed during load, aborting silently")
 			return nil
 		}
 
-		c.Log().Debug().Str("Method", "Load").Int("Attempt", attempt).Msg("launching default receiver")
-		if err := LaunchDefaultReceiver(c.conn); err != nil {
-			lastErr = err
-			if isTimeoutError(err) && attempt < 5 {
-				c.Log().Debug().Str("Method", "Load").Int("Attempt", attempt).Err(err).Msg("timeout, TV may be waking up, retrying...")
-				if !c.IsConnected() {
-					c.Log().Debug().Str("Method", "Load").Msg("connection closed during retry wait, aborting silently")
-					return nil
-				}
-				time.Sleep(4 * time.Second)
-				continue
-			}
-			c.Log().Error().Str("Method", "Load").Err(err).Msg("launch receiver failed")
-			return fmt.Errorf("launch receiver: %w", err)
-		}
-
-		// Retry getting app state with backoff (handles "media receiver app not available")
-		var transportId string
-		for i := range 8 {
-			if !c.IsConnected() {
-				c.Log().Debug().Str("Method", "Load").Msg("connection closed during app update, aborting silently")
-				return nil
-			}
-
-			if err := c.app.Update(); err != nil {
-				c.Log().Debug().Str("Method", "Load").Int("Attempt", i+1).Err(err).Msg("app.Update retry")
-				time.Sleep(time.Duration(i+1) * 500 * time.Millisecond)
-				continue
-			}
-			app := c.app.App()
-			if app != nil && app.TransportId != "" {
-				transportId = app.TransportId
-				c.Log().Debug().Str("Method", "Load").Str("TransportId", transportId).Msg("got transport ID")
-				break
-			}
-			time.Sleep(time.Duration(i+1) * 500 * time.Millisecond)
+		app := c.app.App()
+		transportId := ""
+		if app != nil {
+			transportId = app.TransportId
 		}
 
 		if transportId == "" {
-			lastErr = fmt.Errorf("failed to get transport ID after retries")
-			if attempt < 5 {
-				c.Log().Debug().Str("Method", "Load").Int("Attempt", attempt).Msg("no transport ID, TV may be waking up, retrying...")
+			lastErr = fmt.Errorf("failed to get transport ID after receiver launch")
+			if attempt < 4 {
+				c.Log().Debug().Str("Method", "Load").Int("Attempt", attempt+1).Msg("no transport ID, retrying...")
 				if !c.IsConnected() {
 					c.Log().Debug().Str("Method", "Load").Msg("connection closed during retry wait, aborting silently")
 					return nil
 				}
 				time.Sleep(4 * time.Second)
 				continue
 			}
-			c.Log().Error().Str("Method", "Load").Msg("failed to get transport ID")
+			c.Log().Error().Str("Method", "Load").Err(lastErr).Msg("failed to get transport ID")
 			return lastErr
 		}
 
 		// For live streams: load PAUSED then immediately send PLAY command
 		// This simulates a "fast click" which avoids the 20-30s buffer that autoplay=true triggers
 		autoplay := !live // Only autoplay if NOT a live stream
-		err := LoadWithSubtitles(c.conn, transportId, mediaURL, contentType, startTime, duration, subtitleURL, live, autoplay)
+		err := LoadWithSubtitles(c.conn, transportId, mediaURL, contentType, startTime, duration, subtitleURL, mediaTitle, live, autoplay)
 		if err != nil {
 			lastErr = err
 			if isTimeoutError(err) && attempt < 5 {
@@ -278,8 +362,9 @@ func (c *CastClient) Load(mediaURL string, contentType string, startTime int, du
 // Unlike Load, this skips launching the receiver.
 // Use this when the receiver is already playing media and you want to load new content.
 // If live is true, uses StreamType "LIVE" to identify as live stream.
-func (c *CastClient) LoadOnExisting(mediaURL string, contentType string, startTime int, duration float64, subtitleURL string, live bool) error {
-	c.Log().Debug().Str("Method", "LoadOnExisting").Str("URL", mediaURL).Str("ContentType", contentType).Int("StartTime", startTime).Float64("Duration", duration).Bool("HasSubs", subtitleURL != "").Bool("Live", live).Msg("loading media on existing receiver")
+func (c *CastClient) LoadOnExisting(mediaURL string, contentType string, title string, startTime int, duration float64, subtitleURL string, live bool) error {
+	mediaTitle := normalizeMediaTitle(title, mediaURL)
+	c.Log().Debug().Str("Method", "LoadOnExisting").Str("URL", mediaURL).Str("ContentType", contentType).Str("Title", mediaTitle).Int("StartTime", startTime).Float64("Duration", duration).Bool("HasSubs", subtitleURL != "").Bool("Live", live).Msg("loading media on existing receiver")
 
 	// LoadOnExisting requires an active connection (it's designed for already-running receivers)
 	// Unlike Load(), we don't auto-reconnect because that would defeat the optimization purpose
@@ -310,7 +395,7 @@ func (c *CastClient) LoadOnExisting(mediaURL string, contentType string, startTi
 	}
 
 	// For LoadOnExisting, always autoplay since it's for seek operations on active content
-	err := LoadWithSubtitles(c.conn, transportId, mediaURL, contentType, startTime, duration, subtitleURL, live, true)
+	err := LoadWithSubtitles(c.conn, transportId, mediaURL, contentType, startTime, duration, subtitleURL, mediaTitle, live, true)
 	if err != nil {
 		c.Log().Error().Str("Method", "LoadOnExisting").Err(err).Msg("failed")
 	} else {

castprotocol/loader.go

@@ -1,7 +1,6 @@
 package castprotocol
 
 import (
-	"encoding/json"
 	"fmt"
 	"sync/atomic"
 
@@ -48,9 +47,10 @@ func (p *CustomLoadPayload) SetRequestId(id int) {
 // startTime: start position in seconds
 // duration: total media duration in seconds (0 to let Chromecast detect)
 // subtitleURL: URL of the WebVTT subtitle file (or empty for no subtitles)
+// title: media title shown by the receiver UI
 // live: if true, sets StreamType to "LIVE" to identify as live stream (DMR will show LIVE badge)
 // autoplay: if true, starts playback immediately; if false, waits for PLAY command
-func LoadWithSubtitles(conn cast.Conn, transportId string, mediaURL string, contentType string, startTime int, duration float64, subtitleURL string, live bool, autoplay bool) error {
+func LoadWithSubtitles(conn cast.Conn, transportId string, mediaURL string, contentType string, startTime int, duration float64, subtitleURL string, title string, live bool, autoplay bool) error {
 	streamType := "BUFFERED"
 	if live {
 		streamType = "LIVE"
@@ -66,6 +66,12 @@ func LoadWithSubtitles(conn cast.Conn, transportId string, mediaURL string, cont
 	if duration > 0 {
 		media.Duration = float32(duration)
 	}
+	if title != "" {
+		media.Metadata = &MediaMeta{
+			MetadataType: 0,
+			Title:        title,
+		}
+	}
 
 	var activeTrackIds []int
 
@@ -127,15 +133,12 @@ func (p *LaunchRequest) SetRequestId(id int) {
 	p.RequestId = id
 }
 
-// DefaultMediaReceiverAppID is the app ID for the Default Media Receiver
-const DefaultMediaReceiverAppID = "CC1AD845"
-
 // LaunchDefaultReceiver launches the Default Media Receiver app without loading media.
 // This allows sending a LoadWithSubtitles command afterwards.
 func LaunchDefaultReceiver(conn cast.Conn) error {
 	payload := &LaunchRequest{
 		Type:  "LAUNCH",
-		AppId: DefaultMediaReceiverAppID,
+		AppId: cast.DefaultMediaReceiverAppID,
 	}
 
 	requestID := nextRequestID()
@@ -152,13 +155,3 @@ func LaunchDefaultReceiver(conn cast.Conn) error {
 
 // CastNamespaceReceiver is the namespace for receiver control messages
 const CastNamespaceReceiver = "urn:x-cast:com.google.cast.receiver"
-
-// MarshalJSON for custom JSON output
-func (m *MediaItemWithTracks) MarshalJSON() ([]byte, error) {
-	type Alias MediaItemWithTracks
-	return json.Marshal(&struct {
-		*Alias
-	}{
-		Alias: (*Alias)(m),
-	})
-}