Suspend provider workers

Initial commit for suspending providers

https://bugzilla.redhat.com/show_bug.cgi?id=1455145

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