63 lines
1.8 KiB
Ruby
63 lines
1.8 KiB
Ruby
include ActiveJob::TestHelper
|
|
|
|
RSpec.describe APIEntreprise::Job, type: :job do
|
|
# https://api.rubyonrails.org/classes/ActiveJob/Exceptions/ClassMethods.html
|
|
# #method-i-retry_on
|
|
describe '#perform' do
|
|
let(:dossier) { create(:dossier, :with_entreprise) }
|
|
|
|
context 'when an un-retriable error is raised' do
|
|
let(:errors) { [:standard_error] }
|
|
|
|
it 'does not retry' do
|
|
ensure_errors_force_n_retry(errors, 1)
|
|
end
|
|
end
|
|
|
|
context 'when a retriable error is raised' do
|
|
let(:errors) { [:service_unavaible, :bad_gateway, :timed_out] }
|
|
|
|
it 'retries 5 times' do
|
|
ensure_errors_force_n_retry(errors, 5)
|
|
expect(dossier.reload.api_entreprise_job_exceptions.first).to match('APIEntreprise::API::Error::ServiceUnavailable')
|
|
end
|
|
end
|
|
|
|
def ensure_errors_force_n_retry(errors, retry_nb)
|
|
etablissement = dossier.etablissement
|
|
|
|
errors.each do |error|
|
|
assert_performed_jobs(retry_nb) do
|
|
ErrorJob.perform_later(error, etablissement) rescue StandardError
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
class ErrorJob < APIEntreprise::Job
|
|
def perform(error, etablissement)
|
|
@etablissement = etablissement
|
|
|
|
response = OpenStruct.new(
|
|
effective_url: 'http://host.com/path',
|
|
code: '666',
|
|
body: 'body',
|
|
return_message: 'return_message',
|
|
total_time: 10,
|
|
connect_time: 20,
|
|
headers: 'headers'
|
|
)
|
|
|
|
case error
|
|
when :service_unavaible
|
|
raise APIEntreprise::API::Error::ServiceUnavailable.new(response)
|
|
when :bad_gateway
|
|
raise APIEntreprise::API::Error::BadGateway.new(response)
|
|
when :timed_out
|
|
raise APIEntreprise::API::Error::TimedOut.new(response)
|
|
else
|
|
raise StandardError
|
|
end
|
|
end
|
|
end
|
|
end
|