aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorlain <lain@soykaf.club>2020-04-30 15:57:27 +0200
committerlain <lain@soykaf.club>2020-04-30 15:57:27 +0200
commit417eed4a2b10b0a1fd916839ddb03d0345966123 (patch)
tree5762f9b03edd635bda125bd32e6f654f5710484c /lib
parent1fb383f368b861d7aea77770ba7be6e3dfe3468e (diff)
downloadpleroma-417eed4a2b10b0a1fd916839ddb03d0345966123.tar.gz
SideEffects: Handle deletions.
Diffstat (limited to 'lib')
-rw-r--r--lib/pleroma/web/activity_pub/side_effects.ex22
1 files changed, 20 insertions, 2 deletions
diff --git a/lib/pleroma/web/activity_pub/side_effects.ex b/lib/pleroma/web/activity_pub/side_effects.ex
index 93698a834..ac1d4c222 100644
--- a/lib/pleroma/web/activity_pub/side_effects.ex
+++ b/lib/pleroma/web/activity_pub/side_effects.ex
@@ -7,6 +7,7 @@ defmodule Pleroma.Web.ActivityPub.SideEffects do
"""
alias Pleroma.Notification
alias Pleroma.Object
+ alias Pleroma.User
alias Pleroma.Web.ActivityPub.Utils
def handle(object, meta \\ [])
@@ -33,10 +34,27 @@ defmodule Pleroma.Web.ActivityPub.SideEffects do
# - Replace object with Tombstone
# - Set up notification
def handle(%{data: %{"type" => "Delete", "object" => deleted_object}} = object, meta) do
- with %Object{} = deleted_object <- Object.normalize(deleted_object),
- {:ok, _, _} <- Object.delete(deleted_object) do
+ deleted_object =
+ Object.normalize(deleted_object, false) || User.get_cached_by_ap_id(deleted_object)
+
+ result =
+ case deleted_object do
+ %Object{} ->
+ with {:ok, _, _} <- Object.delete(deleted_object) do
+ :ok
+ end
+
+ %User{} ->
+ with {:ok, _} <- User.delete(deleted_object) do
+ :ok
+ end
+ end
+
+ if result == :ok do
Notification.create_notifications(object)
{:ok, object, meta}
+ else
+ {:error, result}
end
end