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
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
|
#! /usr/bin/env ruby
require 'spec_helper'
require 'puppet/resource/status'
describe Puppet::Resource::Status do
include PuppetSpec::Files
before do
@resource = Puppet::Type.type(:file).new :path => make_absolute("/my/file")
@containment_path = ["foo", "bar", "baz"]
@resource.stubs(:pathbuilder).returns @containment_path
@status = Puppet::Resource::Status.new(@resource)
end
it "should compute type and title correctly" do
expect(@status.resource_type).to eq("File")
expect(@status.title).to eq(make_absolute("/my/file"))
end
[:file, :line, :evaluation_time].each do |attr|
it "should support #{attr}" do
@status.send(attr.to_s + "=", "foo")
expect(@status.send(attr)).to eq("foo")
end
end
[:skipped, :failed, :restarted, :failed_to_restart, :changed, :out_of_sync, :scheduled].each do |attr|
it "should support #{attr}" do
@status.send(attr.to_s + "=", "foo")
expect(@status.send(attr)).to eq("foo")
end
it "should have a boolean method for determining whehter it was #{attr}" do
@status.send(attr.to_s + "=", "foo")
expect(@status).to send("be_#{attr}")
end
end
it "should accept a resource at initialization" do
expect(Puppet::Resource::Status.new(@resource).resource).not_to be_nil
end
it "should set its source description to the resource's path" do
@resource.expects(:path).returns "/my/path"
expect(Puppet::Resource::Status.new(@resource).source_description).to eq("/my/path")
end
it "should set its containment path" do
expect(Puppet::Resource::Status.new(@resource).containment_path).to eq(@containment_path)
end
[:file, :line].each do |attr|
it "should copy the resource's #{attr}" do
@resource.expects(attr).returns "foo"
expect(Puppet::Resource::Status.new(@resource).send(attr)).to eq("foo")
end
end
it "should copy the resource's tags" do
@resource.expects(:tags).returns %w{foo bar}
status = Puppet::Resource::Status.new(@resource)
expect(status).to be_tagged("foo")
expect(status).to be_tagged("bar")
end
it "should always convert the resource to a string" do
@resource.expects(:to_s).returns "foo"
expect(Puppet::Resource::Status.new(@resource).resource).to eq("foo")
end
it "should support tags" do
expect(Puppet::Resource::Status.ancestors).to include(Puppet::Util::Tagging)
end
it "should create a timestamp at its creation time" do
expect(@status.time).to be_instance_of(Time)
end
it "should support adding events" do
event = Puppet::Transaction::Event.new(:name => :foobar)
@status.add_event(event)
expect(@status.events).to eq([event])
end
it "should use '<<' to add events" do
event = Puppet::Transaction::Event.new(:name => :foobar)
expect(@status << event).to equal(@status)
expect(@status.events).to eq([event])
end
it "records an event for a failure caused by an error" do
@status.failed_because(StandardError.new("the message"))
expect(@status.events[0].message).to eq("the message")
expect(@status.events[0].status).to eq("failure")
expect(@status.events[0].name).to eq(:resource_error)
end
it "should count the number of successful events and set changed" do
3.times{ @status << Puppet::Transaction::Event.new(:status => 'success') }
expect(@status.change_count).to eq(3)
expect(@status.changed).to eq(true)
expect(@status.out_of_sync).to eq(true)
end
it "should not start with any changes" do
expect(@status.change_count).to eq(0)
expect(@status.changed).to eq(false)
expect(@status.out_of_sync).to eq(false)
end
it "should not treat failure, audit, or noop events as changed" do
['failure', 'audit', 'noop'].each do |s| @status << Puppet::Transaction::Event.new(:status => s) end
expect(@status.change_count).to eq(0)
expect(@status.changed).to eq(false)
end
it "should not treat audit events as out of sync" do
@status << Puppet::Transaction::Event.new(:status => 'audit')
expect(@status.out_of_sync_count).to eq(0)
expect(@status.out_of_sync).to eq(false)
end
['failure', 'noop', 'success'].each do |event_status|
it "should treat #{event_status} events as out of sync" do
3.times do @status << Puppet::Transaction::Event.new(:status => event_status) end
expect(@status.out_of_sync_count).to eq(3)
expect(@status.out_of_sync).to eq(true)
end
end
describe "When converting to YAML" do
it "should include only documented attributes" do
@status.file = "/foo.rb"
@status.line = 27
@status.evaluation_time = 2.7
@status.tags = %w{one two}
expect(@status.to_yaml_properties).to match_array(Puppet::Resource::Status::YAML_ATTRIBUTES)
end
end
it "should round trip through pson" do
@status.file = "/foo.rb"
@status.line = 27
@status.evaluation_time = 2.7
@status.tags = %w{one two}
@status << Puppet::Transaction::Event.new(:name => :mode_changed, :status => 'audit')
@status.failed = false
@status.changed = true
@status.out_of_sync = true
@status.skipped = false
expect(@status.containment_path).to eq(@containment_path)
tripped = Puppet::Resource::Status.from_data_hash(PSON.parse(@status.to_pson))
expect(tripped.title).to eq(@status.title)
expect(tripped.containment_path).to eq(@status.containment_path)
expect(tripped.file).to eq(@status.file)
expect(tripped.line).to eq(@status.line)
expect(tripped.resource).to eq(@status.resource)
expect(tripped.resource_type).to eq(@status.resource_type)
expect(tripped.evaluation_time).to eq(@status.evaluation_time)
expect(tripped.tags).to eq(@status.tags)
expect(tripped.time).to eq(@status.time)
expect(tripped.failed).to eq(@status.failed)
expect(tripped.changed).to eq(@status.changed)
expect(tripped.out_of_sync).to eq(@status.out_of_sync)
expect(tripped.skipped).to eq(@status.skipped)
expect(tripped.change_count).to eq(@status.change_count)
expect(tripped.out_of_sync_count).to eq(@status.out_of_sync_count)
expect(events_as_hashes(tripped)).to eq(events_as_hashes(@status))
end
def events_as_hashes(report)
report.events.collect do |e|
{
:audited => e.audited,
:property => e.property,
:previous_value => e.previous_value,
:desired_value => e.desired_value,
:historical_value => e.historical_value,
:message => e.message,
:name => e.name,
:status => e.status,
:time => e.time,
}
end
end
end
|
