Module: Shopifydev::ShopifyAPI::ConsumeAPI

Defined in:
lib/shopifydev/shopify_api/consume_api.rb

Class Method Summary collapse

Class Method Details

.consume(num = nil) {|report.last| ... } ⇒ Object

Yields:

  • (report.last) 


4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/shopifydev/shopify_api/consume_api.rb', line 4

def self.consume(num=nil)
  report = []
  num ||= 1
  num = num.to_i
  report << {info: "consuming api calls until only #{num} are left..."}
  yield report.last if block_given?
  res = Shydra::Resources::Product.new.run
  pids = res.data.map{|r| r['id']}
  used, max = res.headers['HTTP_X_SHOPIFY_SHOP_API_CALL_LIMIT'].split('/').map(&:to_i)
  report << {debug: "used: #{used.inspect} max: #{max.inspect}"}
  yield report.last if block_given?
  h = Shydra::Hydra.new(max_concurrency: 50)
  to_consume = max - used - num - 2
  report << {debug: "queueing to_consume: #{to_consume.inspect} requests"}
  yield report.last if block_given?
  if to_consume > 0
    to_consume.times{ h.queue(Shydra::Resources::Product.new(id: pids.sample)) }
    h.run
    ::ShopifyAPI::Shop.current
  end
  report << {status: "credit_left: #{::ShopifyAPI.credit_left}"}
  yield report.last if block_given?

  return report
end