Sha256: 925bcdf177c88071152e8c156452bd682fb70b9eefcbef330e861d8dfab22dc7

Contents?: true

Size: 1.54 KB

Versions: 15

Compression:

Stored size: 1.54 KB

Contents

require 'rails_helper'

describe LHS::Collection do

  let(:total) { 443 }

  let(:limit) { 100 }

  def api_response(ids, offset)
    records = ids.map{|i| {id: i}}
    {
      items: records,
      total: total,
      limit: limit,
      offset: offset
    }.to_json
  end

  let(:datastore) { 'http://local.ch/v2' }

  before(:each) do
    LHC.config.placeholder('datastore', datastore)
    class SomeService < LHS::Service
      endpoint ':datastore/:campaign_id/feedbacks'
      endpoint ':datastore/feedbacks'
    end
  end

  context 'find_each' do

    it 'processes each record by fetching records in batches' do
      stub_request(:get, "#{datastore}/feedbacks?limit=100&offset=1").to_return(status: 200, body: api_response((1..100).to_a, 1))
      stub_request(:get, "#{datastore}/feedbacks?limit=100&offset=101").to_return(status: 200, body: api_response((101..200).to_a, 101))
      stub_request(:get, "#{datastore}/feedbacks?limit=100&offset=201").to_return(status: 200, body: api_response((201..300).to_a, 201))
      stub_request(:get, "#{datastore}/feedbacks?limit=100&offset=301").to_return(status: 200, body: api_response((301..400).to_a, 301))
      stub_request(:get, "#{datastore}/feedbacks?limit=100&offset=401").to_return(status: 200, body: api_response((401..total).to_a, 401))
      count = 0
      SomeService.find_each do |record|
        count += 1
        expect(record.id).to eq(count)
        expect(record).to be_kind_of LHS::Data
        expect(record._proxy).to be_kind_of LHS::Item
      end
      expect(count).to eq total
    end    
  end
end

Version data entries

15 entries across 15 versions & 1 rubygems

Version Path
lhs-2.2.2 spec/service/find_each_spec.rb
lhs-1.6.1 spec/service/find_each_spec.rb
lhs-2.2.1 spec/service/find_each_spec.rb
lhs-2.2.0 spec/service/find_each_spec.rb
lhs-1.6.0 spec/service/find_each_spec.rb
lhs-2.1.1 spec/service/find_each_spec.rb
lhs-2.1.0 spec/service/find_each_spec.rb
lhs-2.0.5 spec/service/find_each_spec.rb
lhs-2.0.4 spec/service/find_each_spec.rb
lhs-2.0.3 spec/service/find_each_spec.rb
lhs-2.0.2 spec/service/find_each_spec.rb
lhs-2.0.1 spec/service/find_each_spec.rb
lhs-2.0.0 spec/service/find_each_spec.rb
lhs-1.5.0 spec/service/find_each_spec.rb
lhs-1.4.0 spec/service/find_each_spec.rb