SpotiFLAC-Mobile/go_backend/youtube.go

package gobackend

import (
	"bufio"
	"context"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"net/url"
	"strconv"
	"strings"
	"sync"
)

type YouTubeDownloader struct {
	client *http.Client
	apiURL string
	mu     sync.Mutex
}

const spotubeBaseURL = "https://spotubedl.com"

var (
	globalYouTubeDownloader *YouTubeDownloader
	youtubeDownloaderOnce   sync.Once
)

type YouTubeQuality string

const (
	YouTubeQualityOpus320 YouTubeQuality = "opus_320"
	YouTubeQualityOpus256 YouTubeQuality = "opus_256"
	YouTubeQualityOpus128 YouTubeQuality = "opus_128"
	YouTubeQualityMP3128  YouTubeQuality = "mp3_128"
	YouTubeQualityMP3256  YouTubeQuality = "mp3_256"
	YouTubeQualityMP3320  YouTubeQuality = "mp3_320"
)

var (
	youtubeOpusSupportedBitrates = []int{128, 256, 320}
	youtubeMp3SupportedBitrates  = []int{128, 256, 320}
)

type CobaltRequest struct {
	URL             string `json:"url"`
	AudioBitrate    string `json:"audioBitrate,omitempty"`
	AudioFormat     string `json:"audioFormat,omitempty"`
	DownloadMode    string `json:"downloadMode,omitempty"`
	FilenameStyle   string `json:"filenameStyle,omitempty"`
	DisableMetadata bool   `json:"disableMetadata,omitempty"`
}

type CobaltResponse struct {
	Status   string `json:"status"`
	URL      string `json:"url,omitempty"`
	Filename string `json:"filename,omitempty"`
	Error    *struct {
		Code    string `json:"code"`
		Context *struct {
			Service string `json:"service,omitempty"`
			Limit   int    `json:"limit,omitempty"`
		} `json:"context,omitempty"`
	} `json:"error,omitempty"`
}

type YouTubeDownloadResult struct {
	FilePath    string
	Title       string
	Artist      string
	Album       string
	ReleaseDate string
	TrackNumber int
	DiscNumber  int
	ISRC        string
	Format      string // "opus" or "mp3"
	Bitrate     int
	LyricsLRC   string
	CoverData   []byte
}

func NewYouTubeDownloader() *YouTubeDownloader {
	youtubeDownloaderOnce.Do(func() {
		globalYouTubeDownloader = &YouTubeDownloader{
			client: NewHTTPClientWithTimeout(DownloadTimeout),
			apiURL: "https://api.qwkuns.me",
		}
	})
	return globalYouTubeDownloader
}

func extractBitrateFromQuality(raw string, defaultBitrate int) int {
	parts := strings.FieldsFunc(raw, func(r rune) bool {
		return (r < '0' || r > '9')
	})
	for i := len(parts) - 1; i >= 0; i-- {
		part := parts[i]
		if part == "" {
			continue
		}
		if parsed, err := strconv.Atoi(part); err == nil {
			return parsed
		}
	}
	return defaultBitrate
}

func nearestSupportedBitrate(value int, supported []int) int {
	nearest := supported[0]
	nearestDistance := absInt(value - nearest)

	for _, option := range supported[1:] {
		distance := absInt(value - option)
		// On tie prefer higher quality.
		if distance < nearestDistance || (distance == nearestDistance && option > nearest) {
			nearest = option
			nearestDistance = distance
		}
	}

	return nearest
}

func absInt(value int) int {
	if value < 0 {
		return -value
	}
	return value
}

