eddb

defmodule Database.Database do
  alias Database.Worker

  @pool_size 10

  def init(state) do
    {:ok, state}
  end

  def start_link() do
    IO.puts("Starting Database Supervisor")

    children =
      1..@pool_size
      |> Enum.map(fn index -> Supervisor.child_spec({Worker, {index}}, id: index) end)

    IO.puts("Started #{length(children)} workers")

    Supervisor.start_link(children, strategy: :one_for_one)
  end

  def child_spec(_) do
    %{
      id: __MODULE__,
      start: {__MODULE__, :start_link, []},
      type: :worker
    }
  end

  def get_worker(key) when is_bitstring(key) do
    index = :erlang.phash2(key, @pool_size) + 1
    Process.whereis(:"db_worker_#{index}")
  end

  def get_remote_worker(node, key) when is_bitstring(key) do
    :rpc.call(node, Database.Database, :get_worker, [key])
  end

  def get_worker_index(pid) do
    get_worker_index_itr(pid, 0)
  end

  defp get_worker_index_itr(pid, index) do
    cond do
      index > @pool_size ->
        nil

      Process.whereis(:"db_worker_#{index}") == pid ->
        index

      true ->
        get_worker_index_itr(pid, index + 1)
    end
  end
end