Sha256: 7f17dad19ecbb7b27bfc6b1f6dde851118071dd02c5cf99e740fb16d8a2bd4a6
Contents?: true
Size: 1.58 KB
Versions: 10
Compression:
Stored size: 1.58 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://datastore-stg.lb-service.sunrise.intra.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
10 entries across 10 versions & 1 rubygems