spec/lib/delivery_failure_tracker_spec.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

# frozen_string_literal: true

require 'rails_helper'

describe DeliveryFailureTracker do
  subject { described_class.new('http://example.com/inbox') }

  describe '#track_success!' do
    before do
      subject.track_failure!
      subject.track_success!
    end

    it 'marks URL as available again' do
      expect(described_class.available?('http://example.com/inbox')).to be true
    end

    it 'resets days to 0' do
      expect(subject.days).to be_zero
    end
  end

  describe '#track_failure!' do
    it 'marks URL as unavailable after 7 days of being called' do
      6.times { |i| Redis.current.sadd('exhausted_deliveries:http://example.com/inbox', i) }
      subject.track_failure!

      expect(subject.days).to eq 7
      expect(described_class.unavailable?('http://example.com/inbox')).to be true
    end

    it 'repeated calls on the same day do not count' do
      subject.track_failure!
      subject.track_failure!

      expect(subject.days).to eq 1
    end
  end

  describe '.filter' do
    before do
      Redis.current.sadd('unavailable_inboxes', 'http://example.com/unavailable/inbox')
    end

    it 'removes URLs that are unavailable' do
      result = described_class.filter(['http://example.com/good/inbox', 'http://example.com/unavailable/inbox'])

      expect(result).to include('http://example.com/good/inbox')
      expect(result).to_not include('http://example.com/unavailable/inbox')
    end
  end

  describe '.track_inverse_success!' do
    let(:from_account) { Fabricate(:account, inbox_url: 'http://example.com/inbox', shared_inbox_url: 'http://example.com/shared/inbox') }

    before do
      Redis.current.sadd('unavailable_inboxes', 'http://example.com/inbox')
      Redis.current.sadd('unavailable_inboxes', 'http://example.com/shared/inbox')

      described_class.track_inverse_success!(from_account)
    end

    it 'marks inbox URL as available again' do
      expect(described_class.available?('http://example.com/inbox')).to be true
    end

    it 'marks shared inbox URL as available again' do
      expect(described_class.available?('http://example.com/shared/inbox')).to be true
    end
  end
end