diff --git a/pd2pg.rb b/pd2pg.rb index c78db83..6de1e15 100644 --- a/pd2pg.rb +++ b/pd2pg.rb @@ -134,7 +134,11 @@ def refresh_bulk(collection) response = api.request( :method => :get, :path => "/api/v1/#{collection}", - :query => {"offset" => offset, "limit" => PAGINATION_LIMIT}, + :query => { + "offset" => offset, + "limit" => PAGINATION_LIMIT, + "total" => true + }, :expects => [200] ) data = JSON.parse(response.body) @@ -193,7 +197,8 @@ def refresh_incremental(collection, query_params={}) "since" => since, "until" => through, "offset" => offset, - "limit" => PAGINATION_LIMIT + "limit" => PAGINATION_LIMIT, + "total" => true }.merge(query_params), :expects => [200] )