Contents

module Acfs

  # Describes a CRUD operation. Handle request creation and response
  # processing as well as error handling and stubbing.
  #
  class Operation
    attr_reader :action, :params, :resource, :data, :callback
    delegate :service, to: :resource

    def initialize(resource, action, opts = {}, &block)
      @resource = resource
      @action   = action.to_sym
      @params   = opts[:params] || {}
      @data     = opts[:data]   || {}
      @callback = block

      raise ArgumentError, 'ID parameter required for READ, UPDATE and DELETE operation.' if single? and id.nil?
    end

    def single?
      [:read, :update, :delete].include? action
    end

    def synchronous?
      [:update, :delete, :create].include? action
    end

    def id
      @id ||= params.delete(:id) || data[:id]
    end

    def url
      single? ? resource.url(id) : resource.url
    end

    def method
      { read: :get, list: :get, update: :put, create: :post, delete: :delete }[action]
    end

    def request
      request = ::Acfs::Request.new url, method: method, params: params, data: data
      request.on_complete do |response|
        handle_failure response unless response.success?
        callback.call response.data
      end
      request
    end

    def handle_failure(response)
      case response.code
        when 404
          raise ::Acfs::ResourceNotFound.new response: response
        when 422
          raise ::Acfs::InvalidResource.new response: response, errors: response.data.try(:[], 'errors')
        else
          raise ::Acfs::ErroneousResponse.new response: response
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
acfs-0.16.0	lib/acfs/operation.rb
acfs-0.15.0	lib/acfs/operation.rb