Contents

module Searchkick
  class ProcessBatchJob < ActiveJob::Base
    queue_as { Searchkick.queue_name }

    def perform(class_name:, record_ids:)
      klass = class_name.constantize
      scope = Searchkick.load_records(klass, record_ids)
      scope = scope.search_import if scope.respond_to?(:search_import)
      records = scope.select(&:should_index?)

      # determine which records to delete
      delete_ids = record_ids - records.map { |r| r.id.to_s }
      delete_records = delete_ids.map { |id| m = klass.new; m.id = id; m }

      # bulk reindex
      index = klass.searchkick_index
      Searchkick.callbacks(:bulk) do
        index.bulk_index(records) if records.any?
        index.bulk_delete(delete_records) if delete_records.any?
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 2 rubygems

Version	Path
searchkick-3.1.1	lib/searchkick/process_batch_job.rb
searchkick-3.1.0	lib/searchkick/process_batch_job.rb
searchkick-3.0.3	lib/searchkick/process_batch_job.rb
searchkick_evichat-0.0.2	lib/searchkick/process_batch_job.rb
searchkick-3.0.2	lib/searchkick/process_batch_job.rb
searchkick-3.0.1	lib/searchkick/process_batch_job.rb
searchkick-3.0.0	lib/searchkick/process_batch_job.rb
searchkick-2.5.0	lib/searchkick/process_batch_job.rb