Added index_name to ReindexV2Job [skip ci]

Andrew Kane
1 parent e21f4fec
Showing 2 changed files with 7 additions and 4 deletions Show diff stats
lib/searchkick/record_indexer.rb
lib/searchkick/reindex_v2_job.rb
@@ -17,7 +17,8 @@ module Searchkick
           raise Searchkick::Error, "Active Job not found"
         end
-        # temporary hack
+        # we could likely combine ReindexV2Job, BulkReindexJob, and ProcessBatchJob
+        # but keep them separate for now
         if single
           record = records.first
@@ -31,7 +32,8 @@ module Searchkick
             record.class.name,
             record.id.to_s,
             method_name ? method_name.to_s : nil,
-            routing: routing
+            routing: routing,
+            index_name: index.name
           )
         else
           Searchkick::BulkReindexJob.perform_later(
@@ -2,15 +2,16 @@ module Searchkick
   class ReindexV2Job < ActiveJob::Base
     queue_as { Searchkick.queue_name }
-    def perform(class_name, id, method_name = nil, routing: nil)
+    def perform(class_name, id, method_name = nil, routing: nil, index_name: nil)
       model = Searchkick.load_model(class_name, allow_child: true)
+      index = index_name ? Searchkick::Index.new(index_name, model.searchkick_options) : model.searchkick_index
       # use should_index? to decide whether to index (not default scope)
       # just like saving inline
       # could use Searchkick.scope() in future
       # but keep for now for backwards compatibility
       model = model.unscoped if model.respond_to?(:unscoped)
       items = [{id: id, routing: routing}]
-      model.searchkick_index.send(:record_indexer).reindex_items(model, items, method_name: method_name, single: true)
+      index.send(:record_indexer).reindex_items(model, items, method_name: method_name, single: true)
     end
   end
 end