Class: Puppet::Application::Apply

Inherits:

Puppet::Application

• Object
• Puppet::Application
• Puppet::Application::Apply

Includes:

Util::Splayer

Defined in:

lib/puppet/application/apply.rb

Constant Summary

Constants inherited from Puppet::Application

DOCPATTERN

Constants included from Util

Util::AbsolutePathPosix, Util::AbsolutePathWindows, Util::DEFAULT_POSIX_MODE, Util::DEFAULT_WINDOWS_MODE

Constants included from Util::POSIX

Util::POSIX::LOCALE_ENV_VARS, Util::POSIX::USER_ENV_VARS

Constants included from Util::SymbolicFileMode

Util::SymbolicFileMode::SetGIDBit, Util::SymbolicFileMode::SetUIDBit, Util::SymbolicFileMode::StickyBit, Util::SymbolicFileMode::SymbolicMode, Util::SymbolicFileMode::SymbolicSpecialToBit

Instance Attribute Summary

Attributes inherited from Puppet::Application

#command_line, #options

Instance Method Summary

• #app_defaults ⇒ Object
• #apply ⇒ Object
• #help ⇒ Object
• #main ⇒ Object
• #run_command ⇒ Object
• #setup ⇒ Object
• #setup_test ⇒ Object

  Enable all of the most common test options.

Methods included from Util::Splayer

#splay, #splayed?

Methods inherited from Puppet::Application

[], available_application_names, banner, clear!, clear?, clear_everything_for_tests, #configure_indirector_routes, controlled_run, exit, find, #handle_logdest_arg, #handlearg, #initialize, #initialize_app_defaults, interrupted?, #log_runtime_environment, #name, option, option_parser_commands, #parse_options, #preinit, restart!, restart_requested?, #run, run_mode, #set_log_level, #setup_logs, stop!, stop_requested?, try_load_class

Methods included from Util

absolute_path?, benchmark, chuser, clear_environment, default_env, deterministic_rand, deterministic_rand_int, exit_on_fail, get_env, get_environment, logmethods, merge_environment, path_to_uri, pretty_backtrace, replace_file, safe_posix_fork, set_env, symbolizehash, thinmark, uri_to_path, which, withenv, withumask

Methods included from Util::POSIX

#get_posix_field, #gid, #idfield, #methodbyid, #methodbyname, #search_posix_field, #uid

Methods included from Util::SymbolicFileMode

#normalize_symbolic_mode, #symbolic_mode_to_int, #valid_symbolic_mode?

Constructor Details

This class inherits a constructor from Puppet::Application

Instance Method Details

#app_defaults ⇒ Object

# File 'lib/puppet/application/apply.rb', line 160

def app_defaults
  super.merge({
    :default_file_terminus => :file_server,
  })
end

#apply ⇒ Object

# File 'lib/puppet/application/apply.rb', line 174

def apply
  if options[:catalog] == "-"
    text = $stdin.read
  else
    text = Puppet::FileSystem.read(options[:catalog], :encoding => 'utf-8')
  end
  catalog = read_catalog(text)
  apply_catalog(catalog)
end

#help ⇒ Object

# File 'lib/puppet/application/apply.rb', line 34

