From ee808fb04177a93be35b1e5eee30dadf1989fa5c Mon Sep 17 00:00:00 2001
From: Claudio Ortolina <cloud8421@gmail.com>
Date: Sat, 24 May 2025 18:04:20 +0100
Subject: [PATCH] Add ability to refresh musicbrainz data async

---
 config/config.exs                                    |  2 +-
 lib/music_library/records.ex                         |  9 +++++++++
 lib/music_library/records/batch.ex                   |  6 ++++++
 .../worker/record_refresh_music_brainz_data.ex       | 12 ++++++++++++
 4 files changed, 28 insertions(+), 1 deletion(-)
 create mode 100644 lib/music_library/worker/record_refresh_music_brainz_data.ex

diff --git a/config/config.exs b/config/config.exs
index 4d657b24..dfb56b4a 100644
--- a/config/config.exs
+++ b/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"
diff --git a/lib/music_library/records.ex b/lib/music_library/records.ex
index 7105da37..31250051 100644
--- a/lib/music_library/records.ex
+++ b/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)}
diff --git a/lib/music_library/records/batch.ex b/lib/music_library/records/batch.ex
index d0d7c747..1c68a834 100644
--- a/lib/music_library/records/batch.ex
+++ b/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
diff --git a/lib/music_library/worker/record_refresh_music_brainz_data.ex b/lib/music_library/worker/record_refresh_music_brainz_data.ex
new file mode 100644
index 00000000..0d08abbe
--- /dev/null
+++ b/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