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
|
class Puppet::Pops::Evaluator::Collectors::AbstractCollector
attr_reader :scope
# The collector's hash of overrides {:parameters => params}
attr_reader :overrides
# The set of collected resources
attr_reader :collected
# An empty array which will be returned by the unresolved_resources
# method unless we have a FixSetCollector
EMPTY_RESOURCES = [].freeze
# Initialized the instance variables needed by the base
# collector class to perform evaluation
#
# @param [Puppet::Parser::Scope] scope
#
# @param [Hash] overrides a hash of optional overrides
# @options opts [Array] :parameters
# @options opts [String] :file
# @options opts [Array] :line
# @options opts [Puppet::Resource::Type] :source
# @options opts [Puppet::Parser::Scope] :scope
def initialize(scope, overrides = nil)
@collected = {}
@scope = scope
if !(overrides.nil? || overrides[:parameters])
raise ArgumentError, _("Exported resource try to override without parameters")
end
@overrides = overrides
end
# Collects resources and marks collected objects as non-virtual. Also
# handles overrides.
#
# @return [Array] the resources we have collected
def evaluate
objects = collect.each do |obj|
obj.virtual = false
end
return false if objects.empty?
if @overrides and !objects.empty?
overrides[:source].override = true
objects.each do |res|
unless @collected.include?(res.ref)
t = res.type
t = Puppet::Pops::Evaluator::Runtime3ResourceSupport.find_resource_type(scope, t)
newres = Puppet::Parser::Resource.new(t, res.title, @overrides)
scope.compiler.add_override(newres)
end
end
end
objects.reject! { |o| @collected.include?(o.ref) }
return false if objects.empty?
objects.reduce(@collected) { |c,o| c[o.ref]=o; c }
objects
end
# This should only return an empty array unless we have
# an FixedSetCollector, in which case it will return the
# resources that have not yet been realized
#
# @return [Array] the resources that have not been resolved
def unresolved_resources
EMPTY_RESOURCES
end
# Collect the specified resources. The way this is done depends on which type
# of collector we are dealing with. This method is implemented differently in
# each of the three child classes
#
# @return [Array] the collected resources
def collect
raise NotImplementedError, "This method must be implemented by the child class"
end
end
|
