summaryrefslogtreecommitdiffstats
path: root/lib/puppet/agent/downloader.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/puppet/agent/downloader.rb')
-rw-r--r--lib/puppet/agent/downloader.rb79
1 files changed, 0 insertions, 79 deletions
diff --git a/lib/puppet/agent/downloader.rb b/lib/puppet/agent/downloader.rb
deleted file mode 100644
index edc5931c3..000000000
--- a/lib/puppet/agent/downloader.rb
+++ /dev/null
@@ -1,79 +0,0 @@
-require 'puppet/agent'
-require 'puppet/resource/catalog'
-
-class Puppet::Agent::Downloader
- attr_reader :name, :path, :source, :ignore
-
- # Determine the timeout value to use.
- def self.timeout
- timeout = Puppet[:configtimeout]
- case timeout
- when String:
- if timeout =~ /^\d+$/
- timeout = Integer(timeout)
- else
- raise ArgumentError, "Configuration timeout must be an integer"
- end
- when Integer: # nothing
- else
- raise ArgumentError, "Configuration timeout must be an integer"
- end
-
- return timeout
- end
-
- # Evaluate our download, returning the list of changed values.
- def evaluate
- Puppet.info "Retrieving #{name}"
-
- files = []
- begin
- Timeout.timeout(self.class.timeout) do
- catalog.apply do |trans|
- trans.changed?.find_all do |resource|
- yield resource if block_given?
- files << resource[:path]
- end
- end
- end
- rescue Puppet::Error, Timeout::Error => detail
- puts detail.backtrace if Puppet[:debug]
- Puppet.err "Could not retrieve #{name}: %s" % detail
- end
-
- return files
- end
-
- def initialize(name, path, source, ignore = nil)
- @name, @path, @source, @ignore = name, path, source, ignore
- end
-
- def catalog
- catalog = Puppet::Resource::Catalog.new
- catalog.add_resource(file)
- catalog
- end
-
- def file
- args = default_arguments.merge(:path => path, :source => source)
- args[:ignore] = ignore if ignore
- Puppet::Type.type(:file).create(args)
- end
-
- private
-
- def default_arguments
- {
- :path => path,
- :recurse => true,
- :source => source,
- :tag => name,
- :owner => Process.uid,
- :group => Process.gid,
- :purge => true,
- :force => true,
- :backup => false,
- :noop => false
- }
- end
-end