Contents

module CurrencyCloud

  class RequestHandler
    
    attr_reader :session
    
    def initialize(session = CurrencyCloud.session)
      @session = session
    end
    
    def get(route, params={}, opts={})
      retry_authenticate('get', route, params, opts) do |url, options|
        HTTParty.get(url, options)
      end
    end
    
    def post(route, params={}, opts={})
      retry_authenticate('post', route, params, opts) do |url, options|
        HTTParty.post(url, options)
      end
    end

    private
    def retry_authenticate(verb, route, params, opts)
      should_retry = opts[:should_retry].nil? ? true : opts.delete(:should_retry)
      description = "to #{verb}: #{route}"
      
      options = process_options(verb, params, opts)

      response = nil
      retry_count = should_retry ? 0 : 2
      while retry_count < 3
        response = yield(full_url(route), options)
        break unless response.code == 401 && should_retry
        session.reauthenticate
        retry_count += 1
      end
      
      process_response(response)
    rescue => e
      raise if e.class.ancestors.include?(ApiError) || e.is_a?(UnexpectedError)
      raise UnexpectedError.new(e)
    end

    def process_options(verb, params, opts)
      options = {:headers => headers }
      params_key = verb == :get ? :query : :body
      options[params_key] = params
      options.merge!(opts)
      # options[:debug_output] = $stdout
      options
    end

    def headers
      headers = {}
      headers['X-Auth-Token'] = session.token if session.token
      headers
    end
        
    def full_url(route)
      "#{session.environment_url}/#{CurrencyCloud::ApiVersion}/" + route
    end
    
    def process_response(response)
      CurrencyCloud::ResponseHandler.process(response)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
currency_cloud-0.5	lib/currency_cloud/request_handler.rb