subclass kubevirt for OSV

app/models/manageiq/providers/openshift/container_manager.rb

@@ -3,6 +3,13 @@
 class ManageIQ::Providers::Openshift::ContainerManager < ManageIQ::Providers::Kubernetes::ContainerManager
  DEFAULT_EXTERNAL_LOGGING_ROUTE_NAME = "logging-kibana-ops".freeze
 
+ has_one :infra_manager,
+ :foreign_key => :parent_ems_id,
+ :class_name => "ManageIQ::Providers::Openshift::InfraManager",
+ :autosave => true,
+ :inverse_of => :parent_manager,
+ :dependent => :destroy
+
  include ManageIQ::Providers::Openshift::ContainerManager::Options
 
  supports :catalog
@@ -21,9 +28,23 @@ def self.event_monitor_class
  ManageIQ::Providers::Openshift::ContainerManager::EventCatcher
  end
 
+ def self.virtualization_options
+ [
+ {
+ :label => _('Disabled'),
+ :value => 'none',
+ },
+ {
+ :label => _('OpenShift Virtualization'),
+ :value => 'kubevirt',
+ :pivot => 'endpoints.kubevirt.hostname',
+ },
+ ]
+ end
+
  def self.raw_connect(hostname, port, options)
  options[:service] ||= "openshift"
- send("#{options[:service]}_connect", hostname, port, options)
+ send(:"#{options[:service]}_connect", hostname, port, options)
  end
 
  def self.openshift_connect(hostname, port, options)

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

@@ -0,0 +1,34 @@
+ManageIQ::Providers::Kubevirt::InfraManager.include(ActsAsStiLeafClass)
+
+class ManageIQ::Providers::Openshift::InfraManager < ManageIQ::Providers::Kubevirt::InfraManager
+ belongs_to :parent_manager,
+ :foreign_key => :parent_ems_id,
+ :inverse_of => :infra_manager,
+ :class_name => "ManageIQ::Providers::Openshift::ContainerManager"
+
+ #
+ # This is the list of features that this provider supports:
+ #
+ supports :catalog
+ supports :provisioning
+
+ def self.ems_type
+ @ems_type ||= "openshift_infra".freeze
+ end
+
+ def self.description
+ @description ||= "OpenShift Virtualization".freeze
+ end
+
+ def self.catalog_types
+ {"openshift" => N_("OpenShift Virtualization")}
+ end
+
+ def default_authentication_type
+ :openshift
+ end
+
+ def self.display_name(number = 1)
+ n_('Infrastructure Provider (OpenShift Virtualization)', 'Infrastructure Providers (OpenShift Virtualization)', number)
+ end
+end

app/models/manageiq/providers/openshift/infra_manager/cluster.rb

@@ -0,0 +1,4 @@
+ManageIQ::Providers::Kubevirt::InfraManager::Cluster.include(ActsAsStiLeafClass)
+
+class ManageIQ::Providers::Openshift::InfraManager::Cluster < ManageIQ::Providers::Kubevirt::InfraManager::Cluster
+end

app/models/manageiq/providers/openshift/infra_manager/connection.rb

@@ -0,0 +1,4 @@
+ManageIQ::Providers::Kubevirt::InfraManager::Connection.include(ActsAsStiLeafClass)
+
+class ManageIQ::Providers::Openshift::InfraManager::Connection < ManageIQ::Providers::Kubevirt::InfraManager::Connection
+end

app/models/manageiq/providers/openshift/infra_manager/host.rb

@@ -0,0 +1,4 @@
+ManageIQ::Providers::Kubevirt::InfraManager::Host.include(ActsAsStiLeafClass)
+
+class ManageIQ::Providers::Openshift::InfraManager::Host < ManageIQ::Providers::Kubevirt::InfraManager::Host
+end

app/models/manageiq/providers/openshift/infra_manager/provision.rb

@@ -0,0 +1,4 @@
+ManageIQ::Providers::Kubevirt::InfraManager::Provision.include(ActsAsStiLeafClass)
+
+class ManageIQ::Providers::Openshift::InfraManager::Provision < ManageIQ::Providers::Kubevirt::InfraManager::Provision
+end

app/models/manageiq/providers/openshift/infra_manager/provision_workflow.rb

@@ -0,0 +1,9 @@
+class ManageIQ::Providers::Openshift::InfraManager::ProvisionWorkflow < ManageIQ::Providers::Kubevirt::InfraManager::ProvisionWorkflow
+ def self.provider_model
+ ManageIQ::Providers::Openshift::InfraManager
+ end
+
+ def dialog_name_from_automate(message = 'get_dialog_name')
+ super(message, {'platform' => 'openshift'})
+ end
+end

app/models/manageiq/providers/openshift/infra_manager/refresh_worker.rb

@@ -0,0 +1,2 @@
+class ManageIQ::Providers::Openshift::InfraManager::RefreshWorker < ManageIQ::Providers::BaseManager::RefreshWorker
+end

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

@@ -0,0 +1,9 @@
+require 'concurrent/atomic/atomic_boolean'
+
+class ManageIQ::Providers::Openshift::InfraManager::RefreshWorker::Runner < ManageIQ::Providers::Kubevirt::InfraManager::RefreshWorker::Runner
+ private
+
+ def provider_class
+ ManageIQ::Providers::Openshift
+ end
+end

app/models/manageiq/providers/openshift/infra_manager/refresher.rb

@@ -0,0 +1,2 @@
+class ManageIQ::Providers::Openshift::InfraManager::Refresher < ManageIQ::Providers::Kubevirt::InfraManager::Refresher
+end

