defmodule EventStore.Registration.DistributedForwarder do
  @moduledoc false

  use GenServer

  alias EventStore.Registration.LocalRegistry

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

  @doc """
  Broadcast the message on the topic to all connected nodes.
  """
  def broadcast(topic, message) do
    for node <- Node.list() do
      Process.send({__MODULE__, node}, {:broadcast, topic, message}, [:noconnect])
    end

    :ok
  end

  def init(_args) do
    {:ok, []}
  end

  def handle_info({:broadcast, topic, message}, state) do
    LocalRegistry.broadcast(topic, message)

    {:noreply, state}
  end
end