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
72
73
74
75
76
77
|
require 'spec_helper'
describe MailRoom::Coordinator do
describe '#initialize' do
it 'builds a watcher for each mailbox' do
MailRoom::MailboxWatcher.expects(:new).with('mailbox1').returns('watcher1')
MailRoom::MailboxWatcher.expects(:new).with('mailbox2').returns('watcher2')
coordinator = MailRoom::Coordinator.new(['mailbox1', 'mailbox2'])
expect(coordinator.watchers).to eq(['watcher1', 'watcher2'])
end
it 'makes no watchers when mailboxes is empty' do
coordinator = MailRoom::Coordinator.new([])
expect(coordinator.watchers).to eq([])
end
it 'sets the health check' do
health_check = MailRoom::HealthCheck.new({ address: '127.0.0.1', port: 8080})
coordinator = MailRoom::Coordinator.new([], health_check)
expect(coordinator.health_check).to eq(health_check)
end
end
describe '#run' do
it 'runs each watcher' do
watcher = stub
watcher.stubs(:run)
watcher.stubs(:quit)
health_check = stub
health_check.stubs(:run)
health_check.stubs(:quit)
MailRoom::MailboxWatcher.stubs(:new).returns(watcher)
coordinator = MailRoom::Coordinator.new(['mailbox1'], health_check)
coordinator.stubs(:sleep_while_running)
watcher.expects(:run)
watcher.expects(:quit)
health_check.expects(:run)
health_check.expects(:quit)
coordinator.run
end
it 'should go to sleep after running watchers' do
coordinator = MailRoom::Coordinator.new([])
coordinator.stubs(:running=)
coordinator.stubs(:running?).returns(false)
coordinator.expects(:running=).with(true)
coordinator.expects(:running?)
coordinator.run
end
it 'should set attribute running to true' do
coordinator = MailRoom::Coordinator.new([])
coordinator.stubs(:sleep_while_running)
coordinator.run
expect(coordinator.running).to eq(true)
end
end
describe '#quit' do
it 'quits each watcher' do
watcher = stub(:quit)
MailRoom::MailboxWatcher.stubs(:new).returns(watcher)
coordinator = MailRoom::Coordinator.new(['mailbox1'])
watcher.expects(:quit)
coordinator.quit
end
end
end
|