app/models/manageiq/providers/openshift/infra_manager/storage.rb

@@ -0,0 +1,4 @@
+ManageIQ::Providers::Kubevirt::InfraManager::Storage.include(ActsAsStiLeafClass)
+
+class ManageIQ::Providers::Openshift::InfraManager::Storage < ManageIQ::Providers::Kubevirt::InfraManager::Storage
+end

app/models/manageiq/providers/openshift/infra_manager/template.rb

@@ -0,0 +1,7 @@
+ManageIQ::Providers::Kubevirt::InfraManager::Template.include(ActsAsStiLeafClass)
+
+class ManageIQ::Providers::Openshift::InfraManager::Template < ManageIQ::Providers::Kubevirt::InfraManager::Template
+ def self.display_name(number = 1)
+ n_('Template (OpenShift Virtualization)', 'Templates (OpenShift Virtualization)', number)
+ end
+end

app/models/manageiq/providers/openshift/infra_manager/vm.rb

@@ -0,0 +1,7 @@
+ManageIQ::Providers::Kubevirt::InfraManager::Vm.include(ActsAsStiLeafClass)
+
+class ManageIQ::Providers::Openshift::InfraManager::Vm < ManageIQ::Providers::Kubevirt::InfraManager::Vm
+ def self.display_name(number = 1)
+ n_('Virtual Machine (OpenShift Virtualization)', 'Virtual Machines (OpenShift Virtualization)', number)
+ end
+end

app/models/manageiq/providers/openshift/inventory.rb

@@ -1,2 +1,47 @@
 class ManageIQ::Providers::Openshift::Inventory < ManageIQ::Providers::Kubernetes::Inventory
+ # def self.persister_class_for(_ems, _target)
+ # ManageIQ::Providers::Openshift::Inventory::Persister
+ # end
+
+ # def self.collector_class_for(_ems, _target)
+ # ManageIQ::Providers::Openshift::Inventory::Collector
+ # end
+
+ def self.parser_class_for(ems, target)
+ if !ems.kind_of?(EmsInfra)
+ super
+ else
+ parser_type = if target_is_vm?(target)
+ "PartialTargetRefresh"
+ else
+ "FullRefresh"
+ end
+ "ManageIQ::Providers::Openshift::Inventory::Parser::InfraManager::#{parser_type}".safe_constantize
+ end
+ end
+
+ def self.build(ems, target)
+ if !ems.kind_of?(EmsInfra)
+ super
+ else
+ collector_class = collector_class_for(ems, target)
+
+ collector = if target_is_vm?(target)
+ collector_class.new(ems, target)
+ else
+ collector_class.new(ems, ems)
+ end
+
+ persister = persister_class_for(ems, target).new(ems, target)
+ new(
+ persister,
+ collector,
+ parser_classes_for(ems, target).map(&:new)
+ )
+ end
+ end
+
+ def self.target_is_vm?(target)
+ target.kind_of?(ManageIQ::Providers::Openshift::InfraManager::Vm)
+ end
 end

app/models/manageiq/providers/openshift/inventory/collector/infra_manager.rb

@@ -0,0 +1,2 @@
+class ManageIQ::Providers::Openshift::Inventory::Collector::InfraManager < ManageIQ::Providers::Kubevirt::Inventory::Collector
+end

app/models/manageiq/providers/openshift/inventory/parser/container_manager/watch_notice.rb

@@ -2,6 +2,7 @@ class ManageIQ::Providers::Openshift::Inventory::Parser::ContainerManager::Watch
  include ManageIQ::Providers::Openshift::Inventory::Parser::OpenshiftParserMixin
 
  def parse
+ byebug
  super
 
  projects

app/models/manageiq/providers/openshift/inventory/parser/infra_manager.rb

@@ -0,0 +1,2 @@
+class ManageIQ::Providers::Openshift::Inventory::Parser::InfraManager < ManageIQ::Providers::Kubevirt::Inventory::Parser
+end

app/models/manageiq/providers/openshift/inventory/parser/infra_manager/full_refresh.rb

@@ -0,0 +1,2 @@
+class ManageIQ::Providers::Openshift::Inventory::Parser::InfraManager::FullRefresh < ManageIQ::Providers::Kubevirt::Inventory::Parser::FullRefresh
+end

app/models/manageiq/providers/openshift/inventory/parser/infra_manager/partial_refresh.rb

@@ -0,0 +1,2 @@
+class ManageIQ::Providers::Openshift::Inventory::Parser::InfraManager::PartialRefresh < ManageIQ::Providers::Kubevirt::Inventory::Parser::PartialRefresh
+end

app/models/manageiq/providers/openshift/inventory/parser/infra_manager/partial_target_refresh.rb

@@ -0,0 +1,2 @@
+class ManageIQ::Providers::Openshift::Inventory::Parser::InfraManager::PartialTargetRefresh < ManageIQ::Providers::Kubevirt::Inventory::Parser::PartialTargetRefresh
+end

app/models/manageiq/providers/openshift/inventory/persister/infra_manager.rb

@@ -0,0 +1,2 @@
+class ManageIQ::Providers::Openshift::Inventory::Persister::InfraManager < ManageIQ::Providers::Kubevirt::Inventory::Persister
+end

config/settings.yml

@@ -33,3 +33,4 @@
  :ems_metrics_collector_worker_openshift: {}
  :ems_refresh_worker:
  :ems_refresh_worker_openshift: {}
+ :ems_refresh_worker_openshift_infra: {}