X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fmix%2Ftasks%2Fpleroma%2Factivity.ex;h=3a79d8f206ded11728c788b1f051b2f26ba6c5bd;hb=6453297e9ce212279e7f6506bd04963092f48d77;hp=512897a02cb27aaa8d62d58e55451ce1ce6af85b;hpb=31b4acca618ba748facd477a89e1929dfb1fa18b;p=akkoma diff --git a/lib/mix/tasks/pleroma/activity.ex b/lib/mix/tasks/pleroma/activity.ex index 512897a02..3a79d8f20 100644 --- a/lib/mix/tasks/pleroma/activity.ex +++ b/lib/mix/tasks/pleroma/activity.ex @@ -4,19 +4,13 @@ defmodule Mix.Tasks.Pleroma.Activity do alias Pleroma.Activity - alias Pleroma.Activity.Search alias Pleroma.User alias Pleroma.Web.CommonAPI alias Pleroma.Pagination require Logger import Mix.Pleroma import Ecto.Query - @shortdoc "A collection of activity debug tasks" - @moduledoc """ - A collection of activity related tasks - mix pleroma.activity get - """ def run(["get", id | _rest]) do start_pleroma() @@ -28,18 +22,19 @@ defmodule Mix.Tasks.Pleroma.Activity do def run(["delete_by_keyword", user, keyword | _rest]) do start_pleroma() u = User.get_by_nickname(user) + Activity - |> Activity.with_preloaded_object() - |> Activity.restrict_deactivated_users() - |> Activity.Queries.by_author(u) - |> query_with(keyword) - |> Pagination.fetch_paginated( - %{"offset" => 0, "limit" => 20, "skip_order" => false}, - :offset - ) - |> Enum.map(fn x -> CommonAPI.delete(x.id, u) end) - |> Enum.count - |> IO.puts + |> Activity.with_preloaded_object() + |> Activity.restrict_deactivated_users() + |> Activity.Queries.by_author(u) + |> query_with(keyword) + |> Pagination.fetch_paginated( + %{"offset" => 0, "limit" => 20, "skip_order" => false}, + :offset + ) + |> Enum.map(fn x -> CommonAPI.delete(x.id, u) end) + |> Enum.count() + |> IO.puts() end defp query_with(q, search_query) do