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
|
require 'spec_helper'
describe 'SDAM Monitoring' do
include Mongo::SDAM
SDAM_MONITORING_TESTS.each do |file|
spec = Mongo::SDAM::Spec.new(file)
context(spec.description) do
before(:all) do
@client = Mongo::Client.new([], heartbeat_frequency: 100, connect_timeout: 0.1)
@subscriber = Mongo::SDAMMonitoring::TestSubscriber.new
@client.subscribe(Mongo::Monitoring::SERVER_OPENING, @subscriber)
@client.subscribe(Mongo::Monitoring::SERVER_CLOSED, @subscriber)
@client.subscribe(Mongo::Monitoring::SERVER_DESCRIPTION_CHANGED, @subscriber)
@client.subscribe(Mongo::Monitoring::TOPOLOGY_OPENING, @subscriber)
@client.subscribe(Mongo::Monitoring::TOPOLOGY_CHANGED, @subscriber)
@client.send(:create_from_uri, spec.uri_string)
end
after(:all) do
@client.close
end
spec.phases.each_with_index do |phase, index|
context("Phase: #{index + 1}") do
before(:all) do
phase.responses.each do |response|
# For each response in the phase, we need to change that server's description.
server = find_server(@client, response.address)
server ||= Mongo::Server.new(
Mongo::Address.new(response.address),
@client.cluster,
@client.instance_variable_get(:@monitoring),
@client.cluster.send(:event_listeners),
@client.cluster.options
)
monitor = server.instance_variable_get(:@monitor)
description = monitor.inspector.run(server.description, response.ismaster, 0.5)
monitor.instance_variable_set(:@description, description)
end
end
phase.outcome.events.each do |expectation|
it "expects a #{expectation.name} to be fired" do
fired_event = @subscriber.first_event(expectation.name)
expect(fired_event).not_to be_nil
expect(fired_event).to match_sdam_monitoring_event(expectation)
end
end
end
end
end
end
end
|
