summaryrefslogtreecommitdiffstats
path: root/lib/puppet
diff options
context:
space:
mode:
authorLuke Kanies <luke@madstop.com>2008-04-11 11:34:51 -0500
committerLuke Kanies <luke@madstop.com>2008-04-11 11:34:51 -0500
commit4aaad26509b2dc9bd45782ec45231e6ea53a4a37 (patch)
treee0715ba0328f149bf030b63a9ce30e3fb57a5d26 /lib/puppet
parent2925ad1cb9aa820785afca58c4fb6e34274dadd4 (diff)
downloadpuppet-4aaad26509b2dc9bd45782ec45231e6ea53a4a37.tar.gz
puppet-4aaad26509b2dc9bd45782ec45231e6ea53a4a37.tar.xz
puppet-4aaad26509b2dc9bd45782ec45231e6ea53a4a37.zip
Modified the 'master' handler to use the Catalog class to
compile node configurations, rather than using the Configuration handler, which was never used directly. I removed the Configuration handler as a result. Modified the 'master' handler (responsible for sending configurations to clients) to always return Time.now as its compile date, so configurations will always get recompiled.
Diffstat (limited to 'lib/puppet')
-rw-r--r--lib/puppet/indirector/catalog/compiler.rb18
-rw-r--r--lib/puppet/network/handler/configuration.rb184
-rw-r--r--lib/puppet/network/handler/master.rb21
-rw-r--r--lib/puppet/parser/resource.rb6
4 files changed, 11 insertions, 218 deletions
diff --git a/lib/puppet/indirector/catalog/compiler.rb b/lib/puppet/indirector/catalog/compiler.rb
index ecc340f75..2b5e8d912 100644
--- a/lib/puppet/indirector/catalog/compiler.rb
+++ b/lib/puppet/indirector/catalog/compiler.rb
@@ -19,7 +19,7 @@ class Puppet::Node::Catalog::Compiler < Puppet::Indirector::Code
end
if catalog = compile(node)
- return catalog.to_transportable
+ return catalog
else
# This shouldn't actually happen; we should either return
# a config or raise an exception.
@@ -44,22 +44,6 @@ class Puppet::Node::Catalog::Compiler < Puppet::Indirector::Code
$0 =~ /puppetmasterd/
end
- # Return the catalog version. Here we're returning the
- # latest of the node, fact, or parse date. These are the
- # three things that go into compiling a client catalog,
- # so changes in any of them result in changes.
- # LAK:FIXME Note that this only works when all three sources
- # use timestamps; once one of them moves to using real versions,
- # the comparison stops working.
- def version(key)
- if node = Puppet::Node.find_by_any_name(key)
- return [Puppet::Node.version(key).to_f, Puppet::Node::Facts.version(key).to_f, interpreter.catalog_version(node).to_f].sort[-1]
- else
- # This is the standard for "got nothing for ya".
- 0
- end
- end
-
private
# Add any extra data necessary to the node.
diff --git a/lib/puppet/network/handler/configuration.rb b/lib/puppet/network/handler/configuration.rb
deleted file mode 100644
index 8168ce1d5..000000000
--- a/lib/puppet/network/handler/configuration.rb
+++ /dev/null
@@ -1,184 +0,0 @@
-require 'openssl'
-require 'puppet'
-require 'puppet/parser/interpreter'
-require 'puppet/sslcertificates'
-require 'xmlrpc/server'
-require 'yaml'
-
-class Puppet::Network::Handler
- class Configuration < Handler
- desc "Puppet's configuration compilation interface. Passed a node name
- or other key, retrieves information about the node (using the ``node_source``)
- and returns a compiled configuration."
-
- include Puppet::Util
-
- attr_accessor :local, :classes
-
- @interface = XMLRPC::Service::Interface.new("configuration") { |iface|
- iface.add_method("string configuration(string)")
- iface.add_method("string version()")
- }
-
- # Compile a node's configuration.
- def configuration(key, client = nil, clientip = nil)
- # If we want to use the cert name as our key
- if Puppet[:node_name] == 'cert' and client
- key = client
- end
-
- # Note that this is reasonable, because either their node source should actually
- # know about the node, or they should be using the ``none`` node source, which
- # will always return data.
- unless node = Puppet::Node.find_by_any_name(key)
- raise Puppet::Error, "Could not find node '%s'" % key
- end
-
- # Add any external data to the node.
- add_node_data(node)
-
- configuration = compile(node)
-
- return translate(configuration)
- end
-
- def initialize(options = {})
- options.each do |param, value|
- case param
- when :Classes: @classes = value
- when :Local: self.local = value
- else
- raise ArgumentError, "Configuration handler does not accept %s" % param
- end
- end
-
- set_server_facts
- end
-
- # Are we running locally, or are our clients networked?
- def local?
- self.local
- end
-
- # Return the configuration version.
- def version(client = nil, clientip = nil)
- if client and node = Puppet::Node.find_by_any_name(client)
- update_node_check(node)
- return interpreter.configuration_version(node)
- else
- # Just return something that will always result in a recompile, because
- # this is local.
- return (Time.now + 1000).to_i
- end
- end
-
- private
-
- # Add any extra data necessary to the node.
- def add_node_data(node)
- # Merge in our server-side facts, so they can be used during compilation.
- node.merge(@server_facts)
-
- # Add any specified classes to the node's class list.
- if @classes
- @classes.each do |klass|
- node.classes << klass
- end
- end
- end
-
- # Compile the actual configuration.
- def compile(node)
- # Pick the benchmark level.
- if local?
- level = :none
- else
- level = :notice
- end
-
- # Ask the interpreter to compile the configuration.
- str = "Compiled configuration for %s" % node.name
- if node.environment
- str += " in environment %s" % node.environment
- end
- config = nil
- benchmark(level, "Compiled configuration for %s" % node.name) do
- begin
- config = interpreter.compile(node)
- rescue => detail
- # If we're local, then we leave it to the local system
- # to handle error reporting, but otherwise we do it here
- # so the interpreter doesn't need to know if the parser
- # is local or not.
- Puppet.err(detail.to_s) unless local?
- raise
- end
- end
-
- return config
- end
-
- # Create our interpreter object.
- def create_interpreter
- return Puppet::Parser::Interpreter.new
- end
-
- # Create/return our interpreter.
- def interpreter
- unless defined?(@interpreter) and @interpreter
- @interpreter = create_interpreter
- end
- @interpreter
- end
-
- # Initialize our server fact hash; we add these to each client, and they
- # won't change while we're running, so it's safe to cache the values.
- def set_server_facts
- @server_facts = {}
-
- # Add our server version to the fact list
- @server_facts["serverversion"] = Puppet.version.to_s
-
- # And then add the server name and IP
- {"servername" => "fqdn",
- "serverip" => "ipaddress"
- }.each do |var, fact|
- if value = Facter.value(fact)
- @server_facts[var] = value
- else
- Puppet.warning "Could not retrieve fact %s" % fact
- end
- end
-
- if @server_facts["servername"].nil?
- host = Facter.value(:hostname)
- if domain = Facter.value(:domain)
- @server_facts["servername"] = [host, domain].join(".")
- else
- @server_facts["servername"] = host
- end
- end
- end
-
- # Translate our configuration appropriately for sending back to a client.
- def translate(config)
- if local?
- config
- else
- CGI.escape(config.to_yaml(:UseBlock => true))
- end
- end
-
- # Mark that the node has checked in. FIXME this needs to be moved into
- # the Node class, or somewhere that's got abstract backends.
- def update_node_check(node)
- if Puppet.features.rails? and Puppet[:storeconfigs]
- Puppet::Rails.connect
-
- host = Puppet::Rails::Host.find_or_create_by_name(node.name)
- host.last_freshcheck = Time.now
- host.save
- end
- end
- end
-end
diff --git a/lib/puppet/network/handler/master.rb b/lib/puppet/network/handler/master.rb
index dabfaca50..851ccc7b2 100644
--- a/lib/puppet/network/handler/master.rb
+++ b/lib/puppet/network/handler/master.rb
@@ -23,8 +23,8 @@ class Puppet::Network::Handler
# Tell a client whether there's a fresh config for it
def freshness(client = nil, clientip = nil)
- client ||= Facter.value("hostname")
- config_handler.version(client, clientip)
+ # Always force a recompile. Newer clients shouldn't do this (as of April 2008).
+ Time.now
end
def initialize(hash = {})
@@ -51,8 +51,6 @@ class Puppet::Network::Handler
if hash.include?(:Classes)
args[:Classes] = hash[:Classes]
end
-
- @config_handler = Puppet::Network::Handler.handler(:configuration).new(args)
end
# Call our various handlers; this handler is getting deprecated.
@@ -63,13 +61,9 @@ class Puppet::Network::Handler
# Pass the facts to the fact handler
Puppet::Node::Facts.new(client, facts).save unless local?
- # And get the configuration from the config handler
- config = nil
- benchmark(:notice, "Compiled configuration for %s" % client) do
- config = config_handler.configuration(client)
- end
+ catalog = Puppet::Node::Catalog.find(client)
- return translate(config.extract)
+ return translate(catalog.extract)
end
private
@@ -93,13 +87,6 @@ class Puppet::Network::Handler
return client, clientip
end
- def config_handler
- unless defined? @config_handler
- @config_handler = Puppet::Network::Handler.handler(:config).new :local => local?
- end
- @config_handler
- end
-
#
def decode_facts(facts)
if @local
diff --git a/lib/puppet/parser/resource.rb b/lib/puppet/parser/resource.rb
index 4b48ff6cf..d214a60ee 100644
--- a/lib/puppet/parser/resource.rb
+++ b/lib/puppet/parser/resource.rb
@@ -303,6 +303,12 @@ class Puppet::Parser::Resource
return bucket
end
+ # Convert this resource to a RAL resource. We hackishly go via the
+ # transportable stuff.
+ def to_type
+ to_trans.to_type
+ end
+
def to_transobject
# Now convert to a transobject
obj = Puppet::TransObject.new(@ref.title, @ref.type)