func parseYouTubeQualityInput(raw string) (format string, bitrate int, normalized YouTubeQuality) {
	normalizedRaw := strings.ToLower(strings.TrimSpace(raw))

	if strings.HasPrefix(normalizedRaw, "opus") {
		parsed := extractBitrateFromQuality(normalizedRaw, 256)
		finalBitrate := nearestSupportedBitrate(parsed, youtubeOpusSupportedBitrates)
		return "opus", finalBitrate, YouTubeQuality(fmt.Sprintf("opus_%d", finalBitrate))
	}

	if strings.HasPrefix(normalizedRaw, "mp3") {
		parsed := extractBitrateFromQuality(normalizedRaw, 320)
		finalBitrate := nearestSupportedBitrate(parsed, youtubeMp3SupportedBitrates)
		return "mp3", finalBitrate, YouTubeQuality(fmt.Sprintf("mp3_%d", finalBitrate))
	}

	// Backward compatibility for legacy symbolic values.
	switch normalizedRaw {
	case "opus_256", "opus256", "opus":
		return "opus", 256, YouTubeQualityOpus256
	case "opus_320", "opus320":
		return "opus", 320, YouTubeQualityOpus320
	case "opus_128", "opus128":
		return "opus", 128, YouTubeQualityOpus128
	case "mp3_320", "mp3320", "mp3", "":
		return "mp3", 320, YouTubeQualityMP3320
	case "mp3_256", "mp3256":
		return "mp3", 256, YouTubeQualityMP3256
	case "mp3_128", "mp3128":
		return "mp3", 128, YouTubeQualityMP3128
	default:
		return "mp3", 320, YouTubeQualityMP3320
	}
}

func (y *YouTubeDownloader) SearchYouTube(trackName, artistName string) (string, error) {
	query := fmt.Sprintf("%s %s", artistName, trackName)
	searchQuery := url.QueryEscape(query)

	GoLog("[YouTube] Search query: %s\n", query)

	youtubeMusicURL := fmt.Sprintf("https://music.youtube.com/search?q=%s", searchQuery)

	return youtubeMusicURL, nil
}

func (y *YouTubeDownloader) GetDownloadURL(youtubeURL string, quality YouTubeQuality) (*CobaltResponse, error) {
	y.mu.Lock()
	defer y.mu.Unlock()

	audioFormat, bitrate, _ := parseYouTubeQualityInput(string(quality))
	audioBitrate := strconv.Itoa(bitrate)

	// Try SpotubeDL first (primary)
	var spotubeErr error
	videoID, extractErr := ExtractYouTubeVideoID(youtubeURL)
	if extractErr == nil {
		GoLog("[YouTube] Requesting from SpotubeDL: videoID=%s (format: %s, bitrate: %s)\n",
			videoID, audioFormat, audioBitrate)

		resp, err := y.requestSpotubeDL(videoID, audioFormat, audioBitrate)
		if err == nil {
			return resp, nil
		}
		spotubeErr = err
		GoLog("[YouTube] SpotubeDL failed: %v, trying Cobalt fallback...\n", err)
	} else {
		GoLog("[YouTube] Could not extract video ID: %v, skipping SpotubeDL\n", extractErr)
	}

	// Fallback: direct Cobalt API (api.qwkuns.me)
	cobaltURL := toYouTubeMusicURL(youtubeURL)
	GoLog("[YouTube] Requesting from Cobalt API: %s (format: %s, bitrate: %s)\n",
		cobaltURL, audioFormat, audioBitrate)

	resp, err := y.requestCobaltDirect(cobaltURL, audioFormat, audioBitrate)
	if err != nil {
		if spotubeErr != nil {
			return nil, fmt.Errorf("all download methods failed: spotubedl: %v, cobalt: %v", spotubeErr, err)
		}
		return nil, fmt.Errorf("all download methods failed: spotubedl: extractErr=%v, cobalt: %v", extractErr, err)
	}

	return resp, nil
}

