mirror of
https://github.com/navidrome/navidrome.git
synced 2026-10-08 18:37:09 +02:00
* refactor(persistence): adopt generic deluan/rest repository API Pin deluan/rest to the refactor branch. REST-facing repository methods take a context and return typed values. Drop DataStore.Resource and ResourceRepository; the native API names typed repositories directly through a per-request adapter that later commits remove. * refactor(persistence): base repository helpers take a context * refactor(persistence): LibraryRepository takes a context per call * refactor(persistence): PropertyRepository takes a context per call * refactor(persistence): UserPropsRepository takes a context per call * refactor(persistence): TranscodingRepository takes a context per call * refactor(persistence): ShareRepository takes a context per call * refactor(persistence): PlayerRepository takes a context per call * refactor(persistence): RadioRepository takes a context per call * refactor(persistence): PlayQueueRepository takes a context per call * refactor(persistence): Tag and Genre repositories take a context per call * refactor(persistence): PluginRepository takes a context per call * refactor(persistence): Scrobble repositories take a context per call * refactor(persistence): FolderRepository takes a context per call * refactor(persistence): Artwork repositories take a context per call * refactor(persistence): UserRepository takes a context per call * refactor(persistence): ArtistRepository takes a context per call ReadAll no longer rewrites the shared sort mappings for the role filter; it works on a per-call copy. * test(persistence): assert artist role sort sanitization in ReadAll * refactor(persistence): AlbumRepository takes a context per call * test(persistence): pass the test context to album repository helpers * refactor(persistence): MediaFileRepository takes a context per call * refactor(persistence): Playlist repositories take a context per call * refactor(persistence): build all repositories once per store * refactor(core): REST repository wrappers are built once * refactor(persistence): repositories are stateless Remove the context field from the base repository and the per-request REST adapter. Enable the containedctx linter so no repository can hold a request context again. * chore(lint): skip containedctx in test files * refactor: share simplifications from the stateless repositories sweep Add deleteOwnedAll on sqlRepository and use it in player/share Delete to remove the duplicated bulk-delete loop; have Share.Repository() return model.ShareRepository so subsonic sharing.go drops its repeated type assertions. * chore(core): assert REST wrappers implement Persistable * chore: reformat imports * perf(persistence): build repositories on first use Each transaction store used to construct all 21 repositories up front, paying for filter and sort mapping setup the block never touched. Fields are now sync.OnceValue thunks, so a store only builds what it uses. * fix(persistence): clean plugin references per deleted user A bulk user delete that fails on a later id had already removed the earlier rows but skipped their plugin cleanup. Cleanup now runs right after each successful delete. * fix(core): unload disabled plugins even when a user delete fails A bulk delete can fail on a later id after earlier users were removed and their plugins auto-disabled. The wrapper returned before unloading, leaving those plugins running until the next successful delete or a restart. * chore(deps): pin deluan/rest to v1.0.1 Replaces the pseudo-version of the refactor branch with the tagged release. REST error messages now name the bare type (Artist, not model.Artist). * test: use the spec context instead of context.Background() Replace the context.Background()/context.TODO() calls this branch added to tests with the spec's ctx, GinkgoT().Context(), or t/b.Context(), so repository calls are bound to the running spec's lifetime. * test: declare the spec context once per Describe Set ctx from GinkgoT().Context() first in each top-level BeforeEach and reuse it, building user contexts on top of it instead of repeating inline calls.
583 lines
21 KiB
Go
583 lines
21 KiB
Go
package model
|
|
|
|
import (
|
|
"cmp"
|
|
"context"
|
|
"encoding/json"
|
|
"fmt"
|
|
"iter"
|
|
"mime"
|
|
"path/filepath"
|
|
"slices"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/deluan/rest"
|
|
"github.com/gohugoio/hashstructure"
|
|
"github.com/navidrome/navidrome/conf"
|
|
"github.com/navidrome/navidrome/consts"
|
|
"github.com/navidrome/navidrome/model/criteria"
|
|
"github.com/navidrome/navidrome/utils"
|
|
"github.com/navidrome/navidrome/utils/gg"
|
|
"github.com/navidrome/navidrome/utils/number"
|
|
"github.com/navidrome/navidrome/utils/slice"
|
|
"github.com/zeebo/xxh3"
|
|
)
|
|
|
|
type MediaFile struct {
|
|
Annotations `structs:"-" hash:"ignore"`
|
|
Bookmarkable `structs:"-" hash:"ignore"`
|
|
ItemImage `structs:"-" hash:"ignore"`
|
|
|
|
// AlbumImage is the parent album's artwork state, hydrated alongside the track's own so a
|
|
// song's Jellyfin album-art tag can be pixel-versioned without a second query.
|
|
AlbumImage ItemImage `structs:"-" json:"-" hash:"ignore"`
|
|
|
|
ID string `structs:"id" json:"id" hash:"ignore"`
|
|
PID string `structs:"pid" json:"-" hash:"ignore"`
|
|
LibraryID int `structs:"library_id" json:"libraryId" hash:"ignore"`
|
|
LibraryPath string `structs:"-" json:"libraryPath" hash:"ignore"`
|
|
LibraryName string `structs:"-" json:"libraryName" hash:"ignore"`
|
|
FolderID string `structs:"folder_id" json:"folderId" hash:"ignore"`
|
|
Path string `structs:"path" json:"path" hash:"ignore"`
|
|
Title string `structs:"title" json:"title"`
|
|
Album string `structs:"album" json:"album"`
|
|
ArtistID string `structs:"artist_id" json:"artistId"` // Deprecated: Use Participants instead
|
|
// Artist is the display name used for the artist.
|
|
Artist string `structs:"artist" json:"artist"`
|
|
AlbumArtistID string `structs:"album_artist_id" json:"albumArtistId"` // Deprecated: Use Participants instead
|
|
// AlbumArtist is the display name used for the album artist.
|
|
AlbumArtist string `structs:"album_artist" json:"albumArtist"`
|
|
AlbumID string `structs:"album_id" json:"albumId" hash:"ignore"`
|
|
HasCoverArt bool `structs:"has_cover_art" json:"hasCoverArt"`
|
|
TrackNumber int `structs:"track_number" json:"trackNumber"`
|
|
DiscNumber int `structs:"disc_number" json:"discNumber"`
|
|
DiscSubtitle string `structs:"disc_subtitle" json:"discSubtitle,omitempty"`
|
|
Year int `structs:"year" json:"year"`
|
|
Date string `structs:"date" json:"date,omitempty"`
|
|
OriginalYear int `structs:"original_year" json:"originalYear"`
|
|
OriginalDate string `structs:"original_date" json:"originalDate,omitempty"`
|
|
ReleaseYear int `structs:"release_year" json:"releaseYear"`
|
|
ReleaseDate string `structs:"release_date" json:"releaseDate,omitempty"`
|
|
Size int64 `structs:"size" json:"size"`
|
|
Suffix string `structs:"suffix" json:"suffix"`
|
|
Duration float32 `structs:"duration" json:"duration"`
|
|
BitRate int `structs:"bit_rate" json:"bitRate"`
|
|
SampleRate int `structs:"sample_rate" json:"sampleRate"`
|
|
BitDepth *int `structs:"bit_depth" json:"bitDepth,omitempty"`
|
|
Channels int `structs:"channels" json:"channels"`
|
|
Codec string `structs:"codec" json:"codec"`
|
|
ProbeData string `structs:"probe_data" json:"-" hash:"ignore"`
|
|
Genre string `structs:"genre" json:"genre"`
|
|
Genres Genres `structs:"-" json:"genres,omitempty"`
|
|
SortTitle string `structs:"sort_title" json:"sortTitle,omitempty"`
|
|
SortAlbumName string `structs:"sort_album_name" json:"sortAlbumName,omitempty"`
|
|
SortArtistName string `structs:"sort_artist_name" json:"sortArtistName,omitempty"` // Deprecated: Use Participants instead
|
|
SortAlbumArtistName string `structs:"sort_album_artist_name" json:"sortAlbumArtistName,omitempty"` // Deprecated: Use Participants instead
|
|
OrderTitle string `structs:"order_title" json:"orderTitle,omitempty"`
|
|
OrderAlbumName string `structs:"order_album_name" json:"orderAlbumName"`
|
|
OrderArtistName string `structs:"order_artist_name" json:"orderArtistName"` // Deprecated: Use Participants instead
|
|
OrderAlbumArtistName string `structs:"order_album_artist_name" json:"orderAlbumArtistName"` // Deprecated: Use Participants instead
|
|
Compilation bool `structs:"compilation" json:"compilation"`
|
|
Comment string `structs:"comment" json:"comment,omitempty"`
|
|
Lyrics string `structs:"lyrics" json:"lyrics"`
|
|
BPM *int `structs:"bpm" json:"bpm,omitempty"`
|
|
ExplicitStatus string `structs:"explicit_status" json:"explicitStatus"`
|
|
CatalogNum string `structs:"catalog_num" json:"catalogNum,omitempty"`
|
|
MbzRecordingID string `structs:"mbz_recording_id" json:"mbzRecordingID,omitempty"`
|
|
MbzReleaseTrackID string `structs:"mbz_release_track_id" json:"mbzReleaseTrackId,omitempty"`
|
|
MbzAlbumID string `structs:"mbz_album_id" json:"mbzAlbumId,omitempty"`
|
|
MbzReleaseGroupID string `structs:"mbz_release_group_id" json:"mbzReleaseGroupId,omitempty"`
|
|
MbzArtistID string `structs:"mbz_artist_id" json:"mbzArtistId,omitempty"` // Deprecated: Use Participants instead
|
|
MbzAlbumArtistID string `structs:"mbz_album_artist_id" json:"mbzAlbumArtistId,omitempty"` // Deprecated: Use Participants instead
|
|
MbzAlbumType string `structs:"mbz_album_type" json:"mbzAlbumType,omitempty"`
|
|
MbzAlbumComment string `structs:"mbz_album_comment" json:"mbzAlbumComment,omitempty"`
|
|
RGAlbumGain *float64 `structs:"rg_album_gain" json:"rgAlbumGain"`
|
|
RGAlbumPeak *float64 `structs:"rg_album_peak" json:"rgAlbumPeak"`
|
|
RGTrackGain *float64 `structs:"rg_track_gain" json:"rgTrackGain"`
|
|
RGTrackPeak *float64 `structs:"rg_track_peak" json:"rgTrackPeak"`
|
|
|
|
Tags Tags `structs:"tags" json:"tags,omitempty" hash:"ignore"` // All imported tags from the original file
|
|
Participants Participants `structs:"participants" json:"participants" hash:"ignore"` // All artists that participated in this track
|
|
|
|
Missing bool `structs:"missing" json:"missing" hash:"ignore"` // If the file is not found in the library's FS
|
|
BirthTime time.Time `structs:"birth_time" json:"birthTime" hash:"ignore"` // Time of file creation (ctime)
|
|
CreatedAt time.Time `structs:"created_at" json:"createdAt" hash:"ignore"` // Time this entry was created in the DB
|
|
UpdatedAt time.Time `structs:"updated_at" json:"updatedAt" hash:"ignore"` // Time of file last update (mtime)
|
|
}
|
|
|
|
func (mf MediaFile) FullTitle() string {
|
|
if s := mf.Tags.First(TagSubtitle); conf.Server.Subsonic.AppendSubtitle && s != "" {
|
|
return appendSuffix(mf.Title, s)
|
|
}
|
|
return mf.Title
|
|
}
|
|
|
|
func (mf MediaFile) FullAlbumName() string {
|
|
if v := mf.Tags.First(TagAlbumVersion); conf.Server.Subsonic.AppendAlbumVersion && v != "" {
|
|
return appendSuffix(mf.Album, v)
|
|
}
|
|
return mf.Album
|
|
}
|
|
|
|
var bracketPairs = map[byte]byte{'(': ')', '[': ']', '{': '}', '<': '>'}
|
|
|
|
func appendSuffix(base, suffix string) string {
|
|
suffix = strings.TrimSpace(suffix)
|
|
if len(suffix) >= 2 && bracketPairs[suffix[0]] == suffix[len(suffix)-1] {
|
|
return base + " " + suffix
|
|
}
|
|
return base + " (" + suffix + ")"
|
|
}
|
|
|
|
func (mf MediaFile) ContentType() string {
|
|
return mime.TypeByExtension("." + mf.Suffix)
|
|
}
|
|
|
|
func (mf MediaFile) CoverArtID() ArtworkID {
|
|
// If it has a cover art, return it (if feature is disabled, skip)
|
|
if mf.HasCoverArt && conf.Server.EnableMediaFileCoverArt {
|
|
return artworkIDFromMediaFile(mf)
|
|
}
|
|
// Otherwise fallback to disc (if available) or album cover
|
|
return mf.DiscCoverArtID()
|
|
}
|
|
|
|
// DiscCoverArtID returns the disc artwork ID when the media file has a disc number,
|
|
// otherwise it returns the album artwork ID.
|
|
func (mf MediaFile) DiscCoverArtID() ArtworkID {
|
|
if mf.DiscNumber > 0 {
|
|
return ArtworkID{Kind: KindDiscArtwork, ID: DiscArtworkID(mf.AlbumID, mf.DiscNumber), Hash: mf.ImageHash}
|
|
}
|
|
return mf.AlbumCoverArtID()
|
|
}
|
|
|
|
// AlbumCoverArtID uses AlbumImage, not the track's own ItemImage: an album id must carry the
|
|
// album's content hash even when the track resolved art of its own.
|
|
func (mf MediaFile) AlbumCoverArtID() ArtworkID {
|
|
return artworkIDFromAlbum(Album{ID: mf.AlbumID, ItemImage: mf.AlbumImage})
|
|
}
|
|
|
|
func (mf MediaFile) StructuredLyrics() (LyricList, error) {
|
|
var lyrics LyricList
|
|
err := json.Unmarshal([]byte(mf.Lyrics), &lyrics)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return lyrics, nil
|
|
}
|
|
|
|
// HasEmbeddedLyrics reports whether the lyrics column holds any lyrics. It is never "" post-scan;
|
|
// no-lyrics is normalized to the "[]" sentinel, so string emptiness alone is meaningless.
|
|
func (mf MediaFile) HasEmbeddedLyrics() bool {
|
|
return mf.Lyrics != "" && mf.Lyrics != "[]"
|
|
}
|
|
|
|
// String is mainly used for debugging
|
|
func (mf MediaFile) String() string {
|
|
return mf.Path
|
|
}
|
|
|
|
type Work struct {
|
|
Name string
|
|
MbzWorkID string
|
|
}
|
|
|
|
type Movement struct {
|
|
Name string
|
|
Number int32
|
|
Count int32
|
|
}
|
|
|
|
func (mf MediaFile) Works() []Work {
|
|
names := mf.Tags.Values(TagWork)
|
|
if len(names) == 0 {
|
|
return nil
|
|
}
|
|
ids := mf.Tags.Values(TagMusicBrainzWorkID)
|
|
works := make([]Work, 0, len(names))
|
|
for i, name := range names {
|
|
w := Work{Name: name}
|
|
if i < len(ids) {
|
|
w.MbzWorkID = ids[i]
|
|
}
|
|
works = append(works, w)
|
|
}
|
|
return works
|
|
}
|
|
|
|
func (mf MediaFile) Movements() []Movement {
|
|
names := mf.Tags.Values(TagMovementName)
|
|
if len(names) == 0 {
|
|
return nil
|
|
}
|
|
numbers := mf.Tags.Values(TagMovementNumber)
|
|
counts := mf.Tags.Values(TagMovementTotal)
|
|
movements := make([]Movement, 0, len(names))
|
|
for i, name := range names {
|
|
m := Movement{Name: name}
|
|
if i < len(numbers) {
|
|
m.Number = number.ParseInt[int32](numbers[i])
|
|
}
|
|
if i < len(counts) {
|
|
m.Count = number.ParseInt[int32](counts[i])
|
|
}
|
|
movements = append(movements, m)
|
|
}
|
|
return movements
|
|
}
|
|
|
|
// Hash returns a hash of the MediaFile based on its tags and audio properties
|
|
func (mf MediaFile) Hash() string {
|
|
opts := &hashstructure.HashOptions{
|
|
IgnoreZeroValue: true,
|
|
ZeroNil: true,
|
|
}
|
|
hash, _ := hashstructure.Hash(mf, opts)
|
|
sum := xxh3.New()
|
|
sum.Write(fmt.Appendf(nil, "%d", hash))
|
|
sum.Write(mf.Tags.Hash())
|
|
sum.Write(mf.Participants.Hash())
|
|
return fmt.Sprintf("%x", sum.Sum(nil))
|
|
}
|
|
|
|
// Equals compares two MediaFiles by their hash. It does not consider the ID, PID, Path and other identifier fields.
|
|
// Check the structure for the fields that are marked with `hash:"ignore"`.
|
|
func (mf MediaFile) Equals(other MediaFile) bool {
|
|
return mf.Hash() == other.Hash()
|
|
}
|
|
|
|
// IsEquivalent compares two MediaFiles by path only. Used for matching missing tracks.
|
|
func (mf MediaFile) IsEquivalent(other MediaFile) bool {
|
|
return utils.BaseName(mf.Path) == utils.BaseName(other.Path)
|
|
}
|
|
|
|
func (mf MediaFile) AbsolutePath() string {
|
|
return filepath.Join(mf.LibraryPath, mf.Path)
|
|
}
|
|
|
|
// AudioCodec returns the audio codec for this file.
|
|
// Uses the stored Codec field if available, otherwise infers from Suffix and audio properties.
|
|
func (mf MediaFile) AudioCodec() string {
|
|
// If we have a stored codec from scanning, normalize and return it
|
|
if mf.Codec != "" {
|
|
return strings.ToLower(mf.Codec)
|
|
}
|
|
// Fallback: infer from Suffix + BitDepth
|
|
return mf.inferCodecFromSuffix()
|
|
}
|
|
|
|
// inferCodecFromSuffix infers the codec from the file extension when Codec field is empty.
|
|
func (mf MediaFile) inferCodecFromSuffix() string {
|
|
switch strings.ToLower(mf.Suffix) {
|
|
case "mp3", "mpga":
|
|
return "mp3"
|
|
case "mp2":
|
|
return "mp2"
|
|
case "ogg", "oga":
|
|
return "vorbis"
|
|
case "opus":
|
|
return "opus"
|
|
case "mpc":
|
|
return "mpc"
|
|
case "wma":
|
|
return "wma"
|
|
case "flac":
|
|
return "flac"
|
|
case "wav":
|
|
return "pcm"
|
|
case "aif", "aiff", "aifc":
|
|
return "pcm"
|
|
case "ape":
|
|
return "ape"
|
|
case "wv", "wvp":
|
|
return "wv"
|
|
case "tta":
|
|
return "tta"
|
|
case "tak":
|
|
return "tak"
|
|
case "shn":
|
|
return "shn"
|
|
case "dsf", "dff":
|
|
return "dsd"
|
|
case "m4a":
|
|
// AAC if BitDepth==0, ALAC if BitDepth>0
|
|
if gg.V(mf.BitDepth) > 0 {
|
|
return "alac"
|
|
}
|
|
return "aac"
|
|
case "m4b", "m4p", "m4r":
|
|
return "aac"
|
|
default:
|
|
return ""
|
|
}
|
|
}
|
|
|
|
type MediaFiles []MediaFile
|
|
|
|
// ToAlbum creates an Album object based on the attributes of this MediaFiles collection.
|
|
// It assumes all mediafiles have the same Album (same ID), or else results are unpredictable.
|
|
func (mfs MediaFiles) ToAlbum() Album {
|
|
if len(mfs) == 0 {
|
|
return Album{}
|
|
}
|
|
a := Album{SongCount: len(mfs), Tags: make(Tags), Participants: make(Participants), Discs: Discs{1: ""}}
|
|
|
|
// Sorting the mediafiles ensure the results will be consistent
|
|
slices.SortFunc(mfs, func(a, b MediaFile) int { return cmp.Compare(a.Path, b.Path) })
|
|
|
|
mbzAlbumIds := make([]string, 0, len(mfs))
|
|
mbzReleaseGroupIds := make([]string, 0, len(mfs))
|
|
comments := make([]string, 0, len(mfs))
|
|
years := make([]int, 0, len(mfs))
|
|
dates := make([]string, 0, len(mfs))
|
|
originalYears := make([]int, 0, len(mfs))
|
|
originalDates := make([]string, 0, len(mfs))
|
|
releaseDates := make([]string, 0, len(mfs))
|
|
rgAlbumGains := make([]*float64, 0, len(mfs))
|
|
rgAlbumPeaks := make([]*float64, 0, len(mfs))
|
|
tags := make(TagList, 0, len(mfs[0].Tags)*len(mfs))
|
|
|
|
a.Missing = true
|
|
embedArtPath := ""
|
|
embedArtDisc := 0
|
|
for _, m := range mfs {
|
|
// We assume these attributes are all the same for all songs in an album
|
|
a.ID = m.AlbumID
|
|
a.LibraryID = m.LibraryID
|
|
a.Name = m.Album
|
|
a.AlbumArtist = m.AlbumArtist
|
|
a.AlbumArtistID = m.AlbumArtistID
|
|
a.SortAlbumName = m.SortAlbumName
|
|
a.SortAlbumArtistName = m.SortAlbumArtistName
|
|
a.OrderAlbumName = m.OrderAlbumName
|
|
a.OrderAlbumArtistName = m.OrderAlbumArtistName
|
|
a.MbzAlbumArtistID = m.MbzAlbumArtistID
|
|
a.MbzAlbumType = m.MbzAlbumType
|
|
a.MbzAlbumComment = m.MbzAlbumComment
|
|
a.CatalogNum = m.CatalogNum
|
|
a.Compilation = a.Compilation || m.Compilation
|
|
|
|
// Calculated attributes based on aggregations
|
|
a.Duration += m.Duration
|
|
a.Size += m.Size
|
|
years = append(years, m.Year)
|
|
dates = append(dates, m.Date)
|
|
originalYears = append(originalYears, m.OriginalYear)
|
|
originalDates = append(originalDates, m.OriginalDate)
|
|
releaseDates = append(releaseDates, m.ReleaseDate)
|
|
rgAlbumGains = append(rgAlbumGains, m.RGAlbumGain)
|
|
rgAlbumPeaks = append(rgAlbumPeaks, m.RGAlbumPeak)
|
|
comments = append(comments, m.Comment)
|
|
mbzAlbumIds = append(mbzAlbumIds, m.MbzAlbumID)
|
|
mbzReleaseGroupIds = append(mbzReleaseGroupIds, m.MbzReleaseGroupID)
|
|
if m.DiscNumber > 0 {
|
|
a.Discs.Add(m.DiscNumber, m.DiscSubtitle)
|
|
}
|
|
tags = append(tags, m.Tags.FlattenAll()...)
|
|
a.Participants.Merge(m.Participants)
|
|
|
|
// Find the MediaFile with cover art and the lowest disc number to use for album cover
|
|
embedArtPath, embedArtDisc = firstArtPath(embedArtPath, embedArtDisc, m)
|
|
|
|
if m.ExplicitStatus == "c" && a.ExplicitStatus != "e" {
|
|
a.ExplicitStatus = "c"
|
|
} else if m.ExplicitStatus == "e" {
|
|
a.ExplicitStatus = "e"
|
|
}
|
|
|
|
a.UpdatedAt = newer(a.UpdatedAt, m.UpdatedAt)
|
|
a.CreatedAt = older(a.CreatedAt, m.BirthTime)
|
|
a.Missing = a.Missing && m.Missing
|
|
}
|
|
|
|
a.EmbedArtPath = embedArtPath
|
|
a.SetTags(tags)
|
|
a.FolderIDs = slice.Unique(slice.Map(mfs, func(m MediaFile) string { return m.FolderID }))
|
|
a.Date, _ = allOrNothing(dates)
|
|
a.OriginalDate, _ = allOrNothing(originalDates)
|
|
a.ReleaseDate, _ = allOrNothing(releaseDates)
|
|
a.MinYear, a.MaxYear = minMax(years)
|
|
a.MinOriginalYear, a.MaxOriginalYear = minMax(originalYears)
|
|
a.Comment, _ = allOrNothing(comments)
|
|
a.MbzAlbumID = slice.MostFrequent(mbzAlbumIds)
|
|
a.MbzReleaseGroupID = slice.MostFrequent(mbzReleaseGroupIds)
|
|
a.RGAlbumGain = mostFrequentPtr(rgAlbumGains)
|
|
a.RGAlbumPeak = mostFrequentPtr(rgAlbumPeaks)
|
|
fixAlbumArtist(&a)
|
|
|
|
return a
|
|
}
|
|
|
|
func allOrNothing(items []string) (string, int) {
|
|
if len(items) == 0 {
|
|
return "", 0
|
|
}
|
|
items = slice.Unique(items)
|
|
if len(items) != 1 {
|
|
return "", len(items)
|
|
}
|
|
return items[0], 1
|
|
}
|
|
|
|
func minMax(items []int) (int, int) {
|
|
var mn, mx = items[0], items[0]
|
|
for _, value := range items {
|
|
mx = max(mx, value)
|
|
if mn == 0 {
|
|
mn = value
|
|
} else if value > 0 {
|
|
mn = min(mn, value)
|
|
}
|
|
}
|
|
return mn, mx
|
|
}
|
|
|
|
// mostFrequentPtr returns a pointer to the most common non-nil value, or nil if
|
|
// none. It counts by dereferenced value so a genuine 0.0 is a real candidate
|
|
// (slice.MostFrequent skips the zero value and compares pointers by identity).
|
|
func mostFrequentPtr(items []*float64) *float64 {
|
|
var counts map[float64]int
|
|
var best float64
|
|
var bestCount int
|
|
for _, it := range items {
|
|
if it == nil {
|
|
continue
|
|
}
|
|
if counts == nil {
|
|
counts = map[float64]int{}
|
|
}
|
|
counts[*it]++
|
|
if counts[*it] > bestCount {
|
|
bestCount = counts[*it]
|
|
best = *it
|
|
}
|
|
}
|
|
if bestCount == 0 {
|
|
return nil
|
|
}
|
|
return &best
|
|
}
|
|
|
|
func newer(t1, t2 time.Time) time.Time {
|
|
if t1.After(t2) {
|
|
return t1
|
|
}
|
|
return t2
|
|
}
|
|
|
|
func older(t1, t2 time.Time) time.Time {
|
|
if t1.IsZero() {
|
|
return t2
|
|
}
|
|
if t2.IsZero() {
|
|
return t1
|
|
}
|
|
if t1.After(t2) {
|
|
return t2
|
|
}
|
|
return t1
|
|
}
|
|
|
|
// fixAlbumArtist sets the AlbumArtist to "Various Artists" if the album has more than one artist
|
|
// or if it is a compilation
|
|
func fixAlbumArtist(a *Album) {
|
|
if !a.Compilation {
|
|
if a.AlbumArtistID == "" {
|
|
artist := a.Participants.First(RoleArtist)
|
|
a.AlbumArtistID = artist.ID
|
|
a.AlbumArtist = artist.Name
|
|
}
|
|
return
|
|
}
|
|
albumArtistIds := slice.Map(a.Participants[RoleAlbumArtist], func(p Participant) string { return p.ID })
|
|
if len(slice.Unique(albumArtistIds)) > 1 {
|
|
a.AlbumArtist = consts.VariousArtists
|
|
a.AlbumArtistID = consts.VariousArtistsID
|
|
}
|
|
}
|
|
|
|
// firstArtPath determines which media file path should be used for album artwork
|
|
// based on disc number (preferring lower disc numbers) and path (for consistency)
|
|
func firstArtPath(currentPath string, currentDisc int, m MediaFile) (string, int) {
|
|
if !m.HasCoverArt {
|
|
return currentPath, currentDisc
|
|
}
|
|
|
|
// If current has no disc number (currentDisc == 0) or new file has lower disc number
|
|
if currentDisc == 0 || (m.DiscNumber < currentDisc && m.DiscNumber > 0) {
|
|
return m.Path, m.DiscNumber
|
|
}
|
|
|
|
// If disc numbers are equal, use path for ordering
|
|
if m.DiscNumber == currentDisc {
|
|
if m.Path < currentPath || currentPath == "" {
|
|
return m.Path, m.DiscNumber
|
|
}
|
|
}
|
|
|
|
return currentPath, currentDisc
|
|
}
|
|
|
|
// ToM3U8 exports the playlist to the Extended M3U8 format, as specified in
|
|
// https://docs.fileformat.com/audio/m3u/#extended-m3u
|
|
func (mfs MediaFiles) ToM3U8(title string, absolutePaths bool) string {
|
|
buf := strings.Builder{}
|
|
buf.WriteString("#EXTM3U\n")
|
|
buf.WriteString(fmt.Sprintf("#PLAYLIST:%s\n", title))
|
|
for _, t := range mfs {
|
|
buf.WriteString(fmt.Sprintf("#EXTINF:%.f,%s - %s\n", t.Duration, t.Artist, t.Title))
|
|
if absolutePaths {
|
|
buf.WriteString(t.AbsolutePath() + "\n")
|
|
} else {
|
|
buf.WriteString(t.Path + "\n")
|
|
}
|
|
}
|
|
return buf.String()
|
|
}
|
|
|
|
type MediaFileCursor iter.Seq2[MediaFile, error]
|
|
|
|
type MediaFileRepository interface {
|
|
rest.Repository[MediaFile]
|
|
CountAll(ctx context.Context, options ...QueryOptions) (int64, error)
|
|
CountBySuffix(ctx context.Context, options ...QueryOptions) (map[string]int64, error)
|
|
Exists(ctx context.Context, id string) (bool, error)
|
|
Put(ctx context.Context, m *MediaFile) error
|
|
UpdateProbeData(ctx context.Context, id string, data string) error
|
|
Get(ctx context.Context, id string) (*MediaFile, error)
|
|
GetWithParticipants(ctx context.Context, id string) (*MediaFile, error)
|
|
GetAll(ctx context.Context, options ...QueryOptions) (MediaFiles, error)
|
|
// GetRandom returns up to options.Max media files in random order, applying the same
|
|
// filters as GetAll. Sort/Order are ignored.
|
|
GetRandom(ctx context.Context, options ...QueryOptions) (MediaFiles, error)
|
|
GetAllByTags(ctx context.Context, tag TagName, values []string, options ...QueryOptions) (MediaFiles, error)
|
|
// MatchesCriteria reports whether the media file matches the criteria's rule
|
|
// expression, using the logged user's annotations. Limit and offset are ignored.
|
|
MatchesCriteria(ctx context.Context, id string, c criteria.Criteria) (bool, error)
|
|
GetCursor(ctx context.Context, options ...QueryOptions) (MediaFileCursor, error)
|
|
// GetAlbumIDsByFolder returns the distinct IDs of albums with non-missing tracks in the given
|
|
// folders or their direct children.
|
|
GetAlbumIDsByFolder(ctx context.Context, lib Library, folderIDs ...string) ([]string, error)
|
|
// GetCursorWithArtwork streams like GetCursor, hydrated, so callers that render images don't
|
|
// pay the scanner's per-row cost; it uses the same id pre-pass as the other cursors.
|
|
GetCursorWithArtwork(ctx context.Context, options ...QueryOptions) (MediaFileCursor, error)
|
|
Delete(ctx context.Context, id string) error
|
|
DeleteMissing(ctx context.Context, ids []string) error
|
|
DeleteAllMissing(ctx context.Context) (int64, error)
|
|
FindByPaths(ctx context.Context, paths []string) (MediaFiles, error)
|
|
// ReassignReferences moves annotations, bookmarks and playlist entries from prevID to newID,
|
|
// keeping newID's own row wherever a user has both.
|
|
ReassignReferences(ctx context.Context, prevID, newID string) error
|
|
|
|
// The following methods are used exclusively by the scanner:
|
|
MarkMissing(ctx context.Context, missing bool, mfs ...*MediaFile) error
|
|
MarkMissingByFolder(ctx context.Context, missing bool, folderIDs ...string) error
|
|
GetMissingAndMatching(ctx context.Context, libId int) (MediaFileCursor, error)
|
|
FindRecentFilesByMBZTrackID(ctx context.Context, missing MediaFile, since time.Time) (MediaFiles, error)
|
|
FindRecentFilesByProperties(ctx context.Context, missing MediaFile, since time.Time) (MediaFiles, error)
|
|
|
|
AnnotatedRepository
|
|
BookmarkableRepository
|
|
SearchableRepository[MediaFiles]
|
|
}
|