Crowdin / Upload translations / upload-translations (push) Skipped
Historical data migration test / test (14-alpine) (push) Canceled after 0s
Historical data migration test / test (15-alpine) (push) Canceled after 0s
Historical data migration test / test (16-alpine) (push) Canceled after 0s
Historical data migration test / test (17-alpine) (push) Canceled after 0s
Bundler Audit / security (push) Canceled after 0s
Haml Linting / lint (push) Canceled after 0s
JavaScript Linting / lint (push) Canceled after 0s
Ruby Linting / lint (push) Canceled after 0s
JavaScript Testing / test (push) Canceled after 0s
Ruby Testing / build (production) (push) Canceled after 0s
Ruby Testing / test (.ruby-version) (push) Canceled after 0s
Ruby Testing / test (3.3) (push) Canceled after 0s
Ruby Testing / test (3.4) (push) Canceled after 0s
Ruby Testing / End to End testing (.ruby-version) (push) Canceled after 0s
Ruby Testing / End to End testing (3.3) (push) Canceled after 0s
Ruby Testing / End to End testing (3.4) (push) Canceled after 0s
Ruby Testing / Elastic Search integration testing (.ruby-version, docker.elastic.co/elasticsearch/elasticsearch:7.17.29) (push) Canceled after 0s
Check i18n / check-i18n (push) Canceled after 0s
CodeQL / Analyze (actions) (push) Canceled after 0s
CodeQL / Analyze (javascript) (push) Canceled after 0s
CodeQL / Analyze (ruby) (push) Canceled after 0s
Ruby Testing / Elastic Search integration testing (.ruby-version, opensearchproject/opensearch:2) (push) Canceled after 0s
Ruby Testing / Elastic Search integration testing (3.3, docker.elastic.co/elasticsearch/elasticsearch:7.17.29) (push) Canceled after 0s
Ruby Testing / Elastic Search integration testing (3.4, docker.elastic.co/elasticsearch/elasticsearch:7.17.29) (push) Canceled after 0s
Check formatting / lint (push) Canceled after 0s
CSS Linting / lint (push) Canceled after 0s
Ruby Testing / Elastic Search integration testing (.ruby-version, docker.elastic.co/elasticsearch/elasticsearch:8.19.2) (push) Canceled after 0s
Chromatic / Check for relevant changes (push) Canceled after 0s
Chromatic / Run Chromatic (push) Canceled after 0s
Snapshot of upstream tag v4.7.3 (commit 8ff11c2bb7b9f0714e947b10fa3629c6542c7121) from https://github.com/mastodon/mastodon, unmodified.
61 lines
1.9 KiB
Ruby
61 lines
1.9 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
RSpec.shared_examples 'worker handling fasp delivery failures' do
|
|
context 'when provider is not available' do
|
|
let(:delivery_last_failed_at) { 1.minute.ago.beginning_of_minute }
|
|
|
|
before do
|
|
provider.update(delivery_last_failed_at:)
|
|
domain = Addressable::URI.parse(provider.base_url).normalized_host
|
|
UnavailableDomain.create!(domain:)
|
|
end
|
|
|
|
it 'does not attempt connecting, does not fail the job and does not update the provider' do
|
|
expect { subject }.to_not raise_error
|
|
expect(stubbed_request).to_not have_been_made
|
|
expect(provider.reload.delivery_last_failed_at).to eq delivery_last_failed_at
|
|
end
|
|
end
|
|
|
|
context 'when connection to provider fails' do
|
|
before do
|
|
base_stubbed_request
|
|
.to_raise(HTTP::ConnectionError)
|
|
end
|
|
|
|
context 'when provider becomes unavailable' do
|
|
before do
|
|
travel_to 5.minutes.ago
|
|
4.times do
|
|
provider.delivery_failure_tracker.track_failure!
|
|
travel_to 1.minute.since
|
|
end
|
|
end
|
|
|
|
it 'updates the provider and does not fail the job, so it will not be retried' do
|
|
expect { subject }.to_not raise_error
|
|
expect(provider.reload.delivery_last_failed_at).to eq Time.current
|
|
end
|
|
end
|
|
|
|
context 'when provider is still marked as available' do
|
|
it 'fails the job so it can be retried' do
|
|
expect { subject }.to raise_error(HTTP::ConnectionError)
|
|
end
|
|
end
|
|
end
|
|
|
|
context 'when connection to a previously unavailable provider succeeds' do
|
|
before do
|
|
provider.update(delivery_last_failed_at: 2.hours.ago)
|
|
domain = Addressable::URI.parse(provider.base_url).normalized_host
|
|
UnavailableDomain.create!(domain:)
|
|
end
|
|
|
|
it 'marks the provider as being available again' do
|
|
expect { subject }.to_not raise_error
|
|
expect(provider).to be_available
|
|
end
|
|
end
|
|
end
|