# See the Pagy documentation: https://ddnexus.github.io/pagy/extras/elasticsearch_rails # frozen_string_literal: true class Pagy # :nodoc: DEFAULT[:elasticsearch_rails_search] ||= :search DEFAULT[:elasticsearch_rails_pagy_search] ||= if DEFAULT[:elasticsearch_rails_search_method] # remove in 6.0 # :nocov: Warning.warn '[PAGY WARNING] The :elasticsearch_rails_search_method variable ' \ 'has been deprecated and will be ignored from pagy 6. ' \ 'Use :elasticsearch_rails_pagy_search instead.' DEFAULT[:elasticsearch_rails_search_method] # :nocov: else :pagy_search end # Paginate ElasticsearchRails response objects module ElasticsearchRailsExtra module_function # Get the count from different version of ElasticsearchRails def total_count(response) total = if response.respond_to?(:raw_response) response.raw_response['hits']['total'] else response.response['hits']['total'] end total.is_a?(Hash) ? total['value'] : total end module ElasticsearchRails # :nodoc: # Return an array used to delay the call of #search # after the pagination variables are merged to the options. # It also pushes to the same array an optional method call. def pagy_elasticsearch_rails(query_or_payload, **options) [self, query_or_payload, options].tap do |args| args.define_singleton_method(:method_missing) { |*a| args += a } end end alias_method Pagy::DEFAULT[:elasticsearch_rails_pagy_search], :pagy_elasticsearch_rails end # Additions for the Pagy class module Pagy # Create a Pagy object from an Elasticsearch::Model::Response::Response object def new_from_elasticsearch_rails(response, vars = {}) vars[:items] = response.search.options[:size] || 10 vars[:page] = ((response.search.options[:from] || 0) / vars[:items]) + 1 vars[:count] = ElasticsearchRailsExtra.total_count(response) new(vars) end end # Add specialized backend methods to paginate ElasticsearchRails searches module Backend private # Return Pagy object and items def pagy_elasticsearch_rails(pagy_search_args, vars = {}) model, query_or_payload, options, *called = pagy_search_args vars = pagy_elasticsearch_rails_get_vars(nil, vars) options[:size] = vars[:items] options[:from] = vars[:items] * (vars[:page] - 1) response = model.send(DEFAULT[:elasticsearch_rails_search], query_or_payload, **options) vars[:count] = ElasticsearchRailsExtra.total_count(response) pagy = ::Pagy.new(vars) # with :last_page overflow we need to re-run the method in order to get the hits return pagy_elasticsearch_rails(pagy_search_args, vars.merge(page: pagy.page)) \ if defined?(::Pagy::OverflowExtra) && pagy.overflow? && pagy.vars[:overflow] == :last_page [pagy, called.empty? ? response : response.send(*called)] end # Sub-method called only by #pagy_elasticsearch_rails: here for easy customization of variables by overriding # the _collection argument is not available when the method is called def pagy_elasticsearch_rails_get_vars(_collection, vars) pagy_set_items_from_params(vars) if defined?(ItemsExtra) vars[:items] ||= DEFAULT[:items] vars[:page] ||= (params[vars[:page_param] || DEFAULT[:page_param]] || 1).to_i vars end end end ElasticsearchRails = ElasticsearchRailsExtra::ElasticsearchRails extend ElasticsearchRailsExtra::Pagy Backend.prepend ElasticsearchRailsExtra::Backend end