Task/add episodes to urls

lib/radiator/resources.ex

@@ -58,7 +58,6 @@ defmodule Radiator.Resources do
         Enum.map(url_attributes, fn attributes ->
           {:ok, url} =
             attributes
-            |> Map.put(:node_id, node_id)
             |> create_url()
 
           url

lib/radiator/resources/node_changed_worker.ex

@@ -16,11 +16,16 @@ defmodule Radiator.Resources.NodeChangedWorker do
 
   def perform(node_id) do
     analyzers = [Radiator.NodeAnalyzer.UrlAnalyzer]
+    node = NodeRepository.get_node!(node_id)
 
     url_attributes =
-      node_id
-      |> NodeRepository.get_node!()
+      node
       |> NodeAnalyzer.do_analyze(analyzers)
+      |> Enum.map(fn attributes ->
+        attributes
+        |> Map.put(:node_id, node_id)
+        |> Map.put(:episode_id, node.episode_id)
+      end)
 
     _created_urls = Resources.rebuild_node_urls(node_id, url_attributes)
     :ok

lib/radiator/resources/url.ex

@@ -31,13 +31,14 @@ defmodule Radiator.Resources.Url do
     embeds_one :meta_data, MetaData
 
     belongs_to :node, Radiator.Outline.Node, type: :binary_id, references: :uuid
+    belongs_to :episode, Radiator.Podcast.Episode
     timestamps(type: :utc_datetime)
   end
 
   @doc false
   def changeset(url, attrs) do
     url
-    |> cast(attrs, [:url, :start_bytes, :size_bytes, :node_id])
+    |> cast(attrs, [:url, :start_bytes, :size_bytes, :node_id, :episode_id])
     |> validate_required([:url, :start_bytes, :size_bytes, :node_id])
     |> cast_embed(:meta_data, with: &MetaData.changeset/2)
   end

priv/repo/migrations/20241222183518_add_episodes_to_urls.exs

@@ -0,0 +1,9 @@
+defmodule Radiator.Repo.Migrations.AddEpisodesToUrls do
+  use Ecto.Migration
+
+  def change do
+    alter table(:urls) do
+      add :episode_id, references(:episodes, on_delete: :nothing)
+    end
+  end
+end

test/radiator/podcast_test.exs

@@ -12,7 +12,7 @@ defmodule Radiator.PodcastTest do
 
     test "list_networks/0 returns all networks" do
       network = network_fixture()
-      assert Podcast.list_networks() == [network]
+      assert Enum.map(Podcast.list_networks(), fn n -> n.id end) == [network.id]
     end
 
     test "list_networks/1 returns all networks with preloaded shows" do

test/radiator/resources_test.exs

@@ -52,10 +52,17 @@ defmodule Radiator.ResourcesbTest do
       url_text = "https://hexdocs.pm"
       node = OutlineFixtures.node_fixture()
       old_url = url_fixture(node_id: node.uuid)
+      episode_id = node.episode_id
 
-      assert [%Url{url: ^url_text, start_bytes: 42, size_bytes: 42}] =
+      assert [%Url{url: ^url_text, start_bytes: 42, size_bytes: 42, episode_id: ^episode_id}] =
                Resources.rebuild_node_urls(node.uuid, [
-                 %{url: url_text, start_bytes: 42, size_bytes: 42}
+                 %{
+                   url: url_text,
+                   start_bytes: 42,
+                   size_bytes: 42,
+                   node_id: node.uuid,
+                   episode_id: episode_id
+                 }
                ])
 
       assert_raise Ecto.NoResultsError, fn -> Resources.get_url!(old_url.id) end

test/support/fixtures/resources_fixtures.ex

@@ -4,12 +4,14 @@ defmodule Radiator.ResourcesFixtures do
   entities via the `Radiator.Resources` context.
   """
   alias Radiator.OutlineFixtures
+  alias Radiator.PodcastFixtures
   alias Radiator.Resources
 
   @doc """
   Generate a url.
   """
   def url_fixture(attrs \\ %{}) do
+    episode_id = get_episode_id(attrs)
     node_id = get_node_id(attrs)
 
     {:ok, url} =
@@ -19,7 +21,8 @@ defmodule Radiator.ResourcesFixtures do
         start_bytes: 23,
         url: "https://elixirschool.com",
         meta_data: %{title: "Elixir School"},
-        node_id: node_id
+        node_id: node_id,
+        episode_id: episode_id
       })
       |> Resources.create_url()
 
@@ -28,4 +31,7 @@ defmodule Radiator.ResourcesFixtures do
 
   defp get_node_id(%{node_id: id}), do: id
   defp get_node_id(_), do: OutlineFixtures.node_fixture().uuid
+
+  defp get_episode_id(%{episode_id: id}), do: id
+  defp get_episode_id(_), do: PodcastFixtures.episode_fixture().id
 end