prompt_runner_sdk

defmodule PromptRunner.Observer.PubSub do
  @moduledoc """
  Convenience helpers for broadcasting PromptRunner events through `Phoenix.PubSub`.
  """

  @spec callback(module(), String.t()) :: (map() -> term())
  def callback(pubsub, topic) do
    fn event -> broadcast(pubsub, topic, event) end
  end

  @spec broadcast(module(), String.t(), map()) :: :ok | {:error, term()}
  def broadcast(pubsub, topic, event) do
    pubsub_module = Module.concat([Phoenix, PubSub])

    if Code.ensure_loaded?(pubsub_module) and function_exported?(pubsub_module, :broadcast, 3) do
      pubsub_module.broadcast(pubsub, topic, {:prompt_runner, event})
    else
      {:error, :phoenix_pubsub_not_available}
    end
  end
end