Class: Hivehook::Resources::BaseService

Inherits:

Object

• Object
• Hivehook::Resources::BaseService

Defined in:

lib/hivehook/resources/base_service.rb

Direct Known Subclasses

APIKeyService, AlertRuleService, ApplicationService, AuditLogService, BookmarkService, DLQService, DeliveryService, DestinationService, EndpointService, EventService, EventTypeSchemaService, MessageService, OrganizationService, OutboundDLQService, OutboundDeliveryService, PortalService, SourceService, StatusService, StreamConsumerService, StreamService, StreamSinkService, SubscriptionService, TransformationService, UserService

Instance Method Summary

• #initialize(transport) ⇒ BaseService constructor

  A new instance of BaseService.

• #iterate(options = {}) ⇒ Object

Constructor Details

#initialize(transport) ⇒ BaseService

Returns a new instance of BaseService.

# File 'lib/hivehook/resources/base_service.rb', line 6

def initialize(transport)
  @transport = transport
end

Instance Method Details

#iterate(options = {}) ⇒ Object

# File 'lib/hivehook/resources/base_service.rb', line 10

def iterate(options = {})
  return enum_for(:iterate, options) unless block_given?

  opts = options.dup
  offset = opts[:offset] || 0
  loop do
    opts[:offset] = offset
    conn = list(opts)
    nodes = conn["nodes"] || []
    nodes.each { |node| yield node }
    page_info = conn["pageInfo"] || {}
    break if !page_info["hasNextPage"] || nodes.empty?

    offset += nodes.length
  end
end