Merge pull request #22759 from agrare/seed_workflows_from_content

Seed workflows from plugins' content/workflows

app/models/manageiq/providers/embedded_automation_manager/configuration_script_source.rb

@@ -51,7 +51,7 @@ def sync_and_notify
   end
 
   def git_repository
-    (super || (ensure_git_repository && super)).tap { |r| sync_git_repository(r) }
+    (super || (ensure_git_repository && super))&.tap { |r| sync_git_repository(r) }
   end
 
   def verify_ssl=(val)
@@ -86,13 +86,17 @@ def sync
   end
 
   def checkout_git_repository(target_directory)
+    return if git_repository.nil?
+
     git_repository.update_repo
     git_repository.checkout(scm_branch, target_directory)
   end
 
   private
 
   def ensure_git_repository
+    return if scm_url.blank?
+
     transaction do
       repo = GitRepository.create!(attrs_for_sync_git_repository)
       if new_record?
@@ -108,6 +112,8 @@ def sync_git_repository(git_repository = nil)
     return unless name_changed? || scm_url_changed? || authentication_id_changed? || @verify_ssl_changed
 
     git_repository ||= self.git_repository
+    return if git_repository.nil?
+
     git_repository.attributes = attrs_for_sync_git_repository
   end
 

lib/vmdb/plugins.rb

@@ -80,6 +80,12 @@ def ansible_runner_content
       end
     end
 
+    def embedded_workflows_content
+      @embedded_workflows_content ||= index_with do |engine|
+        engine.root.join("content", "workflows").glob("**/*.asl")
+      end
+    end
+
     def automate_domains
       @automate_domains ||= begin
         require_relative 'plugins/automate_domain'