class URI::Generic
Public Instance Methods
Downloads the resource to the target.
The target may be a file name (string or task), in which case the file is created from the resource. The target may also be any object that responds to write
, e.g. File
, StringIO, Pipe.
Use the progress bar when running in verbose mode.
# File lib/buildr/core/transports.rb, line 132 def download(target, options = nil) case target when Rake::Task download target.name, options when String # If download breaks we end up with a partial file which is # worse than not having a file at all, so download to temporary # file and then move over. modified = ::File.stat(target).mtime if ::File.exist?(target) temp = Tempfile.new(::File.basename(target)) temp.binmode written = false read({ :progress => verbose }.merge(options || {}).merge(:modified => modified)) { |chunk| written = true; temp.write chunk } temp.close mkpath ::File.dirname(target) # Only attempt to override file if it was actually written to, i.e. "HTTP Not Modified" was not returned. mv temp.path, target if written when ::File read({ :progress => verbose }.merge(options || {}).merge(:modified => target.mtime)) { |chunk| target.write chunk } target.flush else raise ArgumentError, 'Expecting a target that is either a file name (string, task) or object that responds to write (file, pipe).' unless target.respond_to?(:write) read({:progress=>verbose}.merge(options || {})) { |chunk| target.write chunk } target.flush end end
Reads from the resource behind this URI
. The first form returns the content of the resource, the second form yields to the block with each chunk of content (usually more than one).
For options, see URI::read
.
# File lib/buildr/core/transports.rb, line 119 def read(options = nil, &block) fail 'This protocol doesn\'t support reading (yet, how about helping by implementing it?)' end
Uploads from source to the resource.
The source may be a file name (string or task), in which case the file is uploaded to the resource. If the source is a directory, uploads all files inside the directory (including nested directories). The source may also be any object that responds to read
(and optionally size
), e.g. File
, StringIO, Pipe.
Use the progress bar when running in verbose mode.
# File lib/buildr/core/transports.rb, line 194 def upload(source, options = nil) source = source.name if Rake::Task === source options ||= {} if String === source raise NotFoundError, 'No source file/directory to upload.' unless ::File.exist?(source) if ::File.directory?(source) Dir.glob("#{source}/**/*").reject { |file| ::File.directory?(file) }.each do |file| uri = self + (::File.join(self.path, file.sub(source, ''))) uri.upload file, { :digests => [] }.merge(options) end else ::File.open(source, 'rb') { |input| upload input, options } end elsif source.respond_to?(:read) digests = (options[:digests] || [:md5, :sha1]). inject({}) { |hash, name| hash[name] = name.to_s == 'sha512' ? Digest::SHA2.new(512) : Digest.const_get(name.to_s.upcase).new ; hash} size = source.stat.size rescue nil write (options).merge(:progress=>verbose && size, :size=>size) do |bytes| source.read(bytes).tap do |chunk| digests.values.each { |digest| digest << chunk } if chunk end end digests.each do |key, digest| self.merge("#{self.path}.#{key}").write digest.hexdigest, (options).merge(:progress=>false) end else raise ArgumentError, 'Expecting source to be a file name (string, task) or any object that responds to read (file, pipe).' end end
Writes to the resource behind the URI
. The first form writes the content from a string or an object that responds to read
and optionally size
. The second form writes the content by yielding to the block. Each yield should return up to the specified number of bytes, the last yield returns nil.
For options, see URI::write
.
# File lib/buildr/core/transports.rb, line 168 def write(*args, &block) options = args.pop if Hash === args.last options ||= {} if String === args.first ios = StringIO.new(args.first, 'r') write(options.merge(:size=>args.first.size)) { |bytes| ios.read(bytes) } elsif args.first.respond_to?(:read) size = args.first.size rescue nil write({:size=>size}.merge(options)) { |bytes| args.first.read(bytes) } elsif args.empty? && block write_internal options, &block else raise ArgumentError, 'Either give me the content, or pass me a block, otherwise what would I upload?' end end
Protected Instance Methods
Returns the proxy server to use. Obtains the proxy from the relevant environment variable (e.g. HTTP_PROXY). Supports exclusions based on host name and port number from environment variable NO_PROXY.
# File lib/buildr/core/transports.rb, line 249 def proxy_uri proxy = ENV["#{scheme.upcase}_PROXY"] proxy = URI.parse(proxy) if String === proxy excludes = ENV['NO_PROXY'].to_s.split(/\s*,\s*/).compact excludes = excludes.map { |exclude| exclude =~ /:\d+$/ ? exclude : "#{exclude}:*" } return proxy unless excludes.any? { |exclude| ::File.fnmatch(exclude, "#{host}:#{port}") } end