def help
  "\npuppet-apply(8) -- Apply Puppet manifests locally\n========\n\nSYNOPSIS\n--------\nApplies a standalone Puppet manifest to the local system.\n\n\nUSAGE\n-----\npuppet apply [-h|--help] [-V|--version] [-d|--debug] [-v|--verbose]\n[-e|--execute] [--detailed-exitcodes] [-L|--loadclasses]\n[-l|--logdest syslog|eventlog|<FILE>|console] [--noop]\n[--catalog <catalog>] [--write-catalog-summary] <file>\n\n\nDESCRIPTION\n-----------\nThis is the standalone puppet execution tool; use it to apply\nindividual manifests.\n\nWhen provided with a modulepath, via command line or config file, puppet\napply can effectively mimic the catalog that would be served by puppet\nmaster with access to the same modules, although there are some subtle\ndifferences. When combined with scheduling and an automated system for\npushing manifests, this can be used to implement a serverless Puppet\nsite.\n\nMost users should use 'puppet agent' and 'puppet master' for site-wide\nmanifests.\n\n\nOPTIONS\n-------\nNote that any setting that's valid in the configuration\nfile is also a valid long argument. For example, 'tags' is a\nvalid setting, so you can specify '--tags <class>,<tag>'\nas an argument.\n\nSee the configuration file documentation at\nhttps://docs.puppetlabs.com/puppet/latest/reference/configuration.html for the\nfull list of acceptable parameters. A commented list of all\nconfiguration options can also be generated by running puppet with\n'--genconfig'.\n\n* --debug:\nEnable full debugging.\n\n* --detailed-exitcodes:\nProvide extra information about the run via exit codes. If enabled, 'puppet\napply' will use the following exit codes:\n\n0: The run succeeded with no changes or failures; the system was already in\nthe desired state.\n\n1: The run failed.\n\n2: The run succeeded, and some resources were changed.\n\n4: The run succeeded, and some resources failed.\n\n6: The run succeeded, and included both changes and failures.\n\n* --help:\nPrint this help message\n\n* --loadclasses:\nLoad any stored classes. 'puppet agent' caches configured classes\n(usually at /etc/puppetlabs/puppet/classes.txt), and setting this option causes\nall of those classes to be set in your puppet manifest.\n\n* --logdest:\nWhere to send log messages. Choose between 'syslog' (the POSIX syslog\nservice), 'eventlog' (the Windows Event Log), 'console', or the path to a log\nfile. Defaults to 'console'.\n\nA path ending with '.json' will receive structured output in JSON format. The\nlog file will not have an ending ']' automatically written to it due to the\nappending nature of logging. It must be appended manually to make the content\nvalid JSON.\n\n* --noop:\nUse 'noop' mode where Puppet runs in a no-op or dry-run mode. This\nis useful for seeing what changes Puppet will make without actually\nexecuting the changes.\n\n* --execute:\nExecute a specific piece of Puppet code\n\n* --test:\nEnable the most common options used for testing. These are 'verbose',\n'detailed-exitcodes' and 'show_diff'.\n\n* --verbose:\nPrint extra information.\n\n* --catalog:\nApply a JSON catalog (such as one generated with 'puppet master --compile'). You can\neither specify a JSON file or pipe in JSON from standard input.\n\n* --write-catalog-summary\nAfter compiling the catalog saves the resource list and classes list to the node\nin the state directory named classes.txt and resources.txt\n\nEXAMPLE\n-------\n  $ puppet apply -l /tmp/manifest.log manifest.pp\n  $ puppet apply --modulepath=/root/dev/modules -e \"include ntpd::server\"\n  $ puppet apply --catalog catalog.json\n\n\nAUTHOR\n------\nLuke Kanies\n\n\nCOPYRIGHT\n---------\nCopyright (c) 2011 Puppet Labs, LLC Licensed under the Apache 2.0 License\n\n  HELP\nend\n"

#main ⇒ Object

# File 'lib/puppet/application/apply.rb', line 184

