Use correct method to batch refresh musicbrainz data
This commit is contained in:
@@ -1,25 +1,18 @@
|
|||||||
defmodule MusicLibrary.Records.Batch do
|
defmodule MusicLibrary.Records.Batch do
|
||||||
require Logger
|
require Logger
|
||||||
|
|
||||||
|
alias MusicLibrary.Records
|
||||||
alias MusicLibrary.Records.{Cover, Record}
|
alias MusicLibrary.Records.{Cover, Record}
|
||||||
alias MusicLibrary.Repo
|
alias MusicLibrary.Repo
|
||||||
import Ecto.Query
|
import Ecto.Query
|
||||||
|
|
||||||
def refresh_musicbrainz_data do
|
def refresh_musicbrainz_data do
|
||||||
run_on_all_records(fn record ->
|
run_on_all_records(fn record ->
|
||||||
import_musicbrainz_data(record)
|
Records.refresh_musicbrainz_data(record)
|
||||||
Process.sleep(1000)
|
Process.sleep(1000)
|
||||||
end)
|
end)
|
||||||
end
|
end
|
||||||
|
|
||||||
def import_musicbrainz_data(record) do
|
|
||||||
with {:ok, data} <- music_brainz_config().api.get_release_group(record.musicbrainz_id) do
|
|
||||||
record
|
|
||||||
|> Record.add_musicbrainz_data(data)
|
|
||||||
|> Repo.update!()
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
def refresh_old_artwork do
|
def refresh_old_artwork do
|
||||||
run_on_all_records(&refresh_old_artwork/1)
|
run_on_all_records(&refresh_old_artwork/1)
|
||||||
end
|
end
|
||||||
@@ -58,6 +51,4 @@ defmodule MusicLibrary.Records.Batch do
|
|||||||
timeout: :infinity
|
timeout: :infinity
|
||||||
)
|
)
|
||||||
end
|
end
|
||||||
|
|
||||||
defp music_brainz_config, do: MusicBrainz.Config.resolve(:music_library)
|
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user