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

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