aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
Diffstat (limited to 'lib')
-rw-r--r--lib/pleroma/instances.ex16
-rw-r--r--lib/pleroma/instances/instance.ex6
2 files changed, 18 insertions, 4 deletions
diff --git a/lib/pleroma/instances.ex b/lib/pleroma/instances.ex
index 6d445d6b3..0b08f0eb8 100644
--- a/lib/pleroma/instances.ex
+++ b/lib/pleroma/instances.ex
@@ -8,8 +8,20 @@ defmodule Pleroma.Instances do
defdelegate set_reachable(url), to: @adapter
defdelegate set_unreachable(url, unreachable_since \\ nil), to: @adapter
- def reachability_time_threshold,
- do: NaiveDateTime.add(NaiveDateTime.utc_now(), -30 * 24 * 3600, :second)
+ def reachability_datetime_threshold do
+ federation_reachability_timeout_days =
+ Pleroma.Config.get(:instance)[:federation_reachability_timeout_days] || 90
+
+ if federation_reachability_timeout_days > 0 do
+ NaiveDateTime.add(
+ NaiveDateTime.utc_now(),
+ -federation_reachability_timeout_days * 24 * 3600,
+ :second
+ )
+ else
+ ~N[0000-01-01 00:00:00]
+ end
+ end
def host(url_or_host) when is_binary(url_or_host) do
if url_or_host =~ ~r/^http/i do
diff --git a/lib/pleroma/instances/instance.ex b/lib/pleroma/instances/instance.ex
index a17c8dab1..60e8d0e21 100644
--- a/lib/pleroma/instances/instance.ex
+++ b/lib/pleroma/instances/instance.ex
@@ -39,7 +39,8 @@ defmodule Pleroma.Instances.Instance do
Repo.all(
from(i in Instance,
where:
- i.host in ^hosts and i.unreachable_since <= ^Instances.reachability_time_threshold(),
+ i.host in ^hosts and
+ i.unreachable_since <= ^Instances.reachability_datetime_threshold(),
select: i.host
)
)
@@ -51,7 +52,8 @@ defmodule Pleroma.Instances.Instance do
!Repo.one(
from(i in Instance,
where:
- i.host == ^host(url) and i.unreachable_since <= ^Instances.reachability_time_threshold(),
+ i.host == ^host(url) and
+ i.unreachable_since <= ^Instances.reachability_datetime_threshold(),
select: true
)
)