44 lines
1.2 KiB
Elixir
44 lines
1.2 KiB
Elixir
defmodule Mobilizon.Service.Workers.RefreshInstances do
|
|
@moduledoc """
|
|
Worker to refresh the instances materialized view and the relay actors
|
|
"""
|
|
|
|
use Oban.Worker, unique: [period: :infinity, keys: [:event_uuid, :action]]
|
|
|
|
alias Mobilizon.Actors.Actor
|
|
alias Mobilizon.Federation.ActivityPub.Actor, as: ActivityPubActor
|
|
alias Mobilizon.Federation.ActivityPub.Relay
|
|
alias Mobilizon.Instances
|
|
alias Mobilizon.Instances.Instance
|
|
alias Oban.Job
|
|
|
|
@impl Oban.Worker
|
|
@spec perform(Oban.Job.t()) :: :ok
|
|
def perform(%Job{}) do
|
|
Instances.refresh()
|
|
|
|
Instances.all_domains()
|
|
|> Enum.each(&refresh_instance_actor/1)
|
|
end
|
|
|
|
@spec refresh_instance_actor(Instance.t()) ::
|
|
{:ok, Mobilizon.Actors.Actor.t()}
|
|
| {:error,
|
|
ActivityPubActor.make_actor_errors()
|
|
| Mobilizon.Federation.WebFinger.finger_errors()}
|
|
def refresh_instance_actor(%Instance{domain: nil}) do
|
|
{:error, :not_remote_instance}
|
|
end
|
|
|
|
def refresh_instance_actor(%Instance{domain: domain}) do
|
|
%Actor{url: url} = Relay.get_actor()
|
|
%URI{host: host} = URI.new!(url)
|
|
|
|
if host == domain do
|
|
{:error, :not_remote_instance}
|
|
else
|
|
ActivityPubActor.find_or_make_actor_from_nickname("relay@#{domain}")
|
|
end
|
|
end
|
|
end
|