ruby-bundler 1.13.6-2 / usr / lib / ruby / vendor_ruby / bundler / vendor / compact_index_client / lib / compact_index_client.rb

# frozen_string_literal: true
require "pathname"
require "set"

class Bundler::CompactIndexClient
  class Error < StandardError; end

  require "bundler/vendor/compact_index_client/lib/compact_index_client/cache"
  require "bundler/vendor/compact_index_client/lib/compact_index_client/updater"
  require "bundler/vendor/compact_index_client/lib/compact_index_client/version"

  attr_reader :directory

  # @return [Lambda] A lambda that takes an array of inputs and a block, and
  #         maps the inputs with the block in parallel.
  #
  attr_accessor :in_parallel

  def initialize(directory, fetcher)
    @directory = Pathname.new(directory)
    @updater = Updater.new(fetcher)
    @cache = Cache.new(@directory)
    @endpoints = Set.new
    @info_checksums_by_name = {}
    @parsed_checksums = false
    @in_parallel = lambda do |inputs, &blk|
      inputs.map(&blk)
    end
  end

  def names
    update(@cache.names_path, "names")
    @cache.names
  end

  def versions
    update(@cache.versions_path, "versions")
    versions, @info_checksums_by_name = @cache.versions
    versions
  end

  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 spec(name, version, platform = nil)
    update_info(name)
    @cache.specific_dependency(name, version, platform)
  end

  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

private

  def update(local_path, remote_path)
    return unless @endpoints.add?(remote_path)
    @updater.update(local_path, url(remote_path))
  end

  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)
    path
  end
end