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
|
# An object that collects stored objects from the central cache and returns
# them to the current host, yo.
class Puppet::Parser::Collector
attr_accessor :type, :scope, :vquery, :equery, :form, :resources
# Call the collection method, mark all of the returned objects as non-virtual,
# and then delete this object from the list of collections to evaluate.
def evaluate
if self.resources
if objects = collect_resources and ! objects.empty?
return objects
else
return false
end
else
method = "collect_#{@form.to_s}"
objects = send(method).each do |obj|
obj.virtual = false
end
if objects.empty?
return false
else
return objects
end
end
end
def initialize(scope, type, equery, vquery, form)
@scope = scope
# Canonize the type
@type = Puppet::ResourceReference.new(type, "whatever").type
@equery = equery
@vquery = vquery
raise(ArgumentError, "Invalid query form %s" % form) unless [:exported, :virtual].include?(form)
@form = form
end
private
# Create our active record query.
def build_active_record_query
Puppet::Rails.init unless ActiveRecord::Base.connected?
raise Puppet::DevError, "Cannot collect resources for a nil host" unless @scope.host
host = Puppet::Rails::Host.find_by_name(@scope.host)
query = {:include => {:param_values => :param_name}}
search = "(exported=? AND restype=?)"
values = [true, @type]
search += " AND (?)" and values << @equery if @equery
# We're going to collect objects from rails, but we don't want any
# objects from this host.
search = ("host_id != ? AND %s" % search) and values.unshift(host.id) if host
query[:conditions] = [search, *values]
return query
end
# Collect exported objects.
def collect_exported
# First get everything from the export table. Just reuse our
# collect_virtual method but tell it to use 'exported? for the test.
resources = collect_virtual(true).reject { |r| ! r.virtual? }
count = resources.length
query = build_active_record_query
# Now look them up in the rails db. When we support attribute comparison
# and such, we'll need to vary the conditions, but this works with no
# attributes, anyway.
time = Puppet::Util.thinmark do
Puppet::Rails::Resource.find(:all, @type, true, query).each do |obj|
if resource = exported_resource(obj)
count += 1
resources << resource
end
end
end
scope.debug("Collected %s %s resource%s in %.2f seconds" %
[count, @type, count == 1 ? "" : "s", time])
return resources
end
def collect_resources
unless @resources.is_a?(Array)
@resources = [@resources]
end
method = "collect_#{form.to_s}_resources"
send(method)
end
def collect_exported_resources
raise Puppet::ParseError, "realize() is not yet implemented for exported resources"
end
# Collect resources directly; this is the result of using 'realize',
# which specifies resources, rather than using a normal collection.
def collect_virtual_resources
return [] unless defined?(@resources) and ! @resources.empty?
result = @resources.dup.collect do |ref|
if res = @scope.findresource(ref.to_s)
@resources.delete(ref)
res
end
end.reject { |r| r.nil? }.each do |res|
res.virtual = false
end
# If there are no more resources to find, delete this from the list
# of collections.
if @resources.empty?
@scope.compile.delete_collection(self)
end
return result
end
# Collect just virtual objects, from our local compile.
def collect_virtual(exported = false)
if exported
method = :exported?
else
method = :virtual?
end
scope.compile.resources.find_all do |resource|
resource.type == @type and resource.send(method) and match?(resource)
end
end
# Seek a specific exported resource.
def exported_resource(obj)
if existing = @scope.findresource(obj.restype, obj.title)
# Next see if we've already collected this resource
return nil if existing.rails_id == obj.id
# This is the one we've already collected
raise Puppet::ParseError, "Exported resource %s cannot override local resource" % [obj.ref]
end
resource = obj.to_resource(self.scope)
resource.exported = false
scope.compile.add_resource(scope, resource)
return resource
end
# Does the resource match our tests? We don't yet support tests,
# so it's always true at the moment.
def match?(resource)
if self.vquery
return self.vquery.call(resource)
else
return true
end
end
end
|
