aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorlain <lain@soykaf.club>2020-05-21 12:43:09 +0200
committerlain <lain@soykaf.club>2020-05-21 12:43:09 +0200
commitd9d425708e094a428fb05127b97480a122c1c616 (patch)
tree72d48adbb0b3e074b8d46b63ee48c94d3448b8c2 /lib
parent39031f4860c91dee9418f69cc3b295cdfc9316bd (diff)
downloadpleroma-d9d425708e094a428fb05127b97480a122c1c616.tar.gz
SideEffects: Builed out Announce effects.
Diffstat (limited to 'lib')
-rw-r--r--lib/pleroma/web/activity_pub/side_effects.ex8
1 files changed, 7 insertions, 1 deletions
diff --git a/lib/pleroma/web/activity_pub/side_effects.ex b/lib/pleroma/web/activity_pub/side_effects.ex
index bc0d31c45..66aa1f628 100644
--- a/lib/pleroma/web/activity_pub/side_effects.ex
+++ b/lib/pleroma/web/activity_pub/side_effects.ex
@@ -11,6 +11,7 @@ defmodule Pleroma.Web.ActivityPub.SideEffects do
alias Pleroma.Repo
alias Pleroma.User
alias Pleroma.Web.ActivityPub.ActivityPub
+ alias Pleroma.Web.ActivityPub.Visibility
alias Pleroma.Web.ActivityPub.Utils
def handle(object, meta \\ [])
@@ -30,11 +31,16 @@ defmodule Pleroma.Web.ActivityPub.SideEffects do
# Tasks this handles:
# - Add announce to object
# - Set up notification
+ # - Stream out the announce
def handle(%{data: %{"type" => "Announce"}} = object, meta) do
announced_object = Object.get_by_ap_id(object.data["object"])
- Utils.add_announce_to_object(object, announced_object)
+
+ if Visibility.is_public?(object) do
+ Utils.add_announce_to_object(object, announced_object)
+ end
Notification.create_notifications(object)
+ ActivityPub.stream_out(object)
{:ok, object, meta}
end