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