Class: PuppetLibrary::Forge::Multi

Inherits:
Forge
  • Object
show all
Defined in:
lib/puppet_library/forge/multi.rb

Overview

A forge that delegates to multiple other forges.

For queries, all subforges are queried. The results are merged, giving preference to earlier ones. That is, if the same version of a module is found in two different subforges, the one contained in the earlier subforge is kept in the query results.

For downloads, subforges are queried sequentially. The first module found is returned.

Usage:

# A forge that serves modules from disk, and proxies a remote forge
multi_forge = Multi.new
multi_forge.add_forge(Directory.new("/var/modules"))
multi_forge.add_forge(Proxy.new("http://forge.puppetlabs.com"))

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Multi

Returns a new instance of Multi.



41
42
43
 
# File 'lib/puppet_library/forge/multi.rb', line 41

def initialize
    @forges = []
end

Instance Method Details

#add_forge(forge) ⇒ Object

Add another forge to delegate to.



54
55
56
 
# File 'lib/puppet_library/forge/multi.rb', line 54

def add_forge(forge)
    @forges << forge
end

#clear_cache ⇒ Object 



49
50
51
 
# File 'lib/puppet_library/forge/multi.rb', line 49

def clear_cache
    @forges.each_in_parallel &:clear_cache
end

#get_module_buffer(author, name, version) ⇒ Object

Raises:



66
67
68
69
70
71
72
73
74
75
 
# File 'lib/puppet_library/forge/multi.rb', line 66

def get_module_buffer(author, name, version)
    @forges.each do |forge|
        begin
            return forge.get_module_buffer(author, name, version)
        rescue ModuleNotFound
            # Try the next one
        end
    end
    raise ModuleNotFound
end

#get_module_metadata(author, name) ⇒ Object

Raises:



77
78
79
80
81
82
83
84
85
86
87
88
89
 
# File 'lib/puppet_library/forge/multi.rb', line 77

def get_module_metadata(author, name)
    metadata_list = @forges.inject([]) do |metadata_list, forge|
        begin
            metadata_list << forge.get_module_metadata(author, name)
        rescue ModuleNotFound
            metadata_list
        end
    end
    raise ModuleNotFound if metadata_list.empty?
    metadata_list.deep_merge.tap do |metadata|
        metadata["releases"] = metadata["releases"].unique_by { |release| release["version"] }
    end
end

#get_module_metadata_with_dependencies(author, name, version) ⇒ Object 



91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
 
# File 'lib/puppet_library/forge/multi.rb', line 91

def get_module_metadata_with_dependencies(author, name, version)
    metadata_list = []
    @forges.each do |forge|
        begin
            metadata_list << forge.get_module_metadata_with_dependencies(author, name, version)
        rescue ModuleNotFound
            # Try the next one
        end
    end
    raise ModuleNotFound if metadata_list.empty?
    metadata_list.deep_merge.tap do |metadata|
        metadata.each do |module_name, releases|
            metadata[module_name] = releases.unique_by { |release| release["version"] }
        end
    end
end

#prime ⇒ Object 



45
46
47
 
# File 'lib/puppet_library/forge/multi.rb', line 45

def prime
    @forges.each_in_parallel &:prime
end

#search_modules(query) ⇒ Object 



58
59
60
61
62
63
64
 
# File 'lib/puppet_library/forge/multi.rb', line 58

def search_modules(query)
    all_results = @forges.map do |forge|
        forge.search_modules(query)
    end.flatten

    SearchResult.merge_by_full_name(all_results)
end