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
|
# Manage indirections to termini. They are organized in terms of indirections -
# - e.g., configuration, node, file, certificate -- and each indirection has one
# or more terminus types defined. The indirection is configured via the
# +indirects+ method, which will be called by the class extending itself
# with this module.
module Puppet::Indirector
# LAK:FIXME We need to figure out how to handle documentation for the
# different indirection types.
require 'puppet/indirector/indirection'
require 'puppet/indirector/terminus'
# Declare that the including class indirects its methods to
# this terminus. The terminus name must be the name of a Puppet
# default, not the value -- if it's the value, then it gets
# evaluated at parse time, which is before the user has had a chance
# to override it.
def indirects(indirection, options = {})
raise(ArgumentError, "Already handling indirection for %s; cannot also handle %s" % [@indirection.name, indirection]) if defined?(@indirection) and @indirection
# populate this class with the various new methods
extend ClassMethods
include InstanceMethods
# instantiate the actual Terminus for that type and this name (:ldap, w/ args :node)
# & hook the instantiated Terminus into this class (Node: @indirection = terminus)
@indirection = Puppet::Indirector::Indirection.new(self, indirection)
unless options.empty?
options.each do |param, value|
case param
when :terminus_class: @indirection.terminus_class = value
else
raise ArgumenError, "Invalid option '%s' to 'indirects'" % param
end
end
end
@indirection
end
module ClassMethods
attr_reader :indirection
def cache_class=(klass)
indirection.cache_class = klass
end
def terminus_class=(klass)
indirection.terminus_class = klass
end
def find(*args)
indirection.find(*args)
end
def destroy(*args)
indirection.destroy(*args)
end
def search(*args)
indirection.search(*args)
end
def version(*args)
indirection.version(*args)
end
end
module InstanceMethods
# Make it easy for the model to set versions,
# which are used for caching and such.
attr_accessor :version
# these become instance methods
def save(*args)
self.class.indirection.save(self, *args)
end
end
end
|
