feat: custom worker classes

Gemfile

@@ -7,3 +7,4 @@ gemspec
 gem 'bundler'
 gem 'rake'
 gem 'rspec'
+gem 'activesupport'

README.md

@@ -50,6 +50,16 @@ In order to be able to schedule jobs for future execution following [Scheduled J
 #<Interactor::Context message="hello!", sidekiq_options={ queue: :low_priority }, sidekiq_schedule_options={ perform_in: 5 }>
 ```
 
+### Customising the SidekiqWorker Class
+
+You can declare you own class to use for the `::Sidekiq::Worker`. This is useful when raising errors and categorising queues.
+
+```ruby
+sidekiq_worker_class class MyWorkerClass < ::Interactor::SidekiqWorker::Worker; end
+```
+
+The class must inherit from `::Interactor::SidekiqWorker::Worker`.
+
 ## Failure
 
 If you pass invalid parameters to sidekiq, you will get an immediate return with the error message.
@@ -85,11 +95,11 @@ class AsyncAction
   def self.sidekiq_options
     { queue: :low_priority }
   end
-    
+
   def self.sidekiq_schedule_options
     { perform_in: 5 }
   end
-  
+
   def self.handle_sidekiq_exception(error)
     # Integrate with Application Monitoring and Error Tracking Software
   end

lib/interactor/sidekiq.rb

@@ -10,6 +10,7 @@ def self.included(base)
       extend ClassMethods
       extend SidekiqWorker
       include Hooks
+      include SidekiqWorkerConfiguration
 
       # Public: Gets the Interactor::Context of the Interactor instance.
       attr_reader :context
@@ -60,7 +61,7 @@ def async_call(context = {})
       options = handle_sidekiq_options(context)
       schedule_options = delay_sidekiq_schedule_options(context)
 
-      Worker.set(options).perform_in(schedule_options.fetch(:delay, 0), handle_context_for_sidekiq(context))
+      worker_class.set(options).perform_in(schedule_options.fetch(:delay, 0), handle_context_for_sidekiq(context))
       new(context.to_h).context
     rescue Exception => e
       begin
@@ -72,6 +73,14 @@ def async_call(context = {})
 
     private
 
+    def worker_class
+      return Worker if custom_sidekiq_worker_class.nil?
+
+      return custom_sidekiq_worker_class if custom_sidekiq_worker_class < Worker
+
+      raise "#{klass} is not a valid Sidekiq worker class. It must be a subclass of ::Interactor::SidekiqWorker::Worker."
+    end
+
     def handle_context_for_sidekiq(context)
       context.to_h.merge(interactor_class: to_s)
     end
@@ -100,6 +109,22 @@ def handle_sidekiq_schedule_options(context)
     end
   end
 
+  module SidekiqWorkerConfiguration
+    def self.included(base)
+      base.class_eval do
+        extend ClassMethods
+
+        class_attribute :custom_sidekiq_worker_class
+      end
+    end
+
+    module ClassMethods
+      def sidekiq_worker_class(klass)
+        self.custom_sidekiq_worker_class = klass
+      end
+    end
+  end
+
   module Async
     def self.included(base)
       base.class_eval do