Merge pull request #434 from agrare/default_to_streaming_refresh

Default to use streaming_refresh for vSphere

app/models/manageiq/providers/vmware/infra_manager.rb

@@ -123,7 +123,7 @@ def supported_catalog_types
     end
 
     def streaming_refresh_enabled?
-      Settings.prototype.ems_vmware.update_driven_refresh
+      Settings.ems_refresh.vmwarews.streaming_refresh
     end
 
     def remote_console_vmrc_acquire_ticket

app/models/manageiq/providers/vmware/infra_manager/refresh_worker/runner.rb

@@ -1,7 +1,7 @@
 class ManageIQ::Providers::Vmware::InfraManager::RefreshWorker::Runner < ManageIQ::Providers::BaseManager::RefreshWorker::Runner
-  # When using update_driven_refresh we don't need to use the VimBrokerWorker
-  self.require_vim_broker           = !Settings.prototype.ems_vmware.update_driven_refresh
-  self.delay_startup_for_vim_broker = !Settings.prototype.ems_vmware.update_driven_refresh
+  # When using streaming_refresh we don't need to use the VimBrokerWorker
+  self.require_vim_broker           = !Settings.ems_refresh.vmwarews.streaming_refresh
+  self.delay_startup_for_vim_broker = !Settings.ems_refresh.vmwarews.streaming_refresh
 
   def after_initialize
     super

app/models/miq_ems_refresh_core_worker.rb

@@ -6,7 +6,8 @@ class MiqEmsRefreshCoreWorker < MiqWorker
   self.required_roles = ["ems_inventory"]
 
   def self.has_required_role?
-    return false if Settings.prototype.ems_vmware.update_driven_refresh
+    return false if Settings.ems_refresh.vmwarews.streaming_refresh
+
     super
   end
 

app/models/miq_vim_broker_worker.rb

@@ -10,7 +10,7 @@ class MiqVimBrokerWorker < MiqWorker
       smartproxy
       smartstate
     ).tap do |roles|
-      roles << 'ems_inventory' unless Settings.prototype.ems_vmware.update_driven_refresh
+      roles << 'ems_inventory' unless Settings.ems_refresh.vmwarews.streaming_refresh
     end
   }
 

app/models/miq_vim_broker_worker/runner.rb

@@ -46,7 +46,7 @@ def reset_broker_update_sleep_interval
   end
 
   def has_ems_inventory_role?
-    @active_roles.include?("ems_inventory") && !Settings.prototype.ems_vmware.update_driven_refresh
+    @active_roles.include?("ems_inventory") && !Settings.ems_refresh.vmwarews.streaming_refresh
   end
 
   def reset_broker_update_notification

config/settings.yml

@@ -11,6 +11,8 @@
         :power:
           :critical:
 :ems_refresh:
+  :vmwarews:
+    :streaming_refresh: true
   :vmware_cloud:
     :inventory_object_refresh: false
     :get_public_images: false
@@ -27,9 +29,6 @@
     :user:
 #:log:
 #  :level_vim: warn
-:prototype:
-  :ems_vmware:
-    :update_driven_refresh: false
 :workers:
   :worker_base:
     :event_catcher:

spec/models/miq_ems_refresh_core_worker_spec.rb

@@ -14,12 +14,12 @@
   end
 
   context ".has_required_role?" do
-    context "with update_driven_refresh" do
+    context "with streaming_refresh" do
       before do
         stub_settings_merge(
-          :prototype => {
-            :ems_vmware => {
-              :update_driven_refresh => true
+          :ems_refresh => {
+            :vmwarews => {
+              :streaming_refresh => true
             }
           }
         )
@@ -29,12 +29,12 @@
         expect(described_class.has_required_role?).to be_falsy
       end
     end
-    context "without update_driven_refresh" do
+    context "without streaming_refresh" do
       before do
         stub_settings_merge(
-          :prototype => {
-            :ems_vmware => {
-              :update_driven_refresh => false
+          :ems_refresh => {
+            :vmwarews => {
+              :streaming_refresh => false
             }
           }
         )

spec/models/miq_vim_broker_worker/runner_spec.rb

@@ -3,6 +3,7 @@
 
 describe MiqVimBrokerWorker::Runner do
   before do
+    stub_settings_merge(:ems_refresh => {:vmwarews => {:streaming_refresh => false}})
     _guid_2, _server_2, @zone_2 = EvmSpecHelper.create_guid_miq_server_zone
     _guid, server, @zone = EvmSpecHelper.create_guid_miq_server_zone
     @ems = FactoryBot.create(:ems_vmware_with_authentication, :zone => @zone)
@@ -129,8 +130,8 @@
         expect(MiqVimBroker.cacheScope).to eq(:cache_scope_core)
       end
 
-      it "with ems_inventory role using update_driven_refresh" do
-        stub_settings(:prototype => {:ems_vmware => {:update_driven_refresh => true}})
+      it "with ems_inventory role using streaming_refresh" do
+        stub_settings(:ems_refresh => {:vmwarews => {:streaming_refresh => true}})
         @vim_broker_worker.instance_variable_set(:@active_roles, ['ems_inventory'])
         expect(MiqVimBroker).to receive(:new).with(:server).once
         @vim_broker_worker.create_miq_vim_broker_server

spec/models/miq_vim_broker_worker_spec.rb

@@ -8,12 +8,12 @@
     expect(described_class.emses_to_monitor).to match_array @zone.ext_management_systems
   end
 
-  context "update_driven_refresh" do
+  context "streaming_refresh" do
     before do
       stub_settings_merge(
-        :prototype => {
-          :ems_vmware => {
-            :update_driven_refresh => true
+        :ems_refresh => {
+          :vmwarews => {
+            :streaming_refresh => true
           }
         }
       )
@@ -27,9 +27,9 @@
   context "standard refresh" do
     before do
       stub_settings_merge(
-        :prototype => {
-          :ems_vmware => {
-            :update_driven_refresh => false
+        :ems_refresh => {
+          :vmwarews => {
+            :streaming_refresh => false
           }
         }
       )