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