mirrors/navidrome
1
0
Fork 0
mirror of https://github.com/navidrome/navidrome.git synced 2025-04-04 21:17:37 +03:00
Code Issues Projects Releases Packages Wiki Activity

Break-up album/artist refresh in chunks

Browse source
This commit is contained in:
Deluan 2020-09-09 08:57:59 -04:00
parent ba30f7f8be
commit 841c1129ff
3 changed files with 25 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

11
persistence/album_repository.go
View file

@ -138,6 +138,17 @@ func (r *albumRepository) getEmbeddedCovers(ids []string) (map[string]model.Medi
} }
func (r *albumRepository) Refresh(ids ...string) error { func (r *albumRepository) Refresh(ids ...string) error {
chunks := utils.BreakUpStringSlice(ids, 100)
for _, chunk := range chunks {
err := r.refresh(chunk...)
if err != nil {
return err
}
}
return nil
}
func (r *albumRepository) refresh(ids ...string) error {
type refreshAlbum struct { type refreshAlbum struct {
model.Album model.Album
CurrentId string CurrentId string

11
persistence/artist_repository.go
View file

@ -115,6 +115,17 @@ func (r *artistRepository) GetIndex() (model.ArtistIndexes, error) {
} }
func (r *artistRepository) Refresh(ids ...string) error { func (r *artistRepository) Refresh(ids ...string) error {
chunks := utils.BreakUpStringSlice(ids, 100)
for _, chunk := range chunks {
err := r.refresh(chunk...)
if err != nil {
return err
}
}
return nil
}
func (r *artistRepository) refresh(ids ...string) error {
type refreshArtist struct { type refreshArtist struct {
model.Artist model.Artist
CurrentId string CurrentId string

6
utils/strings.go
View file

@ -39,8 +39,8 @@ func MoveString(array []string, srcIndex int, dstIndex int) []string {
return InsertString(RemoveString(array, srcIndex), value, dstIndex) return InsertString(RemoveString(array, srcIndex), value, dstIndex)
} }
func BreakUpStringSlice(mediaFileIds []string, chunkSize int) [][]string { func BreakUpStringSlice(items []string, chunkSize int) [][]string {
numTracks := len(mediaFileIds) numTracks := len(items)
var chunks [][]string var chunks [][]string
for i := 0; i < numTracks; i += chunkSize { for i := 0; i < numTracks; i += chunkSize {
end := i + chunkSize end := i + chunkSize
@ -48,7 +48,7 @@ func BreakUpStringSlice(mediaFileIds []string, chunkSize int) [][]string {
end = numTracks end = numTracks
} }
chunks = append(chunks, mediaFileIds[i:end]) chunks = append(chunks, items[i:end])
} }
return chunks return chunks
} }