Gecko [ primetaxinc.net ]

Name	Size	Permission
commands	[ DIR ]	drwxr-xr-x
core_ext	[ DIR ]	drwxr-xr-x
defaults	[ DIR ]	drwxr-xr-x
ext	[ DIR ]	drwxr-xr-x
gemcutter_utilities	[ DIR ]	drwxr-xr-x
package	[ DIR ]	drwxr-xr-x
request	[ DIR ]	drwxr-xr-x
request_set	[ DIR ]	drwxr-xr-x
resolver	[ DIR ]	drwxr-xr-x
safe_marshal	[ DIR ]	drwxr-xr-x
security	[ DIR ]	drwxr-xr-x
source	[ DIR ]	drwxr-xr-x
ssl_certs	[ DIR ]	drwxr-xr-x
util	[ DIR ]	drwxr-xr-x
vendor	[ DIR ]	drwxr-xr-x
available_set.rb	3 KB	-rw-r--r--
basic_specification.rb	8.13 KB	-rw-r--r--
bundler_version_finder.rb	1.96 KB	-rw-r--r--
ci_detector.rb	3.71 KB	-rw-r--r--
command.rb	15.8 KB	-rw-r--r--
command_manager.rb	5.64 KB	-rw-r--r--
compatibility.rb	1022 B	-rw-r--r--
config_file.rb	16.31 KB	-rw-r--r--
defaults.rb	7.38 KB	-rw-r--r--
dependency.rb	8.45 KB	-rw-r--r--
dependency_installer.rb	9.91 KB	-rw-r--r--
dependency_list.rb	5.55 KB	-rw-r--r--
deprecate.rb	5.04 KB	-rw-r--r--
doctor.rb	3.13 KB	-rw-r--r--
errors.rb	4.53 KB	-rw-r--r--
exceptions.rb	7.13 KB	-rw-r--r--
ext.rb	498 B	-rw-r--r--
gem_runner.rb	2.14 KB	-rw-r--r--
gemcutter_utilities.rb	11.29 KB	-rw-r--r--
gemspec_helpers.rb	394 B	-rw-r--r--
install_default_message.rb	349 B	-rw-r--r--
install_message.rb	323 B	-rw-r--r--
install_update_options.rb	6.56 KB	-rw-r--r--
installer.rb	27.74 KB	-rw-r--r--
installer_uninstaller_utils.rb	771 B	-rw-r--r--
local_remote_options.rb	3.59 KB	-rw-r--r--
name_tuple.rb	2.38 KB	-rw-r--r--
openssl.rb	125 B	-rw-r--r--
package.rb	18.83 KB	-rw-r--r--
package_task.rb	3.79 KB	-rw-r--r--
path_support.rb	1.77 KB	-rw-r--r--
platform.rb	8.41 KB	-rw-r--r--
psych_tree.rb	855 B	-rw-r--r--
query_utils.rb	8.5 KB	-rw-r--r--
rdoc.rb	660 B	-rw-r--r--
remote_fetcher.rb	9.38 KB	-rw-r--r--
request.rb	8.7 KB	-rw-r--r--
request_set.rb	11.29 KB	-rw-r--r--
requirement.rb	7.13 KB	-rw-r--r--
resolver.rb	9.43 KB	-rw-r--r--
s3_uri_signer.rb	5.96 KB	-rw-r--r--
safe_marshal.rb	1.92 KB	-rw-r--r--
safe_yaml.rb	1.04 KB	-rw-r--r--
security.rb	21.69 KB	-rw-r--r--
security_option.rb	1.06 KB	-rw-r--r--
source.rb	5.78 KB	-rw-r--r--
source_list.rb	2.42 KB	-rw-r--r--
spec_fetcher.rb	7.68 KB	-rw-r--r--
specification.rb	69.03 KB	-rw-r--r--
specification_policy.rb	15.59 KB	-rw-r--r--
specification_record.rb	5.21 KB	-rw-r--r--
stub_specification.rb	4.96 KB	-rw-r--r--
target_rbconfig.rb	1.24 KB	-rw-r--r--
text.rb	2.06 KB	-rw-r--r--
uninstaller.rb	10.92 KB	-rw-r--r--
unknown_command_spell_checker....	411 B	-rw-r--r--
update_suggestion.rb	1.85 KB	-rw-r--r--
uri.rb	2.38 KB	-rw-r--r--
uri_formatter.rb	784 B	-rw-r--r--
user_interaction.rb	13.1 KB	-rw-r--r--
util.rb	2.46 KB	-rw-r--r--
validator.rb	3.63 KB	-rw-r--r--
vendored_molinillo.rb	81 B	-rw-r--r--
vendored_net_http.rb	233 B	-rw-r--r--
vendored_optparse.rb	79 B	-rw-r--r--
vendored_securerandom.rb	87 B	-rw-r--r--
vendored_timeout.rb	228 B	-rw-r--r--
vendored_tsort.rb	73 B	-rw-r--r--
version.rb	13.35 KB	-rw-r--r--
version_option.rb	2.17 KB	-rw-r--r--
yaml_serializer.rb	2.42 KB	-rw-r--r--

