projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
URI.encode custom emojis
[akkoma]
/
lib
/
pleroma
/
web
/
activity_pub
/
side_effects.ex
diff --git
a/lib/pleroma/web/activity_pub/side_effects.ex
b/lib/pleroma/web/activity_pub/side_effects.ex
index 55c99ad0cabf3da38ae35494fb192ba8b035f9a6..e37caf6a062b6a6d8334222d5ae3caf9539e0c4d 100644
(file)
--- a/
lib/pleroma/web/activity_pub/side_effects.ex
+++ b/
lib/pleroma/web/activity_pub/side_effects.ex
@@
-28,6
+28,8
@@
defmodule Pleroma.Web.ActivityPub.SideEffects do
require Logger
@cachex Pleroma.Config.get([:cachex, :provider], Cachex)
require Logger
@cachex Pleroma.Config.get([:cachex, :provider], Cachex)
+ @ap_streamer Pleroma.Config.get([:side_effects, :ap_streamer], ActivityPub)
+ @logger Pleroma.Config.get([:side_effects, :logger], Logger)
@behaviour Pleroma.Web.ActivityPub.SideEffects.Handling
@behaviour Pleroma.Web.ActivityPub.SideEffects.Handling
@@
-287,12
+289,12
@@
defmodule Pleroma.Web.ActivityPub.SideEffects do
MessageReference.delete_for_object(deleted_object)
MessageReference.delete_for_object(deleted_object)
-
ActivityPub
.stream_out(object)
-
ActivityPub
.stream_out_participations(deleted_object, user)
+
@ap_streamer
.stream_out(object)
+
@ap_streamer
.stream_out_participations(deleted_object, user)
:ok
else
{:actor, _} ->
:ok
else
{:actor, _} ->
-
L
ogger.error("The object doesn't have an actor: #{inspect(deleted_object)}")
+
@l
ogger.error("The object doesn't have an actor: #{inspect(deleted_object)}")
:no_object_actor
end
:no_object_actor
end