def main
  # Set our code or file to use.
  if options[:code] or command_line.args.length == 0
    Puppet[:code] = options[:code] || STDIN.read
  else
    manifest = command_line.args.shift
    raise "Could not find file #{manifest}" unless Puppet::FileSystem.exist?(manifest)
    Puppet.warning("Only one file can be applied per run.  Skipping #{command_line.args.join(', ')}") if command_line.args.size > 0
  end

  # splay if needed
  splay

  unless Puppet[:node_name_fact].empty?
    # Collect our facts.
    unless facts = Puppet::Node::Facts.indirection.find(Puppet[:node_name_value])
      raise "Could not find facts for #{Puppet[:node_name_value]}"
    end

    Puppet[:node_name_value] = facts.values[Puppet[:node_name_fact]]
    facts.name = Puppet[:node_name_value]
  end

  # Find our Node
  unless node = Puppet::Node.indirection.find(Puppet[:node_name_value])
    raise "Could not find node #{Puppet[:node_name_value]}"
  end

  configured_environment = node.environment || Puppet.lookup(:current_environment)

  apply_environment = manifest ?
    configured_environment.override_with(:manifest => manifest) :
    configured_environment

  # Modify the node descriptor to use the special apply_environment.
  # It is based on the actual environment from the node, or the locally
  # configured environment if the node does not specify one.
  # If a manifest file is passed on the command line, it overrides
  # the :manifest setting of the apply_environment.
  node.environment = apply_environment

  Puppet.override({:current_environment => apply_environment}, "For puppet apply") do
    # Merge in the facts.
    node.merge(facts.values) if facts

    # Add server facts so $server_facts[environment] exists when doing a puppet apply
    if Puppet[:trusted_server_facts]
      node.add_server_facts({})
    end

    # Allow users to load the classes that puppet agent creates.
    if options[:loadclasses]
      file = Puppet[:classfile]
      if Puppet::FileSystem.exist?(file)
        unless FileTest.readable?(file)
          $stderr.puts "#{file} is not readable"
          exit(63)
        end
        node.classes = Puppet::FileSystem.read(file, :encoding => 'utf-8').split(/[\s\n]+/)
      end
    end

    begin
      # Compile the catalog
      starttime = Time.now

      # When compiling, the compiler traps and logs certain errors
      # Those that do not lead to an immediate exit are caught by the general
      # rule and gets logged.
      #
      catalog =
      begin
        Puppet::Resource::Catalog.indirection.find(node.name, :use_node => node)
      rescue Puppet::ParseErrorWithIssue, Puppet::Error
        # already logged and handled by the compiler for these two cases
        exit(1)
      end

      # Translate it to a RAL catalog
      catalog = catalog.to_ral

      catalog.finalize

      catalog.retrieval_duration = Time.now - starttime

      if options[:write_catalog_summary]
        catalog.write_class_file
        catalog.write_resource_file
      end

      exit_status = apply_catalog(catalog)

      if not exit_status
        exit(1)
      elsif options[:detailed_exitcodes] then
        exit(exit_status)
      else
        exit(0)
      end
    rescue => detail
      Puppet.log_exception(detail)
      exit(1)
    end
  end

ensure
  if @profiler
    Puppet::Util::Profiler.remove_profiler(@profiler)
    @profiler.shutdown
  end
end

#run_command ⇒ Object

# File 'lib/puppet/application/apply.rb', line 166

def run_command
  if options[:catalog]
    apply
  else
    main
  end
end

#setup ⇒ Object

# File 'lib/puppet/application/apply.rb', line 304

def setup
  setup_test if options[:test]

  exit(Puppet.settings.print_configs ? 0 : 1) if Puppet.settings.print_configs?

  Puppet::Util::Log.newdestination(:console) unless options[:setdest]

  Signal.trap(:INT) do
    $stderr.puts "Exiting"
    exit(1)
  end

  Puppet.settings.use :main, :agent, :ssl


  if Puppet[:noop]
    Puppet::Resource::Catalog.indirection.cache_class = nil
  elsif Puppet[:catalog_cache_terminus]
    Puppet::Resource::Catalog.indirection.cache_class = Puppet[:catalog_cache_terminus]
  end

  # we want the last report to be persisted locally
  Puppet::Transaction::Report.indirection.cache_class = :yaml

  set_log_level

  if Puppet[:profile]
    @profiler = Puppet::Util::Profiler.add_profiler(Puppet::Util::Profiler::Aggregate.new(Puppet.method(:debug), "apply"))
  end
end

#setup_test ⇒ Object

Enable all of the most common test options.

# File 'lib/puppet/application/apply.rb', line 297

def setup_test
  Puppet.settings.handlearg("--no-splay")
  Puppet.settings.handlearg("--show_diff")
  options[:verbose] = true
  options[:detailed_exitcodes] = true
end