Code Editor : remote_fetcher.rb

# frozen_string_literal: true

require_relative "../rubygems"
require_relative "request"
require_relative "request/connection_pools"
require_relative "s3_uri_signer"
require_relative "uri_formatter"
require_relative "uri"
require_relative "user_interaction"

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

class Gem::RemoteFetcher
  include Gem::UserInteraction

##
  # A FetchError exception wraps up the various possible IO and HTTP failures
  # that could happen while downloading from the internet.

class FetchError < Gem::Exception
    ##
    # The URI which was being accessed when the exception happened.

attr_accessor :uri, :original_uri

def initialize(message, uri)
      uri = Gem::Uri.new(uri)

super uri.redact_credentials_from(message)

@original_uri = uri.to_s
      @uri = uri.redacted.to_s
    end

def to_s # :nodoc:
      "#{super} (#{uri})"
    end
  end

##
  # A FetchError that indicates that the reason for not being
  # able to fetch data was that the host could not be contacted

class UnknownHostError < FetchError
  end
  deprecate_constant(:UnknownHostError)

@fetcher = nil

##
  # Cached RemoteFetcher instance.

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

attr_accessor :headers

##
  # 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)
  # * <tt>:no_proxy</tt>: 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.

def initialize(proxy=nil, dns=nil, headers={})
    require_relative "core_ext/tcpsocket_init" if Gem.configuration.ipv4_fallback_enabled
    require_relative "vendored_net_http"
    require_relative "vendor/uri/lib/uri"

Socket.do_not_reverse_lookup = true

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

@headers = headers
  end

##
  # Given a name and requirement, downloads this gem into cache and returns the
  # filename. Returns nil if the gem cannot be located.
  #--
  # Should probably be integrated with #download below, but that will be a
  # larger, more encompassing effort. -erikh

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

##
  # 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.

def download(spec, source_uri, install_dir = Gem.dir)
    install_cache_dir = File.join install_dir, "cache"
    cache_dir =
      if Dir.pwd == install_dir # see fetch_command
        install_dir
      elsif File.writable?(install_cache_dir) || (File.writable?(install_dir) && !File.exist?(install_cache_dir))
        install_cache_dir
      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

require "fileutils"
    begin
      FileUtils.mkdir_p cache_dir
    rescue StandardError
      nil
    end unless File.exist? cache_dir

source_uri = Gem::Uri.new(source_uri)

scheme = source_uri.scheme

# Gem::URI.parse gets confused by MS Windows paths with forward slashes.
    scheme = nil if /^[a-z]$/i.match?(scheme)

# 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}"

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}"

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

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

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

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

def fetch_http(uri, last_modified = nil, head = false, depth = 0)
    fetch_type = head ? Gem::Net::HTTP::Head : Gem::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 Gem::Net::HTTPOK, Gem::Net::HTTPNotModified then
      response.uri = uri
      head ? response : response.body
    when Gem::Net::HTTPMovedPermanently, Gem::Net::HTTPFound, Gem::Net::HTTPSeeOther,
         Gem::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 = Gem::Uri.new 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

alias_method :fetch_https, :fetch_http

##
  # Downloads +uri+ and returns it as a String.

def fetch_path(uri, mtime = nil, head = false)
    uri = Gem::Uri.new uri

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

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

if data && !head && uri.to_s.end_with?(".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 Gem::Timeout::Error, IOError, SocketError, SystemCallError,
         *(OpenSSL::SSL::SSLError if Gem::HAVE_OPENSSL) => e
    raise FetchError.new("#{e.class}: #{e}", uri)
  end

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

# we have our own signing code here to avoid a dependency on the aws-sdk gem
  def s3_uri_signer(uri)
    Gem::S3URISigner.new(uri)
  end

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

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

data = fetch_path(uri, mtime)

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

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

data
  end

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

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

def https?(uri)
    uri.scheme.casecmp("https").zero?
  end

def close_all
    @pools.each_value(&:close_all)
  end

private

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

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

${this.title}

Code Editor : remote_fetcher.rb