123456789_123456789_123456789_123456789_123456789_

Class: Gem::RemoteFetcher

Relationships & Source Files
Namespace Children
Exceptions:
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, Deprecate
Instance Chain:
Inherits: Object
Defined in: lib/rubygems/remote_fetcher.rb,
lib/rubygems/test_utilities.rb

Overview

RemoteFetcher handles the details of fetching gems and gem information from a remote source.

Class Attribute Summary

Class Method Summary

Deprecate - Extended

deprecate

Simple deprecation method that deprecates name by wrapping it up in a dummy method.

skip_during

Temporarily turn off warnings.

Instance Attribute Summary

Instance Method Summary

UriParsing - Included

UserInteraction - Included

#alert

Displays an alert statement.

#alert_error

Displays an error statement to the error output location.

#alert_warning

Displays a warning statement to the warning output location.

#ask

Asks a question and returns the answer.

#ask_for_password

Asks for a password with a prompt

#ask_yes_no

Asks a yes or no question.

#choose_from_list

Asks the user to answer question with an answer from the given list.

#say

Displays the given statement on the standard output (or equivalent).

#terminate_interaction

Terminates the RubyGems process with the given exit_code

#verbose

Calls say with msg or the results of the block if really_verbose is true.

DefaultUserInteraction - Included

Text - Included

#clean_text

Remove any non-printable characters and make the text suitable for printing.

#format_text

Wraps text to wrap characters and optionally indents by indent characters.

#levenshtein_distance

This code is based directly on the Text gem implementation Returns a value representing the “cost” of transforming str1 into str2.

#truncate_text, #min3

Constructor Details

.new(proxy = nil, dns = nil, headers = {}) ⇒ RemoteFetcher

Initialize a remote fetcher using the source URI and possible proxy information.

proxy

  • [String]: explicit specification of proxy; overrides any environment

    variable setting
  • nil: respect environment variables (HTTP_PROXY, HTTP_PROXY_USER,

    HTTP_PROXY_PASS)
  • :no_proxy: ignore environment variables and _don’t_ use a proxy

#headers: A set of additional HTTP headers to be sent to the server when

