avro_ex_v0

defmodule AvroExV0.Schema.Array do
  use Ecto.Schema
  require AvroExV0.Schema.Macros, as: SchemaMacros
  alias AvroExV0.{Schema, Term}
  alias AvroExV0.Schema.Context
  alias Ecto.Changeset
  import Ecto.Changeset

  @primary_key false
  @required_fields [:items]
  @optional_fields [:metadata]

  embedded_schema do
    field(:items, Term)
    field(:metadata, :map, default: %{})
  end

  @type t :: %__MODULE__{
          items: Schema.schema_types(),
          metadata: %{String.t() => String.t()}
        }

  SchemaMacros.cast_schema(data_fields: [:items])

  def changeset(%__MODULE__{} = struct, params) do
    struct
    |> cast(params, @required_fields ++ @optional_fields)
    |> validate_required(@required_fields)
    |> encode_items
  end

  defp encode_items(%Changeset{} = cs) do
    items =
      cs
      |> get_field(:items)
      |> Schema.cast()

    case items do
      {:ok, item} -> put_change(cs, :items, item)
      {:error, reason} -> add_error(cs, :items, reason)
    end
  end

  def match?(%__MODULE__{items: item_type}, %Context{} = context, data) when is_list(data) do
    Enum.all?(data, fn item ->
      Schema.encodable?(item_type, context, item)
    end)
  end

  def match?(_, _, _), do: false
end