Gecko [ www.corporacionhdm.com.pe ]

Name	Size	Permission	Date
commands	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
core_ext	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
ext	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
package	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
request	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
request_set	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
resolver	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
security	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
source	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
ssl_certs	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
util	[ DIR ]	drwxr-xr-x	2024-03-03 22:43
available_set.rb	2.99 KB	-rw-r--r--	2014-09-14 03:30
basic_specification.rb	6.66 KB	-rw-r--r--	2014-12-07 00:53
command.rb	13.55 KB	-rw-r--r--	2014-09-14 03:30
command_manager.rb	4.63 KB	-rw-r--r--	2014-09-14 03:30
compatibility.rb	1.63 KB	-rw-r--r--	2014-12-25 03:37
config_file.rb	12.57 KB	-rw-r--r--	2017-12-14 13:50
defaults.rb	4.01 KB	-rw-r--r--	2014-09-14 03:30
dependency.rb	8.48 KB	-rw-r--r--	2014-11-17 03:55
dependency_installer.rb	13.81 KB	-rw-r--r--	2014-09-14 03:30
dependency_list.rb	5.44 KB	-rw-r--r--	2014-12-07 00:53
deprecate.rb	1.7 KB	-rw-r--r--	2014-01-07 01:19
doctor.rb	3.04 KB	-rw-r--r--	2014-09-14 03:30
errors.rb	3.12 KB	-rw-r--r--	2014-09-14 03:30
exceptions.rb	6.2 KB	-rw-r--r--	2014-09-14 03:30
ext.rb	431 B	-rw-r--r--	2013-10-16 06:00
gem_runner.rb	1.96 KB	-rw-r--r--	2013-09-14 08:59
gemcutter_utilities.rb	3.94 KB	-rw-r--r--	2014-09-14 03:30
indexer.rb	13.03 KB	-rw-r--r--	2014-11-17 03:55
install_default_message.rb	307 B	-rw-r--r--	2013-07-09 23:21
install_message.rb	281 B	-rw-r--r--	2012-11-29 06:52
install_update_options.rb	5.85 KB	-rw-r--r--	2014-09-14 03:30
installer.rb	22.48 KB	-rw-r--r--	2017-09-10 01:10
installer_test_case.rb	4.23 KB	-rw-r--r--	2014-09-14 03:30
local_remote_options.rb	3.37 KB	-rw-r--r--	2014-09-14 03:30
mock_gem_ui.rb	1.35 KB	-rw-r--r--	2012-11-29 06:52
name_tuple.rb	2.37 KB	-rw-r--r--	2014-09-14 03:30
package.rb	14.87 KB	-rw-r--r--	2018-02-16 16:27
package_task.rb	3.77 KB	-rw-r--r--	2013-08-26 20:24
path_support.rb	1.82 KB	-rw-r--r--	2013-09-14 08:59
platform.rb	6.13 KB	-rw-r--r--	2014-09-14 03:30
psych_additions.rb	269 B	-rw-r--r--	2013-10-20 01:33
psych_tree.rb	763 B	-rw-r--r--	2013-07-09 22:34
rdoc.rb	7.71 KB	-rw-r--r--	2014-09-14 03:30
remote_fetcher.rb	11.09 KB	-rw-r--r--	2017-09-10 01:10
request.rb	6.73 KB	-rw-r--r--	2014-09-14 03:30
request_set.rb	9.4 KB	-rw-r--r--	2014-12-07 00:53
requirement.rb	6.2 KB	-rw-r--r--	2014-09-14 03:30
resolver.rb	13.35 KB	-rw-r--r--	2014-09-14 03:30
safe_yaml.rb	1.11 KB	-rw-r--r--	2017-12-14 13:50
security.rb	20.96 KB	-rw-r--r--	2014-01-20 04:57
server.rb	22.93 KB	-rw-r--r--	2018-02-16 16:27
source.rb	5.21 KB	-rw-r--r--	2014-12-07 00:53
source_list.rb	2.47 KB	-rw-r--r--	2013-11-19 00:34
source_local.rb	111 B	-rw-r--r--	2013-09-14 08:59
source_specific_file.rb	93 B	-rw-r--r--	2013-09-14 08:59
spec_fetcher.rb	6.31 KB	-rw-r--r--	2014-09-14 03:30
specification.rb	72.88 KB	-rw-r--r--	2018-02-16 16:27
stub_specification.rb	3.56 KB	-rw-r--r--	2014-12-07 00:53
syck_hack.rb	2.09 KB	-rw-r--r--	2013-12-19 22:09
test_case.rb	37.49 KB	-rw-r--r--	2016-04-22 09:15
test_utilities.rb	8.44 KB	-rw-r--r--	2014-09-14 03:30
text.rb	1.9 KB	-rw-r--r--	2017-09-10 01:10
uninstaller.rb	8.72 KB	-rw-r--r--	2014-09-14 03:30
uri_formatter.rb	762 B	-rw-r--r--	2013-10-20 01:33
user_interaction.rb	14.64 KB	-rw-r--r--	2014-11-17 03:55
util.rb	2.59 KB	-rw-r--r--	2014-08-03 13:33
validator.rb	4.18 KB	-rw-r--r--	2013-11-30 23:27
version.rb	10.92 KB	-rw-r--r--	2014-09-14 03:30
version_option.rb	1.83 KB	-rw-r--r--	2013-09-14 08:59

