Contents

# frozen_string_literal: true

class LHC::Retry < LHC::Interceptor
  attr_accessor :retries, :current_retry

  class << self
    attr_accessor :max, :all
  end

  def after_response
    response.request.options[:retries] ||= 0
    return unless retry?(response.request)
    response.request.options[:retries] += 1
    current_retry = response.request.options[:retries]
    begin
      response.request.run!
    rescue LHC::Error
      return
    end
    response.request.response if current_retry == response.request.options[:retries]
  end

  private

  def retry?(request)
    return false if request.response.success?
    return false if !request.options.dig(:retry) && !LHC::Retry.all
    request.options[:retries] < max(request)
  end

  def max(request)
    options(request).is_a?(Hash) ? options(request).fetch(:max, LHC::Retry.max) : LHC::Retry.max
  end

  def options(request)
    @options ||= request.options.dig(:retry)
  end
end

LHC::Retry.max = 3

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
lhc-10.5.0	lib/lhc/interceptors/retry.rb
lhc-10.4.3	lib/lhc/interceptors/retry.rb
lhc-10.4.2	lib/lhc/interceptors/retry.rb
lhc-10.4.1	lib/lhc/interceptors/retry.rb
lhc-10.4.0	lib/lhc/interceptors/retry.rb
lhc-10.3.0	lib/lhc/interceptors/retry.rb