Class: Actions::Katello::Repository::CloneContents

Inherits:
Base
  • Object
show all
Includes:
CheckMatchingContent
Defined in:
app/lib/actions/katello/repository/clone_contents.rb

Instance Method Summary collapse

Methods included from CheckMatchingContent

#check_matching_content

Instance Method Details

#finalize ⇒ Object 



62
63
64
65
66
 
# File 'app/lib/actions/katello/repository/clone_contents.rb', line 62

def finalize
  repository = ::Katello::Repository.find(input[:target_repo_id])
  source_checksum_type = input[:source_checksum_type]
  repository.update!(saved_checksum_type: source_checksum_type) if (repository && source_checksum_type)
end

#metadata_generate(source_repositories, new_repository, filters, rpm_filenames, matching_content) ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
 
# File 'app/lib/actions/katello/repository/clone_contents.rb', line 46

def metadata_generate(source_repositories, new_repository, filters, rpm_filenames, matching_content)
  metadata_options = {}

  metadata_options[:matching_content] = matching_content

  if source_repositories.count == 1 && filters.empty? && rpm_filenames.empty?
    metadata_options[:source_repository] = source_repositories.first
  end

  plan_action(Katello::Repository::MetadataGenerate, new_repository, metadata_options)
  unless source_repositories.first.saved_checksum_type == new_repository.saved_checksum_type
    plan_self(:source_checksum_type => source_repositories.first.saved_checksum_type,
              :target_repo_id => new_repository.id)
  end
end

#plan(source_repositories, new_repository, options) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'app/lib/actions/katello/repository/clone_contents.rb', line 7

def plan(source_repositories, new_repository, options)
  filters = options.fetch(:filters, nil)
  rpm_filenames = options.fetch(:rpm_filenames, nil)
  generate_metadata = options.fetch(:generate_metadata, true)
  copy_contents = options.fetch(:copy_contents, true)
  solve_dependencies = options.fetch(:solve_dependencies, false)

  sequence do
    if copy_contents
      plan_action(Pulp3::Orchestration::Repository::CopyAllUnits,
                  new_repository,
                  SmartProxy.pulp_primary,
                  source_repositories,
                  filters: filters, rpm_filenames: rpm_filenames, solve_dependencies: solve_dependencies)
    end

    matching_content = check_matching_content(new_repository, source_repositories)
    metadata_generate(source_repositories, new_repository, filters, rpm_filenames, matching_content) if generate_metadata

    index_options = {id: new_repository.id, force_index: true}
    index_options[:source_repository_id] = source_repositories.first.id if source_repositories.count == 1 && filters.empty? && rpm_filenames.nil?

    if new_repository.deb? && generate_metadata
      plan_action(Candlepin::Product::ContentUpdate,
                  owner:           new_repository.organization.label,
                  repository_id:   new_repository.id,
                  name:            new_repository.root.name,
                  type:            new_repository.root.content_type,
                  arches:          new_repository.root.format_arches,
                  label:           new_repository.root.custom_content_label,
                  content_url:     new_repository.root.custom_content_path,
                  gpg_key_url:     new_repository.yum_gpg_key_url,
                  metadata_expire: new_repository.root.metadata_expire)
    end

    plan_action(Katello::Repository::IndexContent, index_options)
  end
end