Class: Katello::Pulp3::ContentViewVersion::ExportValidator

Inherits:
Object
  • Object
show all
Defined in:
app/services/katello/pulp3/content_view_version/export_validator.rb

Instance Method Summary collapse

Constructor Details

#initialize(export_service:, fail_on_missing_content: true, validate_incremental: true, chunk_size: nil) ⇒ ExportValidator

Returns a new instance of ExportValidator.



8
9
10
11
12
13
 
# File 'app/services/katello/pulp3/content_view_version/export_validator.rb', line 8

def initialize(export_service:, fail_on_missing_content: true, validate_incremental: true, chunk_size: nil)
  @export_service = export_service
  @fail_on_missing_content = fail_on_missing_content
  @validate_incremental = validate_incremental
  @chunk_size = chunk_size
end

Instance Method Details

#generate_repo_mapping(repositories) ⇒ Object 



109
110
111
112
113
114
115
116
117
 
# File 'app/services/katello/pulp3/content_view_version/export_validator.rb', line 109

def generate_repo_mapping(repositories)
  # return a repo mapping with key being the  library_instance_id and value being the repostiory_href
  # used by validate_incremental_export
  repo_map = {}
  repositories.each do |repo|
    repo_map[repo.library_instance_id] = version_href_to_repository_href(repo.version_href)
  end
  repo_map
end

#validate! ⇒ Object 



15
16
17
18
19
20
21
 
# File 'app/services/katello/pulp3/content_view_version/export_validator.rb', line 15

def validate!
  validate_has_repos!
  validate_repositories_immediate! if @fail_on_missing_content
  validate_incremental_export! if @validate_incremental && !from_content_view_version.blank?
  validate_chunk_size
  validate_export_types! if @fail_on_missing_content
end

#validate_chunk_size ⇒ Object 



38
39
40
41
42
43
44
 
# File 'app/services/katello/pulp3/content_view_version/export_validator.rb', line 38

def validate_chunk_size
  return if @chunk_size.blank?

  unless @chunk_size.is_a?(Numeric) && @chunk_size > 0 && @chunk_size < 1e6
    fail ExportValidationError, _("Specify an export chunk size less than 1_000_000 GB")
  end
end

#validate_export_types! ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'app/services/katello/pulp3/content_view_version/export_validator.rb', line 46

def validate_export_types!
  repos = repositories(fetch_all: true).where.not(id: ::Katello::Repository.exportable(format: format))
  if repos.any?
    fail ExportValidationError,
         _("NOTE: Unable to fully export Content View Version '%{content_view} %{current}'"\
           " it contains repositories with un-exportable content types. \n %{repos}" %
           { content_view: content_view_version.content_view.name,
             current: content_view_version.version,
             repos: Export.generate_product_repo_strings(repositories: repos)})

  end
end

#validate_has_repos! ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'app/services/katello/pulp3/content_view_version/export_validator.rb', line 23

def validate_has_repos!
  repos = repositories(fetch_all: true).where(id: ::Katello::Repository.exportable(format: format))
  if repos.empty?
    fail ExportValidationError,
         _("NOTE: Content view version '%{content_view} %{current}'"\
           " does not have any exportable repositories. At least one repository with"\
           " any of the following types"\
           " is required to be able to export: '%{exportable_types}'." %
           { content_view: content_view_version.content_view.name,
             current: content_view_version.version,
             exportable_types: ::Katello::Repository.exportable_types(format: format).join("', '")
           })
  end
end

#validate_incremental_export! ⇒ Object 



86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
 
# File 'app/services/katello/pulp3/content_view_version/export_validator.rb', line 86

def validate_incremental_export!
  validate_incremental_export_point_release!

  from_exporter = Export.new(smart_proxy: smart_proxy, content_view_version: from_content_view_version)

  from_exporter_repos = generate_repo_mapping(from_exporter.repositories(fetch_all: true))
  to_exporter_repos = generate_repo_mapping(repositories(fetch_all: true))

  invalid_repos_exist = (from_exporter_repos.keys & to_exporter_repos.keys).any? do |repo_id|
    from_exporter_repos[repo_id] != to_exporter_repos[repo_id]
  end

  if invalid_repos_exist
    fail ExportValidationError,
        _("Cannot incrementally export from a filtered and a non-filtered content view version."\
           " The exported content view version '%{content_view} %{current}' "\
           " cannot be incrementally updated from version '%{from}.'. "\
           " Please do a full export." % { content_view: content_view_version.content_view.name,
                                           current: content_view_version.version,
                                           from: from_content_view_version.version})
  end
end

#validate_incremental_export_point_release! ⇒ Object 



73
74
75
76
77
78
79
80
81
82
83
84
 
# File 'app/services/katello/pulp3/content_view_version/export_validator.rb', line 73

def validate_incremental_export_point_release!
  # You are trying to export between an incrementally updated content view version and regular version
  if from_content_view_version.incrementally_updated? != content_view_version.incrementally_updated?
    fail ExportValidationError,
         _("Cannot incrementally export from a incrementally exported version and a regular version or vice-versa. "\
           " The exported Content View Version '%{content_view} %{current}' "\
           "cannot be incrementally exported from version '%{from}.'"\
                       " Please do a full export." % { content_view: content_view_version.content_view.name,
                                                       current: content_view_version.version,
                                                       from: from_content_view_version.version})
  end
end

#validate_repositories_immediate! ⇒ Object 



59
60
61
62
63
64
65
66
67
68
69
70
71
 
# File 'app/services/katello/pulp3/content_view_version/export_validator.rb', line 59

def validate_repositories_immediate!
  non_immediate_repos = repositories(fetch_all: true).yum_type.non_immediate
  if non_immediate_repos.any?
    fail ExportValidationError,
         _("NOTE: Unable to fully export Content View Version '%{content_view} %{current}'"\
           " it contains repositories without the 'immediate' download policy."\
           " Update the download policy and sync affected repositories. Once synced republish the content view"\
           " and export the generated version. \n %{repos}" %
           { content_view: content_view_version.content_view.name,
             current: content_view_version.version,
             repos: Export.generate_product_repo_strings(repositories: non_immediate_repos)})
  end
end