git.squeep.com Git - akkoma/blob - priv/repo/migrations/20190710125158_add_following_address_from_source_data.exs

   1 defmodule Pleroma.Repo.Migrations.AddFollowingAddressFromSourceData do
   2   use Ecto.Migration
   3   import Ecto.Query
   4   alias Pleroma.User
   5
   6   def change do
   7     query =
   8       User.external_users_query()
   9       |> select([u], struct(u, [:id, :ap_id, :info]))
  10
  11     Pleroma.Repo.stream(query)
  12     |> Enum.each(fn
  13       %{info: %{source_data: source_data}} = user ->
  14         Ecto.Changeset.cast(user, %{following_address: source_data["following"]}, [
  15           :following_address
  16         ])
  17         |> Pleroma.Repo.update()
  18     end)
  19   end
  20 end