switch mix task to fetch

lib/mix/tasks/pleroma/user.ex

@@ -258,32 +258,26 @@ def run(["untag", nickname | tags]) do
     end
   end
 
-  def run(["broadcast_public_keys" | _rest]) do
+  def run(["refetch_public_keys" | _rest]) do
     start_pleroma()
 
     Pleroma.User.Query.build(%{
-      local: true,
+      external: true,
       is_active: true
     })
     |> Pleroma.Repo.chunk_stream(50, :batches)
     |> Stream.each(fn users ->
       users
       |> Enum.each(fn user ->
-        IO.puts("Broadcasting: #{user.ap_id}")
+        IO.puts("Re-Resolving: #{user.ap_id}")
-        changeset = User.update_changeset(user, %{keys: user.keys})
-        {:ok, unpersisted_user} = Ecto.Changeset.apply_action(changeset, :update)
 
-        updated_object =
+        with {:ok, user} <- Pleroma.User.fetch_by_ap_id(user.ap_id),
-          Pleroma.Web.ActivityPub.UserView.render("user.json", user: unpersisted_user)
+             changeset <- Pleroma.User.update_changeset(user),
-          |> Map.delete("@context")
+             {:ok, _user} <- Pleroma.User.update_and_set_cache(changeset) do
-
+          :ok
-        {:ok, update_data, []} = Builder.update(user, updated_object)
+        else
-
+          error -> IO.puts("Could not resolve: #{user.ap_id}, #{inspect(error)}")
-        {:ok, _update, _} =
+        end
-          Pipeline.common_pipeline(update_data,
-            local: true,
-            user_update_changeset: changeset
-          )
       end)
     end)
     |> Stream.run()