1 defmodule Pleroma.Repo.Migrations.AddFollowingAddressFromSourceData do
14 |> select([u], struct(u, [:id, :ap_id, :info]))
16 Pleroma.Repo.stream(query)
18 %{info: %{source_data: source_data}} = user ->
19 Ecto.Changeset.cast(user, %{following_address: source_data["following"]}, [
22 |> Pleroma.Repo.update()
25 Logger.warn("User #{user.id} / #{user.nickname} does not seem to have source_data")