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
|
require 'puppet/transaction'
require 'puppet/transaction/event'
# Handle all of the work around performing an actual change,
# including calling 'sync' on the properties and producing events.
class Puppet::Transaction::Change
attr_accessor :is, :should, :property, :proxy, :auditing
def auditing?
auditing
end
# Create our event object.
def event
result = property.event
result.previous_value = is
result.desired_value = should
result
end
def initialize(property, currentvalue)
@property = property
@is = currentvalue
@should = property.should
@changed = false
end
def apply
return audit_event if auditing?
return noop_event if noop?
property.sync
result = event()
result.message = property.change_to_s(is, should)
result.status = "success"
result.send_log
result
rescue => detail
puts detail.backtrace if Puppet[:trace]
result = event()
result.status = "failure"
result.message = "change from #{property.is_to_s(is)} to #{property.should_to_s(should)} failed: #{detail}"
result.send_log
result
end
# Is our property noop? This is used for generating special events.
def noop?
@property.noop
end
# The resource that generated this change. This is used for handling events,
# and the proxy resource is used for generated resources, since we can't
# send an event to a resource we don't have a direct relationship with. If we
# have a proxy resource, then the events will be considered to be from
# that resource, rather than us, so the graph resolution will still work.
def resource
self.proxy || @property.resource
end
def to_s
"change #{@property.change_to_s(@is, @should)}"
end
private
def audit_event
# This needs to store the appropriate value, and then produce a new event
result = event
result.message = "audit change: previously recorded value #{property.should_to_s(should)} has been changed to #{property.is_to_s(is)}"
result.status = "audit"
result.send_log
result
end
def noop_event
result = event
result.message = "is #{property.is_to_s(is)}, should be #{property.should_to_s(should)} (noop)"
result.status = "noop"
result.send_log
result
end
end
|
