|
#
|
|
# Copyright 2013 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::Content
|
|
def self.included(base)
|
|
base.send :include, InstanceMethods
|
|
# required for GPG key url generation
|
|
base.send :include, Rails.application.routes.url_helpers
|
|
|
|
base.class_eval do
|
|
before_save :save_content_orchestration
|
|
before_destroy :destroy_content_orchestration
|
|
after_destroy :update_environment_content
|
|
after_create :rectify_gpg_key_orchestration
|
|
after_update :handle_enabled_changed
|
|
end
|
|
end
|
|
|
|
module InstanceMethods
|
|
def destroy_content_orchestration
|
|
if !self.product.provider.redhat_provider?
|
|
pre_queue.create(:name => "remove content : #{self.name}", :priority => 2, :action => [self, :del_content])
|
|
end
|
|
end
|
|
|
|
def save_content_orchestration
|
|
#until candelpin supports view content, just ignore
|
|
if self.new_record? && !self.content_view.default?
|
|
return
|
|
end
|
|
|
|
if self.new_record? && !self.product.provider.redhat_provider? && self.environment.library?
|
|
# pre_queue.create(:name => "create content : #{self.name}", :priority => 2, :action => [self, :create_content],
|
|
# :action_rollback => [self, :del_content]
|
|
#)
|
|
elsif !self.new_record? && should_update_content?
|
|
pre_queue.create(:name => "update content : #{self.name}", :priority => 2, :action => [self, :update_content])
|
|
end
|
|
end
|
|
|
|
def handle_enabled_changed
|
|
update_environment_content if self.enabled_changed?
|
|
end
|
|
|
|
def update_environment_content
|
|
self.content_view.update_cp_content(self.environment)
|
|
end
|
|
|
|
def rectify_gpg_key_orchestration
|
|
#if we are creating a repo with a gpg key, we have to create the content without the gpg key
|
|
# and then update the content with the gpg key (since repo needs content created before it is actually saved
|
|
# and thus can't create the gpg key url)
|
|
if self.gpg_key
|
|
pre_queue.create(:name => "update content : #{self.name}", :priority => 2, :action => [self, :update_content])
|
|
end
|
|
end
|
|
|
|
def del_content
|
|
return true unless self.content_id
|
|
if other_repos_with_same_product_and_content.empty?
|
|
self.product.remove_content_by_id self.content_id
|
|
if other_repos_with_same_content.empty? && !self.product.provider.redhat_provider?
|
|
Resources::Candlepin::Content.destroy(self.content_id)
|
|
end
|
|
end
|
|
|
|
true
|
|
end
|
|
|
|
def content
|
|
return @content unless @content.nil?
|
|
unless self.content_id.nil?
|
|
@content = Katello::Candlepin::Content.find(self.content_id)
|
|
end
|
|
@content
|
|
end
|
|
|
|
def update_content
|
|
#if the gpg key was enabled
|
|
#we only update the content if the content is actually not set properly
|
|
#this means we don't recreate the environment for the same repo in
|
|
#each environment. We do the same for it being disabled, we check
|
|
#to make sure it is not enabled in the contnet before refreshing
|
|
self.content.update(
|
|
:name => self.name,
|
|
:contentUrl => Glue::Pulp::Repos.custom_content_path(self.product, label),
|
|
:gpgUrl => yum_gpg_key_url,
|
|
:label => custom_content_label,
|
|
:type => self.content_type,
|
|
:vendor => Provider::CUSTOM
|
|
)
|
|
end
|
|
|
|
def create_content
|
|
#only used for custom content
|
|
fail 'Can only create content for custom providers' if self.product.provider.redhat_provider?
|
|
new_content = Candlepin::ProductContent.new(
|
|
:content => {
|
|
:name => self.name,
|
|
:contentUrl => Glue::Pulp::Repos.custom_content_path(self.product, self.label),
|
|
:type => self.content_type,
|
|
:label => self.custom_content_label,
|
|
:vendor => Provider::CUSTOM
|
|
},
|
|
:enabled => true
|
|
)
|
|
new_content.create
|
|
self.product.add_content new_content
|
|
self.content_id = new_content.content.id
|
|
self.cp_label = new_content.content.label
|
|
new_content.content
|
|
end
|
|
|
|
def should_update_content?
|
|
(self.gpg_key_id_was.nil? && !self.gpg_key_id.nil? && self.content.gpgUrl == '') ||
|
|
(!self.gpg_key_id_was.nil? && self.gpg_key_id.nil? && self.content.gpgUrl != '')
|
|
end
|
|
|
|
def yum_gpg_key_url
|
|
# if the repo has a gpg key return a url to access it
|
|
if (gpg_key && gpg_key.content.present?)
|
|
host = Katello.config.host
|
|
host += ":" + Katello.config.port.to_s unless Katello.config.port.blank? || Katello.config.port.to_s == "443"
|
|
gpg_key_content_api_repository_url(self, :host => host + Katello.config.url_prefix, :protocol => 'https')
|
|
end
|
|
end
|
|
|
|
def custom_content_label
|
|
"#{organization.label} #{product.label} #{label}".gsub(/\s/, "_")
|
|
end
|
|
end
|
|
|
|
end
|
|
end
|
