Class: Actions::Pulp::Repository::AbstractCopyContent

Inherits:
AbstractAsyncTask show all
Defined in:
app/lib/actions/pulp/repository/abstract_copy_content.rb

Constant Summary

Constants inherited from AbstractAsyncTask

AbstractAsyncTask::FINISHED_STATES

Instance Method Summary collapse

Methods inherited from AbstractAsyncTask

#cancel, #cancel!, #done?, #external_task, #humanized_state, #rescue_external_task, #run

Methods inherited from Abstract

#pulp_extensions, #pulp_resources

Instance Method Details

#content_extension ⇒ Object 



15
16
17
 
# File 'app/lib/actions/pulp/repository/abstract_copy_content.rb', line 15

def content_extension
  fail NotImplementedError
end

#criteria ⇒ Object 



27
28
29
30
31
32
33
34
35
 
# File 'app/lib/actions/pulp/repository/abstract_copy_content.rb', line 27

def criteria
  if input[:full_clauses]
    input[:full_clauses]
  elsif input[:clauses]
    { filters: {:unit => input[:clauses] } }
  else
    {}
  end
end

#external_task=(external_task_data) ⇒ Object 



37
38
39
40
41
 
# File 'app/lib/actions/pulp/repository/abstract_copy_content.rb', line 37

def external_task=(external_task_data)
  external_task_data = [external_task_data] if external_task_data.is_a?(Hash)
  external_task_data = external_task_data.map { |task| task.except('result') } unless input[:include_result]
  super(external_task_data)
end

#invoke_external_task ⇒ Object 



19
20
21
22
23
24
25
 
# File 'app/lib/actions/pulp/repository/abstract_copy_content.rb', line 19

def invoke_external_task
  optional = criteria
  optional[:override_config] = input[:override_config] if input[:override_config]
  content_extension.copy(input[:source_pulp_id],
                         input[:target_pulp_id],
                         criteria)
end