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
|
require 'puppet'
require 'puppet/util/autoload'
class Puppet::Interface
require 'puppet/interface/face_collection'
require 'puppet/interface/action_manager'
include Puppet::Interface::ActionManager
extend Puppet::Interface::ActionManager
require 'puppet/interface/option_manager'
include Puppet::Interface::OptionManager
extend Puppet::Interface::OptionManager
include Puppet::Util
class << self
# This is just so we can search for actions. We only use its
# list of directories to search.
# Can't we utilize an external autoloader, or simply use the $LOAD_PATH? -pvb
def autoloader
@autoloader ||= Puppet::Util::Autoload.new(:application, "puppet/face")
end
def faces
Puppet::Interface::FaceCollection.faces
end
def face?(name, version)
Puppet::Interface::FaceCollection.face?(name, version)
end
def register(instance)
Puppet::Interface::FaceCollection.register(instance)
end
def define(name, version, &block)
if face?(name, version)
face = Puppet::Interface::FaceCollection[name, version]
else
face = self.new(name, version)
Puppet::Interface::FaceCollection.register(face)
# REVISIT: Shouldn't this be delayed until *after* we evaluate the
# current block, not done before? --daniel 2011-04-07
face.load_actions
end
face.instance_eval(&block) if block_given?
return face
end
def [](name, version)
unless face = Puppet::Interface::FaceCollection[name, version]
if current = Puppet::Interface::FaceCollection[name, :current]
raise Puppet::Error, "Could not find version #{version} of #{current}"
else
raise Puppet::Error, "Could not find Puppet Face #{name.inspect}"
end
end
face
end
end
attr_accessor :default_format
def set_default_format(format)
self.default_format = format.to_sym
end
attr_accessor :summary
def summary(value = nil)
@summary = value unless value.nil?
@summary
end
attr_reader :name, :version
def initialize(name, version, &block)
unless Puppet::Interface::FaceCollection.validate_version(version)
raise ArgumentError, "Cannot create face #{name.inspect} with invalid version number '#{version}'!"
end
@name = Puppet::Interface::FaceCollection.underscorize(name)
@version = version
@default_format = :pson
instance_eval(&block) if block_given?
end
# Try to find actions defined in other files.
def load_actions
path = "puppet/face/#{name}"
loaded = []
[path, "#{name}@#{version}/#{path}"].each do |path|
Puppet::Interface.autoloader.search_directories.each do |dir|
fdir = ::File.join(dir, path)
next unless FileTest.directory?(fdir)
Dir.chdir(fdir) do
Dir.glob("*.rb").each do |file|
aname = file.sub(/\.rb/, '')
if loaded.include?(aname)
Puppet.debug "Not loading duplicate action '#{aname}' for '#{name}' from '#{fdir}/#{file}'"
next
end
loaded << aname
Puppet.debug "Loading action '#{aname}' for '#{name}' from '#{fdir}/#{file}'"
require "#{Dir.pwd}/#{aname}"
end
end
end
end
end
def to_s
"Puppet::Face[#{name.inspect}, #{version.inspect}]"
end
########################################################################
# Action decoration, whee! You are not expected to care about this code,
# which exists to support face building and construction. I marked these
# private because the implementation is crude and ugly, and I don't yet know
# enough to work out how to make it clean.
#
# Once we have established that these methods will likely change radically,
# to be unrecognizable in the final outcome. At which point we will throw
# all this away, replace it with something nice, and work out if we should
# be making this visible to the outside world... --daniel 2011-04-14
private
def __invoke_decorations(type, action, passed_args = [], passed_options = {})
[:before, :after].member?(type) or fail "unknown decoration type #{type}"
# Collect the decoration methods matching our pass.
methods = action.options.select do |name|
passed_options.has_key? name
end.map do |name|
action.get_option(name).__decoration_name(type)
end
methods.each do |hook|
begin
respond_to? hook and self.__send__(hook, action, passed_args, passed_options)
rescue => e
Puppet.warning("invoking #{action} #{type} hook: #{e}")
end
end
end
def __decorate(type, name, proc)
meta_def(name, &proc)
method(name).unbind
end
def self.__decorate(type, name, proc)
define_method(name, proc)
instance_method(name)
end
end
|
