improve: Only load async workers if deps available

getvero · Feb 24, 2025 · f5b98f5 · f5b98f5
1 parent f340488
commit f5b98f5
Show file tree

Hide file tree

Showing 5 changed files with 25 additions and 25 deletions.
diff --git a/lib/vero.rb b/lib/vero.rb
@@ -19,6 +19,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)
diff --git a/lib/vero/sucker_punch_worker.rb b/lib/vero/sucker_punch_worker.rb
diff --git a/lib/vero/resque_worker.rb → lib/vero/workers/resque_worker.rb b/lib/vero/resque_worker.rb → lib/vero/workers/resque_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
diff --git a/lib/vero/sidekiq_worker.rb → lib/vero/workers/sidekiq_worker.rb b/lib/vero/sidekiq_worker.rb → lib/vero/workers/sidekiq_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
diff --git a/lib/vero/workers/sucker_punch_worker.rb b/lib/vero/workers/sucker_punch_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