Katello/katello

module Actions
  module Candlepin
    module Owner
      class Import < Candlepin::AbstractAsyncTask
        input_format do
          param :label
          param :path
          param :force
          param :upstream
        end

        def invoke_external_task
          options = input.slice(:force, :upstream)
          ::Katello::Resources::Candlepin::Owner.import(input[:label], input[:path], options)
        end

        def humanized_output
          result_data = output[:task]&.[]('resultData')
          return '' if result_data&.[]('status').blank?
          "Candlepin job status: #{result_data['status']}\n
          Message: #{result_data['statusMessage']}"
        end
      end
    end
  end
end