aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorlain <lain@soykaf.club>2020-04-30 17:58:09 +0200
committerlain <lain@soykaf.club>2020-04-30 17:58:09 +0200
commitc832d96fc9fc0b93befdf3a7064a8c9236e96d07 (patch)
tree0eb1e1038545475c96ed0c055c7653330a6b875e
parent4500fdc04c528331f7289745dc08a34ce18d4da7 (diff)
downloadpleroma-c832d96fc9fc0b93befdf3a7064a8c9236e96d07.tar.gz
SideEffects: Stream out deletes.
-rw-r--r--lib/pleroma/web/activity_pub/side_effects.ex6
1 files changed, 5 insertions, 1 deletions
diff --git a/lib/pleroma/web/activity_pub/side_effects.ex b/lib/pleroma/web/activity_pub/side_effects.ex
index ef58fa399..d260e0069 100644
--- a/lib/pleroma/web/activity_pub/side_effects.ex
+++ b/lib/pleroma/web/activity_pub/side_effects.ex
@@ -9,6 +9,7 @@ defmodule Pleroma.Web.ActivityPub.SideEffects do
alias Pleroma.Object
alias Pleroma.User
alias Pleroma.Web.ActivityPub.Utils
+ alias Pleroma.Web.ActivityPub.ActivityPub
def handle(object, meta \\ [])
@@ -40,9 +41,12 @@ defmodule Pleroma.Web.ActivityPub.SideEffects do
result =
case deleted_object do
%Object{} ->
- with {:ok, _, activity} <- Object.delete(deleted_object),
+ with {:ok, deleted_object, activity} <- Object.delete(deleted_object),
%User{} = user <- User.get_cached_by_ap_id(deleted_object.data["actor"]) do
User.remove_pinnned_activity(user, activity)
+
+ ActivityPub.stream_out(object)
+ ActivityPub.stream_out_participations(deleted_object, user)
:ok
end