Class: Gem::SparseMirror::Command

Inherits:
Object
  • Object
show all
Defined in:
lib/gem-sparse-mirror/command.rb

Constant Summary collapse

SUPPORTS_INFO_SIGNAL = 
Signal.list['INFO']

Instance Method Summary collapse

Instance Method Details

#execute ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/gem-sparse-mirror/command.rb', line 8

def execute
  config_file = File.join Gem.user_home, '.gem', '.mirrorrc'

  raise "Config file #{config_file} not found" unless File.exist? config_file

  mirrors = YAML.load_file config_file

  raise "Invalid config file #{config_file}" unless mirrors.respond_to? :each

  mirrors.each do |mir|
    raise "mirror missing 'from' field" unless mir.has_key? 'from'
    raise "mirror missing 'to' field" unless mir.has_key? 'to'

    get_from = mir['from']
    save_to = File.expand_path mir['to']

    parallelism = mir['parallelism']

    raise "Directory not found: #{save_to}" unless File.exist? save_to
    raise "Not a directory: #{save_to}" unless File.directory? save_to

    mirror = Gem::SparseMirror::Mirror.new(get_from, save_to, parallelism)
    mirror.only = mir["only"]
    mirror.except = Array(mir["except"])

    puts "Fetching: #{mirror.from(Gem::Mirror::SPECS_FILE_Z)} with #{parallelism} threads"
    mirror.update_specs

    puts "Total gems: #{mirror.gems.size}"

    num_to_fetch = mirror.gems_to_fetch.size

    #progress = ui.progress_reporter num_to_fetch,
    #                                      "Fetching #{num_to_fetch} gems"

    trap(:INFO) { puts "Fetched: #{progress.count}/#{num_to_fetch}" } if SUPPORTS_INFO_SIGNAL

    #mirror.update_gems { progress.updated true }

    num_to_delete = mirror.gems_to_delete.size

    #progress = ui.progress_reporter num_to_delete,
    #                           "Deleting #{num_to_delete} gems"

    trap(:INFO) { puts "Fetched: #{progress.count}/#{num_to_delete}" } if SUPPORTS_INFO_SIGNAL

    mirror.delete_gems { progress.updated true }
  end
end