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)
20 defdelegate host(url_or_host), to: Instances
22 def changeset(struct, params \\ %{}) do
24 |> cast(params, [:host, :unreachable_since])
25 |> validate_required([:host])
26 |> unique_constraint(:host)
29 def filter_reachable([]), do: []
31 def filter_reachable(urls_or_hosts) when is_list(urls_or_hosts) do
34 |> Enum.map(&(&1 && host(&1)))
35 |> Enum.filter(&(to_string(&1) != ""))
42 i.unreachable_since <= ^Instances.reachability_datetime_threshold(),
47 Enum.filter(urls_or_hosts, &(&1 && host(&1) not in unreachable_hosts))
50 def reachable?(url_or_host) when is_binary(url_or_host) do
54 i.host == ^host(url_or_host) and
55 i.unreachable_since <= ^Instances.reachability_datetime_threshold(),
61 def reachable?(_), do: true
63 def set_reachable(url_or_host) when is_binary(url_or_host) do
64 with host <- host(url_or_host),
65 %Instance{} = existing_record <- Repo.get_by(Instance, %{host: host}) do
68 |> changeset(%{unreachable_since: nil})
73 def set_reachable(_), do: {:error, nil}
75 def set_unreachable(url_or_host, unreachable_since \\ nil)
77 def set_unreachable(url_or_host, unreachable_since) when is_binary(url_or_host) do
78 unreachable_since = unreachable_since || DateTime.utc_now()
79 host = host(url_or_host)
80 existing_record = Repo.get_by(Instance, %{host: host})
82 changes = %{unreachable_since: unreachable_since}
85 is_nil(existing_record) ->
87 |> changeset(Map.put(changes, :host, host))
90 existing_record.unreachable_since &&
91 NaiveDateTime.compare(existing_record.unreachable_since, unreachable_since) != :gt ->
92 {:ok, existing_record}
101 def set_unreachable(_, _), do: {:error, nil}