# frozen_string_literal: true

class ReeMapper::Array < ReeMapper::AbstractWrapper
  contract(
    Any,
    Kwargs[
      role: Nilor[Symbol, ArrayOf[Symbol]],
      fields_filters: Nilor[ArrayOf[ReeMapper::FieldsFilter]],
    ] => Array
  ).throws(ReeMapper::TypeError)
  def serialize(value, role: nil, fields_filters: nil)
    if !check_value(value)
      raise ReeMapper::TypeError.new("should be an array, got `#{truncate(value.inspect)}`")
    end

    if subject.fields_filter
      fields_filters = if fields_filters
        fields_filters + [subject.fields_filter]
      else
        [subject.fields_filter]
      end
    end

    value.map.with_index do |item, idx|
      next nil if item.nil? && subject.null

      subject.type.serialize(item, role:, fields_filters:)
    rescue ReeMapper::ErrorWithLocation => e
      e.prepend_field_name(idx.to_s)
      e.location ||= subject.location
      raise e
    end
  end

  contract(
    Any,
    Kwargs[
      role: Nilor[Symbol, ArrayOf[Symbol]],
      fields_filters: Nilor[ArrayOf[ReeMapper::FieldsFilter]],
    ] => Array
  ).throws(ReeMapper::TypeError)
  def cast(value, role: nil, fields_filters: nil)
    if !check_value(value)
      raise ReeMapper::TypeError.new("should be an array, got `#{truncate(value.inspect)}`")
    end

    if subject.fields_filter
      fields_filters = if fields_filters
        fields_filters + [subject.fields_filter]
      else
        [subject.fields_filter]
      end
    end

    value.map.with_index do |item, idx|
      next nil if item.nil? && subject.null

      subject.type.cast(item, role:, fields_filters:)
    rescue ReeMapper::ErrorWithLocation => e
      e.prepend_field_name(idx.to_s)
      e.location ||= subject.location
      raise e
    end
  end

  contract(
    Any,
    Kwargs[
      role: Nilor[Symbol, ArrayOf[Symbol]],
      fields_filters: Nilor[ArrayOf[ReeMapper::FieldsFilter]],
    ] => Array
  ).throws(ReeMapper::TypeError)
  def db_dump(value, role: nil, fields_filters: nil)
    if !check_value(value)
      raise ReeMapper::TypeError.new("should be an array, got `#{truncate(value.inspect)}`")
    end

    if subject.fields_filter
      fields_filters = if fields_filters
        fields_filters + [subject.fields_filter]
      else
        [subject.fields_filter]
      end
    end

    value.map.with_index do |item, idx|
      next nil if item.nil? && subject.null

      subject.type.db_dump(item, role:, fields_filters:)
    rescue ReeMapper::ErrorWithLocation => e
      e.prepend_field_name(idx.to_s)
      e.location ||= subject.location
      raise e
    end
  end

  contract(
    Any,
    Kwargs[
      role: Nilor[Symbol, ArrayOf[Symbol]],
      fields_filters: Nilor[ArrayOf[ReeMapper::FieldsFilter]],
    ] => Array
  ).throws(ReeMapper::TypeError)
  def db_load(value, role: nil, fields_filters: nil)
    if !check_value(value)
      raise ReeMapper::TypeError.new("should be an array, got `#{truncate(value.inspect)}`")
    end

    if subject.fields_filter
      fields_filters = if fields_filters
        fields_filters + [subject.fields_filter]
      else
        [subject.fields_filter]
      end
    end

    value.map.with_index do |item, idx|
      next nil if item.nil? && subject.null

      subject.type.db_load(item, role:, fields_filters:)
    rescue ReeMapper::ErrorWithLocation => e
      e.prepend_field_name(idx.to_s)
      e.location ||= subject.location
      raise e
    end
  end

  private

  def check_value(value)
    value.is_a?(Array) || value.class.include?(Enumerable)
  end
end