X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fmix%2Ftasks%2Ffix_ap_users.ex;h=7e970850e12ac115fe684032eb168c1b04690667;hb=79d41aa12e900423a9717187a94faceec7f014fd;hp=ae34757775cafb88b797c34996145fecedc17d5c;hpb=42f30d67fa298212e85b9d2fd73de287255d8e8b;p=akkoma diff --git a/lib/mix/tasks/fix_ap_users.ex b/lib/mix/tasks/fix_ap_users.ex index ae3475777..7e970850e 100644 --- a/lib/mix/tasks/fix_ap_users.ex +++ b/lib/mix/tasks/fix_ap_users.ex @@ -1,6 +1,5 @@ defmodule Mix.Tasks.FixApUsers do use Mix.Task - import Mix.Ecto import Ecto.Query alias Pleroma.{Repo, User} @@ -8,11 +7,16 @@ defmodule Mix.Tasks.FixApUsers do def run([]) do Mix.Task.run("app.start") - q = from u in User, - where: fragment("? @> ?", u.info, ^%{"ap_enabled" => true}) + q = + from( + u in User, + where: fragment("? @> ?", u.info, ^%{"ap_enabled" => true}), + where: u.local == false + ) + users = Repo.all(q) - Enum.each(users, fn(user) -> + Enum.each(users, fn user -> try do IO.puts("Fetching #{user.nickname}") Pleroma.Web.ActivityPub.Transmogrifier.upgrade_user_from_ap_id(user.ap_id, false)