class ForemanInventoryUpload::Async::QueueForUploadJob

# File lib/foreman_inventory_upload/async/queue_for_upload_job.rb, line 32
def base_folder
  input[:base_folder]
end

# File lib/foreman_inventory_upload/async/queue_for_upload_job.rb, line 24
def ensure_ouput_folder
  FileUtils.mkdir_p(uploads_folder)
end

# File lib/foreman_inventory_upload/async/queue_for_upload_job.rb, line 28
def logger
  Foreman::Logging.logger('background')
end

# File lib/foreman_inventory_upload/async/queue_for_upload_job.rb, line 4
def plan(base_folder, report_file, organization_id)
  enqueue_task = plan_self(base_folder: base_folder, report_file: report_file)
  plan_upload_report(enqueue_task.output[:enqueued_file_name], organization_id)
end

# File lib/foreman_inventory_upload/async/queue_for_upload_job.rb, line 40
def plan_upload_report(enqueued_file_name, organization_id)
  plan_action(UploadReportDirectJob, enqueued_file_name, organization_id)
end

# File lib/foreman_inventory_upload/async/queue_for_upload_job.rb, line 36
def report_file
  input[:report_file]
end

# File lib/foreman_inventory_upload/async/queue_for_upload_job.rb, line 9
def run
  logger.debug('Ensuring objects')
  ensure_ouput_folder
  logger.debug("Copying #{report_file} to #{uploads_folder}")
  enqueued_file_name = File.join(uploads_folder, report_file)
  FileUtils.mv(File.join(base_folder, report_file), enqueued_file_name)
  logger.debug("Done copying #{report_file} to #{enqueued_file_name}")

  output[:enqueued_file_name] = enqueued_file_name
end

# File lib/foreman_inventory_upload/async/queue_for_upload_job.rb, line 20
def uploads_folder
  @uploads_folder ||= ForemanInventoryUpload.uploads_folder
end