forked from potsda.mn/mobilizon
150 lines
4.1 KiB
Elixir
150 lines
4.1 KiB
Elixir
defmodule Mobilizon do
|
|
@moduledoc """
|
|
Mobilizon is a decentralized and federated Meetup-like using
|
|
[ActivityPub](http://activitypub.rocks/).
|
|
|
|
It consists of an API server build with [Elixir](http://elixir-lang.github.io/)
|
|
and the [Phoenix Framework](https://hexdocs.pm/phoenix).
|
|
|
|
Mobilizon relies on `Guardian` for auth and `Geo`/Postgis for geographical
|
|
information.
|
|
"""
|
|
|
|
use Application
|
|
|
|
import Cachex.Spec
|
|
|
|
alias Mobilizon.{Config, Storage, Web}
|
|
alias Mobilizon.Federation.ActivityPub
|
|
alias Mobilizon.Service.{ErrorPage, ErrorReporting}
|
|
alias Mobilizon.Service.Export.{Feed, ICalendar}
|
|
|
|
@name Mix.Project.config()[:name]
|
|
@version Mix.Project.config()[:version]
|
|
@env Application.fetch_env!(:mobilizon, :env)
|
|
|
|
@spec named_version :: String.t()
|
|
def named_version, do: "#{@name} #{@version}"
|
|
|
|
@spec user_agent :: String.t()
|
|
def user_agent do
|
|
info = "#{Web.Endpoint.url()} <#{Config.get([:instance, :email], "")}>"
|
|
|
|
"#{named_version()}; #{info}"
|
|
end
|
|
|
|
@spec start(:normal | {:takeover, node} | {:failover, node}, term) ::
|
|
{:ok, pid} | {:ok, pid, term} | {:error, term}
|
|
def start(_type, _args) do
|
|
children =
|
|
[
|
|
# supervisors
|
|
Storage.Repo,
|
|
{Phoenix.PubSub, name: Mobilizon.PubSub},
|
|
Web.Endpoint,
|
|
{Absinthe.Subscription, Web.Endpoint},
|
|
{Oban, Application.get_env(:mobilizon, Oban)},
|
|
# workers
|
|
Guardian.DB.Token.SweeperServer,
|
|
ActivityPub.Federator,
|
|
cachex_spec(:feed, 2500, 60, 60, &Feed.create_cache/1),
|
|
cachex_spec(:ics, 2500, 60, 60, &ICalendar.create_cache/1),
|
|
cachex_spec(
|
|
:actor_key_rotation,
|
|
2500,
|
|
div(Application.get_env(:mobilizon, :activitypub)[:actor_key_rotation_delay], 60),
|
|
60 * 30
|
|
),
|
|
cachex_spec(:statistics, 10, 60, 60),
|
|
cachex_spec(:config, 10, 60, 60),
|
|
cachex_spec(:rich_media_cache, 10, 60, 60),
|
|
cachex_spec(:activity_pub, 2500, 3, 15),
|
|
%{
|
|
id: :cache_key_value,
|
|
start: {Cachex, :start_link, [:key_value]}
|
|
}
|
|
] ++
|
|
task_children(@env)
|
|
|
|
ErrorReporting.configure()
|
|
|
|
:ok = Oban.Telemetry.attach_default_logger()
|
|
|
|
:telemetry.attach_many(
|
|
"oban-errors",
|
|
[[:oban, :job, :exception], [:oban, :circuit, :trip]],
|
|
&ErrorReporting.handle_event/4,
|
|
%{}
|
|
)
|
|
|
|
Supervisor.start_link(children, strategy: :one_for_one, name: Mobilizon.Supervisor)
|
|
end
|
|
|
|
@spec config_change(keyword, keyword, [atom]) :: :ok
|
|
def config_change(changed, _new, removed) do
|
|
Web.Endpoint.config_change(changed, removed)
|
|
|
|
:ok
|
|
end
|
|
|
|
# sobelow_skip ["DOS.StringToAtom"]
|
|
@spec cachex_spec(atom, integer, integer, integer, function | nil) :: Supervisor.child_spec()
|
|
defp cachex_spec(name, limit, default, interval, fallback \\ nil) do
|
|
%{
|
|
id: String.to_atom("cache_#{to_string(name)}"),
|
|
start:
|
|
{Cachex, :start_link,
|
|
[
|
|
name,
|
|
Keyword.merge(
|
|
cachex_options(limit, default, interval),
|
|
fallback_options(fallback)
|
|
)
|
|
]}
|
|
}
|
|
end
|
|
|
|
@spec cachex_options(integer, integer, integer) :: keyword
|
|
defp cachex_options(limit, default, interval) do
|
|
[
|
|
limit: limit,
|
|
expiration:
|
|
expiration(
|
|
default: :timer.minutes(default),
|
|
interval: :timer.seconds(interval)
|
|
)
|
|
]
|
|
end
|
|
|
|
@spec fallback_options(function | nil) :: keyword
|
|
defp fallback_options(nil), do: []
|
|
defp fallback_options(fallback), do: [fallback: fallback(default: fallback)]
|
|
|
|
defp task_children(:test), do: []
|
|
defp task_children(_), do: [relay_actor(), anonymous_actor(), render_error_page()]
|
|
|
|
defp relay_actor do
|
|
%{
|
|
id: :relay_actor_init,
|
|
start: {Task, :start_link, [&ActivityPub.Relay.init/0]},
|
|
restart: :temporary
|
|
}
|
|
end
|
|
|
|
defp anonymous_actor do
|
|
%{
|
|
id: :anonymous_actor_init,
|
|
start: {Task, :start_link, [&Mobilizon.Config.anonymous_actor_id/0]},
|
|
restart: :temporary
|
|
}
|
|
end
|
|
|
|
defp render_error_page do
|
|
%{
|
|
id: :render_error_page_init,
|
|
start: {Task, :start_link, [&ErrorPage.init/0]},
|
|
restart: :temporary
|
|
}
|
|
end
|
|
end
|