akkoma/lib/pleroma/application.ex

205 lines
5.4 KiB
Elixir
Raw Normal View History

# Pleroma: A lightweight social networking server
2018-12-31 15:41:47 +00:00
# Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
# SPDX-License-Identifier: AGPL-3.0-only
2017-03-17 16:09:58 +00:00
defmodule Pleroma.Application do
use Application
import Supervisor.Spec
2017-03-17 16:09:58 +00:00
@name Mix.Project.config()[:name]
2018-11-20 16:55:03 +00:00
@version Mix.Project.config()[:version]
@repository Mix.Project.config()[:source_url]
2018-11-20 16:55:03 +00:00
def name, do: @name
def version, do: @version
def named_version, do: @name <> " " <> @version
def repository, do: @repository
2018-11-20 16:55:03 +00:00
def user_agent do
2018-11-23 16:40:45 +00:00
info = "#{Pleroma.Web.base_url()} <#{Pleroma.Config.get([:instance, :email], "")}>"
named_version() <> "; " <> info
end
2017-03-17 16:09:58 +00:00
# See http://elixir-lang.org/docs/stable/elixir/Application.html
# for more information on OTP Applications
def start(_type, _args) do
import Cachex.Spec
2017-03-17 16:09:58 +00:00
Pleroma.Config.DeprecationWarnings.warn()
2019-01-30 15:32:30 +00:00
setup_instrumenters()
2019-01-28 11:09:41 +00:00
2017-03-17 16:09:58 +00:00
# Define workers and child supervisors to be supervised
2018-03-30 13:01:53 +00:00
children =
[
# Start the Ecto repository
supervisor(Pleroma.Repo, []),
worker(Pleroma.Emoji, []),
worker(Pleroma.Captcha, []),
worker(
Cachex,
[
:used_captcha_cache,
[
ttl_interval: :timer.seconds(Pleroma.Config.get!([Pleroma.Captcha, :seconds_valid]))
]
],
id: :cachex_used_captcha_cache
),
worker(
Cachex,
2018-03-30 13:01:53 +00:00
[
:user_cache,
[
default_ttl: 25_000,
ttl_interval: 1000,
limit: 2500
]
],
id: :cachex_user
),
worker(
Cachex,
2018-03-30 13:01:53 +00:00
[
:object_cache,
[
default_ttl: 25_000,
ttl_interval: 1000,
limit: 2500
]
],
id: :cachex_object
),
worker(
Cachex,
[
:rich_media_cache,
[
default_ttl: :timer.minutes(120),
limit: 5000
]
],
id: :cachex_rich_media
),
worker(
Cachex,
[
:scrubber_cache,
[
limit: 2500
]
],
id: :cachex_scrubber
),
worker(
Cachex,
[
:idempotency_cache,
[
expiration:
expiration(
default: :timer.seconds(6 * 60 * 60),
interval: :timer.seconds(60)
),
limit: 2500
]
],
id: :cachex_idem
),
worker(Pleroma.FlakeId, []),
2019-04-20 12:42:19 +00:00
worker(Pleroma.ScheduledActivityWorker, []),
worker(Pleroma.QuantumScheduler, [])
2018-03-30 13:01:53 +00:00
] ++
hackney_pool_children() ++
[
worker(Pleroma.Web.Federator.RetryQueue, []),
worker(Pleroma.Stats, []),
worker(Task, [&Pleroma.Web.Push.init/0], restart: :temporary, id: :web_push_init),
worker(Task, [&Pleroma.Web.Federator.init/0], restart: :temporary, id: :federator_init)
] ++
streamer_child() ++
chat_child() ++
[
# Start the endpoint when the application starts
supervisor(Pleroma.Web.Endpoint, []),
worker(Pleroma.Gopher.Server, [])
]
2017-03-17 16:09:58 +00:00
# See http://elixir-lang.org/docs/stable/elixir/Supervisor.html
# for other strategies and supported options
opts = [strategy: :one_for_one, name: Pleroma.Supervisor]
2019-04-20 12:42:19 +00:00
result = Supervisor.start_link(children, opts)
:ok = after_supervisor_start()
result
2017-03-17 16:09:58 +00:00
end
2019-04-04 17:36:57 +00:00
defp setup_instrumenters do
2019-03-25 08:29:04 +00:00
require Prometheus.Registry
:ok =
:telemetry.attach(
"prometheus-ecto",
[:pleroma, :repo, :query],
&Pleroma.Repo.Instrumenter.handle_event/4,
%{}
)
Prometheus.Registry.register_collector(:prometheus_process_collector)
Pleroma.Web.Endpoint.MetricsExporter.setup()
Pleroma.Web.Endpoint.PipelineInstrumenter.setup()
Pleroma.Web.Endpoint.Instrumenter.setup()
Pleroma.Repo.Instrumenter.setup()
end
def enabled_hackney_pools do
[:media] ++
if Application.get_env(:tesla, :adapter) == Tesla.Adapter.Hackney do
[:federation]
else
[]
end ++
if Pleroma.Config.get([Pleroma.Uploader, :proxy_remote]) do
2019-01-30 20:08:41 +00:00
[:upload]
else
[]
end
end
if Mix.env() == :test do
defp streamer_child, do: []
defp chat_child, do: []
else
defp streamer_child do
[worker(Pleroma.Web.Streamer, [])]
end
defp chat_child do
if Pleroma.Config.get([:chat, :enabled]) do
[worker(Pleroma.Web.ChatChannel.ChatChannelState, [])]
else
[]
end
end
end
defp hackney_pool_children do
for pool <- enabled_hackney_pools() do
options = Pleroma.Config.get([:hackney_pools, pool])
:hackney_pool.child_spec(pool, options)
end
end
2019-04-20 12:42:19 +00:00
defp after_supervisor_start() do
with digest_config <- Application.get_env(:pleroma, :email_notifications)[:digest],
true <- digest_config[:active],
%Crontab.CronExpression{} = schedule <-
Crontab.CronExpression.Parser.parse!(digest_config[:schedule]) do
Pleroma.QuantumScheduler.new_job()
|> Quantum.Job.set_name(:digest_emails)
|> Quantum.Job.set_schedule(schedule)
|> Quantum.Job.set_task(&Pleroma.DigestEmailWorker.run/0)
|> Pleroma.QuantumScheduler.add_job()
end
:ok
end
2017-03-17 16:09:58 +00:00
end