diff options
| -rw-r--r-- | priv/repo/migrations/20211218181640_resolve_activity_object_conflicts.exs | 23 |
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 |