Scaffold ResolveActivityObjectConflicts migration

1 files changed, 23 insertions, 0 deletions

diff --git a/priv/repo/migrations/20211218181640_resolve_activity_object_conflicts.exs b/priv/repo/migrations/20211218181640_resolve_activity_object_conflicts.exs
new file mode 100644
index 000000000..229d6fa28
--- /dev/null
+++ b/priv/repo/migrations/20211218181640_resolve_activity_object_conflicts.exs
@@ -0,0 +1,23 @@
+defmodule Pleroma.Repo.Migrations.ResolveActivityObjectConflicts do
+  @moduledoc """
+  Find objects with a conflicting activity ID, and update them.
+  """
+  use Ecto.Migration
+
+  alias Pleroma.Object
+  alias Pleroma.Migrators.Support.ObjectId
+  alias Pleroma.Repo
+
+  def up do
+    Object
+    |> join(:inner, [o], a in "activities", on: a.id == o.id)
+    |> Repo.stream()
+    |> Stream.each(fn object ->
+      # TODO
+    end)
+  end
+
+  def down do
+    :ok
+  end
+end