ethereumex

defmodule Ethereumex.Config do
  @moduledoc false
  alias Ethereumex.IpcServer
  alias Ethereumex.WebsocketServer

  def setup_children(), do: setup_children(client_type())

  def setup_children(:ipc) do
    [
      :poolboy.child_spec(:worker, poolboy_config(),
        path: ipc_path(),
        ipc_request_timeout: ipc_request_timeout()
      )
    ]
  end

  def setup_children(:http) do
    pool_opts = http_pool_options()

    [
      {Finch, name: Ethereumex.Finch, pools: pool_opts}
    ]
  end

  def setup_children(:websocket) do
    [
      {WebsocketServer, []}
    ]
  end

  def setup_children(opt), do: raise("Invalid :client option (#{opt}) in config")

  @spec rpc_url() :: binary()
  def rpc_url() do
    case Application.get_env(:ethereumex, :url) do
      url when is_binary(url) and url != "" ->
        url

      els ->
        raise ArgumentError,
          message:
            "Please set config variable `config :ethereumex, :url, \"http://...\", got: `#{inspect(els)}`"
    end
  end

  @spec websocket_url() :: binary()
  def websocket_url() do
    case Application.get_env(:ethereumex, :websocket_url, "") do
      url when is_binary(url) and url != "" ->
        url

      not_a_url ->
        raise ArgumentError,
          message:
            "Please set config variable `config :ethereumex, :websocket_url, \"ws://...\", got `#{not_a_url}`."
    end
  end

  @spec ipc_path() :: binary()
  def ipc_path() do
    case Application.get_env(:ethereumex, :ipc_path, "") do
      path when is_binary(path) and path != "" ->
        path

      not_a_path ->
        raise ArgumentError,
          message:
            "Please set config variable `config :ethereumex, :ipc_path, \"path/to/ipc\", got `#{not_a_path}`. Note: System.user_home! will be prepended to path for you on initialization"
    end
  end

  @spec http_options() :: keyword()
  def http_options() do
    Application.get_env(:ethereumex, :http_options, [])
  end

  @spec http_headers() :: [{String.t(), String.t()}]
  def http_headers() do
    Application.get_env(:ethereumex, :http_headers, [])
  end

  @spec client_type() :: atom()
  def client_type() do
    Application.get_env(:ethereumex, :client_type, :http)
  end

  @spec enable_request_error_logs() :: boolean()
  def enable_request_error_logs() do
    Application.get_env(:ethereumex, :enable_request_error_logs, false)
  end

  @spec format_batch() :: boolean()
  def format_batch() do
    Application.get_env(:ethereumex, :format_batch, true)
  end

  @spec poolboy_config() :: keyword()
  defp poolboy_config() do
    [
      {:name, {:local, :ipc_worker}},
      {:worker_module, IpcServer},
      {:size, ipc_worker_size()},
      {:max_overflow, ipc_max_worker_overflow()}
    ]
  end

  @spec json_module() :: module()
  def json_module() do
    Application.get_env(:ethereumex, :json_module, Jason)
  end

  @spec ipc_worker_size() :: integer()
  defp ipc_worker_size() do
    Application.get_env(:ethereumex, :ipc_worker_size, 5)
  end

  @spec ipc_max_worker_overflow() :: integer()
  defp ipc_max_worker_overflow() do
    Application.get_env(:ethereumex, :ipc_max_worker_overflow, 2)
  end

  @spec ipc_request_timeout() :: integer()
  defp ipc_request_timeout() do
    Application.get_env(:ethereumex, :ipc_request_timeout, 60_000)
  end

  @spec http_pool_options() :: map()
  defp http_pool_options() do
    Application.get_env(:ethereumex, :http_pool_options, %{})
  end
end