lib/avrora/schema/name.ex

defmodule Avrora.Schema.Name do
  @moduledoc """
  Struct for versioned schema names like `io.confluent.Payment:42`.
  """

  defstruct [:origin, :name, :version]

  @type t :: %__MODULE__{
          origin: String.t(),
          name: String.t(),
          version: nil | integer()
        }

  @delimiter_char ":"

  @doc """
  Parse schema name with optional version, returning struct.

  ## Examples

      iex> Avrora.Schema.Name.parse("Payment")
      {:ok, %Avrora.Schema.Name{origin: "Payment", name: "Payment", version: nil}}
      iex> Avrora.Schema.Name.parse("io.confluent.Payment:42")
      {:ok, %Avrora.Schema.Name{origin: "io.confluent.Payment:42", name: "io.confluent.Payment", version: 42}}
  """
  @spec parse(String.t()) :: {:ok, t()} | {:error, term()}
  def parse(payload) when is_binary(payload) do
    with parts <- String.split(payload, @delimiter_char, parts: 2) do
      version = Enum.at(parts, 1)

      version =
        if is_binary(version) do
          case Integer.parse(version) do
            {version, _} -> version
            _ -> nil
          end
        end

      {:ok, %__MODULE__{origin: payload, name: Enum.at(parts, 0), version: version}}
    end
  end
end