Add ability to refresh musicbrainz data async

config/config.exs

@@ -81,7 +81,7 @@ config :error_tracker,
 
 config :music_library, Oban,
   engine: Oban.Engines.Lite,
-  queues: [default: 10, heavy_writes: 1],
+  queues: [default: 10, heavy_writes: 1, music_brainz: 1],
   repo: MusicLibrary.BackgroundRepo
 
 config :music_library, MusicLibrary.ErrorRepo, priv: "priv/error_repo"

lib/music_library/records.ex

@@ -236,6 +236,15 @@ defmodule MusicLibrary.Records do
     end
   end
 
+  def refresh_musicbrainz_data_async(record) do
+    meta = %{title: record.title, artists: Enum.map(record.artists, & &1.name)}
+    params = %{"id" => record.id}
+
+    params
+    |> Worker.RecordRefreshMusicBrainzData.new(meta: meta)
+    |> BackgroundRepo.insert()
+  end
+
   defp merge_releases(musicbrainz_id, musicbrainz_data) do
     with {:ok, releases} <- stream_releases(musicbrainz_id) do
       {:ok, Map.put(musicbrainz_data, "releases", releases)}

lib/music_library/records/batch.ex

@@ -14,6 +14,12 @@ defmodule MusicLibrary.Records.Batch do
     end)
   end
 
+  def refresh_musicbrainz_data_async do
+    run_on_all_records(fn record ->
+      Records.refresh_musicbrainz_data_async(record)
+    end)
+  end
+
   def refresh_old_artwork do
     run_on_all_records(&refresh_old_artwork/1)
   end

lib/music_library/worker/record_refresh_music_brainz_data.ex

@@ -0,0 +1,12 @@
+defmodule MusicLibrary.Worker.RecordRefreshMusicBrainzData do
+  use Oban.Worker, queue: :music_brainz, max_attempts: 3
+
+  @impl Oban.Worker
+  def perform(%Oban.Job{args: %{"id" => record_id}}) do
+    record = MusicLibrary.Records.get_record!(record_id)
+
+    with {:ok, updated_record} <- MusicLibrary.Records.refresh_musicbrainz_data(record) do
+      MusicLibrary.Records.notify_update(updated_record)
+    end
+  end
+end