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
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
|
# The scope class, which handles storing and retrieving variables and types and
# such.
require 'puppet/parser/parser'
require 'puppet/parser/templatewrapper'
require 'puppet/transportable'
require 'strscan'
class Puppet::Parser::Scope
require 'puppet/parser/resource'
AST = Puppet::Parser::AST
Puppet::Util.logmethods(self)
include Enumerable
include Puppet::Util::Errors
attr_accessor :parent, :level, :parser, :source
attr_accessor :name, :type, :base, :keyword
attr_accessor :top, :translated, :exported, :virtual, :configuration
# Proxy accessors
def host
@configuration.node.name
end
def interpreter
@configuration.interpreter
end
# Is the value true? This allows us to control the definition of truth
# in one place.
def self.true?(value)
if value == false or value == "" or value == :undef
return false
else
return true
end
end
# Add to our list of namespaces.
def add_namespace(ns)
return false if @namespaces.include?(ns)
if @namespaces == [""]
@namespaces = [ns]
else
@namespaces << ns
end
end
# Is the type a builtin type?
def builtintype?(type)
if typeklass = Puppet::Type.type(type)
return typeklass
else
return false
end
end
# Retrieve a given class scope from the configuration.
def class_scope(klass)
configuration.class_scope(klass)
end
# Are we the top scope?
def topscope?
@level == 1
end
def exported?
self.exported
end
def findclass(name)
@namespaces.each do |namespace|
if r = parser.findclass(namespace, name)
return r
end
end
return nil
end
def finddefine(name)
@namespaces.each do |namespace|
if r = parser.finddefine(namespace, name)
return r
end
end
return nil
end
def findresource(string, name = nil)
configuration.findresource(string, name)
end
# Initialize our new scope. Defaults to having no parent.
def initialize(hash = {})
if hash.include?(:namespace)
if n = hash[:namespace]
@namespaces = [n]
end
hash.delete(:namespace)
else
@namespaces = [""]
end
hash.each { |name, val|
method = name.to_s + "="
if self.respond_to? method
self.send(method, val)
else
raise Puppet::DevError, "Invalid scope argument %s" % name
end
}
@tags = []
# The symbol table for this scope. This is where we store variables.
@symtable = {}
# All of the defaults set for types. It's a hash of hashes,
# with the first key being the type, then the second key being
# the parameter.
@defaults = Hash.new { |dhash,type|
dhash[type] = {}
}
end
# Collect all of the defaults set at any higher scopes.
# This is a different type of lookup because it's additive --
# it collects all of the defaults, with defaults in closer scopes
# overriding those in later scopes.
def lookupdefaults(type)
values = {}
# first collect the values from the parents
unless parent.nil?
parent.lookupdefaults(type).each { |var,value|
values[var] = value
}
end
# then override them with any current values
# this should probably be done differently
if @defaults.include?(type)
@defaults[type].each { |var,value|
values[var] = value
}
end
#Puppet.debug "Got defaults for %s: %s" %
# [type,values.inspect]
return values
end
# Look up a defined type.
def lookuptype(name)
finddefine(name) || findclass(name)
end
def lookup_qualified_var(name, usestring)
parts = name.split(/::/)
shortname = parts.pop
klassname = parts.join("::")
klass = findclass(klassname)
unless klass
raise Puppet::ParseError, "Could not find class %s" % klassname
end
unless kscope = class_scope(klass)
raise Puppet::ParseError, "Class %s has not been evaluated so its variables cannot be referenced" % klass.classname
end
return kscope.lookupvar(shortname, usestring)
end
private :lookup_qualified_var
# Look up a variable. The simplest value search we do. Default to returning
# an empty string for missing values, but support returning a constant.
def lookupvar(name, usestring = true)
# If the variable is qualified, then find the specified scope and look the variable up there instead.
if name =~ /::/
return lookup_qualified_var(name, usestring)
end
# We can't use "if @symtable[name]" here because the value might be false
if @symtable.include?(name)
if usestring and @symtable[name] == :undef
return ""
else
return @symtable[name]
end
elsif self.parent
return parent.lookupvar(name, usestring)
elsif usestring
return ""
else
return :undefined
end
end
def namespaces
@namespaces.dup
end
# Create a new scope and set these options.
def newscope(options)
configuration.newscope(self, options)
end
# Is this class for a node? This is used to make sure that
# nodes and classes with the same name conflict (#620), which
# is required because of how often the names are used throughout
# the system, including on the client.
def nodescope?
defined?(@nodescope) and @nodescope
end
# We probably shouldn't cache this value... But it's a lot faster
# than doing lots of queries.
def parent
unless defined?(@parent)
@parent = configuration.parent(self)
end
@parent
end
# Return the list of scopes up to the top scope, ordered with our own first.
# This is used for looking up variables and defaults.
def scope_path
if parent
[self, parent.scope_path].flatten.compact
else
[self]
end
end
def resources
@definedtable.values
end
# Store the fact that we've evaluated a given class. We use a hash
# that gets inherited from the top scope down, rather than a global
# hash. We store the object ID, not class name, so that we
# can support multiple unrelated classes with the same name.
def setclass(klass)
if klass.is_a?(AST::HostClass)
unless name = klass.classname
raise Puppet::DevError, "Got a %s with no fully qualified name" %
klass.class
end
@configuration.class_set(name, self)
else
raise Puppet::DevError, "Invalid class %s" % klass.inspect
end
if klass.is_a?(AST::Node)
@nodescope = true
end
nil
end
# Add a new object to our object table and the global list, and do any necessary
# checks.
def setresource(resource)
@configuration.store_resource(self, resource)
# Mark the resource as virtual or exported, as necessary.
if self.exported?
resource.exported = true
elsif self.virtual?
resource.virtual = true
end
return resource
end
# Override a parameter in an existing object. If the object does not yet
# exist, then cache the override in a global table, so it can be flushed
# at the end.
def setoverride(resource)
@configuration.store_override(resource)
end
# Set defaults for a type. The typename should already be downcased,
# so that the syntax is isolated. We don't do any kind of type-checking
# here; instead we let the resource do it when the defaults are used.
def setdefaults(type, params)
table = @defaults[type]
# if we got a single param, it'll be in its own array
params = [params] unless params.is_a?(Array)
params.each { |param|
#Puppet.debug "Default for %s is %s => %s" %
# [type,ary[0].inspect,ary[1].inspect]
if table.include?(param.name)
raise Puppet::ParseError.new("Default already defined for %s { %s }; cannot redefine" % [type, param.name], param.line, param.file)
end
table[param.name] = param
}
end
# Set a variable in the current scope. This will override settings
# in scopes above, but will not allow variables in the current scope
# to be reassigned.
def setvar(name,value, file = nil, line = nil)
#Puppet.debug "Setting %s to '%s' at level %s" %
# [name.inspect,value,self.level]
if @symtable.include?(name)
error = Puppet::ParseError.new("Cannot reassign variable %s" % name)
if file
error.file = file
end
if line
error.line = line
end
raise error
end
@symtable[name] = value
end
# Return an interpolated string.
def strinterp(string, file = nil, line = nil)
# Most strings won't have variables in them.
ss = StringScanner.new(string)
out = ""
while not ss.eos?
if ss.scan(/^\$\{((\w*::)*\w+)\}|^\$((\w*::)*\w+)/)
# If it matches the backslash, then just retun the dollar sign.
if ss.matched == '\\$'
out << '$'
else # look the variable up
out << lookupvar(ss[1] || ss[3]).to_s || ""
end
elsif ss.scan(/^\\(.)/)
# Puppet.debug("Got escape: pos:%d; m:%s" % [ss.pos, ss.matched])
case ss[1]
when 'n'
out << "\n"
when 't'
out << "\t"
when 's'
out << " "
when '\\'
out << '\\'
when '$'
out << '$'
else
str = "Unrecognised escape sequence '#{ss.matched}'"
if file
str += " in file %s" % file
end
if line
str += " at line %s" % line
end
Puppet.warning str
out << ss.matched
end
elsif ss.scan(/^\$/)
out << '$'
elsif ss.scan(/^\\\n/) # an escaped carriage return
next
else
tmp = ss.scan(/[^\\$]+/)
# Puppet.debug("Got other: pos:%d; m:%s" % [ss.pos, tmp])
unless tmp
error = Puppet::ParseError.new("Could not parse string %s" %
string.inspect)
{:file= => file, :line= => line}.each do |m,v|
error.send(m, v) if v
end
raise error
end
out << tmp
end
end
return out
end
# Add a tag to our current list. These tags will be added to all
# of the objects contained in this scope.
def tag(*ary)
ary.each { |tag|
if tag.nil? or tag == ""
puts caller
Puppet.debug "got told to tag with %s" % tag.inspect
next
end
unless tag =~ /^\w[-\w]*$/
fail Puppet::ParseError, "Invalid tag %s" % tag.inspect
end
tag = tag.to_s
unless @tags.include?(tag)
#Puppet.info "Tagging scope %s with %s" % [self.object_id, tag]
@tags << tag
end
}
end
# Return the tags associated with this scope. It's basically
# just our parents' tags, plus our type. We don't cache this value
# because our parent tags might change between calls.
def tags
tmp = [] + @tags
unless ! defined? @type or @type.nil? or @type == ""
tmp << @type.to_s
end
if parent
#info "Looking for tags in %s" % parent.type
parent.tags.each { |tag|
if tag.nil? or tag == ""
Puppet.debug "parent returned tag %s" % tag.inspect
next
end
unless tmp.include?(tag)
tmp << tag
end
}
end
return tmp.sort.uniq
end
# Used mainly for logging
def to_s
if self.name
return "%s[%s]" % [@type, @name]
else
return self.type.to_s
end
end
# Convert our resource to a TransBucket.
def to_trans
bucket = Puppet::TransBucket.new([])
case self.type
when "": bucket.type = "main"
when nil: devfail "A Scope with no type"
else
bucket.type = @type
end
if self.name
bucket.name = self.name
end
return bucket
end
# Undefine a variable; only used for testing.
def unsetvar(var)
if @symtable.include?(var)
@symtable.delete(var)
end
end
def virtual?
self.virtual || self.exported?
end
end
# $Id$
|