add user delete_activities mix task

lib/mix/tasks/pleroma/user.ex

@@ -33,6 +33,10 @@ defmodule Mix.Tasks.Pleroma.User do
 
       mix pleroma.user rm NICKNAME
 
+  ## Delete the user's activities.
+
+      mix pleroma.user delete_activities NICKNAME
+
   ## Deactivate or activate the user's account.
 
       mix pleroma.user toggle_activated NICKNAME
@@ -309,7 +313,7 @@ defmodule Mix.Tasks.Pleroma.User do
 
     with %User{local: true} = user <- User.get_by_nickname(nickname) do
       User.delete_user_activities(user)
-      Mix.shell().info("User #{nickname} statuses deleted..")
+      Mix.shell().info("User #{nickname} statuses deleted.")
     else
       _ ->
         Mix.shell().error("No local user #{nickname}")

lib/pleroma/user.ex

@@ -1088,29 +1088,30 @@ defmodule Pleroma.User do
     # Remove all relationships
     {:ok, followers} = User.get_followers(user)
 
-    followers
+    Enum.each(followers, fn follower -> User.unfollow(follower, user) end)
-    |> Enum.each(fn follower -> User.unfollow(follower, user) end)
 
     {:ok, friends} = User.get_friends(user)
 
-    friends
+    Enum.each(friends, fn followed -> User.unfollow(user, followed) end)
-    |> Enum.each(fn followed -> User.unfollow(user, followed) end)
 
-    query =
+    delete_user_activities(user)
-      from(a in Activity, where: a.actor == ^user.ap_id)
+  end
-      |> Activity.with_preloaded_object()
 
-    Repo.all(query)
+  def delete_user_activities(%User{ap_id: ap_id} = user) do
-    |> Enum.each(fn activity ->
+    Activity
-      case activity.data["type"] do
+    |> where(actor: ^ap_id)
-        "Create" ->
+    |> Activity.with_preloaded_object()
-          ActivityPub.delete(Object.normalize(activity))
+    |> Repo.all()
+    |> Enum.each(fn
+      %{data: %{"type" => "Create"}} = activity ->
+        activity |> Object.normalize() |> ActivityPub.delete()
 
-        # TODO: Do something with likes, follows, repeats.
+      # TODO: Do something with likes, follows, repeats.
-        _ ->
+      _ ->
-          "Doing nothing"
+        "Doing nothing"
-      end
     end)
+
+    {:ok, user}
   end
 
   def html_filter_policy(%User{info: %{no_rich_text: true}}) do

test/tasks/user_test.exs

@@ -248,4 +248,14 @@ defmodule Mix.Tasks.Pleroma.UserTest do
       assert message =~ "Generated"
     end
   end
+
+  describe "running delete_activities" do
+    test "activities are deleted" do
+      %{nickname: nickname} = insert(:user)
+
+      assert :ok == Mix.Tasks.Pleroma.User.run(["delete_activities", nickname])
+      assert_received {:mix_shell, :info, [message]}
+      assert message == "User #{nickname} statuses deleted."
+    end
+  end
 end

test/user_test.exs

@@ -792,6 +792,16 @@ defmodule Pleroma.UserTest do
     assert false == user.info.deactivated
   end
 
+  test ".delete_user_activities deletes all create activities" do
+    user = insert(:user)
+
+    {:ok, activity} = CommonAPI.post(user, %{"status" => "2hu"})
+    {:ok, _} = User.delete_user_activities(user)
+
+    # TODO: Remove favorites, repeats, delete activities.
+    refute Activity.get_by_id(activity.id)
+  end
+
   test ".delete deactivates a user, all follow relationships and all create activities" do
     user = insert(:user)
     followed = insert(:user)