mirror of
https://github.com/mastodon/mastodon.git
synced 2026-05-23 01:26:36 -05:00
Some checks are pending
Bundler Audit / security (push) Waiting to run
Check i18n / check-i18n (push) Waiting to run
Chromatic / Check for relevant changes (push) Waiting to run
Chromatic / Run Chromatic (push) Blocked by required conditions
CodeQL / Analyze (actions) (push) Waiting to run
CodeQL / Analyze (javascript) (push) Waiting to run
CodeQL / Analyze (ruby) (push) Waiting to run
Crowdin / Upload translations / upload-translations (push) Waiting to run
Check formatting / lint (push) Waiting to run
CSS Linting / lint (push) Waiting to run
Haml Linting / lint (push) Waiting to run
JavaScript Linting / lint (push) Waiting to run
Ruby Linting / lint (push) Waiting to run
JavaScript Testing / test (push) Waiting to run
Historical data migration test / test (14-alpine) (push) Waiting to run
Historical data migration test / test (15-alpine) (push) Waiting to run
Historical data migration test / test (16-alpine) (push) Waiting to run
Historical data migration test / test (17-alpine) (push) Waiting to run
Ruby Testing / build (production) (push) Waiting to run
Ruby Testing / build (test) (push) Waiting to run
Ruby Testing / test (.ruby-version) (push) Blocked by required conditions
Ruby Testing / test (3.3) (push) Blocked by required conditions
Ruby Testing / test (3.4) (push) Blocked by required conditions
Ruby Testing / End to End testing (.ruby-version) (push) Blocked by required conditions
Ruby Testing / End to End testing (3.3) (push) Blocked by required conditions
Ruby Testing / End to End testing (3.4) (push) Blocked by required conditions
Ruby Testing / Elastic Search integration testing (.ruby-version, docker.elastic.co/elasticsearch/elasticsearch:7.17.29) (push) Blocked by required conditions
Ruby Testing / Elastic Search integration testing (.ruby-version, docker.elastic.co/elasticsearch/elasticsearch:8.19.2) (push) Blocked by required conditions
Ruby Testing / Elastic Search integration testing (.ruby-version, opensearchproject/opensearch:2) (push) Blocked by required conditions
Ruby Testing / Elastic Search integration testing (3.3, docker.elastic.co/elasticsearch/elasticsearch:7.17.29) (push) Blocked by required conditions
Ruby Testing / Elastic Search integration testing (3.4, docker.elastic.co/elasticsearch/elasticsearch:7.17.29) (push) Blocked by required conditions
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
|