diff options
author | lain <lain@soykaf.club> | 2020-04-30 17:58:09 +0200 |
---|---|---|
committer | lain <lain@soykaf.club> | 2020-04-30 17:58:09 +0200 |
commit | c832d96fc9fc0b93befdf3a7064a8c9236e96d07 (patch) | |
tree | 0eb1e1038545475c96ed0c055c7653330a6b875e | |
parent | 4500fdc04c528331f7289745dc08a34ce18d4da7 (diff) | |
download | pleroma-c832d96fc9fc0b93befdf3a7064a8c9236e96d07.tar.gz |
SideEffects: Stream out deletes.
-rw-r--r-- | lib/pleroma/web/activity_pub/side_effects.ex | 6 |
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 |