Plugins » Katello » Hammer CLI CSV

  require 'hammer_cli_csv/export'

      @server_status = check_server_status

    def check_server_status

      server = option_server || HammerCLI::Settings.get(:csv, :host)

      username = option_username || HammerCLI::Settings.get(:csv, :username)

      password = option_password || HammerCLI::Settings.get(:csv, :password)

      url = "#{server}/api/status"

      uri = URI(url)

      server_status = Net::HTTP.start(uri.host, uri.port,

                               :use_ssl => uri.scheme == 'https',

                               :verify_mode => OpenSSL::SSL::VERIFY_NONE) do |http|

        request = Net::HTTP::Get.new uri.request_uri

        request.basic_auth(username, password)

        response = http.request(request)

        JSON.parse(response.body)

      end

      server_status

    end

        resource_type = (filter['resource_type'] || '').split(':')[-1] # To remove "Katello::" when present

# Copyright 2013-2014 Red Hat, Inc.

#

# This software is licensed to you under the GNU General Public

# License as published by the Free Software Foundation; either version

# 2 of the License (GPLv2) or (at your option) any later version.

# There is NO WARRANTY for this software, express or implied,

# including the implied warranties of MERCHANTABILITY,

# NON-INFRINGEMENT, or FITNESS FOR A PARTICULAR PURPOSE. You should

# have received a copy of GPLv2 along with this software; if not, see

# http://www.gnu.org/licenses/old-licenses/gpl-2.0.txt.

module HammerCLICsv

  class CsvCommand

    class ExportCommand < HammerCLI::Apipie::Command

      command_name 'export'

      desc         'export into directory'

      option %w(-v --verbose), :flag, 'be verbose'

      option %w(--threads), 'THREAD_COUNT', 'Number of threads to hammer with', :default => 1

      option %w(--server), 'SERVER', 'Server URL'

      option %w(-u --username), 'USERNAME', 'Username to access server'

      option %w(-p --password), 'PASSWORD', 'Password to access server'

      option '--dir', 'DIRECTORY', 'directory to import from'

      RESOURCES = %w( organizations locations puppet_environments operating_systems

                      domains architectures partition_tables lifecycle_environments host_collections

                      provisioning_templates

                      subscriptions activation_keys hosts content_hosts reports roles users )

      RESOURCES.each do |resource|

        dashed = resource.sub('_', '-')

        option "--#{dashed}", 'FILE', "csv file for #{dashed}"

      end

      def execute

        @api = ApipieBindings::API.new({

                                         :uri => option_server || HammerCLI::Settings.get(:csv, :host),

                                         :username => option_username || HammerCLI::Settings.get(:csv, :username),

                                         :password => option_password || HammerCLI::Settings.get(:csv, :password),

                                         :api_version => 2

                                       })

        # Swing the hammers

        RESOURCES.each do |resource|

          hammer_resource(resource)

        end

        HammerCLI::EX_OK

      end

      def hammer(context = nil)

        context ||= {

          :interactive => false,

          :username => 'admin', # TODO: this needs to come from config/settings

          :password => 'changeme' # TODO: this needs to come from config/settings

        }

        HammerCLI::MainCommand.new('', context)

      end

      def hammer_resource(resource)

        return if !self.send("option_#{resource}") && !option_dir

        options_file = self.send("option_#{resource}") || "#{option_dir}/#{resource.sub('_', '-')}.csv"

        args = %W( csv #{resource.sub('_', '-')} --csv-export --csv-file #{options_file} )

        args << '-v' if option_verbose?

        args += %W( --threads #{option_threads} )

        args += %W( --server #{option_server} ) if option_server

        hammer.run(args)

      end

    end

  end

end

            csv << [location['name'], 1, '']

          if @server_status['release'] == 'Headpin'

            @api.resource(:filters)

              .call(:create, { 'filter' => {

                        'role_id' => @existing_roles[name],

                        'search' => search,

                        'unlimited' => search.empty?,

                        'organization_ids' => organizations,

                        'location_ids' => locations,

                        'permission_ids' => permissions

                      }})

            @api.resource(:filters)

              .call(:update, {

                      'id' => filter_id,

                      'search' => search,

                      'unlimited' => search.empty?,

                      'organization_ids' => organizations,

                      'location_ids' => locations,

                      'permission_ids' => permissions

                    })

jeneejahns,1,ActivationKey,name = jenee.jahns@megacorp.com,"view_activation_keys,create_activation_keys,edit_activation_keys,destroy_activation_keys",Mega Corporation,