class HammerCLICsv::CsvCommand::SubscriptionsCommand
Constants
- MANIFEST
- ORGANIZATION
Public Class Methods
supported?()
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 11 def self.supported? true end
Public Instance Methods
add_subscription(line, manifest)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 137 def add_subscription(line, manifest) if find_existing_subscription(line, manifest) puts _("'%{name}' of quantity %{quantity} already attached") % {:name => line[SUBS_NAME], :quantity => line[SUBS_QUANTITY]} if option_verbose? return end print _("Attaching '%{name}' of quantity %{quantity}...") % {:name => line[SUBS_NAME], :quantity => line[SUBS_QUANTITY]} if option_verbose? manifest['available_subscriptions'] ||= get_available_subscriptions(manifest) attach_subscription(line, manifest) puts _('done') end
attach_subscription(line, manifest)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 150 def attach_subscription(line, manifest) manifest['available_subscriptions'].each do |subscription| if subscription['productId'] == line[SUBS_SKU] && subscription['quantity'] >= line[SUBS_QUANTITY] api = rest_client("/subscription/consumers/#{manifest['uuid']}/entitlements?pool=#{subscription['id']}&quantity=#{line[SUBS_QUANTITY]}") results = api.post({}.to_json) subscription['quantity'] -= line[SUBS_QUANTITY] return end end print _('subscription unavailable...') end
export(csv)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 30 def export(csv) csv << [NAME, ORGANIZATION, MANIFEST, SUBS_NAME, SUBS_QUANTITY, SUBS_SKU, SUBS_CONTRACT, SUBS_ACCOUNT, SUBS_START, SUBS_END] @api.resource(:organizations).call(:index, {:per_page => 999999})['results'].each do |organization| next if option_organization && organization['name'] != option_organization organization = @api.resource(:organizations).call(:show, {'id' => organization['id']}) export_manifest(csv, organization) export_subscriptions(csv, organization) end end
export_manifest(csv, organization)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 40 def export_manifest(csv, organization) info = organization['owner_details']['upstreamConsumer'] return if info.nil? csv << ["Manifest Name", organization['name'], info['name']] csv << ["Manifest URL", organization['name'], "https://#{info['webUrl']}#{info['uuid']}"] end
export_subscriptions(csv, organization)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 48 def export_subscriptions(csv, organization) @api.resource(:subscriptions).call(:index, { 'per_page' => 999999, 'search' => option_search, 'organization_id' => organization['id'] })['results'].each do |subscription| next if subscription['product_id'].to_i != 0 # Red Hat subs do not have number SKU name = subscription['host'].nil? ? "Subscription" : "Guest Subscription for Host '#{subscription['host']['name']}'" quantity = subscription['quantity'] < 0 ? "Unlimited" : subscription['quantity'] csv << [name, organization['name'], nil, subscription['name'], quantity, subscription['product_id'], subscription['contract_number'], subscription['account_number'], subscription['start_date'], subscription['end_date']] end end
find_existing_subscription(line, manifest)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 167 def find_existing_subscription(line, manifest) manifest['subscriptions'].each do |subscription| if !subscription['csv_matched'] && subscription['pool']['productId'] == line[SUBS_SKU] && subscription['quantity'] == line[SUBS_QUANTITY] subscription['csv_matched'] = true return true end end false end
get_available_subscriptions(manifest)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 162 def get_available_subscriptions(manifest) api = rest_client("/subscription/pools/?consumer=#{manifest['uuid']}&listall=false") JSON.parse(api.get) end
get_existing_manifest(line)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 205 def get_existing_manifest(line) return @manifests[line[ORGANIZATION]][:manifest] if @manifests[line[ORGANIZATION]][:manifest] unless @manifests[line[ORGANIZATION]][:owner] api = rest_client("/subscription/users/#{option_portal_username}/owners") @manifests[line[ORGANIZATION]][:owner] = JSON.parse(api.get)[0]['key'] end api = rest_client("/subscription/owners/#{@manifests[line[ORGANIZATION]][:owner]}/consumers?type=satellite") response = JSON.parse(api.get).each do |manifest| if manifest['name'] == @manifests[line[ORGANIZATION]][:name] @manifests[line[ORGANIZATION]][:manifest] = manifest break end end @manifests[line[ORGANIZATION]][:manifest] end
get_or_create_manifest(line)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 177 def get_or_create_manifest(line) manifest = get_existing_manifest(line) if manifest if manifest['subscriptions'].nil? api = rest_client("/subscription/consumers/#{manifest['uuid']}/entitlements") results = JSON.parse(api.get) manifest['subscriptions'] = results end else api = rest_client("/subscription/consumers?owner=#{@manifests[line[ORGANIZATION]][:owner]}") body = { 'name' => line[MANIFEST], 'type' => 'satellite', 'facts' => { 'distributor_version' => 'sat-6.0', 'system.certificate_version' => '3.2' } } results = api.post(body.to_json, {'accept' => 'json', 'content_type' => 'application/json'} ) manifest = JSON.parse(results) manifest['subscriptions'] = [] @manifests[line[ORGANIZATION]][:manifest] = manifest end manifest end
import()
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 64 def import if option_in_portal? import_into_portal else thread_import do |line| if line[NAME] == 'Manifest' && line[MANIFEST] && !line[MANIFEST].empty? import_manifest(line[ORGANIZATION], line[MANIFEST]) end end end end
import_into_portal()
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 88 def import_into_portal raise _("--portal-username and --portal-password required") unless option_portal_username && option_portal_password raise _("--portal required") unless option_portal @manifests = {} thread_import do |line| return if option_organization && line[ORGANIZATION] != option_organization @manifests[line[ORGANIZATION]] ||= {} import_subscription(line) end @manifests.each do |organization, manifest| print _("Downloading manifest for organization '%{organization}...") % {:organization => organization} if option_verbose? api = rest_client("/subscription/consumers/#{manifest[:manifest]['uuid']}/export") data = api.get({'accept' => 'application/zip'}) filename = manifest[:file] || "#{manifest[:name]}.zip" print _("writing to file '%{filename}'...") % {:filename => filename} if option_verbose? File.open(filename, 'w') do |f| f.binmode f.write data end puts _("done") if option_verbose? import_manifest(organization, filename) end end
import_manifest(organization_name, filename)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 76 def import_manifest(organization_name, filename) return if option_organization && organization_name != option_organization print(_("Importing manifest '%{filename}' into organization '%{organization}'...") % {:filename => filename, :organization => organization_name}) if option_verbose? args = %W{ --server #{ @server } --username #{ @username } --password #{ @password } subscription upload --file #{ filename } --organization-id #{ foreman_organization(:name => organization_name) } } hammer.run(args) puts(_("done")) if option_verbose? end
import_subscription(line)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 116 def import_subscription(line) case line[NAME] when "Manifest Name" print _("Checking manifest '%{name}'...") % {:name => line[MANIFEST]} if option_verbose? @manifests[line[ORGANIZATION]][:name] = line[MANIFEST] @manifests[line[ORGANIZATION]][:manifest] = get_or_create_manifest(line) puts _("done") if option_verbose? when "Manifest URL" # ignore when "Manifest" @manifests[line[ORGANIZATION]][:file] = line[MANIFEST] when "Subscription" manifest = @manifests[line[ORGANIZATION]][:manifest] raise _('Manifest Name row is required before updating from Subscription rows') unless manifest line[SUBS_QUANTITY] = line[SUBS_QUANTITY].to_i #guarantee integer for future calculations add_subscription(line, manifest) else # ignore end end
rest_client(path)
click to toggle source
# File lib/hammer_cli_csv/subscriptions.rb, line 223 def rest_client(path) options = { :headers => { 'accept' => 'application/json', 'accept-language' => HammerCLI::I18n.locale, 'content-type' => 'application/json' }, :user => option_portal_username, :password => option_portal_password, :verify_ssl => OpenSSL::SSL::VERIFY_NONE } RestClient::Resource.new(option_portal + path, options) end