module RemoteResource
  module Querying
    module PersistenceMethods
      extend ActiveSupport::Concern

      module ClassMethods

        def create(attributes = {}, connection_options = {})
          resource = new(attributes)
          response = RemoteResource::Request.new(self, :post, attributes, connection_options).perform
          resource.handle_response(response)
        end

        def destroy(id, connection_options = {})
          resource = new(id: id)
          response = RemoteResource::Request.new(self, :delete, {}, connection_options.merge(id: id)).perform
          resource.handle_response(response)
          resource.destroyed = resource.success?
          resource
        end
      end

      def update_attributes(attributes = {}, connection_options = {})
        rebuild_resource(attributes)
        create_or_update(attributes.reverse_merge(id: id), connection_options)
        success? ? self : false
      end

      def save(connection_options = {})
        create_or_update(self.attributes, connection_options)
        success? ? self : false
      end

      def destroy(connection_options = {})
        id.present? || raise(RemoteResource::IdMissingError.new("`id` is missing from resource"))
        response = RemoteResource::Request.new(self, :delete, {}, connection_options.merge(id: id)).perform
        handle_response(response)
        self.destroyed = success?
        success? ? self : false
      end

      alias_method :update, :update_attributes

      private

      def create_or_update(attributes = {}, connection_options = {})
        if attributes.has_key?(:id) && attributes[:id].present?
          response = RemoteResource::Request.new(self, :patch, attributes.except(:id), connection_options.merge(id: attributes[:id])).perform
        else
          response = RemoteResource::Request.new(self, :post, attributes.except(:id), connection_options).perform
        end
        handle_response(response)
      end

    end
  end
end