Merge pull request #321 from dnd/worker_strategy_options

Allow worker strategies to receive import options

lib/chewy/strategy/active_job.rb

@@ -13,8 +13,8 @@ class ActiveJob < Atomic
       class Worker < ::ActiveJob::Base
         queue_as :chewy
 
-        def perform(type, ids)
-          type.constantize.import!(ids)
+        def perform(type, ids, options = {})
+          type.constantize.import!(ids, options)
         end
       end
 

lib/chewy/strategy/resque.rb

@@ -13,8 +13,8 @@ class Resque < Atomic
       class Worker
         @queue = :chewy
 
-        def self.perform(type, ids)
-          type.constantize.import!(ids)
+        def self.perform(type, ids, options = {})
+          type.constantize.import!(ids, options)
         end
       end
 

lib/chewy/strategy/sidekiq.rb

@@ -13,8 +13,8 @@ class Sidekiq < Atomic
       class Worker
         include ::Sidekiq::Worker
 
-        def perform(type, ids)
-          type.constantize.import!(ids)
+        def perform(type, ids, options = {})
+          type.constantize.import!(ids, options)
         end
       end
 

spec/chewy/strategy/active_job_spec.rb

@@ -45,5 +45,10 @@
         .to update_index(CitiesIndex::City, strategy: :active_job)
         .and_reindex(city, other_city)
     end
+
+    specify do
+      expect(CitiesIndex::City).to receive(:import!).with([city.id, other_city.id], {suffix: '201601'})
+      Chewy::Strategy::ActiveJob::Worker.new.perform("CitiesIndex::City", [city.id, other_city.id], suffix: '201601')
+    end
   end
 end

spec/chewy/strategy/resque_spec.rb

@@ -31,5 +31,10 @@
           .and_reindex(city, other_city)
       end
     end
+
+    specify do
+      expect(CitiesIndex::City).to receive(:import!).with([city.id, other_city.id], {suffix: '201601'})
+      Chewy::Strategy::Resque::Worker.perform("CitiesIndex::City", [city.id, other_city.id], suffix: '201601')
+    end
   end
 end

spec/chewy/strategy/sidekiq_spec.rb

@@ -31,5 +31,10 @@
           .and_reindex(city, other_city)
       end
     end
+
+    specify do
+      expect(CitiesIndex::City).to receive(:import!).with([city.id, other_city.id], {suffix: '201601'})
+      Chewy::Strategy::Sidekiq::Worker.new.perform("CitiesIndex::City", [city.id, other_city.id], suffix: '201601')
+    end
   end
 end