defmodule Kadabra.StreamSupervisor do
  @moduledoc false

  use Supervisor
  import Supervisor.Spec

  alias Kadabra.Stream

  def start_link(ref) do
    name = via_tuple(ref)
    Supervisor.start_link(__MODULE__, :ok, name: name)
  end

  def via_tuple(ref) do
    {:via, Registry, {Registry.Kadabra, {ref, __MODULE__}}}
  end

  def start_opts(id \\ :erlang.make_ref()) do
    [id: id, restart: :transient]
  end

  def start_stream(%{ref: ref} = config, stream_id, window, max_frame) do
    stream = Stream.new(config, stream_id, window, max_frame)
    Supervisor.start_child(via_tuple(ref), [stream])
  end

  def send_frame(ref, stream_id, frame) do
    ref
    |> Stream.via_tuple(stream_id)
    |> Stream.call_recv(frame)
  end

  def stop(ref) do
    ref
    |> via_tuple()
    |> Supervisor.stop()
  end

  def init(:ok) do
    spec = worker(Stream, [], start_opts())
    supervise([spec], strategy: :simple_one_for_one)
  end
end