diff options
author | Mark Felder <feld@feld.me> | 2024-01-21 14:57:15 -0500 |
---|---|---|
committer | Mark Felder <feld@feld.me> | 2024-01-22 18:37:13 -0500 |
commit | 6df93e61c4bb4ccacee7092cd20efe9add9a8500 (patch) | |
tree | 2b725dbaad72952e16ae22a0938843cd01c1fe1d | |
parent | 653b14e1c798bbddc34821fa56f32fef9c227f01 (diff) | |
download | pleroma-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.ex | 32 |
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 |