IPV4_DELAY_SECONDS = 0.1

def initialize(host, serv, *rest)

addrs = []

threads = []

Addrinfo.foreach(host, serv, nil, :STREAM) do |addr|

Thread.report_on_exception = false if defined? Thread.report_on_exception = ()

# frozen_string_literal: true

##

#

# class Legacy

# # ...

# end

#

# # ...

# end

#

# extend Gem::Deprecate

#

# class << self

# extend Gem::Deprecate

# end

# end

end

##

# The host to connect to either from the RUBYGEMS_HOST environment variable

# or from the user's configuration

response = rubygems_api_request(:put, "api/v1/api_key",

sign_in_host, scope: scope) do |request|

request.basic_auth email, password

request.body = URI.encode_www_form({:api_key => api_key }.merge(update_scope_params))

end

response = rubygems_api_request(:post, "api/v1/api_key",

sign_in_host, scope: scope) do |request|

request.basic_auth email, password

request.body = URI.encode_www_form({ name: key_name }.merge(scope_params))

end

request_method = Net::HTTP.const_get method.to_s.capitalize

Gem::RemoteFetcher.fetcher.request(uri, request_method) do |req|

block.call(req)

end

end

@path_warning = false

class << self

##

require 'rubygems/request/connection_pools'

require 'rubygems/s3_uri_signer'

require 'rubygems/uri_formatter'

require 'rubygems/user_interaction'

require 'resolv'

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.

def initialize(message, uri)

super message

@original_uri = uri.dup

@proxy = proxy

@pools = {}

@cert_files = Gem::Request.get_cert_files

@headers = headers

require "fileutils"

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

scheme = source_uri.scheme

unless location = response['Location']

raise FetchError.new("redirecting but no redirect location was given", uri)

end

if https?(uri) && !https?(location)

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

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

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

unless uri.scheme

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

@proxy_uri = proxy_uri

@cert_files = cert_files

@pools = {}

end

def pool_for(uri)

@http_args = http_args

@cert_files = cert_files

@proxy_uri = proxy_uri

@queue << nil

end

@prerelease = options[:prerelease]

requests = []

# Create a thread-safe list of gems to download

sorted_requests.each do |req|

# rubocop:disable Style/MutableConstant

LOAD_CACHE = {} # :nodoc:

# rubocop:enable Style/MutableConstant

private_constant :LOAD_CACHE if defined? private_constant

#

class Gem::UriParser

##

# Parses the #uri, raising if it's invalid

def parse!(uri)

raise URI::InvalidURIError unless uri

# Always escape URI's to deal with potential spaces and such

# A progress reporter that behaves nicely with threaded downloading.

class ThreadedDownloadReporter

##

# The current file name being displayed