func (y *YouTubeDownloader) requestCobaltDirect(videoURL, audioFormat, audioBitrate string) (*CobaltResponse, error) {
	reqBody := CobaltRequest{
		URL:             videoURL,
		AudioFormat:     audioFormat,
		AudioBitrate:    audioBitrate,
		DownloadMode:    "audio",
		FilenameStyle:   "basic",
		DisableMetadata: true,
	}

	jsonData, err := json.Marshal(reqBody)
	if err != nil {
		return nil, fmt.Errorf("failed to marshal request: %w", err)
	}

	req, err := http.NewRequest("POST", y.apiURL, strings.NewReader(string(jsonData)))
	if err != nil {
		return nil, fmt.Errorf("failed to create request: %w", err)
	}

	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("Accept", "application/json")

	resp, err := DoRequestWithUserAgent(y.client, req)
	if err != nil {
		return nil, fmt.Errorf("cobalt API request failed: %w", err)
	}
	defer resp.Body.Close()

	body, err := io.ReadAll(resp.Body)
	if err != nil {
		return nil, fmt.Errorf("failed to read response: %w", err)
	}

	GoLog("[YouTube] Cobalt API response status: %d\n", resp.StatusCode)

	if resp.StatusCode != 200 {
		return nil, fmt.Errorf("cobalt API returned status %d: %s", resp.StatusCode, string(body))
	}

	var cobaltResp CobaltResponse
	if err := json.Unmarshal(body, &cobaltResp); err != nil {
		return nil, fmt.Errorf("failed to parse response: %w", err)
	}

	if cobaltResp.Status == "error" && cobaltResp.Error != nil {
		return nil, fmt.Errorf("cobalt error: %s", cobaltResp.Error.Code)
	}

	if cobaltResp.Status != "tunnel" && cobaltResp.Status != "redirect" {
		return nil, fmt.Errorf("unexpected cobalt status: %s", cobaltResp.Status)
	}

	if cobaltResp.URL == "" {
		return nil, fmt.Errorf("no download URL in response")
	}

	GoLog("[YouTube] Got download URL from Cobalt (status: %s)\n", cobaltResp.Status)
	return &cobaltResp, nil
}

// requestSpotubeDL uses SpotubeDL as a Cobalt proxy (they handle auth to yt-dl.click instances).
// Engines v3/v2 are MP3-oriented outputs, so we only use them for MP3 requests.
func (y *YouTubeDownloader) requestSpotubeDL(videoID, audioFormat, audioBitrate string) (*CobaltResponse, error) {
	engines := []string{"v1"}
	if strings.EqualFold(audioFormat, "mp3") {
		engines = append(engines, "v3", "v2")
	}
	var lastErr error

	for _, engine := range engines {
		resp, err := y.requestSpotubeDLEngine(videoID, audioFormat, audioBitrate, engine)
		if err == nil {
			return resp, nil
		}
		lastErr = err
		GoLog("[YouTube] SpotubeDL (%s) failed: %v\n", engine, err)
	}

	if lastErr == nil {
		lastErr = fmt.Errorf("no SpotubeDL engine available")
	}
	return nil, lastErr
}

