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
|
# frozen_string_literal: true
describe Workers::SendPrivate do
let(:sender_id) { "any_user@example.org" }
let(:obj_str) { "status_message@guid" }
let(:targets) {
{
"https://example.org/receive/user/guid" => "<xml>post</xml>",
"https://example.com/receive/user/guid" => "<xml>post2</xml>"
}
}
let(:failing_targets) { {"https://example.org/receive/user/guid" => "<xml>post</xml>"} }
it "succeeds if all urls were successful" do
expect(DiasporaFederation::Federation::Sender).to receive(:private).with(
sender_id, obj_str, targets
).and_return({})
expect(Workers::SendPrivate).not_to receive(:perform_in)
Workers::SendPrivate.new.perform(sender_id, obj_str, targets)
end
it "retries failing urls" do
expect(DiasporaFederation::Federation::Sender).to receive(:private).with(
sender_id, obj_str, targets
).and_return(failing_targets)
expect(Workers::SendPrivate).to receive(:perform_in).with(
kind_of(Integer), sender_id, obj_str, failing_targets, 1
)
Workers::SendPrivate.new.perform(sender_id, obj_str, targets)
end
it "does not retry failing urls if max retries is reached" do
expect(DiasporaFederation::Federation::Sender).to receive(:private).with(
sender_id, obj_str, targets
).and_return(failing_targets)
expect(Workers::SendPrivate).not_to receive(:perform_in)
expect {
Workers::SendPrivate.new.perform(sender_id, obj_str, targets, 9)
}.to raise_error Workers::SendBase::MaxRetriesReached
end
it "retries contact entities 20 times" do
contact = Fabricate(:contact_entity, author: sender_id, recipient: alice.diaspora_handle)
obj_str = contact.to_s
targets = {"https://example.org/receive/user/guid" => "<xml>post</xml>"}
expect(DiasporaFederation::Federation::Sender).to receive(:private).with(
sender_id, obj_str, targets
).and_return(targets).twice
expect(Workers::SendPrivate).to receive(:perform_in).with(a_kind_of(Numeric), sender_id, obj_str, targets, 19)
Workers::SendPrivate.new.perform(sender_id, obj_str, targets, 18)
expect(Workers::SendPrivate).not_to receive(:perform_in)
expect {
Workers::SendPrivate.new.perform(sender_id, obj_str, targets, 19)
}.to raise_error Workers::SendBase::MaxRetriesReached
end
end
|
