class Slack::Web::Api::Pagination::Cursor

Attributes

client[R]
max_retries[R]
params[R]
sleep_interval[R]
verb[R]

Public Class Methods

new(client, verb, params = {}) click to toggle source
# File lib/slack/web/pagination/cursor.rb, line 15
def initialize(client, verb, params = {})
  @client = client
  @verb = verb
  @params = params.dup
  @sleep_interval = @params.delete(:sleep_interval)
  @max_retries = @params.delete(:max_retries) || client.default_max_retries
end

Public Instance Methods

each() { |response| ... } click to toggle source
# File lib/slack/web/pagination/cursor.rb, line 23
def each
  next_cursor = nil
  retry_count = 0
  loop do
    query = { limit: client.default_page_size }.merge(params).merge(cursor: next_cursor)
    begin
      response = client.send(verb, query)
    rescue Slack::Web::Api::Errors::TooManyRequestsError => e
      raise e if retry_count >= max_retries

      client.logger.debug("#{self.class}##{__method__}") { e.to_s }
      retry_count += 1
      sleep(e.retry_after)
      next
    end
    yield response
    break unless response.response_metadata

    next_cursor = response.response_metadata.next_cursor
    break if next_cursor.nil? || next_cursor == ''

    retry_count = 0
    sleep(sleep_interval) if sleep_interval
  end
end