func (y *YouTubeDownloader) requestSpotubeDLEngine(videoID, audioFormat, audioBitrate, engine string) (*CobaltResponse, error) {
	apiURL := fmt.Sprintf("%s/api/download/%s?engine=%s&format=%s&quality=%s",
		spotubeBaseURL, videoID, url.QueryEscape(engine), url.QueryEscape(audioFormat), url.QueryEscape(audioBitrate))

	GoLog("[YouTube] Requesting from SpotubeDL (%s): %s\n", engine, apiURL)

	req, err := http.NewRequest("GET", apiURL, nil)
	if err != nil {
		return nil, fmt.Errorf("failed to create request: %w", err)
	}

	req.Header.Set("Accept", "application/json")

	resp, err := DoRequestWithUserAgent(y.client, req)
	if err != nil {
		return nil, fmt.Errorf("spotubedl request failed: %w", err)
	}
	defer resp.Body.Close()

	body, err := io.ReadAll(resp.Body)
	if err != nil {
		return nil, fmt.Errorf("failed to read response: %w", err)
	}

	GoLog("[YouTube] SpotubeDL (%s) response status: %d\n", engine, resp.StatusCode)

	if resp.StatusCode != 200 {
		return nil, fmt.Errorf("spotubedl(%s) returned status %d: %s", engine, resp.StatusCode, string(body))
	}

	var result struct {
		URL      string `json:"url"`
		Status   string `json:"status"`
		Error    string `json:"error"`
		Message  string `json:"message"`
		Filename string `json:"filename"`
	}
	if err := json.Unmarshal(body, &result); err != nil {
		return nil, fmt.Errorf("failed to parse spotubedl response: %w", err)
	}

	downloadURL := strings.TrimSpace(result.URL)
	if downloadURL == "" {
		if result.Error != "" {
			return nil, fmt.Errorf("spotubedl(%s) error: %s", engine, result.Error)
		}
		if result.Message != "" {
			return nil, fmt.Errorf("spotubedl(%s) message: %s", engine, result.Message)
		}
		return nil, fmt.Errorf("no download URL from spotubedl(%s)", engine)
	}

	if strings.HasPrefix(downloadURL, "/") {
		downloadURL = spotubeBaseURL + downloadURL
	}

	if !strings.HasPrefix(downloadURL, "http://") && !strings.HasPrefix(downloadURL, "https://") {
		return nil, fmt.Errorf("invalid download URL from spotubedl(%s): %s", engine, downloadURL)
	}

	filename := strings.TrimSpace(result.Filename)
	if filename == "" {
		if parsedURL, parseErr := url.Parse(downloadURL); parseErr == nil {
			if queryFilename := strings.TrimSpace(parsedURL.Query().Get("filename")); queryFilename != "" {
				if decodedFilename, decodeErr := url.QueryUnescape(queryFilename); decodeErr == nil {
					filename = decodedFilename
				} else {
					filename = queryFilename
				}
			}
		}
	}

	GoLog("[YouTube] Got download URL from SpotubeDL (%s)\n", engine)
	return &CobaltResponse{
		Status:   "tunnel",
		URL:      downloadURL,
		Filename: filename,
	}, nil
}

func (y *YouTubeDownloader) DownloadFile(downloadURL, outputPath string, outputFD int, itemID string) error {
	ctx := context.Background()

	if itemID != "" {
		StartItemProgress(itemID)
		defer CompleteItemProgress(itemID)
		ctx = initDownloadCancel(itemID)
		defer clearDownloadCancel(itemID)
	}

	if isDownloadCancelled(itemID) {
		return ErrDownloadCancelled
	}

	req, err := http.NewRequestWithContext(ctx, "GET", downloadURL, nil)
	if err != nil {
		return fmt.Errorf("failed to create request: %w", err)
	}

	resp, err := DoRequestWithUserAgent(y.client, req)
	if err != nil {
		if isDownloadCancelled(itemID) {
			return ErrDownloadCancelled
		}
		return fmt.Errorf("download request failed: %w", err)
	}
	defer resp.Body.Close()

	if resp.StatusCode != 200 {
		return fmt.Errorf("download failed: HTTP %d", resp.StatusCode)
	}

	expectedSize := resp.ContentLength
	if expectedSize > 0 && itemID != "" {
		SetItemBytesTotal(itemID, expectedSize)
	}

	out, err := openOutputForWrite(outputPath, outputFD)
	if err != nil {
		return fmt.Errorf("failed to create output file: %w", err)
	}

	bufWriter := bufio.NewWriterSize(out, 256*1024)

	var written int64
	if itemID != "" {
		progressWriter := NewItemProgressWriter(bufWriter, itemID)
		written, err = io.Copy(progressWriter, resp.Body)
	} else {
		written, err = io.Copy(bufWriter, resp.Body)
	}

	flushErr := bufWriter.Flush()
	closeErr := out.Close()

	if err != nil {
		cleanupOutputOnError(outputPath, outputFD)
		if isDownloadCancelled(itemID) {
			return ErrDownloadCancelled
		}
		return fmt.Errorf("download interrupted: %w", err)
	}
	if flushErr != nil {
		cleanupOutputOnError(outputPath, outputFD)
		return fmt.Errorf("failed to flush buffer: %w", flushErr)
	}
	if closeErr != nil {
		cleanupOutputOnError(outputPath, outputFD)
		return fmt.Errorf("failed to close file: %w", closeErr)
	}

	if expectedSize > 0 && written != expectedSize {
		cleanupOutputOnError(outputPath, outputFD)
		return fmt.Errorf("incomplete download: expected %d bytes, got %d bytes", expectedSize, written)
	}

	GoLog("[YouTube] Download completed: %d bytes written\n", written)

	return nil
}

