diff options
Diffstat (limited to 'lib/chef/knife/cookbook_site_share.rb')
| -rw-r--r-- | lib/chef/knife/cookbook_site_share.rb | 114 |
1 files changed, 114 insertions, 0 deletions
diff --git a/lib/chef/knife/cookbook_site_share.rb b/lib/chef/knife/cookbook_site_share.rb new file mode 100644 index 0000000000..77c4895dcc --- /dev/null +++ b/lib/chef/knife/cookbook_site_share.rb @@ -0,0 +1,114 @@ +# Author:: Nuo Yan (<nuo@opscode.com>) +# Author:: Tim Hinderliter (<tim@opscode.com>) +# Copyright:: Copyright (c) 2010 Opscode, Inc. +# License:: Apache License, Version 2.0 +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +require 'chef/knife' + +class Chef + class Knife + class CookbookSiteShare < Knife + + deps do + require 'chef/cookbook_uploader' + require 'chef/cookbook_site_streaming_uploader' + end + + banner "knife cookbook site share COOKBOOK CATEGORY (options)" + category "cookbook site" + + option :cookbook_path, + :short => "-o PATH:PATH", + :long => "--cookbook-path PATH:PATH", + :description => "A colon-separated path to look for cookbooks in", + :proc => lambda { |o| Chef::Config.cookbook_path = o.split(":") } + + def run + if @name_args.length < 2 + show_usage + ui.fatal("You must specify the cookbook name and the category you want to share this cookbook to.") + exit 1 + end + + config[:cookbook_path] ||= Chef::Config[:cookbook_path] + + cookbook_name = @name_args[0] + category = @name_args[1] + cl = Chef::CookbookLoader.new(config[:cookbook_path]) + if cl.cookbook_exists?(cookbook_name) + cookbook = cl[cookbook_name] + Chef::CookbookUploader.new(cookbook,config[:cookbook_path]).validate_cookbooks + tmp_cookbook_dir = Chef::CookbookSiteStreamingUploader.create_build_dir(cookbook) + begin + Chef::Log.debug("Temp cookbook directory is #{tmp_cookbook_dir.inspect}") + ui.info("Making tarball #{cookbook_name}.tgz") + Chef::Mixin::Command.run_command(:command => "tar -czf #{cookbook_name}.tgz #{cookbook_name}", :cwd => tmp_cookbook_dir) + rescue => e + ui.error("Error making tarball #{cookbook_name}.tgz: #{e.message}. Set log level to debug (-l debug) for more information.") + Chef::Log.debug("\n#{e.backtrace.join("\n")}") + exit(1) + end + + begin + do_upload("#{tmp_cookbook_dir}/#{cookbook_name}.tgz", category, Chef::Config[:node_name], Chef::Config[:client_key]) + ui.info("Upload complete!") + Chef::Log.debug("Removing local staging directory at #{tmp_cookbook_dir}") + FileUtils.rm_rf tmp_cookbook_dir + rescue => e + ui.error("Error uploading cookbook #{cookbook_name} to the Opscode Cookbook Site: #{e.message}. Set log level to debug (-l debug) for more information.") + Chef::Log.debug("\n#{e.backtrace.join("\n")}") + exit(1) + end + + else + ui.error("Could not find cookbook #{cookbook_name} in your cookbook path.") + exit(1) + end + + end + + def do_upload(cookbook_filename, cookbook_category, user_id, user_secret_filename) + uri = "http://cookbooks.opscode.com/api/v1/cookbooks" + + category_string = { 'category'=>cookbook_category }.to_json + + http_resp = Chef::CookbookSiteStreamingUploader.post(uri, user_id, user_secret_filename, { + :tarball => File.open(cookbook_filename), + :cookbook => category_string + }) + + res = Chef::JSONCompat.from_json(http_resp.body) + if http_resp.code.to_i != 201 + if res['error_messages'] + if res['error_messages'][0] =~ /Version already exists/ + ui.error "The same version of this cookbook already exists on the Opscode Cookbook Site." + exit(1) + else + ui.error "#{res['error_messages'][0]}" + exit(1) + end + else + ui.error "Unknown error while sharing cookbook" + ui.error "Server response: #{http_resp.body}" + exit(1) + end + end + res + end + end + + end +end |