initial support for migration plan and request

app/models/migration_plan_provision_request.rb

@@ -0,0 +1,33 @@
+class MigrationPlanProvisionRequest < ServiceTemplateProvisionRequest
+  TASK_DESCRIPTION = 'VM Migrations'.freeze
+
+  def requested_task_idx
+    vm_requests.where(:status => 'Approved')
+  end
+
+  def customize_request_task_attributes(req_task_attrs, vm_request)
+    req_task_attrs[:source] = vm_request.resource
+  end
+
+  def infra_mapping
+    source.service_resources.find_by(:resource_type => 'TransformationMapping')
+  end
+
+  def source_vms
+    vm_requests.where(:status => %w(Queued Failed)).pluck(:resource_id)
+  end
+
+  def validate_vm(vm_id)
+    true
+  end
+
+  def approve_vm(vm_id)
+    vm_requests.find_by(:resource_id => vm_id).update_attributes!(:status => 'Approved')
+  end
+
+  private
+
+  def vm_requests
+    source.service_resources.where(:resource_type => 'VmOrTemplate')
+  end
+end

app/models/migration_plan_provision_task.rb

@@ -0,0 +1,23 @@
+class MigrationPlanProvisionTask < ServiceTemplateProvisionTask
+  def self.base_model
+    MigrationPlanProvisionTask
+  end
+
+  def after_request_task_create
+    update_attributes(:description => "Migrating VM #{source.name}")
+  end
+
+  def resource_action
+    miq_request.source.resource_actions.detect { |ra| ra.action == 'Provision' }
+  end
+
+  def migration_destination(source_obj)
+    miq_request.infra_mapping.find_by(:source => source_obj).destination
+  end
+
+  def update_migration_progress(progress)
+    options[:progress] = (options[:progress]||{}).merge(progress)
+    save
+  end
+end
+

app/models/miq_request.rb

@@ -96,6 +96,11 @@ class MiqRequest < ApplicationRecord
       :AutomationRequest => {
         :automation => N_("Automation")
       }
+    },
+    :MigrationPlan  => {
+      :MigrationPlanProvisionRequest => {
+        :migration_plan => N_("Migration Plan")
+      }
     }
   }.freeze
 

app/models/service_template_migration_plan.rb

@@ -0,0 +1,13 @@
+class ServiceTemplateMigrationPlan < ServiceTemplate
+  def add_vms(vm_ids)
+    vm_ids.each { |vm_id| add_vm(vm_id) }
+    save!
+  end
+
+  def add_vm(vm_id)
+    sr = service_resources.detect { |r| r.resource_type == 'VmOrTemplate' && r.resource_id == vm_id }
+    return unless sr.nil?
+
+    service_resources.new(:resource_type => 'VmOrTemplate', :resource_id => vm_id, :status => 'Queued')
+  end
+end

app/models/service_template_provision_task.rb

@@ -128,7 +128,7 @@ def deliver_to_automate(req_type = request_type, _zone = nil)
       }
 
       # Automate entry point overrides from the resource_action
-      ra = source.resource_actions.detect { |ra| ra.action == 'Provision' } if source.respond_to?(:resource_actions)
+      ra = resource_action
 
       unless ra.nil?
         args[:namespace]        = ra.ae_namespace unless ra.ae_namespace.blank?
@@ -138,7 +138,7 @@ def deliver_to_automate(req_type = request_type, _zone = nil)
         args[:attrs].merge!(ra.ae_attributes)
       end
 
-      args[:attrs].merge!(MiqAeEngine.create_automation_attributes(destination.class.base_model.name => destination))
+      args[:attrs].merge!(MiqAeEngine.create_automation_attributes(destination.class.base_model.name => destination)) unless destination.nil?
       args[:user_id]      = get_user.id
       args[:miq_group_id] = get_user.current_group.id
       args[:tenant_id]    = get_user.current_tenant.id
@@ -158,6 +158,10 @@ def deliver_to_automate(req_type = request_type, _zone = nil)
     end
   end
 
+  def resource_action
+    source.resource_actions.detect { |ra| ra.action == 'Provision' } if source.respond_to?(:resource_actions)
+  end
+
   def service_resource
     return nil if options[:service_resource_id].blank?
     ServiceResource.find_by(:id => options[:service_resource_id])