1 defmodule Pleroma.Instances.Instance do
4 alias Pleroma.Instances
5 alias Pleroma.Instances.Instance
9 import Ecto.{Query, Changeset}
15 field(:unreachable_since, :naive_datetime)
16 field(:reachability_checked_at, :naive_datetime)
21 defdelegate host(url), to: Instances
23 def changeset(struct, params \\ %{}) do
25 |> cast(params, [:host, :unreachable_since, :reachability_checked_at])
26 |> validate_required([:host])
27 |> unique_constraint(:host)
30 def filter_reachable([]), do: []
32 def filter_reachable(urls) when is_list(urls) do
35 |> Enum.map(&(&1 && host(&1)))
36 |> Enum.filter(&(to_string(&1) != ""))
42 i.host in ^hosts and i.unreachable_since <= ^Instances.reachability_time_threshold(),
47 Enum.filter(urls, &(&1 && host(&1) not in unreachable_hosts))
50 def reachable?(url) when is_binary(url) do
54 i.host == ^host(url) and i.unreachable_since <= ^Instances.reachability_time_threshold(),
60 def reachable?(_), do: true
62 def set_reachable(url) when is_binary(url) do
63 with host <- host(url),
64 %Instance{} = existing_record <- Repo.get_by(Instance, %{host: host}) do
67 |> changeset(%{unreachable_since: nil, reachability_checked_at: DateTime.utc_now()})
72 def set_reachable(_), do: {0, :noop}
74 def set_unreachable(url, unreachable_since \\ nil)
76 def set_unreachable(url, unreachable_since) when is_binary(url) do
77 unreachable_since = unreachable_since || DateTime.utc_now()
79 existing_record = Repo.get_by(Instance, %{host: host})
82 unreachable_since: unreachable_since,
83 reachability_checked_at: NaiveDateTime.utc_now()
88 if existing_record.unreachable_since &&
89 NaiveDateTime.compare(existing_record.unreachable_since, unreachable_since) != :gt,
90 do: Map.delete(changes, :unreachable_since),
95 |> changeset(update_changes)
100 |> changeset(Map.put(changes, :host, host))
105 def set_unreachable(_, _), do: {0, :noop}