serum_md

defmodule Serum.DevServer.LiveReloadHandler do
  @moduledoc false

  _moduledocp = """
  A Cowboy Websocket handler that sends signals to clients on file events.
  """

  @behaviour :cowboy_websocket

  import Serum.IOProxy, only: [put_err: 2, put_msg: 2]
  alias Serum.DevServer.Service

  @impl true
  def init(req, state) do
    {:cowboy_websocket, req, state, %{idle_timeout: :infinity}}
  end

  @impl true
  def websocket_init(state) do
    put_msg(:info, "Live Reloader: WebSocket connected.")
    Service.GenServer.subscribe()

    {:ok, state}
  end

  @impl true
  def websocket_handle(message, state) do
    put_err(:warn, "Live Reloader: Ignoring a message from client: #{inspect(message)}")

    {:ok, state}
  end

  @impl true
  def websocket_info(message, state)

  def websocket_info(:send_reload, state) do
    {:reply, {:text, "reload"}, state}
  end

  def websocket_info(_, state), do: {:ok, state}

  @impl true
  def terminate(_reason, _mini_req, _state) do
    put_msg(:info, "Live Reloader: WebSocket disconnected.")

    :ok
  end
end