Add job-iteration integration

Gemfile

@@ -21,6 +21,7 @@ gemspec
 
 gem 'activerecord-jdbcpostgresql-adapter', platforms: [:jruby]
 gem 'appraisal'
+gem 'job-iteration'
 gem 'matrix'
 gem 'nokogiri'
 gem 'pg', platforms: [:mri, :mingw, :x64_mingw]

Gemfile.lock

@@ -219,6 +219,8 @@ GEM
       reline (>= 0.3.8)
     jar-dependencies (0.4.1)
     jdbc-postgres (42.6.0)
+    job-iteration (1.4.1)
+      activejob (>= 5.2)
     json (2.6.3)
     json (2.6.3-java)
     kramdown (2.4.0)
@@ -514,6 +516,7 @@ DEPENDENCIES
   github_changelog_generator
   good_job!
   i18n-tasks
+  job-iteration
   kramdown
   kramdown-parser-gfm
   matrix

lib/good_job.rb

@@ -38,6 +38,8 @@
 require "good_job/shared_executor"
 require "good_job/systemd_service"
 
+require "job_iteration/integrations/good_job"
+
 # GoodJob is a multithreaded, Postgres-based, ActiveJob backend for Ruby on Rails.
 #
 # +GoodJob+ is the top-level namespace and exposes configuration attributes.

lib/job_iteration/integrations/good_job.rb

@@ -0,0 +1,21 @@
+# frozen_string_literal: true
+
+begin
+  require "job-iteration"
+
+  module JobIteration
+    module Integrations
+      module GoodJob
+        class << self
+          def call
+            ::GoodJob.shutdown?
+          end
+        end
+      end
+    end
+  end
+
+  JobIteration.interruption_adapter = JobIteration::Integrations::GoodJob
+rescue LoadError
+  # job-iteration is not present
+end

spec/lib/job_iteration/integrations/good_job_spec.rb

@@ -0,0 +1,27 @@
+# frozen_string_literal: true
+
+require 'rails_helper'
+
+describe JobIteration::Integrations::GoodJob do
+  it 'sets up the interruption adapter' do
+    expect(JobIteration.interruption_adapter).to eq(described_class)
+  end
+
+  describe '.call' do
+    context 'when GoodJob is shutting down' do
+      before { allow(GoodJob).to receive(:shutdown?).and_return(true) }
+
+      it 'returns true' do
+        expect(described_class.call).to be(true)
+      end
+    end
+
+    context 'when GoodJob is not shutting down' do
+      before { allow(GoodJob).to receive(:shutdown?).and_return(false) }
+
+      it 'returns false' do
+        expect(described_class.call).to be(false)
+      end
+    end
+  end
+end