Suspend provider workers

Initial commit for suspending providers

app/models/ext_management_system.rb

@@ -177,6 +177,15 @@ def hostname_format_valid?
 
  default_value_for :enabled, true
 
+ def self.enable(ems_id)
+ ExtManagementSystem.where('id = ? OR parent_ems_id = ?', ems_id, ems_id).update_all(enabled: true)
+ end
+
+ def self.disable(ems_id)
+ ExtManagementSystem.where('id = ? OR parent_ems_id = ?', ems_id, ems_id).update_all(enabled: false)
+ end
+
+
  def self.with_ipaddress(ipaddress)
  joins(:endpoints).where(:endpoints => {:ipaddress => ipaddress})
  end

app/models/miq_queue.rb

@@ -173,6 +173,9 @@ def self.put(options)
  def self.submit_job(options)
  service = options.delete(:service) || "generic"
  resource = options.delete(:affinity)
+
+ return unless resource_enabled?(resource)
+
  case service
  when "automate"
  # options[:queue_name] = "generic"
@@ -206,6 +209,20 @@ def self.submit_job(options)
  put(options)
  end
 
+ # TODO: Array param not seen yet
+ # @param resource [ExtManagementSystem|Nil|Array<Class,id>] resource for affinity. Typically an ems
+ def self.resource_enabled?(resource)
+ if resource.respond_to?(:ext_management_system)
+ ems = resource.ext_management_system
+ if ems.present? && !ems.enabled
+ _log.info("Provider is disabled: #{ems.name}. MiqQueue skipped.")
+ return false
+ end
+ end
+
+ true
+ end
+
  def self.where_queue_name(is_array)
  is_array ? "AND queue_name in (?)" : "AND queue_name = ?"
  end