Rename

require 'rubygems'
require 'rubygems/request'
require 'rubygems/uri_formatter'
require 'rubygems/user_interaction'
require 'rubygems/request/connection_pools'
require 'resolv'

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

def initialize(message, uri)
      super message
      @uri = uri
    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

@fetcher = nil

##
  # Cached RemoteFetcher instance.

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

##
  # 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
  #
  # +dns+: An object to use for DNS resolution of the API endpoint.
  #        By default, use Resolv::DNS.

def initialize(proxy=nil, dns=Resolv::DNS.new)
    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

@dns = dns
  end

##
  # Given a source at +uri+, calculate what hostname to actually
  # connect to query the data for it.

def api_endpoint(uri)
    host = uri.host

begin
      res = @dns.getresource "_rubygems._tcp.#{host}",
                             Resolv::DNS::Resource::IN::SRV
    rescue Resolv::ResolvError
      uri
    else
      target = res.target.to_s.strip

if URI("http://" + target).host.end_with?(".#{host}")
        return URI.parse "#{uri.scheme}://#{target}#{uri.path}"
      end

uri
    end
  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 emcompassing 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.to_s
  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)
    cache_dir =
      if Dir.pwd == install_dir then # see fetch_command
        install_dir
      elsif File.writable? install_dir then
        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

# Always escape URI's to deal with potential spaces and such
    # It should also be considered that source_uri may already be
    # a valid URI with escaped characters. e.g. "{DESede}" is encoded
    # as "%7BDESede%7D". If this is escaped again the percentage
    # symbols will be escaped.
    unless source_uri.is_a?(URI::Generic)
      begin
        source_uri = URI.parse(source_uri)
      rescue
        source_uri = URI.parse(URI.const_defined?(:DEFAULT_PARSER) ?
                               URI::DEFAULT_PARSER.escape(source_uri.to_s) :
                               URI.escape(source_uri.to_s))
      end
    end

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 then
        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 Gem::RemoteFetcher::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 = 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?(':') then
                      "#{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 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 ? Net::HTTP::Head : Net::HTTP::Get
    response   = request uri, fetch_type, last_modified

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

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

alias :fetch_https :fetch_http

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

def fetch_path(uri, mtime = nil, head = false)
    uri = URI.parse uri unless URI::Generic === uri

raise ArgumentError, "bad uri: #{uri}" unless 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.gunzip data
      rescue Zlib::GzipFile::Error
        raise FetchError.new("server did not return a valid file", uri.to_s)
      end
    end

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

def fetch_s3(uri, mtime = nil, head = false)
    public_uri = sign_s3_url(uri)
    fetch_https public_uri, mtime, head
  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 = 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
      open(path, 'wb') do |io|
        io.flock(File::LOCK_EX)
        io.write data
      end
    end

data
  end

##
  # Returns the size of +uri+ in bytes.

def fetch_size(uri) # TODO: phase this out
    response = fetch_path(uri, nil, true)

response['content-length'].to_i
  end

def correct_for_windows_path(path)
    if path[0].chr == '/' && path[1].chr =~ /[a-z]/i && path[2].chr == ':'
      path[1..-1]
    else
      path
    end
  end

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

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.downcase == 'https'
  end

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

protected

# we have our own signing code here to avoid a dependency on the aws-sdk gem
  # fortunately, a simple GET request isn't too complex to sign properly
  def sign_s3_url(uri, expiration = nil)
    require 'base64'
    require 'openssl'

unless uri.user && uri.password
      raise FetchError.new("credentials needed in s3 source, like s3://key:secret@bucket-name/", uri.to_s)
    end

expiration ||= s3_expiration
    canonical_path = "/#{uri.host}#{uri.path}"
    payload = "GET\n\n\n#{expiration}\n#{canonical_path}"
    digest = OpenSSL::HMAC.digest('sha1', uri.password, payload)
    # URI.escape is deprecated, and there isn't yet a replacement that does quite what we want
    signature = Base64.encode64(digest).gsub("\n", '').gsub(/[\+\/=]/) { |c| BASE64_URI_TRANSLATE[c] }
    URI.parse("https://#{uri.host}.s3.amazonaws.com#{uri.path}?AWSAccessKeyId=#{uri.user}&Expires=#{expiration}&Signature=#{signature}")
  end

def s3_expiration
    (Time.now + 3600).to_i # one hour from now
  end

BASE64_URI_TRANSLATE = { '+' => '%2B', '/' => '%2F', '=' => '%3D' }.freeze

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