worker_tracker

defmodule WorkerServer do
  use GenServer

  def start_link(_args) do
    GenServer.start_link(__MODULE__, :ok, name: __MODULE__)
  end

  def get_instances() do
    Registry.lookup(WorkerTracker.CollectionRegistry, "instances")
    |> Enum.map(fn {_pid, instance} -> instance end)
  end

  def init(:ok) do
    Registry.register(WorkerTracker.Notifier, "connection_ready", self())
    {:ok, nil}
  end

  def handle_info({:broadcast, instance}, _state) do
    Task.start(fn ->
      DynamicSupervisor.start_child(
        WorkerSupervisor,
        {WorkerTracker.WorkerInstance.Server, instance}
      )
    end)

    {:noreply, nil}
  end
end