Class: Actions::Pulp3::Orchestration::Repository::GenerateMetadata

Inherits:
Abstract
  • Object
show all
Defined in:
app/lib/actions/pulp3/orchestration/repository/generate_metadata.rb

Instance Method Summary collapse

Methods inherited from Abstract

#smart_proxy

Instance Method Details

#plan(repository, smart_proxy, options = {}) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'app/lib/actions/pulp3/orchestration/repository/generate_metadata.rb', line 6

def plan(repository, smart_proxy, options = {})
  force_publication = options.fetch(:force_publication, repository.publication_href.nil?)

  options[:contents_changed] = (options && options.key?(:contents_changed)) ? options[:contents_changed] : true
  publication_content_type = !::Katello::RepositoryTypeManager.find(repository.content_type).pulp3_skip_publication

  sequence do
    if options[:source_repository] && publication_content_type
      plan_self(source_repository_id: options[:source_repository].id, target_repository_id: repository.id, smart_proxy_id: smart_proxy.id)
    elsif publication_content_type && (force_publication || repository.publication_href.nil? || !repository.using_mirrored_metadata?)
      plan_action(Actions::Pulp3::Repository::CreatePublication, repository, smart_proxy, options)
    end
    plan_action(Actions::Pulp3::ContentGuard::Refresh, smart_proxy) unless repository.unprotected
    plan_action(Actions::Pulp3::Repository::RefreshDistribution, repository, smart_proxy, :contents_changed => options[:contents_changed]) if Setting[:distribute_archived_cvv] || repository.environment
  end
end

#run ⇒ Object 



23
24
25
26
27
28
29
30
31
 
# File 'app/lib/actions/pulp3/orchestration/repository/generate_metadata.rb', line 23

def run
  #we don't have to actually generate a publication, we can reuse the old one
  target_repo = ::Katello::Repository.find(input[:target_repository_id])
  source_repo = ::Katello::Repository.find(input[:source_repository_id])
  if (target_repo.publication_href != source_repo.publication_href && smart_proxy.pulp_primary?)
    target_repo.clear_smart_proxy_sync_histories
  end
  target_repo.update!(publication_href: source_repo.publication_href)
end