(#9080) Add facts from /etc/puppetlabs/facts.d
This fact is a direct copy of R.I.'s work at https://github.com/ripienaar/facter-facts This is necessary plumbing to allow the installer to write a simple text file based on the role the node is receiving. For example: $ cat /etc/puppetlabs/facts.d/puppet_enterprise_mcollective.txt fact_stomp_port=61613 fact_stomp_server=puppetmaster fact_is_puppetagent=true fact_is_puppetmaster=true The mcollectivepe module relies on these facts being set and we need a persistent place to write them during the interview process and later read them when puppet agent runs to configure MCollective on the agent systems. Since stdlib is a public module, both /etc/facts.d and /etc/puppetlabs/facts.d are scanned for static facts.
This commit is contained in:
parent
e8fb6917d1
commit
95c88a1305
1 changed files with 183 additions and 0 deletions
183
lib/facter/facter_dot_d.rb
Normal file
183
lib/facter/facter_dot_d.rb
Normal file
|
@ -0,0 +1,183 @@
|
|||
# A Facter plugin that loads facts from /etc/facts.d.
|
||||
#
|
||||
# Facts can be in the form of JSON, YAML or Text files
|
||||
# and any executable that returns key=value pairs.
|
||||
#
|
||||
# In the case of scripts you can also create a file that
|
||||
# contains a cache TTL. For foo.sh store the ttl as just
|
||||
# a number in foo.sh.ttl
|
||||
#
|
||||
# The cache is stored in /tmp/facts_cache.yaml as a mode
|
||||
# 600 file and will have the end result of not calling your
|
||||
# fact scripts more often than is needed
|
||||
class Facter::Util::DotD
|
||||
require 'yaml'
|
||||
|
||||
def initialize(dir="/etc/facts.d", cache_file="/tmp/facts_cache.yml")
|
||||
@dir = dir
|
||||
@cache_file = cache_file
|
||||
@cache = nil
|
||||
@types = {".txt" => :txt, ".json" => :json, ".yaml" => :yaml}
|
||||
end
|
||||
|
||||
def entries
|
||||
Dir.entries(@dir).reject{|f| f =~ /^\.|\.ttl$/}.sort.map {|f| File.join(@dir, f) }
|
||||
rescue
|
||||
[]
|
||||
end
|
||||
|
||||
def fact_type(file)
|
||||
extension = File.extname(file)
|
||||
|
||||
type = @types[extension] || :unknown
|
||||
|
||||
type = :script if type == :unknown && File.executable?(file)
|
||||
|
||||
return type
|
||||
end
|
||||
|
||||
def txt_parser(file)
|
||||
File.readlines(file).each do |line|
|
||||
if line =~ /^(.+)=(.+)$/
|
||||
var = $1; val = $2
|
||||
|
||||
Facter.add(var) do
|
||||
setcode { val }
|
||||
end
|
||||
end
|
||||
end
|
||||
rescue Exception => e
|
||||
Facter.warn("Failed to handle #{file} as text facts: #{e.class}: #{e}")
|
||||
end
|
||||
|
||||
def json_parser(file)
|
||||
begin
|
||||
require 'json'
|
||||
rescue LoadError
|
||||
require 'rubygems'
|
||||
retry
|
||||
end
|
||||
|
||||
JSON.load(File.read(file)).each_pair do |f, v|
|
||||
Facter.add(f) do
|
||||
setcode { v }
|
||||
end
|
||||
end
|
||||
rescue Exception => e
|
||||
Facter.warn("Failed to handle #{file} as json facts: #{e.class}: #{e}")
|
||||
end
|
||||
|
||||
def yaml_parser(file)
|
||||
require 'yaml'
|
||||
|
||||
YAML.load_file(file).each_pair do |f, v|
|
||||
Facter.add(f) do
|
||||
setcode { v }
|
||||
end
|
||||
end
|
||||
rescue Exception => e
|
||||
Facter.warn("Failed to handle #{file} as yaml facts: #{e.class}: #{e}")
|
||||
end
|
||||
|
||||
def script_parser(file)
|
||||
result = cache_lookup(file)
|
||||
ttl = cache_time(file)
|
||||
|
||||
unless result
|
||||
result = Facter::Util::Resolution.exec(file)
|
||||
|
||||
if ttl > 0
|
||||
Facter.debug("Updating cache for #{file}")
|
||||
cache_store(file, result)
|
||||
cache_save!
|
||||
end
|
||||
else
|
||||
Facter.debug("Using cached data for #{file}")
|
||||
end
|
||||
|
||||
result.split("\n").each do |line|
|
||||
if line =~ /^(.+)=(.+)$/
|
||||
var = $1; val = $2
|
||||
|
||||
Facter.add(var) do
|
||||
setcode { val }
|
||||
end
|
||||
end
|
||||
end
|
||||
rescue Exception => e
|
||||
Facter.warn("Failed to handle #{file} as script facts: #{e.class}: #{e}")
|
||||
Facter.debug(e.backtrace.join("\n\t"))
|
||||
end
|
||||
|
||||
def cache_save!
|
||||
cache = load_cache
|
||||
File.open(@cache_file, "w", 0600) {|f| f.write(YAML.dump(cache)) }
|
||||
rescue
|
||||
end
|
||||
|
||||
def cache_store(file, data)
|
||||
load_cache
|
||||
|
||||
@cache[file] = {:data => data, :stored => Time.now.to_i}
|
||||
rescue
|
||||
end
|
||||
|
||||
def cache_lookup(file)
|
||||
cache = load_cache
|
||||
|
||||
return nil if cache.empty?
|
||||
|
||||
ttl = cache_time(file)
|
||||
|
||||
if cache[file]
|
||||
now = Time.now.to_i
|
||||
|
||||
return cache[file][:data] if ttl == -1
|
||||
return cache[file][:data] if (now - cache[file][:stored]) <= ttl
|
||||
return nil
|
||||
else
|
||||
return nil
|
||||
end
|
||||
rescue
|
||||
return nil
|
||||
end
|
||||
|
||||
def cache_time(file)
|
||||
meta = file + ".ttl"
|
||||
|
||||
return File.read(meta).chomp.to_i
|
||||
rescue
|
||||
return 0
|
||||
end
|
||||
|
||||
def load_cache
|
||||
unless @cache
|
||||
if File.exist?(@cache_file)
|
||||
@cache = YAML.load_file(@cache_file)
|
||||
else
|
||||
@cache = {}
|
||||
end
|
||||
end
|
||||
|
||||
return @cache
|
||||
rescue
|
||||
@cache = {}
|
||||
return @cache
|
||||
end
|
||||
|
||||
def create
|
||||
entries.each do |fact|
|
||||
type = fact_type(fact)
|
||||
parser = "#{type}_parser"
|
||||
|
||||
if respond_to?("#{type}_parser")
|
||||
Facter.debug("Parsing #{fact} using #{parser}")
|
||||
|
||||
send(parser, fact)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
Facter::Util::DotD.new("/etc/facts.d").create
|
||||
Facter::Util::DotD.new("/etc/puppetlabs/facts.d").create
|
Loading…
Reference in a new issue