fetching the gem.
[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 84

def initialize(proxy=nil, dns=nil, headers={})
  require 'net/http'
  require 'stringio'
  require 'time'
  require 'uri'

  Socket.do_not_reverse_lookup = true

  @proxy = proxy
  @pools = {}
  @pool_lock = Mutex.new
  @cert_files = Gem::Request.get_cert_files

  @headers = headers
end

Class Attribute Details

.fetcher (rw)

Cached RemoteFetcher instance.

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 64

def self.fetcher
  @fetcher ||= self.new Gem.configuration[:http_proxy]
end

.fetcher=(fetcher) (rw)

This method is for internal use only.
[ GitHub ]

  
# File 'lib/rubygems/test_utilities.rb', line 171

def self.fetcher=(fetcher)
  @fetcher = fetcher
end

Instance Attribute Details

#headers (rw)

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 68

attr_accessor :headers

Instance Method Details

#cache_update_path(uri, path = nil, update = true)

Downloads uri to Gem.path if necessary. If no path is given, it just passes the data.

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 296

def cache_update_path(uri, path = nil, update = true)
  mtime = path && File.stat(path).mtime rescue nil

  data = fetch_path(uri, mtime)

  if data == nil # indicates the server returned 304 Not Modified
    return Gem.read_binary(path)
  end

  if update and path
    Gem.write_binary(path, data)
  end

  data
end

#close_all

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 343

def close_all
  @pools.each_value {|pool| pool.close_all}
end

#download(spec, source_uri, install_dir = Gem.dir)

Moves the gem spec from source_uri to the cache dir unless it is already there. If the source_uri is local the gem cache dir copy is always replaced.

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 122

def download(spec, source_uri, install_dir = Gem.dir)
  cache_dir =
    if Dir.pwd == install_dir  # see fetch_command
      install_dir
    elsif File.writable? install_dir
      File.join install_dir, "cache"
    else
      File.join Gem.user_dir, "cache"
    end

  gem_file_name = File.basename spec.cache_file
  local_gem_path = File.join cache_dir, gem_file_name

  FileUtils.mkdir_p cache_dir rescue nil unless File.exist? cache_dir

  source_uri = parse_uri(source_uri)

  scheme = source_uri.scheme

  # URI.parse gets confused by MS Windows paths with forward slashes.
  scheme = nil if scheme =~ /^[a-z]$/i

  # REFACTOR: split this up and dispatch on scheme (eg download_http)
  # REFACTOR: be sure to clean up fake fetcher when you do this... cleaner
  case scheme
  when 'http', 'https', 's3' then
    unless File.exist? local_gem_path
      begin
        verbose "Downloading gem #{gem_file_name}"

        remote_gem_path = source_uri + "gems/#{gem_file_name}"

        self.cache_update_path remote_gem_path, local_gem_path
      rescue FetchError
        raise if spec.original_platform == spec.platform

        alternate_name = "#{spec.original_name}.gem"

        verbose "Failed, downloading gem #{alternate_name}"

        remote_gem_path = source_uri + "gems/#{alternate_name}"

        self.cache_update_path remote_gem_path, local_gem_path
      end
    end
  when 'file' then
    begin
      path = source_uri.path
      path = File.dirname(path) if File.extname(path) == '.gem'

      remote_gem_path = Gem::Util.correct_for_windows_path(File.join(path, 'gems', gem_file_name))

      FileUtils.cp(remote_gem_path, local_gem_path)
    rescue Errno::EACCES
      local_gem_path = source_uri.to_s
    end

    verbose "Using local gem #{local_gem_path}"
  when nil then # TODO test for local overriding cache
    source_path = if Gem.win_platform? && source_uri.scheme &&
                     !source_uri.path.include?(':')
                    "#{source_uri.scheme}:#{source_uri.path}"
                  else
                    source_uri.path
                  end

    source_path = Gem::UriFormatter.new(source_path).unescape

    begin
      FileUtils.cp source_path, local_gem_path unless
        File.identical?(source_path, local_gem_path)
    rescue Errno::EACCES
      local_gem_path = source_uri.to_s
    end

    verbose "Using local gem #{local_gem_path}"
  else
    raise ArgumentError, "unsupported URI scheme #{source_uri.scheme}"
  end

  local_gem_path
end

#download_to_cache(dependency)

Given a name and requirement, downloads this gem into cache and returns the filename. Returns nil if the gem cannot be located.

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 107

def download_to_cache(dependency)
  found, _ = Gem::SpecFetcher.fetcher.spec_for_dependency dependency

  return if found.empty?

  spec, source = found.max_by { |(s,_)| s.version }

  download spec, source.uri
end

#fetch_file(uri, *_)

File Fetcher. Dispatched by #fetch_path. Use it instead.

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 208

def fetch_file(uri, *_)
  Gem.read_binary Gem::Util.correct_for_windows_path uri.path
end

#fetch_http(uri, last_modified = nil, head = false, depth = 0) Also known as: #fetch_https

HTTP Fetcher. Dispatched by #fetch_path. Use it instead.

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 215

def fetch_http(uri, last_modified = nil, head = false, depth = 0)
  fetch_type = head ? Net::HTTP::Head : Net::HTTP::Get
  response   = request uri, fetch_type, last_modified do |req|
    headers.each { |k,v| req.add_field(k,v) }
  end

  case response
  when Net::HTTPOK, Net::HTTPNotModified then
    response.uri = uri if response.respond_to? :uri
    head ? response : response.body
  when Net::HTTPMovedPermanently, Net::HTTPFound, Net::HTTPSeeOther,
       Net::HTTPTemporaryRedirect then
    raise FetchError.new('too many redirects', uri) if depth > 10

    unless location = response['Location']
      raise FetchError.new("redirecting but no redirect location was given", uri)
    end
    location = parse_uri location

    if https?(uri) && !https?(location)
      raise FetchError.new("redirecting to non-https resource: #{location}", uri)
    end

    fetch_http(location, last_modified, head, depth + 1)
  else
    raise FetchError.new("bad response #{response.message} #{response.code}", uri)
  end
end

#fetch_https(uri, last_modified = nil, head = false, depth = 0)

Alias for #fetch_http.

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 244

alias :fetch_https :fetch_http

#fetch_path(uri, mtime = nil, head = false)

Downloads uri and returns it as a String.

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 249

def fetch_path(uri, mtime = nil, head = false)
  uri = parse_uri uri

  unless uri.scheme
    raise ArgumentError, "uri scheme is invalid: #{uri.scheme.inspect}"
  end

  data = send "fetch_#{uri.scheme}", uri, mtime, head

  if data and !head and uri.to_s =~ /\.gz$/
    begin
      data = Gem::Util.gunzip data
    rescue Zlib::GzipFile::Error
      raise FetchError.new("server did not return a valid file", uri)
    end
  end

  data
rescue Timeout::Error
  raise UnknownHostError.new('timed out', uri)
rescue IOError, SocketError, SystemCallError,
       *(OpenSSL::SSL::SSLError if defined?(OpenSSL)) => e
  if e.message =~ /getaddrinfo/
    raise UnknownHostError.new('no such name', uri)
  else
    raise FetchError.new("#{e.class}: #{e}", uri)
  end
end

#fetch_s3(uri, mtime = nil, head = false)

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 278

def fetch_s3(uri, mtime = nil, head = false)
  begin
    public_uri = s3_uri_signer(uri).sign
  rescue Gem::S3URISigner::ConfigurationError, Gem::S3URISigner::InstanceProfileError => e
    raise FetchError.new(e.message, "s3://#{uri.host}")
  end
  fetch_https public_uri, mtime, head
end

#fetch_size(uri)

Returns the size of uri in bytes.

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 315

def fetch_size(uri)
  response = fetch_path(uri, nil, true)

  response['content-length'].to_i
end

#https?(uri) ⇒ Boolean

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 339

def https?(uri)
  uri.scheme.downcase == 'https'
end

#pools_for(proxy) (private)

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 353

def pools_for(proxy)
  @pool_lock.synchronize do
    @pools[proxy] ||= Gem::Request::ConnectionPools.new proxy, @cert_files
  end
end

#proxy_for(proxy, uri) (private)

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 349

def proxy_for(proxy, uri)
  Gem::Request.proxy_uri(proxy || Gem::Request.get_proxy_from_env(uri.scheme))
end

#request(uri, request_class, last_modified = nil)

Performs a Net::HTTP request of type request_class on uri returning a Net::HTTP response object. request maintains a table of persistent connections to reduce connect overhead.

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 328

def request(uri, request_class, last_modified = nil)
  proxy = proxy_for @proxy, uri
  pool  = pools_for(proxy).pool_for uri

  request = Gem::Request.new uri, request_class, last_modified, pool

  request.fetch do |req|
    yield req if block_given?
  end
end

#s3_uri_signer(uri)

we have our own signing code here to avoid a dependency on the aws-sdk gem

[ GitHub ]

  
# File 'lib/rubygems/remote_fetcher.rb', line 288

def s3_uri_signer(uri)
  Gem::S3URISigner.new(uri)
end