mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
Import rubygems 1.5.0 (release candidate)
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@30599 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
d26fb035ca
commit
e798ccbacf
173 changed files with 2721 additions and 2455 deletions
|
@ -1,18 +1,17 @@
|
|||
######################################################################
|
||||
# This file is imported from the rubygems project.
|
||||
# DO NOT make modifications in this repo. They _will_ be reverted!
|
||||
# File a patch instead and assign it to Ryan Davis or Eric Hodel.
|
||||
######################################################################
|
||||
|
||||
#--
|
||||
# Copyright 2006 by Chad Fowler, Rich Kilmer, Jim Weirich and others.
|
||||
# All rights reserved.
|
||||
# See LICENSE.txt for permissions.
|
||||
#++
|
||||
|
||||
require 'rubygems/user_interaction'
|
||||
require 'rubygems/specification'
|
||||
|
||||
# :stopdoc:
|
||||
module Gem
|
||||
autoload :SpecFetcher, 'rubygems/spec_fetcher'
|
||||
end
|
||||
# :startdoc:
|
||||
|
||||
##
|
||||
# The SourceIndex object indexes all the gems available from a
|
||||
# particular source (e.g. a list of gem directories, or a remote
|
||||
|
@ -28,8 +27,6 @@ class Gem::SourceIndex
|
|||
|
||||
include Enumerable
|
||||
|
||||
include Gem::UserInteraction
|
||||
|
||||
attr_reader :gems # :nodoc:
|
||||
|
||||
##
|
||||
|
@ -38,8 +35,6 @@ class Gem::SourceIndex
|
|||
attr_accessor :spec_dirs
|
||||
|
||||
class << self
|
||||
include Gem::UserInteraction
|
||||
|
||||
##
|
||||
# Factory method to construct a source index instance for a given
|
||||
# path.
|
||||
|
@ -83,33 +78,7 @@ class Gem::SourceIndex
|
|||
# loaded spec.
|
||||
|
||||
def load_specification(file_name)
|
||||
return nil unless file_name and File.exist? file_name
|
||||
|
||||
spec_code = if defined? Encoding then
|
||||
File.read file_name, :encoding => 'UTF-8'
|
||||
else
|
||||
File.read file_name
|
||||
end.untaint
|
||||
|
||||
begin
|
||||
gemspec = eval spec_code, binding, file_name
|
||||
|
||||
if gemspec.is_a?(Gem::Specification)
|
||||
gemspec.loaded_from = file_name
|
||||
return gemspec
|
||||
end
|
||||
alert_warning "File '#{file_name}' does not evaluate to a gem specification"
|
||||
rescue SignalException, SystemExit
|
||||
raise
|
||||
rescue SyntaxError => e
|
||||
alert_warning e
|
||||
alert_warning spec_code
|
||||
rescue Exception => e
|
||||
alert_warning "#{e.inspect}\n#{spec_code}"
|
||||
alert_warning "Invalid .gemspec format in '#{file_name}'"
|
||||
end
|
||||
|
||||
return nil
|
||||
Gem::Specification.load file_name
|
||||
end
|
||||
|
||||
end
|
||||
|
@ -150,7 +119,7 @@ class Gem::SourceIndex
|
|||
spec_files = Dir.glob File.join(spec_dir, '*.gemspec')
|
||||
|
||||
spec_files.each do |spec_file|
|
||||
gemspec = self.class.load_specification spec_file.untaint
|
||||
gemspec = Gem::Specification.load spec_file
|
||||
add_spec gemspec if gemspec
|
||||
end
|
||||
end
|
||||
|
@ -275,8 +244,8 @@ class Gem::SourceIndex
|
|||
##
|
||||
# Find a gem by an exact match on the short name.
|
||||
|
||||
def find_name(gem_name, version_requirement = Gem::Requirement.default)
|
||||
dep = Gem::Dependency.new gem_name, version_requirement
|
||||
def find_name(gem_name, requirement = Gem::Requirement.default)
|
||||
dep = Gem::Dependency.new gem_name, requirement
|
||||
search dep
|
||||
end
|
||||
|
||||
|
@ -290,7 +259,7 @@ class Gem::SourceIndex
|
|||
# behavior is deprecated and will be removed.
|
||||
|
||||
def search(gem_pattern, platform_only = false)
|
||||
version_requirement = nil
|
||||
requirement = nil
|
||||
only_platform = false
|
||||
|
||||
# TODO - Remove support and warning for legacy arguments after 2008/11
|
||||
|
@ -300,10 +269,10 @@ class Gem::SourceIndex
|
|||
|
||||
case gem_pattern
|
||||
when Regexp then
|
||||
version_requirement = platform_only || Gem::Requirement.default
|
||||
requirement = platform_only || Gem::Requirement.default
|
||||
when Gem::Dependency then
|
||||
only_platform = platform_only
|
||||
version_requirement = gem_pattern.requirement
|
||||
requirement = gem_pattern.requirement
|
||||
gem_pattern = if Regexp === gem_pattern.name then
|
||||
gem_pattern.name
|
||||
elsif gem_pattern.name.empty? then
|
||||
|
@ -312,17 +281,17 @@ class Gem::SourceIndex
|
|||
/^#{Regexp.escape gem_pattern.name}$/
|
||||
end
|
||||
else
|
||||
version_requirement = platform_only || Gem::Requirement.default
|
||||
requirement = platform_only || Gem::Requirement.default
|
||||
gem_pattern = /#{gem_pattern}/i
|
||||
end
|
||||
|
||||
unless Gem::Requirement === version_requirement then
|
||||
version_requirement = Gem::Requirement.create version_requirement
|
||||
unless Gem::Requirement === requirement then
|
||||
requirement = Gem::Requirement.create requirement
|
||||
end
|
||||
|
||||
specs = all_gems.values.select do |spec|
|
||||
spec.name =~ gem_pattern and
|
||||
version_requirement.satisfied_by? spec.version
|
||||
requirement.satisfied_by? spec.version
|
||||
end
|
||||
|
||||
if only_platform then
|
||||
|
@ -354,19 +323,9 @@ class Gem::SourceIndex
|
|||
latest_specs.each do |local|
|
||||
dependency = Gem::Dependency.new local.name, ">= #{local.version}"
|
||||
|
||||
begin
|
||||
fetcher = Gem::SpecFetcher.fetcher
|
||||
remotes = fetcher.find_matching dependency
|
||||
remotes = remotes.map { |(_,version,_),_| version }
|
||||
rescue Gem::RemoteFetcher::FetchError => e
|
||||
raise unless fetcher.warn_legacy e do
|
||||
require 'rubygems/source_info_cache'
|
||||
|
||||
specs = Gem::SourceInfoCache.search_with_source dependency, true
|
||||
|
||||
remotes = specs.map { |spec,| spec.version }
|
||||
end
|
||||
end
|
||||
fetcher = Gem::SpecFetcher.fetcher
|
||||
remotes = fetcher.find_matching dependency
|
||||
remotes = remotes.map { |(_, version, _), _| version }
|
||||
|
||||
latest = remotes.sort.last
|
||||
|
||||
|
@ -376,43 +335,6 @@ class Gem::SourceIndex
|
|||
outdateds
|
||||
end
|
||||
|
||||
##
|
||||
# Updates this SourceIndex from +source_uri+. If +all+ is false, only the
|
||||
# latest gems are fetched.
|
||||
|
||||
def update(source_uri, all)
|
||||
source_uri = URI.parse source_uri unless URI::Generic === source_uri
|
||||
source_uri.path += '/' unless source_uri.path =~ /\/$/
|
||||
|
||||
use_incremental = false
|
||||
|
||||
begin
|
||||
gem_names = fetch_quick_index source_uri, all
|
||||
remove_extra gem_names
|
||||
missing_gems = find_missing gem_names
|
||||
|
||||
return false if missing_gems.size.zero?
|
||||
|
||||
say "Missing metadata for #{missing_gems.size} gems" if
|
||||
missing_gems.size > 0 and Gem.configuration.really_verbose
|
||||
|
||||
use_incremental = missing_gems.size <= Gem.configuration.bulk_threshold
|
||||
rescue Gem::OperationNotSupportedError => ex
|
||||
alert_error "Falling back to bulk fetch: #{ex.message}" if
|
||||
Gem.configuration.really_verbose
|
||||
use_incremental = false
|
||||
end
|
||||
|
||||
if use_incremental then
|
||||
update_with_missing(source_uri, missing_gems)
|
||||
else
|
||||
new_index = fetch_bulk_index(source_uri)
|
||||
@gems.replace(new_index.gems)
|
||||
end
|
||||
|
||||
true
|
||||
end
|
||||
|
||||
def ==(other) # :nodoc:
|
||||
self.class === other and @gems == other.gems
|
||||
end
|
||||
|
@ -421,166 +343,6 @@ class Gem::SourceIndex
|
|||
Marshal.dump(self)
|
||||
end
|
||||
|
||||
private
|
||||
|
||||
def fetcher
|
||||
require 'rubygems/remote_fetcher'
|
||||
|
||||
Gem::RemoteFetcher.fetcher
|
||||
end
|
||||
|
||||
def fetch_index_from(source_uri)
|
||||
@fetch_error = nil
|
||||
|
||||
indexes = %W[
|
||||
Marshal.#{Gem.marshal_version}.Z
|
||||
Marshal.#{Gem.marshal_version}
|
||||
yaml.Z
|
||||
yaml
|
||||
]
|
||||
|
||||
indexes.each do |name|
|
||||
spec_data = nil
|
||||
index = source_uri + name
|
||||
begin
|
||||
spec_data = fetcher.fetch_path index
|
||||
spec_data = unzip(spec_data) if name =~ /\.Z$/
|
||||
|
||||
if name =~ /Marshal/ then
|
||||
return Marshal.load(spec_data)
|
||||
else
|
||||
return YAML.load(spec_data)
|
||||
end
|
||||
rescue => e
|
||||
if Gem.configuration.really_verbose then
|
||||
alert_error "Unable to fetch #{name}: #{e.message}"
|
||||
end
|
||||
|
||||
@fetch_error = e
|
||||
end
|
||||
end
|
||||
|
||||
nil
|
||||
end
|
||||
|
||||
def fetch_bulk_index(source_uri)
|
||||
say "Bulk updating Gem source index for: #{source_uri}" if
|
||||
Gem.configuration.verbose
|
||||
|
||||
index = fetch_index_from(source_uri)
|
||||
if index.nil? then
|
||||
raise Gem::RemoteSourceException,
|
||||
"Error fetching remote gem cache: #{@fetch_error}"
|
||||
end
|
||||
@fetch_error = nil
|
||||
index
|
||||
end
|
||||
|
||||
##
|
||||
# Get the quick index needed for incremental updates.
|
||||
|
||||
def fetch_quick_index(source_uri, all)
|
||||
index = all ? 'index' : 'latest_index'
|
||||
|
||||
zipped_index = fetcher.fetch_path source_uri + "quick/#{index}.rz"
|
||||
|
||||
unzip(zipped_index).split("\n")
|
||||
rescue ::Exception => e
|
||||
unless all then
|
||||
say "Latest index not found, using quick index" if
|
||||
Gem.configuration.really_verbose
|
||||
|
||||
fetch_quick_index source_uri, true
|
||||
else
|
||||
raise Gem::OperationNotSupportedError,
|
||||
"No quick index found: #{e.message}"
|
||||
end
|
||||
end
|
||||
|
||||
##
|
||||
# Make a list of full names for all the missing gemspecs.
|
||||
|
||||
def find_missing(spec_names)
|
||||
unless defined? @originals then
|
||||
@originals = {}
|
||||
each do |full_name, spec|
|
||||
@originals[spec.original_name] = spec
|
||||
end
|
||||
end
|
||||
|
||||
spec_names.find_all { |full_name|
|
||||
@originals[full_name].nil?
|
||||
}
|
||||
end
|
||||
|
||||
def remove_extra(spec_names)
|
||||
dictionary = spec_names.inject({}) { |h, k| h[k] = true; h }
|
||||
each do |name, spec|
|
||||
remove_spec name unless dictionary.include? spec.original_name
|
||||
end
|
||||
end
|
||||
|
||||
##
|
||||
# Unzip the given string.
|
||||
|
||||
def unzip(string)
|
||||
require 'zlib'
|
||||
Gem.inflate string
|
||||
end
|
||||
|
||||
##
|
||||
# Tries to fetch Marshal representation first, then YAML
|
||||
|
||||
def fetch_single_spec(source_uri, spec_name)
|
||||
@fetch_error = nil
|
||||
|
||||
begin
|
||||
marshal_uri = source_uri + "quick/Marshal.#{Gem.marshal_version}/#{spec_name}.gemspec.rz"
|
||||
zipped = fetcher.fetch_path marshal_uri
|
||||
return Marshal.load(unzip(zipped))
|
||||
rescue => ex
|
||||
@fetch_error = ex
|
||||
|
||||
if Gem.configuration.really_verbose then
|
||||
say "unable to fetch marshal gemspec #{marshal_uri}: #{ex.class} - #{ex}"
|
||||
end
|
||||
end
|
||||
|
||||
begin
|
||||
yaml_uri = source_uri + "quick/#{spec_name}.gemspec.rz"
|
||||
zipped = fetcher.fetch_path yaml_uri
|
||||
return YAML.load(unzip(zipped))
|
||||
rescue => ex
|
||||
@fetch_error = ex
|
||||
if Gem.configuration.really_verbose then
|
||||
say "unable to fetch YAML gemspec #{yaml_uri}: #{ex.class} - #{ex}"
|
||||
end
|
||||
end
|
||||
|
||||
nil
|
||||
end
|
||||
|
||||
##
|
||||
# Update the cached source index with the missing names.
|
||||
|
||||
def update_with_missing(source_uri, missing_names)
|
||||
progress = ui.progress_reporter(missing_names.size,
|
||||
"Updating metadata for #{missing_names.size} gems from #{source_uri}")
|
||||
missing_names.each do |spec_name|
|
||||
gemspec = fetch_single_spec(source_uri, spec_name)
|
||||
if gemspec.nil? then
|
||||
ui.say "Failed to download spec #{spec_name} from #{source_uri}:\n" \
|
||||
"\t#{@fetch_error.message}"
|
||||
else
|
||||
add_spec gemspec
|
||||
progress.updated spec_name
|
||||
end
|
||||
@fetch_error = nil
|
||||
end
|
||||
progress.done
|
||||
progress.count
|
||||
end
|
||||
|
||||
end
|
||||
|
||||
# :stopdoc:
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue