|
module Proxy::Puppet
|
|
extend Proxy::Log
|
|
extend Proxy::Util
|
|
require 'proxy/puppet/puppet_class'
|
|
require 'proxy/puppet/environment'
|
|
|
|
|
|
class << self
|
|
def run *hosts
|
|
# Search in /opt/ for puppet enterprise users
|
|
default_path = ["/usr/sbin", "/usr/bin", "/opt/puppet/bin"]
|
|
# search for puppet for users using puppet 2.6+
|
|
puppetrun = which("puppetrun", default_path) || which("puppet", default_path)
|
|
sudo = which("sudo", "/usr/bin")
|
|
|
|
unless puppetrun and sudo
|
|
logger.warn "sudo or puppetrun binary was not found - aborting"
|
|
return false
|
|
end
|
|
# Append kick to the puppet command if we are not using the old puppetca command
|
|
puppetrun << " kick" unless puppetrun.include?('puppetrun')
|
|
|
|
command = %x[#{sudo} #{puppetrun} --host #{hosts.join(" --host ")}]
|
|
unless command =~ /finished with exit code 0/
|
|
logger.warn command
|
|
return false
|
|
end
|
|
return true
|
|
end
|
|
end
|
|
end
|
