From 605ab12fb88b0048d410a65d8e4b42e64590eb5e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Martin=20W=C3=B6ginger?= <martin.woeginger@gmail.com>
Date: Tue, 17 Dec 2024 19:05:48 +0100
Subject: [PATCH] migration to create inbox and root containers for all shows
 and episodes and add all nodes to these containers

---
 ...dd_node_containers_to_existing_records.exs | 79 +++++++++++++++++++
 1 file changed, 79 insertions(+)
 create mode 100644 priv/repo/migrations/20241217180012_add_node_containers_to_existing_records.exs

diff --git a/priv/repo/migrations/20241217180012_add_node_containers_to_existing_records.exs b/priv/repo/migrations/20241217180012_add_node_containers_to_existing_records.exs
new file mode 100644
index 00000000..cf47a661
--- /dev/null
+++ b/priv/repo/migrations/20241217180012_add_node_containers_to_existing_records.exs
@@ -0,0 +1,79 @@
+defmodule Radiator.Repo.Migrations.AddNodeContainersToExistingRecords do
+  use Ecto.Migration
+
+  import Ecto.Query, warn: false
+  alias Radiator.Repo
+  alias Radiator.Outline.{Node, NodeContainer}
+  alias Radiator.Podcast.{Episode, Show}
+
+  def up do
+    # Disable automatic timestamps for this migration
+    Application.put_env(:radiator, :disable_timestamps, true)
+
+    # Add node containers to existing shows
+    Repo.all(Show)
+    |> Enum.each(fn show ->
+      # Create containers
+      {:ok, inbox} = %NodeContainer{} |> Repo.insert()
+      {:ok, outline} = %NodeContainer{} |> Repo.insert()
+
+      # Update show with containers
+      show
+      |> Ecto.Changeset.change(%{
+        inbox_node_container_id: inbox.id,
+        outline_node_container_id: outline.id
+      })
+      |> Repo.update!()
+
+      # Update all nodes belonging to this show
+      from(n in Node, where: n.show_id == ^show.id)
+      |> Repo.update_all(set: [outline_node_container_id: outline.id])
+    end)
+
+    # Add node containers to existing episodes
+    Repo.all(Episode)
+    |> Enum.each(fn episode ->
+      # Create containers
+      {:ok, inbox} = %NodeContainer{} |> Repo.insert()
+      {:ok, outline} = %NodeContainer{} |> Repo.insert()
+
+      # Update episode with containers
+      episode
+      |> Ecto.Changeset.change(%{
+        inbox_node_container_id: inbox.id,
+        outline_node_container_id: outline.id
+      })
+      |> Repo.update!()
+
+      # Update all nodes belonging to this episode
+      from(n in Node, where: n.episode_id == ^episode.id)
+      |> Repo.update_all(set: [outline_node_container_id: outline.id])
+    end)
+
+    # Re-enable automatic timestamps
+    Application.delete_env(:radiator, :disable_timestamps)
+  end
+
+  def down do
+    # In down migration, we'll remove the container associations but keep the containers
+    # to prevent data loss
+
+    # Remove container associations from shows
+    from(s in Show)
+    |> Repo.update_all(set: [
+      inbox_node_container_id: nil,
+      outline_node_container_id: nil
+    ])
+
+    # Remove container associations from episodes
+    from(e in Episode)
+    |> Repo.update_all(set: [
+      inbox_node_container_id: nil,
+      outline_node_container_id: nil
+    ])
+
+    # Remove container associations from nodes
+    from(n in Node)
+    |> Repo.update_all(set: [outline_node_container_id: nil])
+  end
+end