require 'active_support/core_ext/hash/indifferent_access'

require 'rest_in_peace/definition_proxy'

module RESTinPeace

  def self.included(base)
    base.send :extend, ClassMethods
    base.send :include, ActiveModel::Dirty
  end

  def api
    self.class.api
  end

  def initialize(attributes = {})
    set_attributes attributes
  end

  def payload(changes_only = true)
    hash_representation = { id: id }
    if changes_only
      changed.each do |key|
        value = send(key)
        hash_representation[key.to_sym] = hash_representation_of_object(value)
      end
    else
      hash_representation = to_h
    end
    if self.class.rip_namespace
      { id: id, self.class.rip_namespace => hash_representation }
    else
      hash_representation
    end
  end

  def clear_changes
    case
    when respond_to?(:clear_changes_information) # ActiveModel >= 4.2
      clear_changes_information
    when respond_to?(:reset_changes) # ActiveModel >= 4.0 && <= 4.1
      reset_changes
    else # ActiveModel <= 3.2
      return unless @changed_attributes
      @changed_attributes.clear
    end
  end

  def update_attributes(attributes)
    attributes.each do |key, value|
      next unless respond_to?("#{key}=")
      send("#{key}=", value)
    end
  end

  def to_h
    hash_representation = {}
    self.class.rip_attributes.values.flatten.each do |attr|
      hash_representation[attr] = send(attr)
    end
    hash_representation
  end

  def set_attributes(attributes)
    attributes.each do |key, value|
      next unless respond_to?(key)
      if respond_to?("#{key}=")
        send("#{key}=", value)
      else
        instance_variable_set("@#{key}", value)
      end
    end
  end

  def force_attributes_from_hash(attributes)
    set_attributes attributes
    clear_changes
  end

  def hash_representation_of_object(object)
    return object.payload if object.respond_to?(:payload)
    return object.map { |element| hash_representation_of_object(element) } if object.is_a?(Array)
    object
  end

  module ClassMethods
    attr_accessor :api
    attr_accessor :rip_namespace

    def rest_in_peace(&block)
      definition_proxy = RESTinPeace::DefinitionProxy.new(self)
      definition_proxy.instance_eval(&block)
    end

    def rip_registry
      @rip_registry ||= {
        resource: [],
        collection: [],
      }
    end

    def rip_attributes
      @rip_attributes ||= {
        read: [],
        write: [],
      }
    end
  end
end