func BuildYouTubeSearchURL(trackName, artistName string) string {
	query := fmt.Sprintf("%s %s official audio", artistName, trackName)
	return fmt.Sprintf("https://music.youtube.com/search?q=%s", url.QueryEscape(query))
}

func BuildYouTubeWatchURL(videoID string) string {
	return fmt.Sprintf("https://music.youtube.com/watch?v=%s", videoID)
}

func isYouTubeVideoID(s string) bool {
	if len(s) != 11 {
		return false
	}
	for _, c := range s {
		if !((c >= 'a' && c <= 'z') || (c >= 'A' && c <= 'Z') || (c >= '0' && c <= '9') || c == '-' || c == '_') {
			return false
		}
	}
	return true
}

func IsYouTubeURL(urlStr string) bool {
	lower := strings.ToLower(urlStr)
	return strings.Contains(lower, "youtube.com") ||
		strings.Contains(lower, "youtu.be") ||
		strings.Contains(lower, "music.youtube.com")
}

// toYouTubeMusicURL converts any YouTube URL to music.youtube.com format.
// YouTube Music URLs bypass the login requirement that affects regular YouTube videos on Cobalt.
func toYouTubeMusicURL(rawURL string) string {
	videoID, err := ExtractYouTubeVideoID(rawURL)
	if err != nil {
		return rawURL
	}
	return fmt.Sprintf("https://music.youtube.com/watch?v=%s", videoID)
}

func ExtractYouTubeVideoID(urlStr string) (string, error) {
	if strings.Contains(urlStr, "youtu.be/") {
		parts := strings.Split(urlStr, "youtu.be/")
		if len(parts) >= 2 {
			videoID := strings.Split(parts[1], "?")[0]
			videoID = strings.Split(videoID, "&")[0]
			return strings.TrimSpace(videoID), nil
		}
	}

	parsed, err := url.Parse(urlStr)
	if err != nil {
		return "", fmt.Errorf("invalid URL: %w", err)
	}

	if v := parsed.Query().Get("v"); v != "" {
		return v, nil
	}

	if strings.Contains(parsed.Path, "/embed/") {
		parts := strings.Split(parsed.Path, "/embed/")
		if len(parts) >= 2 {
			return strings.Split(parts[1], "/")[0], nil
		}
	}

	if strings.Contains(parsed.Path, "/v/") {
		parts := strings.Split(parsed.Path, "/v/")
		if len(parts) >= 2 {
			return strings.Split(parts[1], "/")[0], nil
		}
	}

	return "", fmt.Errorf("could not extract video ID from URL")
}

// searchYouTubeMusicViaExtension uses the YT Music extension's customSearch
// to find a track by artist + title. It filters for tracks only (not videos,
// albums, or playlists) and returns the YouTube Music watch URL for the first
// matching track, or "" if nothing was found.
func searchYouTubeMusicViaExtension(artistName, trackName string) string {
	extManager := GetExtensionManager()
	searchProviders := extManager.GetSearchProviders()

	// Find the ytmusic-spotiflac extension
	var ytProvider *ExtensionProviderWrapper
	for _, p := range searchProviders {
		if p.extension.ID == "ytmusic-spotiflac" {
			ytProvider = p
			break
		}
	}
	if ytProvider == nil {
		GoLog("[YouTube] YT Music extension not found or not enabled, skipping fallback\n")
		return ""
	}

	query := strings.TrimSpace(artistName + " " + trackName)
	if query == "" {
		return ""
	}

	GoLog("[YouTube] Searching YT Music extension for: %s\n", query)
	results, err := ytProvider.CustomSearch(query, map[string]interface{}{
		"filter": "tracks",
	})
	if err != nil {
		GoLog("[YouTube] YT Music extension search failed: %v\n", err)
		return ""
	}

	// Find the first track result (item_type == "track" with a valid video ID)
	for _, track := range results {
		if track.ItemType != "" && track.ItemType != "track" {
			continue
		}
		videoID := strings.TrimSpace(track.ID)
		if videoID == "" {
			continue
		}
		if isYouTubeVideoID(videoID) {
			return BuildYouTubeWatchURL(videoID)
		}
	}

	GoLog("[YouTube] YT Music extension returned no matching tracks for: %s\n", query)
	return ""
}

