projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'cleanup/unused-proxy-opts' into 'develop'
[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 679ea1a4d5df7679b4c99206aefe41bb2d6e5e74..76287f2744e2da71b113314749fade022be1c203 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