X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fmix%2Ftasks%2Fpleroma%2Factivity.ex;h=84b9c16f9dd331f96a44c4ecc35308381130d46c;hb=9be6caf125f93ce8547a5f808681253131c32148;hp=512897a02cb27aaa8d62d58e55451ce1ce6af85b;hpb=31b4acca618ba748facd477a89e1929dfb1fa18b;p=akkoma diff --git a/lib/mix/tasks/pleroma/activity.ex b/lib/mix/tasks/pleroma/activity.ex index 512897a02..84b9c16f9 100644 --- a/lib/mix/tasks/pleroma/activity.ex +++ b/lib/mix/tasks/pleroma/activity.ex @@ -1,22 +1,17 @@ +# credo:disable-for-this-file # Pleroma: A lightweight social networking server # Copyright © 2017-2018 Pleroma Authors # SPDX-License-Identifier: AGPL-3.0-only 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 +23,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