1621 lines
46 KiB
Go
1621 lines
46 KiB
Go
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) 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
|
|
}
|