improve: Only load async workers if deps available

Author: jylamont

lib/vero.rb

@@ -5,6 +5,9 @@
 require "rest-client"
 require "zeitwerk"
 
+module Vero
+end
+
 loader = Zeitwerk::Loader.for_gem
 loader.inflector.inflect(
   "api_context" => "APIContext",
@@ -19,6 +22,12 @@
   "unsubscribe_api" => "UnsubscribeAPI"
 )
 loader.ignore("#{__dir__}/generators")
+
+loader.push_dir("#{__dir__}/vero/workers", namespace: Vero)
+loader.ignore("#{__dir__}/vero/workers/resque_worker") unless defined?(Resque)
+loader.ignore("#{__dir__}/vero/workers/sidekiq_worker") unless defined?(::Sidekiq)
+loader.ignore("#{__dir__}/vero/workers/sucker_punch_worker") unless defined?(SuckerPunch)
+
 loader.setup
 
 require "vero/railtie" if defined?(Rails)

lib/vero/sucker_punch_worker.rb

@@ -6,10 +6,8 @@ class Vero::ResqueWorker
   @queue = :vero
 
   def self.perform(api_class, domain, options)
-    new_options = options.transform_keys(&:to_sym)
-
-    api_class.constantize.new(domain, new_options).perform
-
-    Vero::App.log(self, "method: #{api_class}, options: #{options.to_json}, response: resque job queued")
+    Vero::Senders::Base.new.call(api_class, domain, options)
+  rescue => e
+    Vero::App.log(self, "method: #{api_class}, options: #{options.to_json}, response: #{e.message}")
   end
 end

lib/vero/resque_worker.rb lib/vero/workers/resque_worker.rblib/vero/resque_worker.rb renamed to lib/vero/workers/resque_worker.rb

@@ -6,8 +6,8 @@ class Vero::SidekiqWorker
   include ::Sidekiq::Worker
 
   def perform(api_class, domain, options)
-    api_class.constantize.new(domain, options).perform
-
-    Vero::App.log(self, "method: #{api_class}, options: #{options.to_json}, response: sidekiq job queued")
+    Vero::Senders::Base.new.call(api_class, domain, options)
+  rescue => e
+    Vero::App.log(self, "method: #{api_class}, options: #{options.to_json}, response: #{e.message}")
   end
 end

lib/vero/sidekiq_worker.rb lib/vero/workers/sidekiq_worker.rblib/vero/sidekiq_worker.rb renamed to lib/vero/workers/sidekiq_worker.rb

@@ -0,0 +1,13 @@
+# frozen_string_literal: true
+
+require "sucker_punch"
+
+class Vero::SuckerPunchWorker
+  include SuckerPunch::Job
+
+  def perform(api_class, domain, options)
+    Vero::Senders::Base.new.call(api_class, domain, options)
+  rescue => e
+    Vero::App.log(self, "method: #{api_class}, options: #{options.to_json}, response: #{e.message}")
+  end
+end