|
#
|
|
# Copyright 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 Katello
|
|
module Glue::Candlepin::ActivationKey
|
|
|
|
def self.included(base)
|
|
base.send :include, LazyAccessor
|
|
base.send :include, InstanceMethods
|
|
|
|
base.class_eval do
|
|
before_save :save_activation_key_orchestration
|
|
before_destroy :destroy_activation_key_orchestration
|
|
end
|
|
end
|
|
|
|
module InstanceMethods
|
|
|
|
def get_pools
|
|
Resources::Candlepin::ActivationKey.pools(self.organization.label)
|
|
end
|
|
|
|
def get_keys
|
|
Resources::Candlepin::ActivationKey.get
|
|
end
|
|
|
|
def get_key_pools
|
|
key_pools = Resources::Candlepin::ActivationKey.get(self.cp_id)[0][:pools]
|
|
pools = []
|
|
key_pools.each do |key_pool|
|
|
key_pool[:pool][:amount] = (key_pool[:quantity] ? key_pool[:quantity] : 0)
|
|
pools << key_pool[:pool]
|
|
end
|
|
pools
|
|
end
|
|
|
|
def set_activation_key
|
|
Rails.logger.debug _("Creating an activation key in candlepin: #{label}")
|
|
json = Resources::Candlepin::ActivationKey.create(self.label, self.organization.label)
|
|
self.cp_id = json[:id]
|
|
rescue => e
|
|
Rails.logger.error _("Failed to create candlepin activation_key %s") % "#{self.label}: #{e}, #{e.backtrace.join("\n")}"
|
|
raise e
|
|
end
|
|
|
|
def del_activation_key
|
|
Rails.logger.debug _("Deleting activation_key in candlepin: %s") % self.label
|
|
Resources::Candlepin::ActivationKey.destroy self.cp_id
|
|
true
|
|
rescue => e
|
|
Rails.logger.error _("Failed to delete candlepin activation key %s") % "#{self.label}: #{e}, #{e.backtrace.join("\n")}"
|
|
raise e
|
|
end
|
|
|
|
def save_activation_key_orchestration
|
|
case self.orchestration_for
|
|
when :create
|
|
pre_queue.create(:name => "candlepin activation_key: #{self.label}", :priority => 2, :action => [self, :set_activation_key])
|
|
end
|
|
end
|
|
|
|
def destroy_activation_key_orchestration
|
|
pre_queue.create(:name => "candlepin activation_key: #{self.label}", :priority => 3, :action => [self, :del_activation_key])
|
|
end
|
|
|
|
def subscribe(pool_id, quantity = 1)
|
|
Resources::Candlepin::ActivationKey.add_pools self.cp_id, pool_id, quantity
|
|
end
|
|
|
|
def unsubscribe(pool_id)
|
|
Resources::Candlepin::ActivationKey.remove_pools self.cp_id, pool_id
|
|
end
|
|
end
|
|
end
|
|
end
|
