class Bundler::CompactIndexClient
def dependencies(names)
def dependencies(names) in_parallel.call(names) do |name| update_info(name) @cache.dependencies(name).map {|d| d.unshift(name) } end.flatten(1) end
def initialize(directory, fetcher)
def initialize(directory, fetcher) @directory = Pathname.new(directory) @updater = Updater.new(fetcher) @cache = Cache.new(@directory) @endpoints = Set.new @info_checksums_by_name = {} @in_parallel = lambda do |inputs, &blk| inputs.map(&blk) end end
def names
def names update(@cache.names_path, "names") @cache.names end
def spec(name, version, platform = nil)
def spec(name, version, platform = nil) update_info(name) @cache.specific_dependency(name, version, platform) end
def update(local_path, remote_path)
def update(local_path, remote_path) return if @endpoints.include?(remote_path) @updater.update(local_path, url(remote_path)) @endpoints << remote_path end
def update_and_parse_checksums!
def update_and_parse_checksums! return @info_checksums_by_name if @parsed_checksums update(@cache.versions_path, "versions") @info_checksums_by_name = @cache.checksums @parsed_checksums = true end
def update_info(name)
def update_info(name) path = @cache.info_path(name) checksum = @updater.checksum_for_file(path) return unless existing = @info_checksums_by_name[name] return if checksum == existing update(path, "info/#{name}") end
def url(path)
def url(path) path end
def versions
def versions update(@cache.versions_path, "versions") versions, @info_checksums_by_name = @cache.versions versions end