Class Gem::RemoteFetcher < Object

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 42
def self.fetcher
  @fetcher ||= self.new Gem.configuration[:http_proxy]
end

# File ../ruby/lib/rubygems/test_utilities.rb, line 132
def self.fetcher=(fetcher)
  @fetcher = fetcher
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 57
def initialize(proxy = nil)
  require 'net/http'
  require 'stringio'
  require 'time'
  require 'uri'

  Socket.do_not_reverse_lookup = true

  @connections = {}
  @requests = Hash.new 0
  @proxy_uri =
    case proxy
    when :no_proxy then nil
    when nil then get_proxy_from_env
    when URI::HTTP then proxy
    else URI.parse(proxy)
    end
  @user_agent = user_agent
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 356
def add_rubygems_trusted_certs(store)
  Dir.glob(BuiltinSSLCerts).each do |ssl_cert_file|
    store.add_file ssl_cert_file
  end
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 333
def configure_connection_for_https(connection)
  require 'net/https'

  connection.use_ssl = true
  connection.verify_mode =
    Gem.configuration.ssl_verify_mode || OpenSSL::SSL::VERIFY_PEER

  store = OpenSSL::X509::Store.new

  if Gem.configuration.ssl_ca_cert
    if File.directory? Gem.configuration.ssl_ca_cert
      store.add_path Gem.configuration.ssl_ca_cert
    else
      store.add_file Gem.configuration.ssl_ca_cert
    end
  else
    store.set_default_paths
    add_rubygems_trusted_certs(store)
  end

  connection.cert_store = store
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 306
def connection_for(uri)
  net_http_args = [uri.host, uri.port]

  if @proxy_uri then
    net_http_args += [
      @proxy_uri.host,
      @proxy_uri.port,
      @proxy_uri.user,
      @proxy_uri.password
    ]
  end

  connection_id = [Thread.current.object_id, *net_http_args].join ':'
  @connections[connection_id] ||= Net::HTTP.new(*net_http_args)
  connection = @connections[connection_id]

  if https?(uri) and !connection.started? then
    configure_connection_for_https(connection)
  end

  connection.start unless connection.started?

  connection
