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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
require 'spec_helper'
describe 'Server Discovery and Monitoring' do
include Mongo::SDAM
SERVER_DISCOVERY_TESTS.each do |file|
spec = Mongo::SDAM::Spec.new(file)
context(spec.description) do
before(:all) do
@client = Mongo::Client.new([])
@client.send(:create_from_uri, spec.uri_string)
client_options = @client.instance_variable_get(:@options)
@client.instance_variable_set(:@options, client_options.merge(heartbeat_frequency: 100, connect_timeout: 0.1))
@client.cluster.instance_variable_set(:@options, client_options.merge(heartbeat_frequency: 100, connect_timeout: 0.1))
@client.cluster.instance_variable_get(:@servers).each { |s| s.disconnect!; s.unknown!; }
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|
server = find_server(@client, response.address)
unless server
server = Mongo::Server.new(
Mongo::Address.new(response.address),
@client.cluster,
@client.instance_variable_get(:@monitoring),
@client.cluster.send(:event_listeners),
@client.cluster.options
)
server.disconnect!
server.unknown!
end
monitor = server.instance_variable_get(:@monitor)
description = monitor.inspector.run(server.description, response.ismaster, 0.5)
monitor.instance_variable_set(:@description, description)
end
end
if phase.outcome.compatible?
let(:cluster_addresses) do
@client.cluster.instance_variable_get(:@servers).
collect(&:address).collect(&:to_s).uniq.sort
end
let(:phase_addresses) do
phase.outcome.servers.keys.sort
end
it "sets the cluster topology to #{phase.outcome.topology_type}" do
expect(@client.cluster).to be_topology(phase.outcome.topology_type)
end
it "sets the cluster replica set name to #{phase.outcome.set_name.inspect}" do
expect(@client.cluster.replica_set_name).to eq(phase.outcome.set_name)
end
it "sets the cluster logical session timeout minutes to #{phase.outcome.logical_session_timeout.inspect}" do
expect(@client.cluster.logical_session_timeout).to eq(phase.outcome.logical_session_timeout)
end
it "has the expected servers in the cluster" do
expect(cluster_addresses).to eq(phase_addresses)
end
phase.outcome.servers.each do |uri, server|
it "sets #{uri} to #{server['type']}" do
expect(find_server(@client, uri)).to be_server_type(server['type'])
end
it "sets #{uri} replica set name to #{server['setName'].inspect}" do
expect(find_server(@client, uri).replica_set_name).to eq(server['setName'])
end
end
else
before do
@client.cluster.servers.each do |server|
allow(server).to receive(:connectable?).and_return(true)
end
end
it 'raises an UnsupportedFeatures error' do
expect {
Mongo::ServerSelector.get(mode: :primary).select_server(@client.cluster)
Mongo::ServerSelector.get(mode: :secondary).select_server(@client.cluster)
}.to raise_exception(Mongo::Error::UnsupportedFeatures)
end
end
end
end
end
end
end
|
