Sha256: d3393da722106466b79d50a64e0026d2649ae91c532aab96b7567849e5c99d72

Contents?: true

Size: 1.57 KB

Versions: 2

Compression:

Stored size: 1.57 KB

Contents

module TwitterRetry
  module Retryable
    # retry when error occurred matched with {#RETRYABLE_ERRORS}
    # @return [true]  successful
    # @return [false] error is ignored (ex. {Twitter::Error::Forbidden})
    # @raise [SuspendedError]
    # @raise [RetryOverError] retried {TwitterRetry::TwitterRetry#max_retry_count} count, but all failure
    # @raise [CannotRetryableError]
    def with_handing
      retry_count = 0

      begin
        yield

      rescue => error
        return false               if ignorable?(error)
        raise SuspendedError       if suspended?(error)
        raise CannotRetryableError unless retryable?(error)
        raise RetryOverError       unless retry_count < TwitterRetry.config.max_retry_count

        retry_count += 1
        sleep(TwitterRetry.config.sleep_second)
        retry
      end

      # successful
      true
    end

    # whether retryable error
    # @param error [Exception]
    def retryable?(error)
      TwitterRetry.config.retryable_errors.any? do |error_class, message|
        error.is_a?(error_class) && error.message.include?(message)
      end
    end

    # whether ignorable error
    # @param error [Exception]
    def ignorable?(error)
      TwitterRetry.config.ignorable_errors.any? do |error_class, message|
        error.is_a?(error_class) && error.message.include?(message)
      end
    end

    # whether suspended user error
    def suspended?(error)
      error.is_a?(Twitter::Error::Forbidden) &&
        error.message.include?("Your account is suspended and is not permitted to access this feature.")
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
twitter_retry-0.1.0 lib/twitter_retry/retryable.rb
twitter_retry-0.1.0.beta1 lib/twitter_retry/retryable.rb