Class: Chef::Knife::CookbookUpload
Constant Summary
collapse
- CHECKSUM =
"checksum".freeze
- MATCH_CHECKSUM =
/[0-9a-f]{32,}/.freeze
Constants inherited
from Chef::Knife
CHEF_ORGANIZATION_MANAGEMENT, OFFICIAL_PLUGINS, OPSCODE_HOSTED_CHEF_ACCESS_CONTROL
Instance Attribute Summary
Attributes inherited from Chef::Knife
#name_args, #ui
Instance Method Summary
collapse
#file_class
Methods inherited from Chef::Knife
#api_key, #apply_computed_config, category, chef_config_dir, #cli_keys, common_name, #config_file_settings, config_loader, #config_source, #configure_chef, #create_object, #delete_object, dependency_loaders, deps, #format_rest_error, guess_category, #humanize_exception, #humanize_http_exception, inherited, #initialize, list_commands, load_commands, load_config, load_deps, #maybe_setup_fips, #merge_configs, msg, #noauth_rest, #parse_options, reset_config_loader!, reset_subcommands!, #rest, run, #run_with_pretty_exceptions, #server_url, #show_usage, snake_case_name, subcommand_category, subcommand_class_from, subcommand_files, subcommand_loader, subcommands, subcommands_by_category, #test_mandatory_field, ui, unnamed?, use_separate_defaults?, #username
#constantize, #convert_to_class_name, #convert_to_snake_case, #filename_to_qualified_string, #normalize_snake_case_name, #snake_case_basename
Constructor Details
This class inherits a constructor from Chef::Knife
Instance Method Details
#cookbook_repo ⇒ Object
202
203
204
205
206
207
|
# File 'lib/chef/knife/cookbook_upload.rb', line 202
def cookbook_repo
@cookbook_loader ||= begin
Chef::Cookbook::FileVendor.fetch_from_disk(config[:cookbook_path])
Chef::CookbookLoader.new(config[:cookbook_path])
end
end
|
#cookbooks_to_upload ⇒ Object
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
|
# File 'lib/chef/knife/cookbook_upload.rb', line 179
def cookbooks_to_upload
@cookbooks_to_upload ||=
if config[:all]
cookbook_repo.load_cookbooks
else
upload_set = {}
@name_args.each do |cookbook_name|
begin
unless upload_set.key?(cookbook_name)
upload_set[cookbook_name] = cookbook_repo[cookbook_name]
if config[:depends]
upload_set[cookbook_name].metadata.dependencies.each_key { |dep| @name_args << dep }
end
end
rescue Exceptions::CookbookNotFoundInRepo => e
ui.error(e.message)
Log.debug(e)
end
end
upload_set
end
end
|
#environment ⇒ Object
216
217
218
|
# File 'lib/chef/knife/cookbook_upload.rb', line 216
def environment
@environment ||= config[:environment] ? Environment.load(config[:environment]) : nil
end
|
#run ⇒ Object
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
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
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
# File 'lib/chef/knife/cookbook_upload.rb', line 80
def run
if ! config[:all] && @name_args.empty?
show_usage
ui.fatal("You must specify the --all flag or at least one cookbook name")
exit 1
end
config[:cookbook_path] ||= Chef::Config[:cookbook_path]
assert_environment_valid!
version_constraints_to_update = {}
upload_failures = 0
upload_ok = 0
@server_side_cookbooks = Chef::CookbookVersion.list_all_versions
justify_width = @server_side_cookbooks.map(&:size).max.to_i + 2
cookbooks = []
cookbooks_to_upload.each do |cookbook_name, cookbook|
raise Chef::Exceptions::MetadataNotFound.new(cookbook.root_paths[0], cookbook_name) unless cookbook.has_metadata_file?
if cookbook.metadata.name.nil?
message = "Cookbook loaded at path [#{cookbook.root_paths[0]}] has invalid metadata: #{cookbook.metadata.errors.join("; ")}"
raise Chef::Exceptions::MetadataNotValid, message
end
cookbooks << cookbook
end
if cookbooks.empty?
cookbook_path = config[:cookbook_path].respond_to?(:join) ? config[:cookbook_path].join(", ") : config[:cookbook_path]
ui.warn("Could not find any cookbooks in your cookbook path: #{cookbook_path}. Use --cookbook-path to specify the desired path.")
else
begin
tmp_cl = Chef::CookbookLoader.copy_to_tmp_dir_from_array(cookbooks)
tmp_cl.load_cookbooks
tmp_cl.compile_metadata
tmp_cl.freeze_versions if config[:freeze]
cookbooks_for_upload = []
tmp_cl.each do |cookbook_name, cookbook|
cookbooks_for_upload << cookbook
version_constraints_to_update[cookbook_name] = cookbook.version
end
if config[:all]
if cookbooks_for_upload.any?
begin
upload(cookbooks_for_upload, justify_width)
rescue Chef::Exceptions::CookbookFrozen
ui.warn("Not updating version constraints for some cookbooks in the environment as the cookbook is frozen.")
ui.error("Uploading of some of the cookbooks must be failed. Remove cookbook whose version is frozen from your cookbooks repo OR use --force option.")
upload_failures += 1
rescue SystemExit => e
tmp_cl.unlink!
raise exit e.status
end
ui.info("Uploaded all cookbooks.") if upload_failures == 0
end
else
tmp_cl.each do |cookbook_name, cookbook|
begin
upload([cookbook], justify_width)
upload_ok += 1
rescue Exceptions::CookbookNotFoundInRepo => e
upload_failures += 1
ui.error("Could not find cookbook #{cookbook_name} in your cookbook path, skipping it")
Log.debug(e)
upload_failures += 1
rescue Exceptions::CookbookFrozen
ui.warn("Not updating version constraints for #{cookbook_name} in the environment as the cookbook is frozen.")
upload_failures += 1
rescue SystemExit => e
tmp_cl.unlink!
raise exit e.status
end
end
if upload_failures == 0
ui.info "Uploaded #{upload_ok} cookbook#{upload_ok == 1 ? "" : "s"}."
elsif upload_failures > 0 && upload_ok > 0
ui.warn "Uploaded #{upload_ok} cookbook#{upload_ok == 1 ? "" : "s"} ok but #{upload_failures} " +
"cookbook#{upload_failures == 1 ? "" : "s"} upload failed."
elsif upload_failures > 0 && upload_ok == 0
ui.error "Failed to upload #{upload_failures} cookbook#{upload_failures == 1 ? "" : "s"}."
exit 1
end
end
unless version_constraints_to_update.empty?
update_version_constraints(version_constraints_to_update) if config[:environment]
end
ensure
tmp_cl.unlink!
end
end
end
|
#update_version_constraints(new_version_constraints) ⇒ Object
209
210
211
212
213
214
|
# File 'lib/chef/knife/cookbook_upload.rb', line 209
def update_version_constraints(new_version_constraints)
new_version_constraints.each do |cookbook_name, version|
environment.cookbook_versions[cookbook_name] = "= #{version}"
end
environment.save
end
|