X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fmix%2Fpleroma.ex;h=4eff378599657b9bb1d480835e45683fc6659ad2;hb=364b6969eb7c79e57ed02345ddff4f48519e6b0a;hp=6df1cf538156a3ddf7bed446b9e36ed0f0e361d9;hpb=0a5b22bc3b1a0011b83e1a77f4f58700266c260a;p=akkoma diff --git a/lib/mix/pleroma.ex b/lib/mix/pleroma.ex index 6df1cf538..4eff37859 100644 --- a/lib/mix/pleroma.ex +++ b/lib/mix/pleroma.ex @@ -1,5 +1,5 @@ # Pleroma: A lightweight social networking server -# Copyright © 2017-2020 Pleroma Authors +# Copyright © 2017-2021 Pleroma Authors # SPDX-License-Identifier: AGPL-3.0-only defmodule Mix.Pleroma do @@ -12,7 +12,9 @@ defmodule Mix.Pleroma do :cachex, :flake_id, :swoosh, - :timex + :timex, + :fast_html, + :oban ] @cachex_children ["object", "user", "scrubber", "web_resp"] @doc "Common functions to be reused in mix tasks" @@ -21,30 +23,34 @@ defmodule Mix.Pleroma do Pleroma.Config.Oban.warn() Pleroma.Application.limiters_setup() Application.put_env(:phoenix, :serve_endpoints, false, persistent: true) + Finch.start_link(name: MyFinch) - if Pleroma.Config.get(:env) != :test do - Application.put_env(:logger, :console, level: :debug) - end - adapter = Application.get_env(:tesla, :adapter) + unless System.get_env("DEBUG") do + Logger.remove_backend(:console) + end - apps = - if adapter == Tesla.Adapter.Gun do - [:gun | @apps] - else - [:hackney | @apps] - end + Enum.each(@apps, &Application.ensure_all_started/1) - Enum.each(apps, &Application.ensure_all_started/1) + oban_config = [ + crontab: [], + repo: Pleroma.Repo, + log: false, + queues: [], + plugins: [] + ] children = [ Pleroma.Repo, + Pleroma.Emoji, {Pleroma.Config.TransferTask, false}, Pleroma.Web.Endpoint, - {Oban, Pleroma.Config.get(Oban)} + {Oban, oban_config}, + {Majic.Pool, + [name: Pleroma.MajicPool, pool_size: Pleroma.Config.get([:majic_pool, :size], 2)]} ] ++ - http_children(adapter) + elasticsearch_children() cachex_children = Enum.map(@cachex_children, &Pleroma.Application.build_cachex(&1, [])) @@ -98,12 +104,6 @@ defmodule Mix.Pleroma do end end - def shell_yes?(message) do - if mix_shell?(), - do: Mix.shell().yes?("Continue?"), - else: shell_prompt(message, "Continue?") in ~w(Yn Y y) - end - def shell_info(message) do if mix_shell?(), do: Mix.shell().info(message), @@ -123,10 +123,13 @@ defmodule Mix.Pleroma do ~S(') <> String.replace(path, ~S('), ~S(\')) <> ~S(') end - defp http_children(Tesla.Adapter.Gun) do - Pleroma.Gun.ConnectionPool.children() ++ - [{Task, &Pleroma.HTTP.AdapterHelper.Gun.limiter_setup/0}] - end + def elasticsearch_children do + config = Pleroma.Config.get([Pleroma.Search, :module]) - defp http_children(_), do: [] + if config == Pleroma.Search.Elasticsearch do + [Pleroma.Search.Elasticsearch.Cluster] + else + [] + end + end end