fl_hook_client

defmodule FLHook.Client.Reply do
  @moduledoc false

  alias FLHook.Result
  alias FLHook.Utils

  defstruct [:client, chardata: [], lines: [], status: :pending]

  @type t :: %__MODULE__{
          chardata: IO.chardata(),
          client: nil | GenServer.from(),
          lines: [String.t()],
          status: :pending | :ok | {:error, String.t()}
        }

  @spec add_chunk(t, binary) :: t
  def add_chunk(%__MODULE__{status: :pending} = reply, chunk) do
    data = [reply.chardata, chunk]

    {status, lines} =
      data
      |> IO.chardata_to_string()
      |> String.splitter(Utils.line_sep())
      |> Enum.reduce_while({:pending, []}, fn
        "OK" <> _, {_, lines} ->
          {:cont, {:ok, lines}}

        "ERR " <> reason, {_, lines} ->
          {:cont, {{:error, String.trim_trailing(reason)}, lines}}

        line, {:pending, lines} ->
          {:cont, {:pending, [line | lines]}}

        _line, acc ->
          {:halt, acc}
      end)

    %{reply | chardata: data, lines: lines, status: status}
  end

  @spec to_result(t) :: Result.t()
  def to_result(%__MODULE__{status: :ok} = reply) do
    %Result{lines: Enum.reverse(reply.lines)}
  end
end