summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMark Felder <feld@feld.me>2024-01-21 14:57:15 -0500
committerMark Felder <feld@feld.me>2024-01-22 18:37:13 -0500
commit6df93e61c4bb4ccacee7092cd20efe9add9a8500 (patch)
tree2b725dbaad72952e16ae22a0938843cd01c1fe1d
parent653b14e1c798bbddc34821fa56f32fef9c227f01 (diff)
downloadpleroma-6df93e61c4bb4ccacee7092cd20efe9add9a8500.tar.gz
pleroma-6df93e61c4bb4ccacee7092cd20efe9add9a8500.zip
Use config to determine sending to the streamer registry instead of MIX_ENV compile time function definition
-rw-r--r--lib/pleroma/web/streamer.ex32
1 files changed, 13 insertions, 19 deletions
diff --git a/lib/pleroma/web/streamer.ex b/lib/pleroma/web/streamer.ex
index 0c9f04f82..35c015e24 100644
--- a/lib/pleroma/web/streamer.ex
+++ b/lib/pleroma/web/streamer.ex
@@ -20,7 +20,6 @@ defmodule Pleroma.Web.Streamer do
alias Pleroma.Web.Plugs.OAuthScopesPlug
alias Pleroma.Web.StreamerView
- @mix_env Mix.env()
@registry Pleroma.Web.StreamerRegistry
def registry, do: @registry
@@ -396,25 +395,20 @@ defmodule Pleroma.Web.Streamer do
end
end
- # In test environment, only return true if the registry is started.
- # In benchmark environment, returns false.
- # In any other environment, always returns true.
- cond do
- @mix_env == :test ->
- def should_env_send? do
- case Process.whereis(@registry) do
- nil ->
- false
+ # In dev/prod the streamer registry is expected to be started, so return true
+ # In test it is possible to have the registry started for a test so it will check
+ # In benchmark it will never find the process alive and return false
+ def should_env_send? do
+ if Application.get_env(:pleroma, Pleroma.Application)[:streamer_registry] do
+ true
+ else
+ case Process.whereis(@registry) do
+ nil ->
+ false
- pid ->
- Process.alive?(pid)
- end
+ pid ->
+ Process.alive?(pid)
end
-
- @mix_env == :benchmark ->
- def should_env_send?, do: false
-
- true ->
- def should_env_send?, do: true
+ end
end
end