mirror of
https://github.com/wanderer-industries/wanderer
synced 2026-04-30 22:40:30 +00:00
Dmitry Popov
453 lines
16 KiB
Elixir
453 lines
16 KiB
Elixir
import Config
|
||
import WandererApp.ConfigHelpers
|
||
|
||
if System.get_env("PHX_SERVER") do
|
||
config :wanderer_app, WandererAppWeb.Endpoint, server: true
|
||
end
|
||
|
||
config_dir = System.get_env("CONFIG_DIR", "/run/secrets")
|
||
|
||
app_name = System.get_env("FLY_APP_NAME", "NOT_FLY_APP")
|
||
|
||
host =
|
||
case app_name == "NOT_FLY_APP" do
|
||
true -> System.get_env("PHX_HOST", "localhost")
|
||
_ -> "#{app_name}.fly.dev"
|
||
end
|
||
|
||
web_port =
|
||
System.get_env(
|
||
"PORT",
|
||
case config_env() do
|
||
:test -> "5000"
|
||
_env -> "8000"
|
||
end
|
||
)
|
||
|> String.to_integer()
|
||
|
||
web_app_url =
|
||
case app_name == "NOT_FLY_APP" do
|
||
true -> System.get_env("WEB_APP_URL", "http://#{host}:#{web_port}")
|
||
_ -> "https://#{host}"
|
||
end
|
||
|
||
base_url = URI.parse(web_app_url)
|
||
|
||
if base_url.scheme not in ["http", "https"] do
|
||
raise "WEB_APP_URL must start with `http` or `https`. Currently configured as `#{System.get_env("WEB_APP_URL")}`"
|
||
end
|
||
|
||
http_port = System.get_env("HTTP_PORT", "80") |> String.to_integer()
|
||
https_port = System.get_env("HTTPS_PORT", "443") |> String.to_integer()
|
||
|
||
port =
|
||
case app_name == "NOT_FLY_APP" do
|
||
true -> System.get_env("WEB_EXTERNAL_PORT", "#{web_port}") |> String.to_integer()
|
||
_ -> http_port
|
||
end
|
||
|
||
scheme = System.get_env("WEB_EXTERNAL_SCHEME", "http")
|
||
|
||
public_api_disabled =
|
||
config_dir
|
||
|> get_var_from_path_or_env("WANDERER_PUBLIC_API_DISABLED", "false")
|
||
|> String.to_existing_atom()
|
||
|
||
character_api_disabled =
|
||
config_dir
|
||
|> get_var_from_path_or_env("WANDERER_CHARACTER_API_DISABLED", "true")
|
||
|> String.to_existing_atom()
|
||
|
||
wanderer_kills_service_enabled =
|
||
config_dir
|
||
|> get_var_from_path_or_env("WANDERER_KILLS_SERVICE_ENABLED", "false")
|
||
|> String.to_existing_atom()
|
||
|
||
wanderer_kills_base_url =
|
||
config_dir
|
||
|> get_var_from_path_or_env("WANDERER_KILLS_BASE_URL", "ws://wanderer-kills:4004")
|
||
|
||
map_subscriptions_enabled =
|
||
config_dir
|
||
|> get_var_from_path_or_env("WANDERER_MAP_SUBSCRIPTIONS_ENABLED", "false")
|
||
|> String.to_existing_atom()
|
||
|
||
map_subscription_characters_limit =
|
||
config_dir
|
||
|> get_int_from_path_or_env("WANDERER_MAP_SUBSCRIPTION_CHARACTERS_LIMIT", 10_000)
|
||
|
||
map_subscription_hubs_limit =
|
||
config_dir
|
||
|> get_int_from_path_or_env("WANDERER_MAP_SUBSCRIPTION_HUBS_LIMIT", 10)
|
||
|
||
map_subscription_base_price =
|
||
config_dir
|
||
|> get_int_from_path_or_env("WANDERER_MAP_SUBSCRIPTION_BASE_PRICE", 100_000_000)
|
||
|
||
map_subscription_extra_characters_50_price =
|
||
config_dir
|
||
|> get_int_from_path_or_env("WANDERER_MAP_SUBSCRIPTION_EXTRA_CHARACTERS_50_PRICE", 50_000_000)
|
||
|
||
map_subscription_extra_hubs_10_price =
|
||
config_dir
|
||
|> get_int_from_path_or_env("WANDERER_MAP_SUBSCRIPTION_EXTRA_HUBS_10_PRICE", 10_000_000)
|
||
|
||
map_connection_auto_expire_hours =
|
||
config_dir
|
||
|> get_int_from_path_or_env("WANDERER_MAP_CONNECTION_AUTO_EXPIRE_HOURS", 24)
|
||
|
||
map_connection_auto_eol_hours =
|
||
config_dir
|
||
|> get_int_from_path_or_env("WANDERER_MAP_CONNECTION_AUTO_EOL_HOURS", 21)
|
||
|
||
map_connection_eol_expire_timeout_mins =
|
||
config_dir
|
||
|> get_int_from_path_or_env("WANDERER_MAP_CONNECTION_EOL_EXPIRE_TIMEOUT_MINS", 60)
|
||
|
||
wallet_tracking_enabled =
|
||
config_dir
|
||
|> get_var_from_path_or_env("WANDERER_WALLET_TRACKING_ENABLED", "false")
|
||
|> String.to_existing_atom()
|
||
|
||
admins =
|
||
System.get_env("WANDERER_ADMINS", "")
|
||
|> case do
|
||
"" -> []
|
||
admins -> admins |> String.split(",")
|
||
end
|
||
|
||
restrict_maps_creation =
|
||
config_dir
|
||
|> get_var_from_path_or_env("WANDERER_RESTRICT_MAPS_CREATION", "false")
|
||
|> String.to_existing_atom()
|
||
|
||
restrict_acls_creation =
|
||
config_dir
|
||
|> get_var_from_path_or_env("WANDERER_RESTRICT_ACLS_CREATION", "false")
|
||
|> String.to_existing_atom()
|
||
|
||
config :wanderer_app,
|
||
web_app_url: web_app_url,
|
||
git_sha: System.get_env("GIT_SHA", "111"),
|
||
custom_route_base_url: System.get_env("CUSTOM_ROUTE_BASE_URL"),
|
||
invites: System.get_env("WANDERER_INVITES", "false") |> String.to_existing_atom(),
|
||
admin_username: System.get_env("WANDERER_ADMIN_USERNAME", "admin"),
|
||
admin_password: System.get_env("WANDERER_ADMIN_PASSWORD"),
|
||
admins: admins,
|
||
base_metrics_only:
|
||
System.get_env("WANDERER_BASE_METRICS_ONLY", "false") |> String.to_existing_atom(),
|
||
corp_id: System.get_env("WANDERER_CORP_ID", "-1") |> String.to_integer(),
|
||
corp_wallet: System.get_env("WANDERER_CORP_WALLET", ""),
|
||
corp_wallet_eve_id: System.get_env("WANDERER_CORP_WALLET_EVE_ID", "-1"),
|
||
public_api_disabled: public_api_disabled,
|
||
active_tracking_pool: System.get_env("WANDERER_ACTIVE_TRACKING_POOL", "default"),
|
||
tracking_pool_max_size:
|
||
System.get_env("WANDERER_TRACKING_POOL_MAX_SIZE", "300") |> String.to_integer(),
|
||
character_tracking_pause_disabled:
|
||
System.get_env("WANDERER_CHARACTER_TRACKING_PAUSE_DISABLED", "true")
|
||
|> String.to_existing_atom(),
|
||
character_api_disabled: character_api_disabled,
|
||
wanderer_kills_service_enabled: wanderer_kills_service_enabled,
|
||
wanderer_kills_base_url: wanderer_kills_base_url,
|
||
map_subscriptions_enabled: map_subscriptions_enabled,
|
||
map_connection_auto_expire_hours: map_connection_auto_expire_hours,
|
||
map_connection_auto_eol_hours: map_connection_auto_eol_hours,
|
||
map_connection_eol_expire_timeout_mins: map_connection_eol_expire_timeout_mins,
|
||
wallet_tracking_enabled: wallet_tracking_enabled,
|
||
restrict_maps_creation: restrict_maps_creation,
|
||
restrict_acls_creation: restrict_acls_creation,
|
||
subscription_settings: %{
|
||
plans: [
|
||
%{
|
||
id: "alpha",
|
||
characters_limit: map_subscription_characters_limit,
|
||
hubs_limit: map_subscription_hubs_limit,
|
||
base_price: 0,
|
||
monthly_discount: 0
|
||
},
|
||
%{
|
||
id: "omega",
|
||
characters_limit: map_subscription_characters_limit * 2,
|
||
hubs_limit: map_subscription_hubs_limit * 2,
|
||
base_price: map_subscription_base_price,
|
||
month_3_discount: 0.2,
|
||
month_6_discount: 0.4,
|
||
month_12_discount: 0.5
|
||
}
|
||
],
|
||
extra_characters_50: map_subscription_extra_characters_50_price,
|
||
extra_hubs_10: map_subscription_extra_hubs_10_price
|
||
},
|
||
# Finch pool configuration - separate pools for different services
|
||
# ESI Character Tracking pool - high capacity for bulk character operations
|
||
# With 30+ TrackerPools × ~100 concurrent tasks, need large pool
|
||
finch_esi_character_pool_size:
|
||
System.get_env("WANDERER_FINCH_ESI_CHARACTER_POOL_SIZE", "200") |> String.to_integer(),
|
||
finch_esi_character_pool_count:
|
||
System.get_env("WANDERER_FINCH_ESI_CHARACTER_POOL_COUNT", "4") |> String.to_integer(),
|
||
# ESI General pool - standard capacity for general ESI operations
|
||
finch_esi_general_pool_size:
|
||
System.get_env("WANDERER_FINCH_ESI_GENERAL_POOL_SIZE", "50") |> String.to_integer(),
|
||
finch_esi_general_pool_count:
|
||
System.get_env("WANDERER_FINCH_ESI_GENERAL_POOL_COUNT", "4") |> String.to_integer(),
|
||
# Webhooks pool - isolated from ESI rate limits
|
||
finch_webhooks_pool_size:
|
||
System.get_env("WANDERER_FINCH_WEBHOOKS_POOL_SIZE", "25") |> String.to_integer(),
|
||
finch_webhooks_pool_count:
|
||
System.get_env("WANDERER_FINCH_WEBHOOKS_POOL_COUNT", "2") |> String.to_integer(),
|
||
# Default pool - everything else (email, license manager, etc.)
|
||
finch_default_pool_size:
|
||
System.get_env("WANDERER_FINCH_DEFAULT_POOL_SIZE", "25") |> String.to_integer(),
|
||
finch_default_pool_count:
|
||
System.get_env("WANDERER_FINCH_DEFAULT_POOL_COUNT", "2") |> String.to_integer(),
|
||
# Character tracker concurrency settings
|
||
# Location updates need high concurrency for <2s response with 3000+ characters
|
||
location_concurrency:
|
||
System.get_env("WANDERER_LOCATION_CONCURRENCY", "#{System.schedulers_online() * 12}")
|
||
|> String.to_integer()
|
||
|
||
config :ueberauth, Ueberauth,
|
||
providers: [
|
||
eve:
|
||
{WandererApp.Ueberauth.Strategy.Eve,
|
||
[
|
||
default_scope:
|
||
"esi-location.read_location.v1 esi-location.read_ship_type.v1 esi-location.read_online.v1 esi-ui.write_waypoint.v1 esi-search.search_structures.v1",
|
||
wallet_scope:
|
||
"esi-location.read_location.v1 esi-location.read_ship_type.v1 esi-location.read_online.v1 esi-ui.write_waypoint.v1 esi-search.search_structures.v1 esi-wallet.read_character_wallet.v1",
|
||
admin_scope:
|
||
"esi-location.read_location.v1 esi-location.read_ship_type.v1 esi-location.read_online.v1 esi-ui.write_waypoint.v1 esi-search.search_structures.v1 esi-wallet.read_character_wallet.v1 esi-wallet.read_corporation_wallets.v1 esi-mail.send_mail.v1",
|
||
callback_url: "#{web_app_url}/auth/eve/callback"
|
||
]}
|
||
]
|
||
|
||
config :ueberauth, WandererApp.Ueberauth.Strategy.Eve.OAuth,
|
||
client_id: {WandererApp.Ueberauth, :client_id},
|
||
client_secret: {WandererApp.Ueberauth, :client_secret},
|
||
client_id_default: System.get_env("EVE_CLIENT_ID", "<EVE_CLIENT_ID>"),
|
||
client_id_1: System.get_env("EVE_CLIENT_ID_1", ""),
|
||
client_id_2: System.get_env("EVE_CLIENT_ID_2", ""),
|
||
client_id_3: System.get_env("EVE_CLIENT_ID_3", ""),
|
||
client_id_4: System.get_env("EVE_CLIENT_ID_4", ""),
|
||
client_id_5: System.get_env("EVE_CLIENT_ID_5", ""),
|
||
client_id_6: System.get_env("EVE_CLIENT_ID_6", ""),
|
||
client_id_7: System.get_env("EVE_CLIENT_ID_7", ""),
|
||
client_id_8: System.get_env("EVE_CLIENT_ID_8", ""),
|
||
client_id_9: System.get_env("EVE_CLIENT_ID_9", ""),
|
||
client_id_10: System.get_env("EVE_CLIENT_ID_10", ""),
|
||
client_id_with_wallet:
|
||
System.get_env("EVE_CLIENT_WITH_WALLET_ID", "<EVE_CLIENT_WITH_WALLET_ID>"),
|
||
client_id_with_corp_wallet:
|
||
System.get_env("EVE_CLIENT_WITH_CORP_WALLET_ID", "<EVE_CLIENT_WITH_CORP_WALLET_ID>"),
|
||
client_secret_default: System.get_env("EVE_CLIENT_SECRET", "<EVE_CLIENT_SECRET>"),
|
||
client_secret_1: System.get_env("EVE_CLIENT_SECRET_1", ""),
|
||
client_secret_2: System.get_env("EVE_CLIENT_SECRET_2", ""),
|
||
client_secret_3: System.get_env("EVE_CLIENT_SECRET_3", ""),
|
||
client_secret_4: System.get_env("EVE_CLIENT_SECRET_4", ""),
|
||
client_secret_5: System.get_env("EVE_CLIENT_SECRET_5", ""),
|
||
client_secret_6: System.get_env("EVE_CLIENT_SECRET_6", ""),
|
||
client_secret_7: System.get_env("EVE_CLIENT_SECRET_7", ""),
|
||
client_secret_8: System.get_env("EVE_CLIENT_SECRET_8", ""),
|
||
client_secret_9: System.get_env("EVE_CLIENT_SECRET_9", ""),
|
||
client_secret_10: System.get_env("EVE_CLIENT_SECRET_10", ""),
|
||
client_secret_with_wallet:
|
||
System.get_env("EVE_CLIENT_WITH_WALLET_SECRET", "<EVE_CLIENT_WITH_WALLET_SECRET>"),
|
||
client_secret_with_corp_wallet:
|
||
System.get_env("EVE_CLIENT_WITH_CORP_WALLET_SECRET", "<EVE_CLIENT_WITH_CORP_WALLET_SECRET>")
|
||
|
||
config :logger,
|
||
truncate: :infinity,
|
||
level:
|
||
String.to_existing_atom(
|
||
System.get_env(
|
||
"LOG_LEVEL",
|
||
case config_env() do
|
||
:prod -> "info"
|
||
:dev -> "info"
|
||
:test -> "debug"
|
||
end
|
||
)
|
||
)
|
||
|
||
sheduler_jobs =
|
||
map_subscriptions_enabled
|
||
|> case do
|
||
true ->
|
||
[
|
||
{"@hourly", {WandererApp.Map.SubscriptionManager, :process, []}}
|
||
]
|
||
|
||
_ ->
|
||
[]
|
||
end
|
||
|
||
config :wanderer_app, WandererApp.Scheduler,
|
||
timezone: :utc,
|
||
jobs:
|
||
[
|
||
{"@daily", {WandererApp.Map.Audit, :archive, []}},
|
||
{"@daily", {WandererApp.Map.GarbageCollector, :cleanup_chain_passages, []}},
|
||
{"@daily", {WandererApp.Map.GarbageCollector, :cleanup_system_signatures, []}}
|
||
] ++ sheduler_jobs,
|
||
timeout: :infinity
|
||
|
||
if config_env() == :prod do
|
||
database_unix_socket =
|
||
System.get_env("DATABASE_UNIX_SOCKET")
|
||
|
||
database =
|
||
database_unix_socket
|
||
|> case do
|
||
nil ->
|
||
System.get_env("DATABASE_URL") ||
|
||
raise """
|
||
environment variable DATABASE_URL is missing.
|
||
For example: ecto://USER:PASS@HOST/DATABASE
|
||
"""
|
||
|
||
_ ->
|
||
System.get_env("DATABASE_NAME") ||
|
||
raise """
|
||
environment variable DATABASE_NAME is missing.
|
||
For example: "wanderer"
|
||
"""
|
||
end
|
||
|
||
config :wanderer_app, WandererApp.Repo,
|
||
pool_size: String.to_integer(System.get_env("POOL_SIZE") || "10")
|
||
|
||
if not is_nil(database_unix_socket) do
|
||
config :wanderer_app, WandererApp.Repo,
|
||
socket_dir: database_unix_socket,
|
||
database: database
|
||
else
|
||
db_ssl_enabled =
|
||
config_dir
|
||
|> get_var_from_path_or_env("DATABASE_SSL_ENABLED", "false")
|
||
|> String.to_existing_atom()
|
||
|
||
db_ssl_verify_none =
|
||
config_dir
|
||
|> get_var_from_path_or_env("DATABASE_SSL_VERIFY_NONE", "false")
|
||
|> String.to_existing_atom()
|
||
|
||
client_opts =
|
||
if db_ssl_verify_none do
|
||
[verify: :verify_none]
|
||
end
|
||
|
||
maybe_ipv6 =
|
||
config_dir
|
||
|> get_var_from_path_or_env("ECTO_IPV6", "false")
|
||
|> String.to_existing_atom()
|
||
|> case do
|
||
true -> [:inet6]
|
||
_ -> []
|
||
end
|
||
|
||
config :wanderer_app, WandererApp.Repo,
|
||
url: database,
|
||
ssl: db_ssl_enabled,
|
||
ssl_opts: client_opts,
|
||
socket_options: maybe_ipv6
|
||
end
|
||
|
||
# The secret key base is used to sign/encrypt cookies and other secrets.
|
||
# A default value is used in config/dev.exs and config/test.exs but you
|
||
# want to use a different value for prod and you most likely don't want
|
||
# to check this value into version control, so we use an environment
|
||
# variable instead.
|
||
secret_key_base =
|
||
System.get_env("SECRET_KEY_BASE") ||
|
||
raise """
|
||
environment variable SECRET_KEY_BASE is missing.
|
||
You can generate one by calling: mix phx.gen.secret
|
||
"""
|
||
|
||
config :wanderer_app, :dns_cluster_query, System.get_env("DNS_CLUSTER_QUERY")
|
||
|
||
config :wanderer_app, WandererAppWeb.Endpoint,
|
||
url: [scheme: base_url.scheme, host: base_url.host, path: base_url.path, port: base_url.port],
|
||
http: [
|
||
# Enable IPv6 and bind on all interfaces.
|
||
# Set it to {0, 0, 0, 0, 0, 0, 0, 1} for local network only access.
|
||
# See the documentation on https://hexdocs.pm/plug_cowboy/Plug.Cowboy.html
|
||
# for details about using IPv6 vs IPv4 and loopback vs public addresses.
|
||
ip: {0, 0, 0, 0},
|
||
port: web_port
|
||
],
|
||
secret_key_base: secret_key_base
|
||
|
||
if scheme == "https" && http_port do
|
||
config :wanderer_app, WandererAppWeb.Endpoint,
|
||
url: [host: host, port: 443, scheme: scheme],
|
||
server: true,
|
||
force_ssl: [hsts: true],
|
||
http: [
|
||
port: http_port
|
||
],
|
||
https: [
|
||
port: https_port,
|
||
cipher_suite: :strong,
|
||
otp_app: :wanderer_app,
|
||
keyfile: "/certs/private.key",
|
||
certfile: "/certs/certificate.crt"
|
||
]
|
||
|
||
config :wanderer_app, WandererApp.PromEx,
|
||
grafana: [
|
||
host: System.get_env("GRAFANA_CLOUD_HOST", "<GRAFANA_CLOUD_HOST>"),
|
||
auth_token: System.get_env("GRAFANA_CLOUD_AUTH_TOKEN", "<GRAFANA_CLOUD_AUTH_TOKEN>"),
|
||
folder_name: System.get_env("GRAFANA_CLOUD_FOLDER_NAME", "wanderer"),
|
||
upload_dashboards_on_start: true
|
||
]
|
||
|
||
config :wanderer_app,
|
||
grafana_datasource_id: System.get_env("GRAFANA_DATASOURCE_ID", "wanderer")
|
||
end
|
||
|
||
promex_disabled? =
|
||
config_dir
|
||
|> get_var_from_path_or_env("PROMEX_DISABLED", "true")
|
||
|> String.to_existing_atom()
|
||
|
||
config :wanderer_app, WandererApp.PromEx,
|
||
disabled: promex_disabled?,
|
||
manual_metrics_start_delay: :no_delay,
|
||
metrics_server: [
|
||
port: System.get_env("METRICS_PORT", "4021") |> String.to_integer(),
|
||
path: "/metrics",
|
||
protocol: :http,
|
||
pool_size: 5,
|
||
cowboy_opts: [ip: {0, 0, 0, 0}]
|
||
]
|
||
end
|
||
|
||
# License Manager API Configuration
|
||
config :wanderer_app, :license_manager,
|
||
api_url: System.get_env("LM_API_URL", "http://localhost:4000"),
|
||
auth_key: System.get_env("LM_AUTH_KEY")
|
||
|
||
# SSE Configuration
|
||
config :wanderer_app, :sse,
|
||
enabled:
|
||
config_dir
|
||
|> get_var_from_path_or_env("WANDERER_SSE_ENABLED", "false")
|
||
|> String.to_existing_atom(),
|
||
max_connections_total:
|
||
config_dir |> get_int_from_path_or_env("WANDERER_SSE_MAX_CONNECTIONS", 1000),
|
||
max_connections_per_map:
|
||
config_dir |> get_int_from_path_or_env("SSE_MAX_CONNECTIONS_PER_MAP", 50),
|
||
max_connections_per_api_key:
|
||
config_dir |> get_int_from_path_or_env("SSE_MAX_CONNECTIONS_PER_API_KEY", 10),
|
||
keepalive_interval: config_dir |> get_int_from_path_or_env("SSE_KEEPALIVE_INTERVAL", 30000),
|
||
connection_timeout: config_dir |> get_int_from_path_or_env("SSE_CONNECTION_TIMEOUT", 300_000)
|
||
|
||
# External Events Configuration
|
||
config :wanderer_app, :external_events,
|
||
webhooks_enabled:
|
||
config_dir
|
||
|> get_var_from_path_or_env("WANDERER_WEBHOOKS_ENABLED", "false")
|
||
|> String.to_existing_atom(),
|
||
webhook_timeout_ms: config_dir |> get_int_from_path_or_env("WANDERER_WEBHOOK_TIMEOUT_MS", 15000)
|