Class: Pod::CDNSource
- Includes:
- Concurrent
- Defined in:
- lib/cocoapods-core/cdn_source.rb
Overview
Subclass of Pod::Source to provide support for CDN-based Specs repositories
Direct Known Subclasses
Constant Summary collapse
- MAX_NUMBER_OF_RETRIES =
(ENV['COCOAPODS_CDN_MAX_NUMBER_OF_RETRIES'] || 5).to_i
Constants inherited from Source
Instance Attribute Summary
Attributes inherited from Source
Querying the source collapse
-
#all_specs ⇒ Array<Specification>
All the specifications contained by the source.
-
#pod_sets ⇒ Array<Sets>
The sets of all the Pods.
-
#pods ⇒ Array<String>
The list of the name of all the Pods.
-
#specification_path(name, version) ⇒ Pathname
Returns the path of the specification with the given name and version.
-
#versions(name) ⇒ Array<Version>
All the available versions for the Pod, sorted from highest to lowest.
Searching the source collapse
- #git? ⇒ Boolean
- #indexable? ⇒ Boolean
-
#search(query) ⇒ Set
A set for a given dependency.
-
#search_by_name(query, full_text_search = false) ⇒ Array<Set>
The list of the sets that contain the search term.
-
#update(_show_output) ⇒ Array<String>
Check update dates for all existing files.
- #updateable? ⇒ Boolean
Instance Method Summary collapse
- #deprecated_local_podspecs ⇒ Object
- #files_definitely_to_update ⇒ Object
-
#initialize(repo) ⇒ CDNSource
constructor
A new instance of CDNSource.
- #preheat_existing_files ⇒ Object
- #refresh_metadata ⇒ Object
-
#specs_dir ⇒ Pathname
The directory where the specs are stored.
-
#type ⇒ String
The type of the source.
-
#url ⇒ String
The URL of the source.
Methods inherited from Source
#<=>, #fuzzy_search, #inspect, #metadata_path, #name, #pod_path, #pods_for_specification_paths, #set, #specification, #to_hash, #to_yaml, #verify_compatibility!
Constructor Details
#initialize(repo) ⇒ CDNSource
Returns a new instance of CDNSource.
21 22 23 24 25 26 27 28 29 30 31 |
# File 'lib/cocoapods-core/cdn_source.rb', line 21 def initialize(repo) @check_existing_files_for_update = false # Optimization: we initialize startup_time when the source is first initialized # and then test file modification dates against it. Any file that was touched # after the source was initialized, is considered fresh enough. @startup_time = Time.new @version_arrays_by_fragment_by_name = {} super(repo) end |
Instance Method Details
#all_specs ⇒ Array<Specification>
Returns all the specifications contained by the source.
177 178 179 |
# File 'lib/cocoapods-core/cdn_source.rb', line 177 def all_specs raise Informative, "Can't retrieve all the specs for a CDN-backed source, it will take forever" end |
#deprecated_local_podspecs ⇒ Object
77 78 79 80 81 82 |
# File 'lib/cocoapods-core/cdn_source.rb', line 77 def deprecated_local_podspecs download_file('deprecated_podspecs.txt') local_file('deprecated_podspecs.txt', &:to_a). map { |f| Pathname.new(f.chomp) }. select { |f| repo.join(f).exist? } end |
#files_definitely_to_update ⇒ Object
73 74 75 |
# File 'lib/cocoapods-core/cdn_source.rb', line 73 def files_definitely_to_update Pathname.glob(repo.join('**/*.{txt,yml}')).map { |f| f.relative_path_from(repo).to_s } end |
#git? ⇒ Boolean
268 269 270 |
# File 'lib/cocoapods-core/cdn_source.rb', line 268 def git? false end |
#indexable? ⇒ Boolean
272 273 274 |
# File 'lib/cocoapods-core/cdn_source.rb', line 272 def indexable? false end |
#pod_sets ⇒ Array<Sets>
Returns the sets of all the Pods.
183 184 185 |
# File 'lib/cocoapods-core/cdn_source.rb', line 183 def pod_sets raise Informative, "Can't retrieve all the pod sets for a CDN-backed source, it will take forever" end |
#pods ⇒ Array<String>
Returns the list of the name of all the Pods.
95 96 97 98 |
# File 'lib/cocoapods-core/cdn_source.rb', line 95 def pods download_file('all_pods.txt') local_file('all_pods.txt', &:to_a).map(&:chomp) end |
#preheat_existing_files ⇒ Object
59 60 61 62 63 64 65 66 67 68 69 70 71 |
# File 'lib/cocoapods-core/cdn_source.rb', line 59 def preheat_existing_files files_to_update = files_definitely_to_update + deprecated_local_podspecs - ['deprecated_podspecs.txt'] debug "CDN: #{name} Going to update #{files_to_update.count} files" concurrent_requests_catching_errors do # Queue all tasks first loaders = files_to_update.map do |file| download_file_async(file) end # Block and wait for all to complete running on Hydra Promises.zip_futures_on(HYDRA_EXECUTOR, *loaders).wait! end end |
#refresh_metadata ⇒ Object
45 46 47 48 49 50 51 52 53 54 55 56 57 |
# File 'lib/cocoapods-core/cdn_source.rb', line 45 def if .nil? unless repo.exist? debug "CDN: Repo #{name} does not exist!" return end specs_dir.mkpath download_file('CocoaPods-version.yml') end super end |
#search(query) ⇒ Set
Rename to #load_set
This method is optimized for fast lookups by name, i.e. it does not require iterating through #pod_sets
Returns a set for a given dependency. The set is identified by the name of the dependency and takes into account subspecs.
198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 |
# File 'lib/cocoapods-core/cdn_source.rb', line 198 def search(query) unless specs_dir raise Informative, "Unable to find a source named: `#{name}`" end if query.is_a?(Dependency) query = query.root_name end fragment = pod_shard_fragment(query) ensure_versions_file_loaded(fragment) version_arrays_by_name = @version_arrays_by_fragment_by_name[fragment] || {} found = version_arrays_by_name[query].nil? ? nil : query if found set = set(query) set if set.specification_name == query end end |
#search_by_name(query, full_text_search = false) ⇒ Array<Set>
full text search requires to load the specification for each pod, and therefore not supported.
Returns The list of the sets that contain the search term.
231 232 233 234 235 236 237 238 239 240 241 242 243 244 |
# File 'lib/cocoapods-core/cdn_source.rb', line 231 def search_by_name(query, full_text_search = false) if full_text_search require 'algoliasearch' begin algolia_result = algolia_search_index.search(query, :attributesToRetrieve => 'name') names = algolia_result['hits'].map { |r| r['name'] } names.map { |n| set(n) }.reject { |s| s.versions.compact.empty? } rescue Algolia::AlgoliaError => e raise Informative, "CDN: #{name} - Cannot perform full-text search because Algolia returned an error: #{e}" end else super(query) end end |
#specification_path(name, version) ⇒ Pathname
Returns the path of the specification with the given name and version.
160 161 162 163 164 165 166 167 168 169 170 171 172 |
# File 'lib/cocoapods-core/cdn_source.rb', line 160 def specification_path(name, version) raise ArgumentError, 'No name' unless name raise ArgumentError, 'No version' unless version unless versions(name).include?(Version.new(version)) raise StandardError, "Unable to find the specification #{name} " \ "(#{version}) in the #{self.name} source." end podspec_version_path_relative = Pathname.new(version.to_s).join("#{name}.podspec.json") relative_podspec = relative_pod_path(name).join(podspec_version_path_relative).to_s download_file(relative_podspec) pod_path(name).join(podspec_version_path_relative) end |
#specs_dir ⇒ Pathname
Returns The directory where the specs are stored.
86 87 88 |
# File 'lib/cocoapods-core/cdn_source.rb', line 86 def specs_dir @specs_dir ||= repo + 'Specs' end |
#type ⇒ String
Returns The type of the source.
41 42 43 |
# File 'lib/cocoapods-core/cdn_source.rb', line 41 def type 'CDN' end |
#update(_show_output) ⇒ Array<String>
Check update dates for all existing files. Does not download non-existing specs, since CDN-backed repo is updated live.
254 255 256 257 258 259 260 261 262 |
# File 'lib/cocoapods-core/cdn_source.rb', line 254 def update(_show_output) @check_existing_files_for_update = true begin preheat_existing_files ensure @check_existing_files_for_update = false end [] end |
#updateable? ⇒ Boolean
264 265 266 |
# File 'lib/cocoapods-core/cdn_source.rb', line 264 def updateable? true end |
#url ⇒ String
Returns The URL of the source.
35 36 37 |
# File 'lib/cocoapods-core/cdn_source.rb', line 35 def url @url ||= File.read(repo.join('.url')).chomp.chomp('/') + '/' end |
#versions(name) ⇒ Array<Version>
Returns all the available versions for the Pod, sorted from highest to lowest.
106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 |
# File 'lib/cocoapods-core/cdn_source.rb', line 106 def versions(name) return nil unless specs_dir raise ArgumentError, 'No name' unless name fragment = pod_shard_fragment(name) ensure_versions_file_loaded(fragment) return @versions_by_name[name] unless @versions_by_name[name].nil? pod_path_actual = pod_path(name) pod_path_relative = relative_pod_path(name) return nil if @version_arrays_by_fragment_by_name[fragment][name].nil? concurrent_requests_catching_errors do loaders = [] @versions_by_name[name] ||= @version_arrays_by_fragment_by_name[fragment][name].map do |version| # Optimization: ensure all the podspec files at least exist. The correct one will get refreshed # in #specification_path regardless. podspec_version_path_relative = Pathname.new(version).join("#{name}.podspec.json") unless pod_path_actual.join(podspec_version_path_relative).exist? # Queue all podspec download tasks first loaders << download_file_async(pod_path_relative.join(podspec_version_path_relative).to_s) end begin Version.new(version) if version[0, 1] != '.' rescue ArgumentError raise Informative, 'An unexpected version directory ' \ "`#{version}` was encountered for the " \ "`#{pod_path_actual}` Pod in the `#{name}` repository." end end.compact.sort.reverse # Block and wait for all to complete running on Hydra Promises.zip_futures_on(HYDRA_EXECUTOR, *loaders).wait! end @versions_by_name[name] end |