Sync r10k then run puppet on respective environment on agents

webhook_payload.rb

#!/opt/puppet/bin/ruby
require 'mcollective'
require 'yaml'
include MCollective::RPC

WEBHOOK_CONFIG = '/etc/webhook.yaml'

ENV['HOME'] = '/var/lib/peadmin'
ENV['PATH'] = '/sbin:/usr/sbin:/bin:/usr/bin:/opt/puppet/bin'


if (File.exists?(WEBHOOK_CONFIG))
  $config = YAML.load_file(WEBHOOK_CONFIG)
else
  raise "Configuration file: #{WEBHOOK_CONFIG} does not exist"
end


def mco(branch)
  options =  MCollective::Util.default_options
  options[:config] = $config['client_cfg']
  client = rpcclient('r10k', :exit_on_failure => false,:options => options)
  client.discovery_timeout = $config['discovery_timeout'].to_i
  client.timeout           = $config['client_timeout'].to_i
  result = client.send('deploy',{:environment => branch})
end # end deploy()

def puppet(environment)
  options =  MCollective::Util.default_options
  options[:config] = $config['client_cfg']
  options[:fact]   = {:fact => 'r10k_environment', :value => "#{environment}",:operator => '==' }
  client = rpcclient('puppet', :exit_on_failure => false,:options => options)
  client.discovery_timeout = $config['discovery_timeout'].to_i
  client.timeout           = $config['client_timeout'].to_i
  #result = client.send('runonce')
  result = client.custom_request('runonce',{},client.discover,{:fact => "r10k_environment=#{environment}"})
end # end deploy()






r10k_result = mco(ARGV[0]).first
if r10k_result.results[:statuscode] == 0
  message = r10k_result.results[:statusmsg]
else
  raise r10k_result.results[:statusmsg]
end
puts message

puppet_result = puppet(ARGV[0])
puts puppet_result.inspect
~