1 defmodule Pleroma.Repo.Migrations.AddFollowingAddressFromSourceData do
8 User.external_users_query()
9 |> select([u], struct(u, [:id, :ap_id, :info]))
11 Pleroma.Repo.stream(query)
13 %{info: %{source_data: source_data}} = user ->
14 Ecto.Changeset.cast(user, %{following_address: source_data["following"]}, [
17 |> Pleroma.Repo.update()