boltx

defmodule Boltx.Internals.PackStream.EncoderHelper do
  @moduledoc false
  alias Boltx.Internals.BoltVersionHelper
  alias Boltx.Internals.PackStreamError

  use Boltx.Internals.PackStream.V1
  use Boltx.Internals.PackStream.V2
  use Boltx.Internals.PackStream.Utils

  @available_bolt_versions BoltVersionHelper.available_versions()
  @last_version BoltVersionHelper.last()

  @doc """
  For the given `data_type` and `bolt_version`, determine the right enconding function
  and call it agains `data`
  """
  @spec call_encode(atom(), any(), any()) :: binary() | PackStreamError.t()
  def call_encode(data_type, data, bolt_version)
      when is_integer(bolt_version) and bolt_version in @available_bolt_versions do
    do_call_encode(data_type, data, bolt_version)
  end

  def call_encode(data_type, data, bolt_version) when is_integer(bolt_version) do
    if bolt_version > @last_version do
      call_encode(data_type, data, @last_version)
    else
      raise PackStreamError,
        data_type: data_type,
        data: data,
        bolt_version: bolt_version,
        message: "Unsupported encoder version"
    end
  end

  def call_encode(data_type, data, bolt_version) do
    raise PackStreamError,
      data_type: data_type,
      data: data,
      bolt_version: bolt_version,
      message: "Unsupported encoder version"
  end
end