ManageIQ/manageiq

module AsyncDeleteMixin
  extend ActiveSupport::Concern
  included do
    def self._queue_task(task, ids, task_id = nil, queue_options = {})
      ids.each do |id|
        ops = {
          :class_name  => name,
          :instance_id => id,
          :msg_timeout => 3600,
          :method_name => task.to_s,
        }.merge(queue_options)

        ops[:args] = [task_id] if task_id

        MiqQueue.put(ops)
      end
    end

    def self.delete_queue(ids)
      ids = Array.wrap(ids)
      _log.info("Queuing delete of #{name} with the following ids: #{ids.inspect}")
      _queue_task(:delete, ids)
    end

    def self.destroy_queue(ids)
      ids = Array.wrap(ids)
      _log.info("Queuing destroy of #{name} with the following ids: #{ids.inspect}")
      _queue_task(:destroy, ids)
    end

    def delete_queue
      _log.info("Queuing delete of #{self.class.name} with id: #{id}")
      self.class._queue_task(:delete, Array.wrap(id))
    end

    def destroy_queue
      _log.info("Queuing destroy of #{self.class.name} with id: #{id}")
      self.class._queue_task(:destroy, Array.wrap(id))
    end
  end
end