module Faraday::Retryable

def exhausted_retries(options, env, exception)
  options.exhausted_retries_block.call(
    env: env,
    exception: exception,
    options: options
  )
end

def retries_zero?(retries, env, exception)
  retries.zero? && retry_request?(env, exception)
end

def with_retries(env:, options:, retries:, body:, errmatch:)
  yield
rescue errmatch => e
  exhausted_retries(options, env, e) if retries_zero?(retries, env, e)
  if retries.positive? && retry_request?(env, e)
    retries -= 1
    rewind_files(body)
    if (sleep_amount = calculate_sleep_amount(retries + 1, env))
      options.retry_block.call(
        env: env,
        options: options,
        retry_count: options.max - (retries + 1),
        exception: e,
        will_retry_in: sleep_amount
      )
      sleep sleep_amount
      retry
    end
  end
  raise unless e.is_a?(Faraday::RetriableResponse)
  e.response
end