123456789_123456789_123456789_123456789_123456789_

Class: Bundler::Fetcher::CompactIndex

Relationships & Source Files
Namespace Children
Classes:
ClientFetcher
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, Base
Instance Chain:
self, Base
Inherits: Bundler::Fetcher::Base
Defined in: lib/bundler/fetcher/compact_index.rb

Class Method Summary

Base - Inherited

.new

Instance Attribute Summary

Base - Inherited

#api_fetcher?, #available?, #display_uri, #downloader, #gem_remote_fetcher, #remote

Instance Method Summary

Base - Inherited

#fetch_uri, #remote_uri, #log_specs

Constructor Details

This class inherits a constructor from Bundler::Fetcher::Base

Class Method Details

.compact_index_request(method_name)

[ GitHub ] 

  


# File 'lib/bundler/fetcher/compact_index.rb', line 9



def self.compact_index_request(method_name)
  method = instance_method(method_name)
  undef_method(method_name)
  define_method(method_name) do |*args, &blk|
    method.bind_call(self, *args, &blk)
  rescue NetworkDownError, CompactIndexClient::Updater::MismatchedChecksumError => e
    raise HTTPError, e.message
  rescue AuthenticationRequiredError, BadAuthenticationError
    # Fail since we got a 401 from the server.
    raise
  rescue HTTPError => e
    Bundler.ui.trace(e)
    nil
  end
end


  







Instance Attribute Details



  

    #api_fetcher?  ⇒ Boolean  (readonly)
  

  [ GitHub ]


  

  


# File 'lib/bundler/fetcher/compact_index.rb', line 62



def api_fetcher?
  true
end


  








  

    #available?  ⇒ Boolean  (readonly)
  

  [ GitHub ]


  

  


# File 'lib/bundler/fetcher/compact_index.rb', line 49



def available?
  unless SharedHelpers.md5_available?
    Bundler.ui.debug("FIPS mode is enabled, bundler can't use the CompactIndex API")
    return nil
  end
  # Read info file checksums out of /versions, so we can know if gems are up to date
  compact_index_client.available?
rescue CompactIndexClient::Updater::MismatchedChecksumError => e
  Bundler.ui.debug(e.message)
  nil
end


  







Instance Method Details



  

    #bundle_worker(func = nil)   (private)
  

  [ GitHub ]


  

  


# File 'lib/bundler/fetcher/compact_index.rb', line 91



def bundle_worker(func = nil)
  @bundle_worker ||= begin
    worker_name = "Compact Index (#{display_uri.host})"
    Bundler::Worker.new(Bundler.settings.processor_count, worker_name, func)
  end
  @bundle_worker.tap do |worker|
    worker.instance_variable_set(:@func, func) if func
  end
end


  








  

    #cache_path   (private)
  

  [ GitHub ]


  

  


# File 'lib/bundler/fetcher/compact_index.rb', line 101



def cache_path
  Bundler.user_cache.join("compact_index", remote.cache_slug)
end


  








  

    #client_fetcher   (private)
  

  [ GitHub ]


  

  


# File 'lib/bundler/fetcher/compact_index.rb', line 105



def client_fetcher
  ClientFetcher.new(self, Bundler.ui)
end


  








  

    #compact_index_client   (private)
  

  [ GitHub ]


  

  


# File 'lib/bundler/fetcher/compact_index.rb', line 68



def compact_index_client
  @compact_index_client ||=
    SharedHelpers.filesystem_access(cache_path) do
      CompactIndexClient.new(cache_path, client_fetcher)
    end
end


  








  

    #fetch_gem_infos(names)   (private)
  

  [ GitHub ]


  

  


# File 'lib/bundler/fetcher/compact_index.rb', line 75



def fetch_gem_infos(names)
  in_parallel(names) {|name| compact_index_client.info(name) }
rescue TooManyRequestsError # rubygems.org is rate limiting us, slow down.
  @bundle_worker&.stop
  @bundle_worker = nil # reset it.  Not sure if necessary
  compact_index_client.reset!
  names.map {|name| compact_index_client.info(name) }
end


  








  

    #in_parallel(inputs, &blk)   (private)
  

  [ GitHub ]


  

  


# File 'lib/bundler/fetcher/compact_index.rb', line 84



def in_parallel(inputs, &blk)
  func = lambda {|object, _index| blk.call(object) }
  worker = bundle_worker(func)
  inputs.each {|input| worker.enq(input) }
  inputs.map { worker.deq }
end


  








  

    #specs(gem_names)  
  

  [ GitHub ]


  

  


# File 'lib/bundler/fetcher/compact_index.rb', line 25



def specs(gem_names)
  specs_for_names(gem_names)
end


  








  

    #specs_for_names(gem_names)  
  

  [ GitHub ]


  

  


# File 'lib/bundler/fetcher/compact_index.rb', line 30



def specs_for_names(gem_names)
  gem_info = []
  complete_gems = []
  remaining_gems = gem_names.dup

  until remaining_gems.empty?
    log_specs { "Looking up gems #{remaining_gems.inspect}" }
    deps = fetch_gem_infos(remaining_gems).flatten(1)
    next_gems = deps.flat_map {|d| d[CompactIndexClient::INFO_DEPS].flat_map(&:first) }.uniq
    deps.each {|dep| gem_info << dep }
    complete_gems.concat(deps.map(&:first)).uniq!
    remaining_gems = next_gems - complete_gems
  end
  @bundle_worker&.stop
  @bundle_worker = nil # reset it.  Not sure if necessary

  gem_info
end