Contents

require "intercom/utils"
require "ext/sliceable_hash"

module Intercom
  class ClientCollectionProxy

    attr_reader :resource_name, :finder_url, :resource_class

    def initialize(resource_name, finder_details: {}, client:)
      @resource_name = resource_name
      @resource_class = Utils.constantize_resource_name(resource_name)
      @finder_url = (finder_details[:url] || "/#{@resource_name}")
      @finder_params = (finder_details[:params] || {})
      @client = client
    end

    def each(&block)
      next_page = nil
      loop do
        if next_page
          response_hash = @client.get(next_page, {})
        else
          response_hash = @client.get(@finder_url, @finder_params)
        end
        raise Intercom::HttpError.new('Http Error - No response entity returned') unless response_hash
        deserialize_response_hash(response_hash, block)
        next_page = extract_next_link(response_hash)
        break if next_page.nil?
      end
      self
    end

    def [](target_index)
      self.each_with_index do |item, index|
        return item if index == target_index
      end
      nil
    end

    include Enumerable

    private

    def deserialize_response_hash(response_hash, block)
      top_level_type = response_hash.delete('type')
      if resource_name == 'subscriptions'
        top_level_entity_key = 'items'
      else
        top_level_entity_key = Utils.entity_key_from_type(top_level_type)
      end
      response_hash[top_level_entity_key].each do |object_json|
        block.call Lib::TypedJsonDeserializer.new(object_json).deserialize
      end
    end

    def paging_info_present?(response_hash)
      !!(response_hash['pages'] && response_hash['pages']['type'])
    end

    def extract_next_link(response_hash)
      return nil unless paging_info_present?(response_hash)
      paging_info = response_hash.delete('pages')
      paging_info["next"]
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
intercom-3.5.1	lib/intercom/client_collection_proxy.rb
intercom-3.4.0	lib/intercom/client_collection_proxy.rb
intercom-3.3.0	lib/intercom/client_collection_proxy.rb
intercom-3.2.0	lib/intercom/client_collection_proxy.rb
intercom-3.1.0	lib/intercom/client_collection_proxy.rb
intercom-3.0.6	lib/intercom/client_collection_proxy.rb
intercom-3.0.5	lib/intercom/client_collection_proxy.rb
intercom-3.0.4	lib/intercom/client_collection_proxy.rb