Class: Actions::Candlepin::Environment::SetContent

Inherits:
Base
  • Object
show all
Defined in:
app/lib/actions/candlepin/environment/set_content.rb

Instance Method Summary collapse

Instance Method Details

#existing_ids ⇒ Object 



65
66
67
68
69
70
71
72
73
74
75
76
 
# File 'app/lib/actions/candlepin/environment/set_content.rb', line 65

def existing_ids
  ::Katello::Resources::Candlepin::Environment.
      find(input[:cp_environment_id])[:environmentContent].map do |content|
    if content.key?('contentId')
      # Supports Candlepin 4.2.11 and up
      content['contentId']
    else
      # Supports Candlepin versions below 4.2.11
      content[:content][:id]
    end
  end
end

#finalize ⇒ Object

rubocop:disable Metrics/AbcSize, Metrics/MethodLength



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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
 
# File 'app/lib/actions/candlepin/environment/set_content.rb', line 16

def finalize # rubocop:disable Metrics/AbcSize, Metrics/MethodLength
  content_view = ::Katello::ContentView.find(input[:content_view_id])
  environment = ::Katello::KTEnvironment.find(input[:environment_id])
  content_ids = content_view.repos(environment).map(&:content_id).uniq.compact
  # in case we create new custom repository that doesn't have the
  # content_id set yet in the plan phase, we allow to pass it as
  # additional argument
  content_ids << input[:new_content_id] if input[:new_content_id] && !content_ids.include?(input[:new_content_id])
  saved_cp_ids = existing_ids
  output[:add_ids] = content_ids - saved_cp_ids
  output[:delete_ids] = saved_cp_ids - content_ids
  max_retries = 4
  retries = 0
  until output[:add_ids].empty?
    begin
      output[:add_response] = ::Katello::Resources::Candlepin::Environment.add_content(input[:cp_environment_id], output[:add_ids])
      break
    rescue RestClient::Conflict => e
      raise e if ((retries += 1) == max_retries)
      # Candlepin raises a 409 in case it gets a duplicate content id add to an environment
      # Since its a dup id refresh the existing ids list (which hopefully will not have the duplicate content)
      # and try again.
      output[:add_ids] = content_ids - existing_ids
    rescue RestClient::ResourceNotFound, RestClient::NotFound => e
      # Set a higher limit for retries just in case the missing content is not being parsed from the error body correctly.
      # If the content is not found after the retries, assume it is gone and continue.
      raise e if ((retries += 1) == 1_000)
      # Parse the missing content from the Candlepin response and remove it from the add_ids list.
      missing_content = JSON.parse(e.response.body)['displayMessage'].split(' ')[-1].gsub(/[".]/, '')
      Rails.logger.debug "Content #{missing_content} not found in the environment. Removing it from the add_ids list."
      output[:add_ids].delete(missing_content)
    end
  end
  retries = 0
  until output[:delete_ids].empty?
    begin
      output[:delete_response] = ::Katello::Resources::Candlepin::Environment.delete_content(input[:cp_environment_id], output[:delete_ids])
      break
    rescue RestClient::ResourceNotFound
      # If the content is not found after the retries, assume it is gone and continue.
      break if ((retries += 1) == max_retries)
      # Candlepin raises a 404 in case a content id is not found in this environment
      # If thats the case lets just refresh the existing ids list (which hopefully will not have the 404'd content)
      # and try again.
      output[:delete_ids] = existing_ids - content_ids
    end
  end
end

#plan(content_view, environment, content_view_environment, new_content_id = nil) ⇒ Object 



9
10
11
12
13
14
 
# File 'app/lib/actions/candlepin/environment/set_content.rb', line 9

def plan(content_view, environment, content_view_environment, new_content_id = nil)
  plan_self(:content_view_id => content_view.id,
            :environment_id => environment.id,
            :cp_environment_id => content_view_environment.cp_id,
            :new_content_id => new_content_id)
end