Support ActiveJob 7.2 enqueue_after_transaction_commit

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## master
 
+- Add support for `ActiveJob::Base.enqueue_after_transaction_commit`. ([@joshuay03][])
+
 - Add ActionCable adapter. ([@arthurWD][])
 
 ## 1.0.1 (2023-12-01) ❄️
@@ -143,3 +145,5 @@ This, for example, makes Isolator compatible with Rails multi-database apps.
 [@Mange]: https://github.com/Mange
 [@tomgi]: https://github.com/tomgi
 [@tagirahmad]: https://github.com/tagirahmad
+[@arthurWD]: https://github.com/arthurWD
+[@joshuay03]: https://github.com/joshuay03

lib/isolator/adapter_builder.rb

@@ -13,6 +13,7 @@ def call(target: nil, method_name: nil, **options)
           self.exception_class = options[:exception_class] if options.key?(:exception_class)
           self.exception_message = options[:exception_message] if options.key?(:exception_message)
           self.details_message = options[:details_message] if options.key?(:details_message)
+          self.disabled = options[:disabled] if options.key?(:disabled)
         end
 
         mod = build_mod(method_name, adapter)

lib/isolator/adapters/background_jobs/active_job.rb

@@ -7,4 +7,9 @@
   details_message: ->(obj) {
     "#{obj.class.name}" \
     "#{obj.arguments.any? ? " (#{obj.arguments.join(", ")})" : ""}"
-  }
+  },
+  disabled: begin
+    config = ActiveJob::Base.try(:enqueue_after_transaction_commit)
+    config == :always || (config == :default &&
+      ActiveJob::Base.queue_adapter.try(:enqueue_after_transaction_commit?) == true)
+  end

lib/isolator/adapters/base.rb

@@ -4,6 +4,7 @@ module Isolator
   module Adapters
     # Used as a "template" for adapters
     module Base
+      attr_writer :disabled
       attr_accessor :exception_class, :exception_message, :details_message
 
       def disable!

spec/isolator/adapters/background_jobs/active_job_spec.rb

@@ -17,5 +17,57 @@
     specify do
       expect { ActiveJobWorker.perform_later("test") }.to raise_error(Isolator::BackgroundJobError, /ActiveJobWorker.+test/)
     end
+
+    context "with enqueue_after_transaction_commit configured", if: ActiveRecord.version >= Gem::Version.new("7.2") do
+      context "configured to :always" do
+        before do
+          allow(ActiveJob::Base).to receive(:enqueue_after_transaction_commit) { :always }
+        end
+
+        specify do
+          expect { ActiveJobWorker.perform_later("test") }.to_not raise_error
+        end
+      end
+
+      context "configured to :default" do
+        before do
+          allow(ActiveJob::Base).to receive(:enqueue_after_transaction_commit) { :default }
+        end
+
+        context "with queue_adapter enqueue_after_transaction_commit enabled" do
+          let (:queue_adapter) { double("queue_adapter", enqueue_after_transaction_commit?: true) }
+
+          before do
+            allow(ActiveJob::Base).to receive(:queue_adapter) { queue_adapter }
+          end
+
+          specify do
+            expect { ActiveJobWorker.perform_later("test") }.to_not raise_error
+          end
+        end
+
+        context "with queue_adapter enqueue_after_transaction_commit disabled" do
+          let (:queue_adapter) { double("queue_adapter", enqueue_after_transaction_commit?: false) }
+
+          before do
+            allow(ActiveJob::Base).to receive(:queue_adapter) { queue_adapter }
+          end
+
+          specify do
+            expect { ActiveJobWorker.perform_later("test") }.to raise_error(Isolator::BackgroundJobError, /ActiveJobWorker.+test/)
+          end
+        end
+      end
+
+      context "configured to :never" do
+        before do
+          allow(ActiveJob::Base).to receive(:enqueue_after_transaction_commit) { :never }
+        end
+
+        specify do
+          expect { ActiveJobWorker.perform_later("test") }.to raise_error(Isolator::BackgroundJobError, /ActiveJobWorker.+test/)
+        end
+      end
+    end
   end
 end