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