diff options
| author | Alex Gleason <alex@alexgleason.me> | 2021-05-21 18:14:07 -0500 |
|---|---|---|
| committer | Alex Gleason <alex@alexgleason.me> | 2021-05-21 18:14:07 -0500 |
| commit | 5314718891a1e9d3605b2f2a26696cbd574f335d (patch) | |
| tree | 4d840ae8f8c02ae997991635c03fe8d93fec9d57 | |
| parent | bf8d35d773a8d5b2f989e267acef4e053ac4c314 (diff) | |
Cycles: use runtime deps in lib/pleroma/web/activity_pub/side_effects.ex
| -rw-r--r-- | lib/pleroma/web/activity_pub/side_effects.ex | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/lib/pleroma/web/activity_pub/side_effects.ex b/lib/pleroma/web/activity_pub/side_effects.ex index 0b9a9f0c5..c32f800ce 100644 --- a/lib/pleroma/web/activity_pub/side_effects.ex +++ b/lib/pleroma/web/activity_pub/side_effects.ex @@ -28,11 +28,13 @@ defmodule Pleroma.Web.ActivityPub.SideEffects do require Logger @cachex Pleroma.Config.get([:cachex, :provider], Cachex) - @ap_streamer Pleroma.Config.get([:side_effects, :ap_streamer], ActivityPub) + @ap_streamer Pleroma.Config.get([:side_effects, :ap_streamer]) @logger Pleroma.Config.get([:side_effects, :logger], Logger) @behaviour Pleroma.Web.ActivityPub.SideEffects.Handling + defp ap_streamer(), do: @ap_streamer || ActivityPub + @impl true def handle(object, meta \\ []) @@ -289,8 +291,8 @@ defmodule Pleroma.Web.ActivityPub.SideEffects do MessageReference.delete_for_object(deleted_object) - @ap_streamer.stream_out(object) - @ap_streamer.stream_out_participations(deleted_object, user) + ap_streamer().stream_out(object) + ap_streamer().stream_out_participations(deleted_object, user) :ok else {:actor, _} -> |