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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
# frozen_string_literal: true
require 'json'
require 'helpers/acceptance/tests/manifest_shared_examples'
require 'helpers/acceptance/tests/bad_manifest_shared_examples'
# Describes how to apply a manifest with a SLM policy, verify it, and clean it up
shared_examples 'SLM policy application' do |es_config, name, slm_policy, param|
context 'present' do
let(:extra_manifest) do
<<-MANIFEST
elasticsearch::snapshot_repository { '#{slm_policy['repository']}':
ensure => 'present',
location => '/var/lib/elasticsearch/backup'
}
elasticsearch::slm_policy { '#{name}':
ensure => 'present',
#{param}
}
MANIFEST
end
include_examples('manifest application')
include_examples('SLM policy content', es_config, slm_policy, name)
end
context 'absent' do
let(:extra_manifest) do
<<-MANIFEST
elasticsearch::slm_policy { '#{name}':
ensure => absent,
}
MANIFEST
end
include_examples('manifest application')
end
end
# Verifies the content of a loaded SLM policy.
shared_examples 'SLM policy content' do |es_config, slm_policy, _name|
elasticsearch_port = es_config['http.port']
describe port(elasticsearch_port) do
it 'open', :with_retries do
expect(subject).to be_listening
end
end
describe "http://localhost:#{elasticsearch_port}/_slm/policy" do
subject { shell("curl http://localhost:#{elasticsearch_port}/_slm/policy") }
it 'returns the configured SLM policy', :with_retries do
expect(JSON.parse(subject.stdout).values).
to include(include('policy' => slm_policy))
end
end
end
# Main entrypoint for SLM policy tests
shared_examples 'SLM policy operations' do |es_config, slm_policy|
describe 'policy resources' do
before :all do # rubocop:disable RSpec/BeforeAfterAll
shell "mkdir -p #{default.puppet['codedir']}/modules/another/files"
create_remote_file(
default,
"#{default.puppet['codedir']}/modules/another/files/good.json",
JSON.dump(slm_policy)
)
create_remote_file(
default,
"#{default.puppet['codedir']}/modules/another/files/bad.json",
JSON.dump(slm_policy)[0..-5]
)
end
es_config = {
'http.port' => 9200,
'node.name' => 'elasticsearchSlm01',
'path.repo' => '/var/lib/elasticsearch'
}
# Override the manifest in order to populate 'path.repo'
let(:manifest) do
package = if v[:is_snapshot]
<<-MANIFEST
manage_repo => false,
package_url => '#{v[:snapshot_package]}',
MANIFEST
else
<<-MANIFEST
# Hard version set here due to plugin incompatibilities.
version => '#{v[:elasticsearch_full_version]}',
MANIFEST
end
<<-MANIFEST
api_timeout => 60,
config => {
#{es_config.map { |k, v| " '#{k}' => '#{v}'," }.join("\n")}
},
jvm_options => [
'-Xms128m',
'-Xmx128m',
],
oss => #{v[:oss]},
#{package}
MANIFEST
end
let(:manifest_class_parameters) { 'restart_on_change => true' }
context 'configured through' do
context '`source`' do
include_examples(
'SLM policy application',
es_config,
SecureRandom.hex(8),
slm_policy,
"source => 'puppet:///modules/another/good.json'"
)
end
context '`content`' do
include_examples(
'SLM policy application',
es_config,
SecureRandom.hex(8),
slm_policy,
"content => '#{JSON.dump(slm_policy)}'"
)
end
context 'bad json' do
let(:extra_manifest) do
<<-MANIFEST
elasticsearch::slm_policy { '#{SecureRandom.hex(8)}':
ensure => 'present',
file => 'puppet:///modules/another/bad.json'
}
MANIFEST
end
include_examples('invalid manifest application')
end
end
end
end
|