func downloadFromYouTube(req DownloadRequest) (YouTubeDownloadResult, error) {
	downloader := NewYouTubeDownloader()

	format, bitrate, quality := parseYouTubeQualityInput(req.Quality)

	// URL lookup priority: YouTube video ID > YT Music extension > SongLink (Spotify/Deezer/ISRC)
	var youtubeURL string
	var lookupErr error

	// SpotifyID might actually be a YouTube video ID (from YT Music extension)
	if req.SpotifyID != "" && isYouTubeVideoID(req.SpotifyID) {
		youtubeURL = BuildYouTubeWatchURL(req.SpotifyID)
		GoLog("[YouTube] SpotifyID appears to be YouTube video ID, using directly: %s\n", youtubeURL)
	}

	// Try YT Music extension search first (if installed) - more accurate, tracks only
	if youtubeURL == "" && (req.TrackName != "" || req.ArtistName != "") {
		youtubeURL = searchYouTubeMusicViaExtension(req.ArtistName, req.TrackName)
		if youtubeURL != "" {
			GoLog("[YouTube] Found YouTube URL via YT Music extension: %s\n", youtubeURL)
		}
	}

	// Fallback: Try Spotify ID via SongLink
	if youtubeURL == "" && req.SpotifyID != "" && !isYouTubeVideoID(req.SpotifyID) {
		GoLog("[YouTube] Looking up YouTube URL via SongLink for Spotify ID: %s\n", req.SpotifyID)
		songlink := NewSongLinkClient()
		youtubeURL, lookupErr = songlink.GetYouTubeURLFromSpotify(req.SpotifyID)
		if lookupErr != nil {
			GoLog("[YouTube] SongLink Spotify lookup failed: %v\n", lookupErr)
		} else {
			GoLog("[YouTube] Found YouTube URL via SongLink (Spotify): %s\n", youtubeURL)
		}
	}

	// Fallback: Try Deezer ID via SongLink
	if youtubeURL == "" && req.DeezerID != "" {
		GoLog("[YouTube] Looking up YouTube URL via SongLink for Deezer ID: %s\n", req.DeezerID)
		songlink := NewSongLinkClient()
		youtubeURL, lookupErr = songlink.GetYouTubeURLFromDeezer(req.DeezerID)
		if lookupErr != nil {
			GoLog("[YouTube] SongLink Deezer lookup failed: %v\n", lookupErr)
		} else {
			GoLog("[YouTube] Found YouTube URL via SongLink (Deezer): %s\n", youtubeURL)
		}
	}

	// Fallback: Try ISRC via SongLink
	if youtubeURL == "" && req.ISRC != "" {
		GoLog("[YouTube] Looking up YouTube URL via SongLink for ISRC: %s\n", req.ISRC)
		songlink := NewSongLinkClient()
		availability, isrcErr := songlink.CheckTrackAvailability("", req.ISRC)
		if isrcErr == nil && availability.YouTube && availability.YouTubeURL != "" {
			youtubeURL = availability.YouTubeURL
			GoLog("[YouTube] Found YouTube URL via SongLink (ISRC): %s\n", youtubeURL)
		} else if isrcErr != nil {
			GoLog("[YouTube] SongLink ISRC lookup failed: %v\n", isrcErr)
		}
	}

	// Cobalt requires direct video URLs, not search URLs
	if youtubeURL == "" {
		return YouTubeDownloadResult{}, fmt.Errorf("could not find YouTube URL for track: %s - %s (no Spotify/Deezer ID available or track not on YouTube)", req.ArtistName, req.TrackName)
	}

	GoLog("[YouTube] Requesting download from Cobalt for: %s\n", youtubeURL)

	cobaltResp, err := downloader.GetDownloadURL(youtubeURL, quality)
	if err != nil {
		return YouTubeDownloadResult{}, fmt.Errorf("failed to get download URL: %w", err)
	}

	ext := ".mp3"
	if format == "opus" {
		ext = ".opus"
	}

	// Some SpotubeDL engines may return a different output container than requested.
	// Respect the provider-reported filename to avoid saving MP3 bytes with .opus extension.
	if cobaltResp != nil && cobaltResp.Filename != "" {
		lowerName := strings.ToLower(strings.TrimSpace(cobaltResp.Filename))
		switch {
		case strings.HasSuffix(lowerName, ".mp3"):
			ext = ".mp3"
			format = "mp3"
		case strings.HasSuffix(lowerName, ".opus"), strings.HasSuffix(lowerName, ".ogg"):
			ext = ".opus"
			format = "opus"
		}
	}

	filename := buildFilenameFromTemplate(req.FilenameFormat, map[string]any{
		"title":  req.TrackName,
		"artist": req.ArtistName,
		"album":  req.AlbumName,
		"track":  req.TrackNumber,
		"year":   extractYear(req.ReleaseDate),
		"date":   req.ReleaseDate,
		"disc":   req.DiscNumber,
	})
	filename = sanitizeFilename(filename) + ext

	var outputPath string
	isSafOutput := isFDOutput(req.OutputFD) || strings.TrimSpace(req.OutputPath) != ""
	if isSafOutput {
		outputPath = strings.TrimSpace(req.OutputPath)
		if outputPath == "" && isFDOutput(req.OutputFD) {
			outputPath = fmt.Sprintf("/proc/self/fd/%d", req.OutputFD)
		}
	} else {
		outputPath = req.OutputDir + "/" + filename
	}

	GoLog("[YouTube] Downloading to: %s\n", outputPath)

	var parallelResult *ParallelDownloadResult
	if req.EmbedLyrics || req.CoverURL != "" {
		GoLog("[YouTube] Starting parallel fetch for cover and lyrics...\n")
		parallelResult = FetchCoverAndLyricsParallel(
			req.CoverURL,
			req.EmbedMaxQualityCover,
			req.SpotifyID,
			req.TrackName,
			req.ArtistName,
			req.EmbedLyrics,
			int64(req.DurationMS),
		)
	}

	if err := downloader.DownloadFile(cobaltResp.URL, outputPath, req.OutputFD, req.ItemID); err != nil {
		return YouTubeDownloadResult{}, fmt.Errorf("download failed: %w", err)
	}

	lyricsLRC := ""
	var coverData []byte
	if parallelResult != nil {
		if parallelResult.LyricsLRC != "" {
			lyricsLRC = parallelResult.LyricsLRC
			GoLog("[YouTube] Got lyrics from lrclib (%d lines)\n", len(parallelResult.LyricsData.Lines))
		}
		if parallelResult.CoverData != nil {
			coverData = parallelResult.CoverData
			GoLog("[YouTube] Got cover art (%d bytes)\n", len(coverData))
		}
	}

	return YouTubeDownloadResult{
		FilePath:    outputPath,
		Title:       req.TrackName,
		Artist:      req.ArtistName,
		Album:       req.AlbumName,
		ReleaseDate: req.ReleaseDate,
		TrackNumber: req.TrackNumber,
		DiscNumber:  req.DiscNumber,
		ISRC:        req.ISRC,
		Format:      format,
		Bitrate:     bitrate,
		LyricsLRC:   lyricsLRC,
		CoverData:   coverData,
	}, nil
}