mirror of
https://github.com/navidrome/navidrome.git
synced 2025-04-15 19:50:37 +03:00
Cleaning old data from artists indexes
This commit is contained in:
parent
107321219a
commit
0e20910061
@ -27,4 +27,5 @@ type ArtistIndexRepository interface {
|
||||
Put(m *ArtistIndex) error
|
||||
Get(id string) (*ArtistIndex, error)
|
||||
GetAll() (ArtistIndexes, error)
|
||||
DeleteAll() error
|
||||
}
|
||||
|
@ -37,4 +37,13 @@ func (r *artistIndexRepository) GetAll() (domain.ArtistIndexes, error) {
|
||||
return indices, err
|
||||
}
|
||||
|
||||
func (r *artistIndexRepository) DeleteAll() error {
|
||||
var empty domain.ArtistIndexes
|
||||
_, err := r.purgeInactive(empty, func(e interface{}) string {
|
||||
return e.(domain.ArtistIndex).Id
|
||||
})
|
||||
|
||||
return err
|
||||
}
|
||||
|
||||
var _ domain.ArtistIndexRepository = (*artistIndexRepository)(nil)
|
||||
|
@ -317,6 +317,7 @@ func (i *Importer) findGroup(ig utils.IndexGroups, name string) string {
|
||||
}
|
||||
|
||||
func (i *Importer) saveIndex(artistIndex map[string]tempIndex) error {
|
||||
i.idxRepo.DeleteAll()
|
||||
for k, temp := range artistIndex {
|
||||
idx := &domain.ArtistIndex{Id: k}
|
||||
for _, v := range temp {
|
||||
|
Loading…
x
Reference in New Issue
Block a user