rescue OpenSSL::SSL::SSLError, Errno::EHOSTDOWN => e
  raise FetchError.new(e.message, uri)
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 362
def correct_for_windows_path(path)
  if path[0].chr == '/' && path[1].chr =~ /[a-z]/i && path[2].chr == ':'
    path = path[1..-1]
  else
    path
  end
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 100
def download(spec, source_uri, install_dir = Gem.dir)
  Gem.ensure_gem_subdirectories(install_dir) rescue nil

  if File.writable?(install_dir)
    cache_dir = File.join install_dir, "cache"
  else
    cache_dir = 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

 # Always escape URI's to deal with potential spaces and such
  unless URI::Generic === source_uri
    source_uri = URI.parse(URI.const_defined?(:DEFAULT_PARSER) ?
                           URI::DEFAULT_PARSER.escape(source_uri.to_s) :
                           URI.escape(source_uri.to_s))
  end

  scheme = source_uri.scheme

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

  case scheme
  when 'http', 'https' then
    unless File.exist? local_gem_path then
      begin
        say "Downloading gem #{gem_file_name}" if
          Gem.configuration.really_verbose

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

        gem = self.fetch_path remote_gem_path
      rescue Gem::RemoteFetcher::FetchError
        raise if spec.original_platform == spec.platform

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

        say "Failed, downloading gem #{alternate_name}" if
          Gem.configuration.really_verbose

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

        gem = self.fetch_path remote_gem_path
      end

      File.open local_gem_path, 'wb' do |fp|
        fp.write gem
      end
    end
  when 'file' then
    begin
      path = source_uri.path
      path = File.dirname(path) if File.extname(path) == '.gem'

      remote_gem_path = 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

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

    source_path = unescape source_path

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

    say "Using local gem #{local_gem_path}" if
      Gem.configuration.really_verbose
  else
    raise Gem::InstallError, "unsupported URI scheme #{source_uri.scheme}"
  end

  local_gem_path
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 84
def download_to_cache dependency
  found = Gem::SpecFetcher.fetcher.fetch dependency, true, true,
                                         dependency.prerelease?

  return if found.empty?

  spec, source_uri = found.sort_by { |(s,_)| s.version }.last

  download spec, source_uri
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 258
def escape(str)
  return unless str
  @uri_parser ||= uri_escaper
  @uri_parser.escape str
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 196
def fetch_file uri, *_
  Gem.read_binary correct_for_windows_path uri.path
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 203
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

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

    location = URI.parse response['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

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 231
def fetch_path(uri, mtime = nil, head = false)
  uri = URI.parse uri unless URI::Generic === uri

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

  data = send "fetch_#{uri.scheme}", uri, mtime, head
  data = Gem.gunzip data if data and not head and uri.to_s =~ /gz$/
  data
rescue FetchError
  raise
rescue Timeout::Error
  raise FetchError.new('timed out', uri.to_s)
rescue IOError, SocketError, SystemCallError => e
  raise FetchError.new("#{e.class}: #{e}", uri.to_s)
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 252
def fetch_size(uri) # TODO: phase this out
  response = fetch_path(uri, nil, true)

  response['content-length'].to_i
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 279
def get_proxy_from_env
  env_proxy = ENV['http_proxy'] || ENV['HTTP_PROXY']

  return nil if env_proxy.nil? or env_proxy.empty?

  uri = URI.parse(normalize_uri(env_proxy))

  if uri and uri.user.nil? and uri.password.nil? then
    # Probably we have http_proxy_* variables?
    uri.user = escape(ENV['http_proxy_user'] || ENV['HTTP_PROXY_USER'])
    uri.password = escape(ENV['http_proxy_pass'] || ENV['HTTP_PROXY_PASS'])
  end

  uri
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 502
def https?(uri)
  uri.scheme.downcase == 'https'
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 298
def normalize_uri(uri)
  (uri =~ /^(https?|ftp|file):/) ? uri : "http://#{uri}"
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 374
def open_uri_or_path(uri, last_modified = nil, head = false, depth = 0)
  raise "NO: Use fetch_path instead"
  # TODO: deprecate for fetch_path
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 384
def request(uri, request_class, last_modified = nil)
  request = request_class.new uri.request_uri

  unless uri.nil? || uri.user.nil? || uri.user.empty? then
    request.basic_auth uri.user, uri.password
  end

  request.add_field 'User-Agent', @user_agent
  request.add_field 'Connection', 'keep-alive'
  request.add_field 'Keep-Alive', '30'

  if last_modified then
    last_modified = last_modified.utc
    request.add_field 'If-Modified-Since', last_modified.rfc2822
  end

  yield request if block_given?

  connection = connection_for uri

  retried = false
  bad_response = false

  begin
    @requests[connection.object_id] += 1

    say "#{request.method} #{uri}" if
      Gem.configuration.really_verbose

    file_name = File.basename(uri.path)
    # perform download progress reporter only for gems
    if request.response_body_permitted? && file_name =~ /\.gem$/
      reporter = ui.download_reporter
      response = connection.request(request) do |incomplete_response|
        if Net::HTTPOK === incomplete_response
          reporter.fetch(file_name, incomplete_response.content_length)
          downloaded = 0
          data = ''

          incomplete_response.read_body do |segment|
            data << segment
            downloaded += segment.length
            reporter.update(downloaded)
          end
          reporter.done
          if incomplete_response.respond_to? :body=
            incomplete_response.body = data
          else
            incomplete_response.instance_variable_set(:@body, data)
          end
        end
      end
    else
      response = connection.request request
    end

    say "#{response.code} #{response.message}" if
      Gem.configuration.really_verbose

  rescue Net::HTTPBadResponse
    say "bad response" if Gem.configuration.really_verbose

    reset connection

    raise FetchError.new('too many bad responses', uri) if bad_response

    bad_response = true
    retry
  # HACK work around EOFError bug in Net::HTTP
  # NOTE Errno::ECONNABORTED raised a lot on Windows, and make impossible
  # to install gems.
  rescue EOFError, Timeout::Error,
         Errno::ECONNABORTED, Errno::ECONNRESET, Errno::EPIPE

    requests = @requests[connection.object_id]
    say "connection reset after #{requests} requests, retrying" if
      Gem.configuration.really_verbose

    raise FetchError.new('too many connection resets', uri) if retried

    reset connection

    retried = true
    retry
  end

  response
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 476
def reset(connection)
  @requests.delete connection.object_id

  connection.finish
  connection.start
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 264
def unescape(str)
  return unless str
  @uri_parser ||= uri_escaper
  @uri_parser.unescape str
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 270
def uri_escaper
  URI::Parser.new
rescue NameError
  URI
end

# File ../ruby/lib/rubygems/remote_fetcher.rb, line 483
def user_agent
  ua = "RubyGems/#{Gem::VERSION} #{Gem::Platform.local}"

  ruby_version = RUBY_VERSION
  ruby_version += 'dev' if RUBY_PATCHLEVEL == -1

  ua << " Ruby/#{ruby_version} (#{RUBY_RELEASE_DATE}"
  if RUBY_PATCHLEVEL >= 0 then
    ua << " patchlevel #{RUBY_PATCHLEVEL}"
  elsif defined?(RUBY_REVISION) then
    ua << " revision #{RUBY_REVISION}"
  end
  ua << ")"

  ua << " #{RUBY_ENGINE}" if defined?(RUBY_ENGINE) and RUBY_ENGINE != 'ruby'

  ua
end