package main import ( "context" "encoding/base64" "encoding/json" "fmt" "io" "os" "path/filepath" "net/http" "strings" "time" "github.com/afkarxyz/SpotiFLAC/backend" "github.com/wailsapp/wails/v2/pkg/runtime" ) type App struct { ctx context.Context } const checkOperationTimeout = 10 * time.Second func NewApp() *App { return &App{} } type timedResult[T any] struct { value T err error } func runWithTimeout[T any](timeout time.Duration, fn func() (T, error)) (T, error) { resultCh := make(chan timedResult[T], 1) go func() { value, err := fn() resultCh <- timedResult[T]{value: value, err: err} }() select { case result := <-resultCh: return result.value, result.err case <-time.After(timeout): var zero T return zero, fmt.Errorf("operation timed out after %s", timeout) } } func (a *App) getFirstArtist(artistString string) string { if artistString == "" { return "" } delimiters := []string{", ", " & ", " feat. ", " ft. ", " featuring "} for _, d := range delimiters { if idx := strings.Index(strings.ToLower(artistString), d); idx != -1 { return strings.TrimSpace(artistString[:idx]) } } return artistString } func (a *App) startup(ctx context.Context) { a.ctx = ctx if err := backend.InitHistoryDB("SpotiFLAC"); err != nil { fmt.Printf("Failed to init history DB: %v\n", err) } if err := backend.InitISRCCacheDB(); err != nil { fmt.Printf("Failed to init ISRC cache DB: %v\n", err) } if err := backend.InitProviderPriorityDB(); err != nil { fmt.Printf("Failed to init provider priority DB: %v\n", err) } } func (a *App) shutdown(ctx context.Context) { backend.CloseHistoryDB() backend.CloseISRCCacheDB() backend.CloseProviderPriorityDB() } type SpotifyMetadataRequest struct { URL string `json:"url"` Batch bool `json:"batch"` Delay float64 `json:"delay"` Timeout float64 `json:"timeout"` Separator string `json:"separator,omitempty"` } type DownloadRequest struct { Service string `json:"service"` Query string `json:"query,omitempty"` TrackName string `json:"track_name,omitempty"` ArtistName string `json:"artist_name,omitempty"` AlbumName string `json:"album_name,omitempty"` AlbumArtist string `json:"album_artist,omitempty"` ReleaseDate string `json:"release_date,omitempty"` CoverURL string `json:"cover_url,omitempty"` ApiURL string `json:"api_url,omitempty"` OutputDir string `json:"output_dir,omitempty"` AudioFormat string `json:"audio_format,omitempty"` FilenameFormat string `json:"filename_format,omitempty"` TrackNumber bool `json:"track_number,omitempty"` Position int `json:"position,omitempty"` UseAlbumTrackNumber bool `json:"use_album_track_number,omitempty"` SpotifyID string `json:"spotify_id,omitempty"` EmbedLyrics bool `json:"embed_lyrics,omitempty"` EmbedMaxQualityCover bool `json:"embed_max_quality_cover,omitempty"` ServiceURL string `json:"service_url,omitempty"` Duration int `json:"duration,omitempty"` ItemID string `json:"item_id,omitempty"` SpotifyTrackNumber int `json:"spotify_track_number,omitempty"` SpotifyDiscNumber int `json:"spotify_disc_number,omitempty"` SpotifyTotalTracks int `json:"spotify_total_tracks,omitempty"` SpotifyTotalDiscs int `json:"spotify_total_discs,omitempty"` Copyright string `json:"copyright,omitempty"` Publisher string `json:"publisher,omitempty"` PlaylistName string `json:"playlist_name,omitempty"` PlaylistOwner string `json:"playlist_owner,omitempty"` AllowFallback bool `json:"allow_fallback"` UseFirstArtistOnly bool `json:"use_first_artist_only,omitempty"` UseSingleGenre bool `json:"use_single_genre,omitempty"` EmbedGenre bool `json:"embed_genre,omitempty"` Separator string `json:"separator,omitempty"` } type DownloadResponse struct { Success bool `json:"success"` Message string `json:"message"` File string `json:"file,omitempty"` Error string `json:"error,omitempty"` AlreadyExists bool `json:"already_exists,omitempty"` ItemID string `json:"item_id,omitempty"` } func cleanupInvalidDownloadArtifacts(paths ...string) { seen := make(map[string]struct{}, len(paths)) for _, path := range paths { if path == "" { continue } if _, ok := seen[path]; ok { continue } seen[path] = struct{}{} if err := os.Remove(path); err == nil { fmt.Printf("Removed invalid download artifact: %s\n", path) } } } func (a *App) GetStreamingURLs(spotifyTrackID string, region string) (string, error) { if spotifyTrackID == "" { return "", fmt.Errorf("spotify track ID is required") } fmt.Printf("[GetStreamingURLs] Called for track ID: %s, Region: %s\n", spotifyTrackID, region) client := backend.NewSongLinkClient() urls, err := client.GetAllURLsFromSpotify(spotifyTrackID, region) if err != nil { return "", err } jsonData, err := json.Marshal(urls) if err != nil { return "", fmt.Errorf("failed to encode response: %v", err) } return string(jsonData), nil } func (a *App) GetSpotifyMetadata(req SpotifyMetadataRequest) (string, error) { if req.URL == "" { return "", fmt.Errorf("URL parameter is required") } if req.Delay == 0 { req.Delay = 1.0 } if req.Timeout == 0 { req.Timeout = 300.0 } ctx, cancel := context.WithTimeout(context.Background(), time.Duration(req.Timeout*float64(time.Second))) defer cancel() settings, err := a.LoadSettings() separator := req.Separator if separator == "" { separator = ", " if err == nil && settings != nil { if sep, ok := settings["separator"].(string); ok { if sep == "semicolon" { separator = "; " } else if sep == "comma" { separator = ", " } } } } if err == nil && settings != nil { if useAPI, ok := settings["useSpotFetchAPI"].(bool); ok && useAPI { if apiURL, ok := settings["spotFetchAPIUrl"].(string); ok && apiURL != "" { data, err := backend.GetSpotifyDataWithAPI(ctx, req.URL, true, apiURL, req.Batch, time.Duration(req.Delay*float64(time.Second)), separator, func(tracks interface{}) { runtime.EventsEmit(a.ctx, "metadata-stream", tracks) }) if err != nil { return "", fmt.Errorf("failed to fetch metadata from API: %v", err) } jsonData, err := json.MarshalIndent(data, "", " ") if err != nil { return "", fmt.Errorf("failed to encode response: %v", err) } return string(jsonData), nil } } } data, err := backend.GetFilteredSpotifyData(ctx, req.URL, req.Batch, time.Duration(req.Delay*float64(time.Second)), separator, func(tracks interface{}) { runtime.EventsEmit(a.ctx, "metadata-stream", tracks) }) if err != nil { return "", fmt.Errorf("failed to fetch metadata: %v", err) } jsonData, err := json.MarshalIndent(data, "", " ") if err != nil { return "", fmt.Errorf("failed to encode response: %v", err) } return string(jsonData), nil } type SpotifySearchRequest struct { Query string `json:"query"` Limit int `json:"limit"` } func (a *App) SearchSpotify(req SpotifySearchRequest) (*backend.SearchResponse, error) { if req.Query == "" { return nil, fmt.Errorf("search query is required") } if req.Limit <= 0 { req.Limit = 10 } ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) defer cancel() return backend.SearchSpotify(ctx, req.Query, req.Limit) } type SpotifySearchByTypeRequest struct { Query string `json:"query"` SearchType string `json:"search_type"` Limit int `json:"limit"` Offset int `json:"offset"` } func (a *App) SearchSpotifyByType(req SpotifySearchByTypeRequest) ([]backend.SearchResult, error) { if req.Query == "" { return nil, fmt.Errorf("search query is required") } if req.SearchType == "" { return nil, fmt.Errorf("search type is required") } if req.Limit <= 0 { req.Limit = 50 } ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) defer cancel() return backend.SearchSpotifyByType(ctx, req.Query, req.SearchType, req.Limit, req.Offset) } func (a *App) DownloadTrack(req DownloadRequest) (DownloadResponse, error) { if req.Service == "qobuz" && req.SpotifyID == "" { return DownloadResponse{ Success: false, Error: "Spotify ID is required for Qobuz", }, fmt.Errorf("spotify ID is required for Qobuz") } if req.Service == "" { req.Service = "tidal" } if req.OutputDir == "" { req.OutputDir = "." } else { if req.PlaylistName != "" { sanitizedPlaylist := backend.SanitizeFilename(req.PlaylistName) req.OutputDir = filepath.Join(req.OutputDir, sanitizedPlaylist) } req.OutputDir = backend.SanitizeFolderPath(req.OutputDir) } if req.AudioFormat == "" { req.AudioFormat = "LOSSLESS" } var err error var filename string if req.FilenameFormat == "" { req.FilenameFormat = "title-artist" } itemID := req.ItemID if itemID == "" { if req.SpotifyID != "" { itemID = fmt.Sprintf("%s-%d", req.SpotifyID, time.Now().UnixNano()) } else { itemID = fmt.Sprintf("%s-%s-%d", req.TrackName, req.ArtistName, time.Now().UnixNano()) } backend.AddToQueue(itemID, req.TrackName, req.ArtistName, req.AlbumName, req.SpotifyID) } backend.SetDownloading(true) backend.StartDownloadItem(itemID) defer backend.SetDownloading(false) spotifyURL := "" if req.SpotifyID != "" { spotifyURL = fmt.Sprintf("https://open.spotify.com/track/%s", req.SpotifyID) } if req.SpotifyID != "" && (req.Copyright == "" || req.Publisher == "" || req.SpotifyTotalDiscs == 0 || req.ReleaseDate == "" || req.SpotifyTotalTracks == 0 || req.SpotifyTrackNumber == 0) { ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel() trackURL := fmt.Sprintf("https://open.spotify.com/track/%s", req.SpotifyID) metadataSeparator := req.Separator if metadataSeparator == "" { metadataSeparator = ", " metadataSettings, _ := a.LoadSettings() if metadataSettings != nil { if sep, ok := metadataSettings["separator"].(string); ok { if sep == "semicolon" { metadataSeparator = "; " } else if sep == "comma" { metadataSeparator = ", " } } } } trackData, err := backend.GetFilteredSpotifyData(ctx, trackURL, false, 0, metadataSeparator, nil) if err == nil { var trackResp struct { Track struct { Copyright string `json:"copyright"` Publisher string `json:"publisher"` TotalDiscs int `json:"total_discs"` TotalTracks int `json:"total_tracks"` TrackNumber int `json:"track_number"` ReleaseDate string `json:"release_date"` } `json:"track"` } if jsonData, jsonErr := json.Marshal(trackData); jsonErr == nil { if json.Unmarshal(jsonData, &trackResp) == nil { if req.Copyright == "" && trackResp.Track.Copyright != "" { req.Copyright = trackResp.Track.Copyright } if req.Publisher == "" && trackResp.Track.Publisher != "" { req.Publisher = trackResp.Track.Publisher } if req.SpotifyTotalDiscs == 0 && trackResp.Track.TotalDiscs > 0 { req.SpotifyTotalDiscs = trackResp.Track.TotalDiscs } if req.SpotifyTotalTracks == 0 && trackResp.Track.TotalTracks > 0 { req.SpotifyTotalTracks = trackResp.Track.TotalTracks } if req.SpotifyTrackNumber == 0 && trackResp.Track.TrackNumber > 0 { req.SpotifyTrackNumber = trackResp.Track.TrackNumber } if req.ReleaseDate == "" && trackResp.Track.ReleaseDate != "" { req.ReleaseDate = trackResp.Track.ReleaseDate } } } } } if req.TrackName != "" && req.ArtistName != "" { expectedFilename := backend.BuildExpectedFilename(req.TrackName, req.ArtistName, req.AlbumName, req.AlbumArtist, req.ReleaseDate, req.FilenameFormat, req.PlaylistName, req.PlaylistOwner, req.TrackNumber, req.Position, req.SpotifyDiscNumber, req.UseAlbumTrackNumber) expectedPath := filepath.Join(req.OutputDir, expectedFilename) if fileInfo, err := os.Stat(expectedPath); err == nil && fileInfo.Size() > 100*1024 { backend.SkipDownloadItem(itemID, expectedPath) return DownloadResponse{ Success: true, Message: "File already exists", File: expectedPath, AlreadyExists: true, ItemID: itemID, }, nil } } lyricsChan := make(chan string, 1) isrcChan := make(chan string, 1) if req.SpotifyID != "" { if req.EmbedLyrics { go func() { client := backend.NewLyricsClient() resp, _, err := client.FetchLyricsAllSources(req.SpotifyID, req.TrackName, req.ArtistName, req.AlbumName, req.Duration) if err == nil && resp != nil && len(resp.Lines) > 0 { lrc := client.ConvertToLRC(resp, req.TrackName, req.ArtistName) lyricsChan <- lrc } else { lyricsChan <- "" } }() } else { close(lyricsChan) } if req.Service == "qobuz" { go func() { client := backend.NewSongLinkClient() isrc, err := client.GetISRCDirect(req.SpotifyID) if err != nil { fmt.Printf("Warning: failed to resolve ISRC for Qobuz: %v\n", err) } isrcChan <- isrc }() } else { close(isrcChan) } } else { close(lyricsChan) close(isrcChan) } switch req.Service { case "amazon": downloader := backend.NewAmazonDownloader() if req.ServiceURL != "" { filename, err = downloader.DownloadByURL(req.ServiceURL, req.OutputDir, req.AudioFormat, req.FilenameFormat, req.PlaylistName, req.PlaylistOwner, req.TrackNumber, req.Position, req.TrackName, req.ArtistName, req.AlbumName, req.AlbumArtist, req.ReleaseDate, req.CoverURL, req.SpotifyTrackNumber, req.SpotifyDiscNumber, req.SpotifyTotalTracks, req.EmbedMaxQualityCover, req.SpotifyTotalDiscs, req.Copyright, req.Publisher, spotifyURL, req.UseFirstArtistOnly, req.UseSingleGenre, req.EmbedGenre) } else { filename, err = downloader.DownloadBySpotifyID(req.SpotifyID, req.OutputDir, req.AudioFormat, req.FilenameFormat, req.PlaylistName, req.PlaylistOwner, req.TrackNumber, req.Position, req.TrackName, req.ArtistName, req.AlbumName, req.AlbumArtist, req.ReleaseDate, req.CoverURL, req.SpotifyTrackNumber, req.SpotifyDiscNumber, req.SpotifyTotalTracks, req.EmbedMaxQualityCover, req.SpotifyTotalDiscs, req.Copyright, req.Publisher, spotifyURL, req.UseFirstArtistOnly, req.UseSingleGenre, req.EmbedGenre) } case "tidal": if req.ApiURL == "" || req.ApiURL == "auto" { downloader := backend.NewTidalDownloader("") if req.ServiceURL != "" { filename, err = downloader.DownloadByURLWithFallback(req.ServiceURL, req.OutputDir, req.AudioFormat, req.FilenameFormat, req.TrackNumber, req.Position, req.TrackName, req.ArtistName, req.AlbumName, req.AlbumArtist, req.ReleaseDate, req.UseAlbumTrackNumber, req.CoverURL, req.EmbedMaxQualityCover, req.SpotifyTrackNumber, req.SpotifyDiscNumber, req.SpotifyTotalTracks, req.SpotifyTotalDiscs, req.Copyright, req.Publisher, spotifyURL, req.AllowFallback, req.UseFirstArtistOnly, req.UseSingleGenre, req.EmbedGenre) } else { filename, err = downloader.Download(req.SpotifyID, req.OutputDir, req.AudioFormat, req.FilenameFormat, req.TrackNumber, req.Position, req.TrackName, req.ArtistName, req.AlbumName, req.AlbumArtist, req.ReleaseDate, req.UseAlbumTrackNumber, req.CoverURL, req.EmbedMaxQualityCover, req.SpotifyTrackNumber, req.SpotifyDiscNumber, req.SpotifyTotalTracks, req.SpotifyTotalDiscs, req.Copyright, req.Publisher, spotifyURL, req.AllowFallback, req.UseFirstArtistOnly, req.UseSingleGenre, req.EmbedGenre) } } else { downloader := backend.NewTidalDownloader(req.ApiURL) if req.ServiceURL != "" { filename, err = downloader.DownloadByURL(req.ServiceURL, req.OutputDir, req.AudioFormat, req.FilenameFormat, req.TrackNumber, req.Position, req.TrackName, req.ArtistName, req.AlbumName, req.AlbumArtist, req.ReleaseDate, req.UseAlbumTrackNumber, req.CoverURL, req.EmbedMaxQualityCover, req.SpotifyTrackNumber, req.SpotifyDiscNumber, req.SpotifyTotalTracks, req.SpotifyTotalDiscs, req.Copyright, req.Publisher, spotifyURL, req.AllowFallback, req.UseFirstArtistOnly, req.UseSingleGenre, req.EmbedGenre) } else { filename, err = downloader.Download(req.SpotifyID, req.OutputDir, req.AudioFormat, req.FilenameFormat, req.TrackNumber, req.Position, req.TrackName, req.ArtistName, req.AlbumName, req.AlbumArtist, req.ReleaseDate, req.UseAlbumTrackNumber, req.CoverURL, req.EmbedMaxQualityCover, req.SpotifyTrackNumber, req.SpotifyDiscNumber, req.SpotifyTotalTracks, req.SpotifyTotalDiscs, req.Copyright, req.Publisher, spotifyURL, req.AllowFallback, req.UseFirstArtistOnly, req.UseSingleGenre, req.EmbedGenre) } } case "qobuz": fmt.Println("Waiting for ISRC (Qobuz dependency)...") isrc := <-isrcChan downloader := backend.NewQobuzDownloader() quality := req.AudioFormat if quality == "" { quality = "6" } filename, err = downloader.DownloadTrackWithISRC(isrc, req.OutputDir, quality, req.FilenameFormat, req.TrackNumber, req.Position, req.TrackName, req.ArtistName, req.AlbumName, req.AlbumArtist, req.ReleaseDate, req.UseAlbumTrackNumber, req.CoverURL, req.EmbedMaxQualityCover, req.SpotifyTrackNumber, req.SpotifyDiscNumber, req.SpotifyTotalTracks, req.SpotifyTotalDiscs, req.Copyright, req.Publisher, spotifyURL, req.AllowFallback, req.UseFirstArtistOnly, req.UseSingleGenre, req.EmbedGenre) default: return DownloadResponse{ Success: false, Error: fmt.Sprintf("Unknown service: %s", req.Service), }, fmt.Errorf("unknown service: %s", req.Service) } if err != nil { backend.FailDownloadItem(itemID, fmt.Sprintf("Download failed: %v", err)) if filename != "" && !strings.HasPrefix(filename, "EXISTS:") { if _, statErr := os.Stat(filename); statErr == nil { fmt.Printf("Removing corrupted/partial file after failed download: %s\n", filename) if removeErr := os.Remove(filename); removeErr != nil { fmt.Printf("Warning: Failed to remove corrupted file %s: %v\n", filename, removeErr) } } } return DownloadResponse{ Success: false, Error: fmt.Sprintf("Download failed: %v", err), ItemID: itemID, }, err } alreadyExists := false if strings.HasPrefix(filename, "EXISTS:") { alreadyExists = true filename = strings.TrimPrefix(filename, "EXISTS:") } if !alreadyExists { validated, validationErr := backend.ValidateDownloadedTrackDuration(filename, req.Duration) if validationErr != nil { cleanupInvalidDownloadArtifacts(filename) errorMessage := validationErr.Error() backend.FailDownloadItem(itemID, errorMessage) return DownloadResponse{ Success: false, Error: errorMessage, ItemID: itemID, }, fmt.Errorf(errorMessage) } if !validated { fmt.Printf("[DownloadValidation] Skipped duration validation for %s (expected=%ds)\n", filename, req.Duration) } } if !alreadyExists && req.SpotifyID != "" && req.EmbedLyrics && (strings.HasSuffix(filename, ".flac") || strings.HasSuffix(filename, ".mp3") || strings.HasSuffix(filename, ".m4a")) { fmt.Printf("\nWaiting for lyrics fetch to complete...\n") lyrics := <-lyricsChan if lyrics != "" { fmt.Printf("\n--- Full LRC Content ---\n") fmt.Println(lyrics) fmt.Printf("--- End LRC Content ---\n\n") fmt.Printf("Embedding into: %s\n", filename) if err := backend.EmbedLyricsOnlyUniversal(filename, lyrics); err != nil { fmt.Printf("Failed to embed lyrics: %v\n", err) } else { fmt.Printf("Lyrics embedded successfully!\n") } } else { fmt.Println("No lyrics found to embed.") } } else { select { case <-lyricsChan: default: } } message := "Download completed successfully" if alreadyExists { message = "File already exists" backend.SkipDownloadItem(itemID, filename) } else { if strings.EqualFold(filepath.Ext(filename), ".flac") && req.CoverURL != "" { coverClient := backend.NewCoverClient() if iconErr := coverClient.ApplyMacOSFLACFileIcon(filename, req.CoverURL, 256, req.EmbedMaxQualityCover); iconErr != nil { fmt.Printf("Warning: failed to set macOS FLAC file icon: %v\n", iconErr) } else { fmt.Printf("macOS FLAC file icon set: %s\n", filename) } } if fileInfo, statErr := os.Stat(filename); statErr == nil { finalSize := float64(fileInfo.Size()) / (1024 * 1024) backend.CompleteDownloadItem(itemID, filename, finalSize) } else { backend.CompleteDownloadItem(itemID, filename, 0) } go func(fPath, track, artist, album, sID, cover, format, source string) { time.Sleep(2 * time.Second) quality := "Unknown" durationStr := "0:00" meta, err := backend.GetTrackMetadata(fPath) if err == nil { if meta.Bitrate > 0 { quality = fmt.Sprintf("%dkbps/%.1fkHz", meta.Bitrate/1000, float64(meta.SampleRate)/1000.0) } else if meta.SampleRate > 0 { quality = fmt.Sprintf("%.1fkHz", float64(meta.SampleRate)/1000.0) } d := int(meta.Duration) durationStr = fmt.Sprintf("%d:%02d", d/60, d%60) } else { fmt.Printf("[History] Failed to get metadata for %s: %v\n", fPath, err) } item := backend.HistoryItem{ SpotifyID: sID, Title: track, Artists: artist, Album: album, DurationStr: durationStr, CoverURL: cover, Quality: quality, Format: strings.ToUpper(format), Path: fPath, Source: source, } if item.Format == "" || item.Format == "LOSSLESS" { ext := filepath.Ext(fPath) if len(ext) > 1 { item.Format = strings.ToUpper(ext[1:]) } } switch item.Format { case "6", "7", "27": item.Format = "FLAC" } backend.AddHistoryItem(item, "SpotiFLAC") }(filename, req.TrackName, req.ArtistName, req.AlbumName, req.SpotifyID, req.CoverURL, req.AudioFormat, req.Service) } return DownloadResponse{ Success: true, Message: message, File: filename, AlreadyExists: alreadyExists, ItemID: itemID, }, nil } func (a *App) OpenFolder(path string) error { if path == "" { return fmt.Errorf("path is required") } err := backend.OpenFolderInExplorer(path) if err != nil { return fmt.Errorf("failed to open folder: %v", err) } return nil } func (a *App) OpenConfigFolder() error { configDir, err := backend.EnsureAppDir() if err != nil { return fmt.Errorf("failed to create config directory: %v", err) } return backend.OpenFolderInExplorer(configDir) } func (a *App) SelectFolder(defaultPath string) (string, error) { return backend.SelectFolderDialog(a.ctx, defaultPath) } func (a *App) SelectFile() (string, error) { return backend.SelectFileDialog(a.ctx) } func (a *App) GetDefaults() map[string]string { return map[string]string{ "downloadPath": backend.GetDefaultMusicPath(), } } func (a *App) GetDownloadProgress() backend.ProgressInfo { return backend.GetDownloadProgress() } func (a *App) GetDownloadQueue() backend.DownloadQueueInfo { return backend.GetDownloadQueue() } func (a *App) ClearCompletedDownloads() { backend.ClearDownloadQueue() } func (a *App) ClearAllDownloads() { backend.ClearAllDownloads() } func (a *App) AddToDownloadQueue(spotifyID, trackName, artistName, albumName string) string { itemID := fmt.Sprintf("%s-%d", spotifyID, time.Now().UnixNano()) backend.AddToQueue(itemID, trackName, artistName, albumName, "") return itemID } func (a *App) MarkDownloadItemFailed(itemID, errorMsg string) { backend.FailDownloadItem(itemID, errorMsg) } func (a *App) CancelAllQueuedItems() { backend.CancelAllQueuedItems() } func (a *App) ExportFailedDownloads() (string, error) { queueInfo := backend.GetDownloadQueue() var failedItems []string hasFailed := false for _, item := range queueInfo.Queue { if item.Status == backend.StatusFailed { hasFailed = true break } } if !hasFailed { return "No failed downloads to export.", nil } failedItems = append(failedItems, fmt.Sprintf("Failed Downloads Report - %s", time.Now().Format("2006-01-02 15:04:05"))) failedItems = append(failedItems, strings.Repeat("-", 50)) failedItems = append(failedItems, "") count := 0 for _, item := range queueInfo.Queue { if item.Status == backend.StatusFailed { count++ line := fmt.Sprintf("%d. %s - %s", count, item.TrackName, item.ArtistName) if item.AlbumName != "" { line += fmt.Sprintf(" (%s)", item.AlbumName) } failedItems = append(failedItems, line) failedItems = append(failedItems, fmt.Sprintf(" Error: %s", item.ErrorMessage)) if item.SpotifyID != "" { failedItems = append(failedItems, fmt.Sprintf(" ID: %s", item.SpotifyID)) failedItems = append(failedItems, fmt.Sprintf(" URL: https://open.spotify.com/track/%s", item.SpotifyID)) } failedItems = append(failedItems, "") } } content := strings.Join(failedItems, "\n") defaultFilename := fmt.Sprintf("SpotiFLAC_%s_Failed.txt", time.Now().Format("20060102_150405")) path, err := runtime.SaveFileDialog(a.ctx, runtime.SaveDialogOptions{ DefaultFilename: defaultFilename, Title: "Export Failed Downloads", Filters: []runtime.FileFilter{ { DisplayName: "Text Files (*.txt)", Pattern: "*.txt", }, }, }) if err != nil { return "", fmt.Errorf("failed to open save dialog: %v", err) } if path == "" { return "Export cancelled", nil } if err := os.WriteFile(path, []byte(content), 0644); err != nil { return "", fmt.Errorf("failed to write file: %v", err) } return fmt.Sprintf("Successfully exported %d failed downloads to %s", count, path), nil } func (a *App) CheckAPIStatus(apiType string, apiURL string) bool { isOnline, err := runWithTimeout(checkOperationTimeout, func() (bool, error) { var checkURL string if apiType == "tidal" { checkURL = fmt.Sprintf("%s/track/?id=441821360&quality=HI_RES_LOSSLESS", apiURL) } else if apiType == "qobuz" { checkURL = fmt.Sprintf("%s/api/stream?trackId=360735657&format_id=27", apiURL) } else if apiType == "qbz" { checkURL = fmt.Sprintf("%s/api/track/360735657?quality=27", apiURL) } else if apiType == "amazon" { checkURL = fmt.Sprintf("%s/status", apiURL) } else { checkURL = apiURL } client := &http.Client{Timeout: 10 * time.Second} req, err := http.NewRequest("GET", checkURL, nil) if err != nil { return false, err } req.Header.Set("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/145.0.0.0 Safari/537.36") maxRetries := 3 for i := 0; i < maxRetries; i++ { resp, err := client.Do(req) if err == nil { statusCode := resp.StatusCode if apiType == "amazon" && statusCode == 200 { body, readErr := io.ReadAll(resp.Body) resp.Body.Close() if readErr == nil && strings.Contains(string(body), `"amazonMusic":"up"`) { return true, nil } } else { resp.Body.Close() if statusCode == 200 { return true, nil } } } if i < maxRetries-1 { time.Sleep(1 * time.Second) } } return false, nil }) if err != nil { fmt.Printf("CheckAPIStatus timeout/error for %s (%s): %v\n", apiType, apiURL, err) return false } return isOnline } func (a *App) Quit() { panic("quit") } func (a *App) GetDownloadHistory() ([]backend.HistoryItem, error) { return backend.GetHistoryItems("SpotiFLAC") } func (a *App) ClearDownloadHistory() error { return backend.ClearHistory("SpotiFLAC") } func (a *App) DeleteDownloadHistoryItem(id string) error { return backend.DeleteHistoryItem(id, "SpotiFLAC") } func (a *App) GetFetchHistory() ([]backend.FetchHistoryItem, error) { return backend.GetFetchHistoryItems("SpotiFLAC") } func (a *App) AddFetchHistory(item backend.FetchHistoryItem) error { return backend.AddFetchHistoryItem(item, "SpotiFLAC") } func (a *App) ClearFetchHistory() error { return backend.ClearFetchHistory("SpotiFLAC") } func (a *App) DeleteFetchHistoryItem(id string) error { return backend.DeleteFetchHistoryItem(id, "SpotiFLAC") } func (a *App) ClearFetchHistoryByType(itemType string) error { return backend.ClearFetchHistoryByType(itemType, "SpotiFLAC") } func (a *App) SaveSpectrumImage(audioFilePath string, base64Data string) (string, error) { if audioFilePath == "" || base64Data == "" { return "", fmt.Errorf("file path and image data are required") } base64Data = strings.TrimPrefix(base64Data, "data:image/png;base64,") data, err := base64.StdEncoding.DecodeString(base64Data) if err != nil { return "", fmt.Errorf("failed to decode base64 image: %v", err) } ext := filepath.Ext(audioFilePath) baseName := strings.TrimSuffix(filepath.Base(audioFilePath), ext) outPath := filepath.Join(filepath.Dir(audioFilePath), baseName+".png") err = os.WriteFile(outPath, data, 0644) if err != nil { return "", fmt.Errorf("failed to save image to disk: %v", err) } return outPath, nil } type LyricsDownloadRequest struct { SpotifyID string `json:"spotify_id"` TrackName string `json:"track_name"` ArtistName string `json:"artist_name"` AlbumName string `json:"album_name"` AlbumArtist string `json:"album_artist"` ReleaseDate string `json:"release_date"` OutputDir string `json:"output_dir"` FilenameFormat string `json:"filename_format"` TrackNumber bool `json:"track_number"` Position int `json:"position"` UseAlbumTrackNumber bool `json:"use_album_track_number"` DiscNumber int `json:"disc_number"` } func (a *App) DownloadLyrics(req LyricsDownloadRequest) (backend.LyricsDownloadResponse, error) { if req.SpotifyID == "" { return backend.LyricsDownloadResponse{ Success: false, Error: "Spotify ID is required", }, fmt.Errorf("spotify ID is required") } client := backend.NewLyricsClient() backendReq := backend.LyricsDownloadRequest{ SpotifyID: req.SpotifyID, TrackName: req.TrackName, ArtistName: req.ArtistName, AlbumName: req.AlbumName, AlbumArtist: req.AlbumArtist, ReleaseDate: req.ReleaseDate, OutputDir: req.OutputDir, FilenameFormat: req.FilenameFormat, TrackNumber: req.TrackNumber, Position: req.Position, UseAlbumTrackNumber: req.UseAlbumTrackNumber, DiscNumber: req.DiscNumber, } resp, err := client.DownloadLyrics(backendReq) if err != nil { return backend.LyricsDownloadResponse{ Success: false, Error: err.Error(), }, err } return *resp, nil } type CoverDownloadRequest struct { CoverURL string `json:"cover_url"` TrackName string `json:"track_name"` ArtistName string `json:"artist_name"` AlbumName string `json:"album_name"` AlbumArtist string `json:"album_artist"` ReleaseDate string `json:"release_date"` OutputDir string `json:"output_dir"` FilenameFormat string `json:"filename_format"` TrackNumber bool `json:"track_number"` Position int `json:"position"` DiscNumber int `json:"disc_number"` } func (a *App) DownloadCover(req CoverDownloadRequest) (backend.CoverDownloadResponse, error) { if req.CoverURL == "" { return backend.CoverDownloadResponse{ Success: false, Error: "Cover URL is required", }, fmt.Errorf("cover URL is required") } client := backend.NewCoverClient() backendReq := backend.CoverDownloadRequest{ CoverURL: req.CoverURL, TrackName: req.TrackName, ArtistName: req.ArtistName, AlbumName: req.AlbumName, AlbumArtist: req.AlbumArtist, ReleaseDate: req.ReleaseDate, OutputDir: req.OutputDir, FilenameFormat: req.FilenameFormat, TrackNumber: req.TrackNumber, Position: req.Position, DiscNumber: req.DiscNumber, } resp, err := client.DownloadCover(backendReq) if err != nil { return backend.CoverDownloadResponse{ Success: false, Error: err.Error(), }, err } return *resp, nil } type HeaderDownloadRequest struct { HeaderURL string `json:"header_url"` ArtistName string `json:"artist_name"` OutputDir string `json:"output_dir"` } func (a *App) DownloadHeader(req HeaderDownloadRequest) (backend.HeaderDownloadResponse, error) { if req.HeaderURL == "" { return backend.HeaderDownloadResponse{ Success: false, Error: "Header URL is required", }, fmt.Errorf("header URL is required") } if req.ArtistName == "" { return backend.HeaderDownloadResponse{ Success: false, Error: "Artist name is required", }, fmt.Errorf("artist name is required") } client := backend.NewCoverClient() backendReq := backend.HeaderDownloadRequest{ HeaderURL: req.HeaderURL, ArtistName: req.ArtistName, OutputDir: req.OutputDir, } resp, err := client.DownloadHeader(backendReq) if err != nil { return backend.HeaderDownloadResponse{ Success: false, Error: err.Error(), }, err } return *resp, nil } type GalleryImageDownloadRequest struct { ImageURL string `json:"image_url"` ArtistName string `json:"artist_name"` ImageIndex int `json:"image_index"` OutputDir string `json:"output_dir"` } func (a *App) DownloadGalleryImage(req GalleryImageDownloadRequest) (backend.GalleryImageDownloadResponse, error) { if req.ImageURL == "" { return backend.GalleryImageDownloadResponse{ Success: false, Error: "Image URL is required", }, fmt.Errorf("image URL is required") } if req.ArtistName == "" { return backend.GalleryImageDownloadResponse{ Success: false, Error: "Artist name is required", }, fmt.Errorf("artist name is required") } client := backend.NewCoverClient() backendReq := backend.GalleryImageDownloadRequest{ ImageURL: req.ImageURL, ArtistName: req.ArtistName, ImageIndex: req.ImageIndex, OutputDir: req.OutputDir, } resp, err := client.DownloadGalleryImage(backendReq) if err != nil { return backend.GalleryImageDownloadResponse{ Success: false, Error: err.Error(), }, err } return *resp, nil } type AvatarDownloadRequest struct { AvatarURL string `json:"avatar_url"` ArtistName string `json:"artist_name"` OutputDir string `json:"output_dir"` } func (a *App) DownloadAvatar(req AvatarDownloadRequest) (backend.AvatarDownloadResponse, error) { if req.AvatarURL == "" { return backend.AvatarDownloadResponse{ Success: false, Error: "Avatar URL is required", }, fmt.Errorf("avatar URL is required") } if req.ArtistName == "" { return backend.AvatarDownloadResponse{ Success: false, Error: "Artist name is required", }, fmt.Errorf("artist name is required") } client := backend.NewCoverClient() backendReq := backend.AvatarDownloadRequest{ AvatarURL: req.AvatarURL, ArtistName: req.ArtistName, OutputDir: req.OutputDir, } resp, err := client.DownloadAvatar(backendReq) if err != nil { return backend.AvatarDownloadResponse{ Success: false, Error: err.Error(), }, err } return *resp, nil } func (a *App) CheckTrackAvailability(spotifyTrackID string) (string, error) { if spotifyTrackID == "" { return "", fmt.Errorf("spotify track ID is required") } return runWithTimeout(checkOperationTimeout, func() (string, error) { client := backend.NewSongLinkClient() availability, err := client.CheckTrackAvailability(spotifyTrackID) if err != nil { return "", err } jsonData, err := json.Marshal(availability) if err != nil { return "", fmt.Errorf("failed to encode response: %v", err) } return string(jsonData), nil }) } func (a *App) IsFFmpegInstalled() (bool, error) { return backend.IsFFmpegInstalled() } func (a *App) IsFFprobeInstalled() (bool, error) { return backend.IsFFprobeInstalled() } type DownloadFFmpegRequest struct{} type DownloadFFmpegResponse struct { Success bool `json:"success"` Message string `json:"message"` Error string `json:"error,omitempty"` } func (a *App) DownloadFFmpeg() DownloadFFmpegResponse { runtime.EventsEmit(a.ctx, "ffmpeg:status", "starting") err := backend.DownloadFFmpeg(func(progress int) { runtime.EventsEmit(a.ctx, "ffmpeg:progress", progress) }) if err != nil { runtime.EventsEmit(a.ctx, "ffmpeg:status", "failed") return DownloadFFmpegResponse{ Success: false, Error: err.Error(), } } runtime.EventsEmit(a.ctx, "ffmpeg:status", "completed") return DownloadFFmpegResponse{ Success: true, Message: "FFmpeg installed successfully", } } func (a *App) GetBrewPath() string { return backend.GetBrewPath() } func (a *App) IsBrewFFmpegInstalled() (bool, error) { return backend.IsBrewFFmpegInstalled() } type InstallFFmpegWithBrewResponse struct { Success bool `json:"success"` Message string `json:"message"` Error string `json:"error,omitempty"` } func (a *App) InstallFFmpegWithBrew() InstallFFmpegWithBrewResponse { runtime.EventsEmit(a.ctx, "ffmpeg:status", "Installing FFmpeg via Homebrew...") err := backend.InstallFFmpegWithBrew(func(progress int, status string) { runtime.EventsEmit(a.ctx, "ffmpeg:progress", progress) runtime.EventsEmit(a.ctx, "ffmpeg:status", status) }) if err != nil { runtime.EventsEmit(a.ctx, "ffmpeg:status", "failed") return InstallFFmpegWithBrewResponse{ Success: false, Error: err.Error(), } } runtime.EventsEmit(a.ctx, "ffmpeg:status", "completed") return InstallFFmpegWithBrewResponse{ Success: true, Message: "FFmpeg installed successfully via Homebrew", } } type ConvertAudioRequest struct { InputFiles []string `json:"input_files"` OutputFormat string `json:"output_format"` Bitrate string `json:"bitrate"` Codec string `json:"codec"` } func (a *App) ConvertAudio(req ConvertAudioRequest) ([]backend.ConvertAudioResult, error) { backendReq := backend.ConvertAudioRequest{ InputFiles: req.InputFiles, OutputFormat: req.OutputFormat, Bitrate: req.Bitrate, Codec: req.Codec, } return backend.ConvertAudio(backendReq) } type ResampleAudioRequest struct { InputFiles []string `json:"input_files"` SampleRate string `json:"sample_rate"` BitDepth string `json:"bit_depth"` } func (a *App) ResampleAudio(req ResampleAudioRequest) ([]backend.ResampleResult, error) { backendReq := backend.ResampleRequest{ InputFiles: req.InputFiles, SampleRate: req.SampleRate, BitDepth: req.BitDepth, } return backend.ResampleAudio(backendReq) } func (a *App) SelectAudioFiles() ([]string, error) { files, err := backend.SelectMultipleFiles(a.ctx) if err != nil { return nil, err } return files, nil } func (a *App) GetFlacInfoBatch(paths []string) []backend.FlacInfo { return backend.GetFlacInfoBatch(paths) } func (a *App) GetFileSizes(files []string) map[string]int64 { return backend.GetFileSizes(files) } func (a *App) ListDirectoryFiles(dirPath string) ([]backend.FileInfo, error) { if dirPath == "" { return nil, fmt.Errorf("directory path is required") } return backend.ListDirectory(dirPath) } func (a *App) ListAudioFilesInDir(dirPath string) ([]backend.FileInfo, error) { if dirPath == "" { return nil, fmt.Errorf("directory path is required") } return backend.ListAudioFiles(dirPath) } func (a *App) ReadFileMetadata(filePath string) (*backend.AudioMetadata, error) { if filePath == "" { return nil, fmt.Errorf("file path is required") } return backend.ReadAudioMetadata(filePath) } func (a *App) PreviewRenameFiles(files []string, format string) []backend.RenamePreview { return backend.PreviewRename(files, format) } func (a *App) RenameFilesByMetadata(files []string, format string) []backend.RenameResult { return backend.RenameFiles(files, format) } func (a *App) ReadTextFile(filePath string) (string, error) { content, err := os.ReadFile(filePath) if err != nil { return "", err } return string(content), nil } func (a *App) ReadFileAsBase64(filePath string) (string, error) { content, err := os.ReadFile(filePath) if err != nil { return "", err } return base64.StdEncoding.EncodeToString(content), nil } func (a *App) DecodeAudioForAnalysis(filePath string) (*backend.AnalysisDecodeResponse, error) { if filePath == "" { return nil, fmt.Errorf("file path is required") } return backend.DecodeAudioForAnalysis(filePath) } func (a *App) RenameFileTo(oldPath, newName string) error { dir := filepath.Dir(oldPath) ext := filepath.Ext(oldPath) newPath := filepath.Join(dir, newName+ext) return os.Rename(oldPath, newPath) } func (a *App) SelectImageVideo() ([]string, error) { return backend.SelectImageVideoDialog(a.ctx) } func (a *App) ReadImageAsBase64(filePath string) (string, error) { content, err := os.ReadFile(filePath) if err != nil { return "", err } ext := strings.ToLower(filepath.Ext(filePath)) var mimeType string switch ext { case ".jpg", ".jpeg": mimeType = "image/jpeg" case ".png": mimeType = "image/png" case ".gif": mimeType = "image/gif" case ".webp": mimeType = "image/webp" default: mimeType = "image/jpeg" } encoded := base64.StdEncoding.EncodeToString(content) return fmt.Sprintf("data:%s;base64,%s", mimeType, encoded), nil } type CheckFileExistenceRequest struct { SpotifyID string `json:"spotify_id"` TrackName string `json:"track_name"` ArtistName string `json:"artist_name"` AlbumName string `json:"album_name,omitempty"` AlbumArtist string `json:"album_artist,omitempty"` ReleaseDate string `json:"release_date,omitempty"` TrackNumber int `json:"track_number,omitempty"` DiscNumber int `json:"disc_number,omitempty"` Position int `json:"position,omitempty"` UseAlbumTrackNumber bool `json:"use_album_track_number,omitempty"` FilenameFormat string `json:"filename_format,omitempty"` IncludeTrackNumber bool `json:"include_track_number,omitempty"` AudioFormat string `json:"audio_format,omitempty"` RelativePath string `json:"relative_path,omitempty"` } type CheckFileExistenceResult struct { SpotifyID string `json:"spotify_id"` Exists bool `json:"exists"` FilePath string `json:"file_path,omitempty"` TrackName string `json:"track_name,omitempty"` ArtistName string `json:"artist_name,omitempty"` } func (a *App) CheckFilesExistence(outputDir string, rootDir string, tracks []CheckFileExistenceRequest) []CheckFileExistenceResult { if len(tracks) == 0 { return []CheckFileExistenceResult{} } outputDir = backend.NormalizePath(outputDir) if rootDir != "" { rootDir = backend.NormalizePath(rootDir) } defaultFilenameFormat := "title-artist" type result struct { index int result CheckFileExistenceResult } resultsChan := make(chan result, len(tracks)) var rootDirFiles map[string]string rootDirFilesOnce := false getRootDirFiles := func() map[string]string { if rootDirFilesOnce { return rootDirFiles } rootDirFiles = make(map[string]string) if rootDir != "" && rootDir != outputDir { filepath.Walk(rootDir, func(path string, info os.FileInfo, err error) error { if err != nil { return nil } if !info.IsDir() { if strings.EqualFold(filepath.Ext(path), ".flac") || strings.EqualFold(filepath.Ext(path), ".mp3") { rootDirFiles[info.Name()] = path } } return nil }) } rootDirFilesOnce = true return rootDirFiles } for i, track := range tracks { go func(idx int, t CheckFileExistenceRequest) { res := CheckFileExistenceResult{ SpotifyID: t.SpotifyID, TrackName: t.TrackName, ArtistName: t.ArtistName, Exists: false, } if t.TrackName == "" || t.ArtistName == "" { resultsChan <- result{index: idx, result: res} return } filenameFormat := t.FilenameFormat if filenameFormat == "" { filenameFormat = defaultFilenameFormat } trackNumber := t.Position if t.UseAlbumTrackNumber && t.TrackNumber > 0 { trackNumber = t.TrackNumber } fileExt := ".flac" if t.AudioFormat == "mp3" { fileExt = ".mp3" } expectedFilenameBase := backend.BuildExpectedFilename( t.TrackName, t.ArtistName, t.AlbumName, t.AlbumArtist, t.ReleaseDate, filenameFormat, "", "", t.IncludeTrackNumber, trackNumber, t.DiscNumber, t.UseAlbumTrackNumber, ) expectedFilename := strings.TrimSuffix(expectedFilenameBase, ".flac") + fileExt targetDir := outputDir if t.RelativePath != "" { targetDir = filepath.Join(outputDir, t.RelativePath) } expectedPath := filepath.Join(targetDir, expectedFilename) if fileInfo, err := os.Stat(expectedPath); err == nil && fileInfo.Size() > 100*1024 { res.Exists = true res.FilePath = expectedPath } else { res.FilePath = expectedFilename } resultsChan <- result{index: idx, result: res} }(i, track) } results := make([]CheckFileExistenceResult, len(tracks)) missingIndices := []int{} for i := 0; i < len(tracks); i++ { r := <-resultsChan results[r.index] = r.result if !results[r.index].Exists { missingIndices = append(missingIndices, r.index) } } if len(missingIndices) > 0 && rootDir != "" { filesMap := getRootDirFiles() if len(filesMap) > 0 { for _, idx := range missingIndices { expectedFilename := results[idx].FilePath baseName := filepath.Base(expectedFilename) if path, ok := filesMap[baseName]; ok { results[idx].Exists = true results[idx].FilePath = path } else { results[idx].FilePath = "" } } } else { for _, idx := range missingIndices { results[idx].FilePath = "" } } } else { for _, idx := range missingIndices { results[idx].FilePath = "" } } return results } func (a *App) SkipDownloadItem(itemID, filePath string) { backend.SkipDownloadItem(itemID, filePath) } func (a *App) GetPreviewURL(trackID string) (string, error) { return backend.GetPreviewURL(trackID) } func (a *App) GetConfigPath() (string, error) { dir, err := backend.GetFFmpegDir() if err != nil { return "", err } return filepath.Join(dir, "config.json"), nil } func (a *App) SaveSettings(settings map[string]interface{}) error { configPath, err := a.GetConfigPath() if err != nil { return err } dir := filepath.Dir(configPath) if _, err := os.Stat(dir); os.IsNotExist(err) { if err := os.MkdirAll(dir, 0755); err != nil { return err } } data, err := json.MarshalIndent(settings, "", " ") if err != nil { return err } return os.WriteFile(configPath, data, 0644) } func (a *App) LoadSettings() (map[string]interface{}, error) { configPath, err := a.GetConfigPath() if err != nil { return nil, err } if _, err := os.Stat(configPath); os.IsNotExist(err) { return nil, nil } data, err := os.ReadFile(configPath) if err != nil { return nil, err } var settings map[string]interface{} if err := json.Unmarshal(data, &settings); err != nil { return nil, err } return settings, nil } func (a *App) CheckFFmpegInstalled() (bool, error) { return backend.IsFFmpegInstalled() } func (a *App) CreateM3U8File(m3u8Name string, outputDir string, filePaths []string) error { if len(filePaths) == 0 { return nil } if err := os.MkdirAll(outputDir, 0755); err != nil { return err } fnName := m3u8Name safeName := backend.SanitizeFilename(fnName) if safeName == "" { safeName = "playlist" } m3u8Path := filepath.Join(outputDir, safeName+".m3u8") f, err := os.Create(m3u8Path) if err != nil { return err } defer f.Close() if _, err := f.WriteString("#EXTM3U\n"); err != nil { return err } for _, path := range filePaths { if path == "" { continue } relPath, err := filepath.Rel(outputDir, path) if err != nil { relPath = path } relPath = filepath.ToSlash(relPath) if _, err := f.WriteString(relPath + "\n"); err != nil { return err } } return nil }