class Celsius::Primo::Adapter::Mget
Mget
is implemented by ordinary searches, because the original “get” of primo does not return the same amount of informations as a “search” for ids.
Because searching for to many ids at once might cause trouble, a mget is split up into n searches, to be more easy to digest by primo.
Constants
- RECORDS_PER_SEARCH
Public Instance Methods
call(mget_request, options = {})
click to toggle source
# File lib/celsius/primo/adapter/mget.rb, line 12 def call(mget_request, options = {}) options = deep_stringify(options) search_results = search_requests_from(mget_request).map do |search_request| adapter.search(search_request, return_raw_response: options["return_raw_response"]) end search_results.inject({"docs" => []}) do |mget_result, search_result| mget_result["docs"].concat(search_result["hits"]["hits"]) return mget_result end end
search_requests_from(mget_request)
click to toggle source
# File lib/celsius/primo/adapter/mget.rb, line 25 def search_requests_from(mget_request) mget_request["docs"].each_slice(RECORDS_PER_SEARCH).to_a.map.with_index do |array, index| { from: index * RECORDS_PER_SEARCH, size: RECORDS_PER_SEARCH, query: { ids: array.map { |element| element["_id"] } } } end end